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.