Package | Description |
---|---|
com.hazelcast.internal.networking.nio |
Contains the non blocking
EventLoopGroup functionality. |
com.hazelcast.internal.networking.nio.iobalancer |
Contains Handler Migration classes
|
Modifier and Type | Field and Description |
---|---|
protected NioThread |
NioPipeline.owner |
Modifier and Type | Method and Description |
---|---|
NioThread[] |
NioEventLoopGroup.getInputThreads() |
NioThread[] |
NioEventLoopGroup.getOutputThreads() |
NioThread |
MigratablePipeline.owner()
Get NioThread currently owning this pipeline.
|
NioThread |
NioPipeline.owner() |
Modifier and Type | Method and Description |
---|---|
void |
MigratablePipeline.requestMigration(NioThread newOwner)
Requests the MigratablePipeline to move to the new NioThread.
|
void |
NioInboundPipeline.requestMigration(NioThread newOwner)
Migrates this Pipeline to a new NioThread.
|
void |
NioOutboundPipeline.requestMigration(NioThread newOwner) |
Constructor and Description |
---|
NioInboundPipeline(NioChannel channel,
NioThread owner,
ChannelErrorHandler errorHandler,
ILogger logger,
IOBalancer balancer,
ChannelInitializer initializer) |
NioOutboundPipeline(NioChannel channel,
NioThread owner,
ChannelErrorHandler errorHandler,
ILogger logger,
IOBalancer balancer,
ChannelInitializer initializer) |
Constructor and Description |
---|
IOBalancer(NioThread[] inputThreads,
NioThread[] outputThreads,
String hzName,
int balancerIntervalSeconds,
LoggingService loggingService) |
IOBalancer(NioThread[] inputThreads,
NioThread[] outputThreads,
String hzName,
int balancerIntervalSeconds,
LoggingService loggingService) |
Copyright © 2018 Hazelcast, Inc.. All Rights Reserved.