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 © 2017 Hazelcast, Inc.. All Rights Reserved.