| 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 This whole package is internal and no compatibility will be provided. | 
| 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.