| Package | Description |
|---|---|
| com.hazelcast.client.connection.nio |
Contains classes related to New IO for com.hazelcast.client.connection
|
| com.hazelcast.internal.networking |
Contains the socket connection functionality.
|
| com.hazelcast.internal.networking.nonblocking |
Contains the non blocking
TcpIpConnectionMonitor. |
| com.hazelcast.internal.networking.spinning |
Contains the implementation of the
SpinningIOThreadingModel. |
| 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. |
| Modifier and Type | Class and Description |
|---|---|
class |
ClientConnection
Client implementation of
Connection. |
| Modifier and Type | Method and Description |
|---|---|
SocketReader |
IOThreadingModel.newSocketReader(SocketConnection connection)
Creates a new SocketReader for the given connection.
|
SocketWriter |
IOThreadingModel.newSocketWriter(SocketConnection connection)
Creates a new SocketWriter for the given connection.
|
void |
IOThreadingModel.onConnectionAdded(SocketConnection connection)
Is called when a connection is added.
|
void |
IOThreadingModel.onConnectionRemoved(SocketConnection connection)
Is called when a connection is removed.
|
| Modifier and Type | Field and Description |
|---|---|
protected SocketConnection |
AbstractHandler.connection |
| Modifier and Type | Method and Description |
|---|---|
SocketReader |
NonBlockingIOThreadingModel.newSocketReader(SocketConnection connection) |
SocketWriter |
NonBlockingIOThreadingModel.newSocketWriter(SocketConnection connection) |
void |
NonBlockingIOThreadingModel.onConnectionAdded(SocketConnection connection) |
void |
NonBlockingIOThreadingModel.onConnectionRemoved(SocketConnection connection) |
| Constructor and Description |
|---|
AbstractHandler(SocketConnection connection,
NonBlockingIOThread ioThread,
int initialOps,
ILogger logger,
IOBalancer ioBalancer) |
NonBlockingSocketReader(SocketConnection connection,
NonBlockingIOThread ioThread,
ILogger logger,
IOBalancer balancer,
SocketReaderInitializer initializer) |
NonBlockingSocketWriter(SocketConnection connection,
NonBlockingIOThread ioThread,
ILogger logger,
IOBalancer balancer,
SocketWriterInitializer initializer) |
| Modifier and Type | Field and Description |
|---|---|
protected SocketConnection |
AbstractHandler.connection |
| Modifier and Type | Method and Description |
|---|---|
void |
SpinningInputThread.addConnection(SocketConnection connection) |
SocketReader |
SpinningIOThreadingModel.newSocketReader(SocketConnection connection) |
SocketWriter |
SpinningIOThreadingModel.newSocketWriter(SocketConnection connection) |
void |
SpinningIOThreadingModel.onConnectionAdded(SocketConnection connection) |
void |
SpinningIOThreadingModel.onConnectionRemoved(SocketConnection connection) |
void |
SpinningInputThread.removeConnection(SocketConnection connection) |
| Constructor and Description |
|---|
AbstractHandler(SocketConnection connection,
ILogger logger,
IOOutOfMemoryHandler oomeHandler) |
SpinningSocketReader(SocketConnection connection,
ILogger logger,
IOOutOfMemoryHandler oomeHandler,
SocketReaderInitializer initializer) |
SpinningSocketWriter(SocketConnection connection,
ILogger logger,
IOOutOfMemoryHandler oomeHandler,
SocketWriterInitializer initializer) |
| Modifier and Type | Class and Description |
|---|---|
class |
TcpIpConnection
The Tcp/Ip implementation of the
Connection. |
Copyright © 2018 Hazelcast, Inc.. All Rights Reserved.