Package | Description |
---|---|
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. |
Constructor and Description |
---|
NonBlockingIOThreadingModel(LoggingService loggingService,
MetricsRegistry metricsRegistry,
String hzName,
IOOutOfMemoryHandler oomeHandler,
int inputThreadCount,
int outputThreadCount,
int balanceIntervalSeconds,
SocketWriterInitializer socketWriterInitializer,
SocketReaderInitializer socketReaderInitializer) |
NonBlockingSocketReader(SocketConnection connection,
NonBlockingIOThread ioThread,
ILogger logger,
IOBalancer balancer,
SocketReaderInitializer initializer) |
Constructor and Description |
---|
SpinningIOThreadingModel(LoggingService loggingService,
IOOutOfMemoryHandler oomeHandler,
SocketWriterInitializer socketWriterInitializer,
SocketReaderInitializer socketReaderInitializer,
String hzName) |
SpinningSocketReader(SocketConnection connection,
ILogger logger,
IOOutOfMemoryHandler oomeHandler,
SocketReaderInitializer initializer) |
Modifier and Type | Class and Description |
---|---|
class |
SocketReaderInitializerImpl |
Copyright © 2017 Hazelcast, Inc.. All Rights Reserved.