Package | Description |
---|---|
com.hazelcast.client.connection.nio |
Contains classes related to New IO for com.hazelcast.client.connection
|
com.hazelcast.nio.tcp.nonblocking |
Contains the non blocking
TcpIpConnectionMonitor . |
com.hazelcast.nio.tcp.nonblocking.iobalancer |
Contains Handler Migration classes
|
Modifier and Type | Class and Description |
---|---|
class |
ClientNonBlockingOutputThread
ClientNonBlockingOutputThread facilitates non-blocking writing for Hazelcast Clients.
|
Constructor and Description |
---|
AbstractClientSelectionHandler(ClientConnection connection,
NonBlockingIOThread ioThread,
LoggingService loggingService) |
ClientConnection(HazelcastClientInstanceImpl client,
NonBlockingIOThread in,
NonBlockingIOThread out,
int connectionId,
SocketChannelWrapper socketChannelWrapper) |
ClientReadHandler(ClientConnection connection,
NonBlockingIOThread ioThread,
int bufferSize,
boolean direct,
LoggingService loggingService) |
ClientWriteHandler(ClientConnection connection,
NonBlockingIOThread ioThread,
int bufferSize,
boolean direct,
LoggingService loggingService) |
Modifier and Type | Field and Description |
---|---|
protected NonBlockingIOThread |
AbstractHandler.ioThread |
Modifier and Type | Method and Description |
---|---|
NonBlockingIOThread[] |
NonBlockingIOThreadingModel.getInputThreads() |
NonBlockingIOThread[] |
NonBlockingIOThreadingModel.getOutputThreads() |
NonBlockingIOThread |
MigratableHandler.getOwner()
Get NonBlockingIOThread currently owning this handler.
|
NonBlockingIOThread |
AbstractHandler.getOwner() |
Modifier and Type | Method and Description |
---|---|
void |
NonBlockingSocketWriter.requestMigration(NonBlockingIOThread newOwner) |
void |
NonBlockingSocketReader.requestMigration(NonBlockingIOThread newOwner)
Migrates this handler to a new NonBlockingIOThread.
|
void |
MigratableHandler.requestMigration(NonBlockingIOThread newOwner)
Requests the MigratableHandler to move to the new NonBlockingIOThread.
|
Constructor and Description |
---|
AbstractHandler(TcpIpConnection connection,
NonBlockingIOThread ioThread,
int initialOps) |
NonBlockingSocketReader(TcpIpConnection connection,
NonBlockingIOThread ioThread,
MetricsRegistry metricsRegistry) |
Constructor and Description |
---|
IOBalancer(NonBlockingIOThread[] inputThreads,
NonBlockingIOThread[] outputThreads,
HazelcastThreadGroup threadGroup,
int balancerIntervalSeconds,
LoggingService loggingService) |
IOBalancer(NonBlockingIOThread[] inputThreads,
NonBlockingIOThread[] outputThreads,
HazelcastThreadGroup threadGroup,
int balancerIntervalSeconds,
LoggingService loggingService) |
Copyright © 2016 Hazelcast, Inc.. All Rights Reserved.