| Package | Description | 
|---|---|
| com.hazelcast.instance | 
 This package contains Hazelcast Instance functionality. 
 | 
| com.hazelcast.nio | 
 This package contains classes related to New IO 
 | 
| com.hazelcast.nio.ascii | 
 Contains SocketTextReader and SocketTextWriter classes; 
 | 
| com.hazelcast.nio.tcp | 
 Contains functionality for the TCP/IP Networking between cluster members 
 | 
| com.hazelcast.nio.tcp.nonblocking | 
 Contains the non blocking  
TcpIpConnectionMonitor. | 
| com.hazelcast.nio.tcp.nonblocking.iobalancer | 
 Contains Handler Migration classes 
 | 
| com.hazelcast.nio.tcp.spinning | 
 Contains the implementation of the  
SpinningIOThreadingModel. | 
| Modifier and Type | Method and Description | 
|---|---|
ReadHandler | 
DefaultNodeExtension.createReadHandler(TcpIpConnection connection,
                 IOService ioService)  | 
ReadHandler | 
NodeExtension.createReadHandler(TcpIpConnection connection,
                 IOService ioService)
Creates a ReadHandler for given Connection instance. 
 | 
WriteHandler | 
DefaultNodeExtension.createWriteHandler(TcpIpConnection connection,
                  IOService ioService)  | 
WriteHandler | 
NodeExtension.createWriteHandler(TcpIpConnection connection,
                  IOService ioService)
Creates a WriteHandler for given Connection instance. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
ReadHandler | 
NodeIOService.createReadHandler(TcpIpConnection connection)  | 
ReadHandler | 
IOService.createReadHandler(TcpIpConnection connection)  | 
WriteHandler | 
NodeIOService.createWriteHandler(TcpIpConnection connection)  | 
WriteHandler | 
IOService.createWriteHandler(TcpIpConnection connection)  | 
| Constructor and Description | 
|---|
TextReadHandler(TcpIpConnection connection)  | 
TextWriteHandler(TcpIpConnection connection)  | 
| Modifier and Type | Field and Description | 
|---|---|
protected TcpIpConnection | 
MemberReadHandler.connection  | 
| Modifier and Type | Method and Description | 
|---|---|
Set<TcpIpConnection> | 
TcpIpConnectionManager.getActiveConnections()  | 
| Modifier and Type | Method and Description | 
|---|---|
SocketReader | 
IOThreadingModel.newSocketReader(TcpIpConnection connection)
Creates a new SocketReader for the given connection. 
 | 
SocketWriter | 
IOThreadingModel.newSocketWriter(TcpIpConnection connection)
Creates a new SocketWriter for the given connection. 
 | 
void | 
IOThreadingModel.onConnectionAdded(TcpIpConnection connection)
Is called when a connection is added. 
 | 
void | 
IOThreadingModel.onConnectionRemoved(TcpIpConnection connection)
Is called when a connection is removed. 
 | 
| Constructor and Description | 
|---|
MemberReadHandler(TcpIpConnection connection,
                 PacketDispatcher packetDispatcher)  | 
| Modifier and Type | Field and Description | 
|---|---|
protected TcpIpConnection | 
AbstractHandler.connection  | 
| Modifier and Type | Method and Description | 
|---|---|
SocketReader | 
NonBlockingIOThreadingModel.newSocketReader(TcpIpConnection connection)  | 
SocketWriter | 
NonBlockingIOThreadingModel.newSocketWriter(TcpIpConnection connection)  | 
void | 
NonBlockingIOThreadingModel.onConnectionAdded(TcpIpConnection connection)  | 
void | 
NonBlockingIOThreadingModel.onConnectionRemoved(TcpIpConnection connection)  | 
| Constructor and Description | 
|---|
AbstractHandler(TcpIpConnection connection,
               NonBlockingIOThread ioThread,
               int initialOps)  | 
NonBlockingSocketReader(TcpIpConnection connection,
                       NonBlockingIOThread ioThread,
                       MetricsRegistry metricsRegistry)  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
IOBalancer.connectionAdded(TcpIpConnection connection)  | 
void | 
IOBalancer.connectionRemoved(TcpIpConnection connection)  | 
| Modifier and Type | Field and Description | 
|---|---|
protected TcpIpConnection | 
AbstractHandler.connection  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
SpinningInputThread.addConnection(TcpIpConnection connection)  | 
void | 
SpinningOutputThread.addConnection(TcpIpConnection connection)  | 
SocketReader | 
SpinningIOThreadingModel.newSocketReader(TcpIpConnection connection)  | 
SocketWriter | 
SpinningIOThreadingModel.newSocketWriter(TcpIpConnection connection)  | 
void | 
SpinningIOThreadingModel.onConnectionAdded(TcpIpConnection connection)  | 
void | 
SpinningIOThreadingModel.onConnectionRemoved(TcpIpConnection connection)  | 
void | 
SpinningInputThread.removeConnection(TcpIpConnection connection)  | 
void | 
SpinningOutputThread.removeConnection(TcpIpConnection connection)  | 
| Constructor and Description | 
|---|
AbstractHandler(TcpIpConnection connection,
               ILogger logger)  | 
SpinningSocketReader(TcpIpConnection connection,
                    MetricsRegistry metricsRegistry,
                    ILogger logger)  | 
SpinningSocketWriter(TcpIpConnection connection,
                    MetricsRegistry metricsRegistry,
                    ILogger logger)  | 
Copyright © 2016 Hazelcast, Inc.. All Rights Reserved.