com.hazelcast.internal.networking.nio

Class NioInboundPipeline

java.lang.Object

com.hazelcast.internal.networking.nio.NioPipeline

com.hazelcast.internal.networking.nio.NioInboundPipeline

All Implemented Interfaces:

MigratablePipeline, Closeable, AutoCloseable

public final class NioInboundPipeline
extends NioPipeline

When the NioThread receives a read event from the Selector, then the process() is called to read out the data from the socket into a bytebuffer and hand it over to the ChannelInboundHandler to get processed.

Field Summary

Fields

Modifier and Type	Field and Description
protected ByteBuffer	inputBuffer

Fields inherited from class com.hazelcast.internal.networking.nio.NioPipeline

channel, completedMigrations, LOAD_BALANCING_BYTE, LOAD_BALANCING_FRAME, LOAD_BALANCING_HANDLE, LOAD_TYPE, logger, owner, processCount, selectionKey

Constructor Summary

Constructors

Constructor and Description
NioInboundPipeline(NioChannel channel, NioThread owner, ChannelErrorHandler errorHandler, ILogger logger, IOBalancer balancer, ChannelInitializer initializer)

Method Summary

Modifier and Type	Method and Description
void	close()
SwCounter	getNormalFramesReadCounter()
SwCounter	getPriorityFramesReadCounter()
long	lastReadTimeMillis()
long	load() Get 'load' recorded by the current pipeline.
void	process() Called when there are bytes available for reading, or space available to write.
void	publishMetrics()
void	requestMigration(NioThread newOwner) Migrates this Pipeline to a new NioThread.
String	toString()

Methods inherited from class com.hazelcast.internal.networking.nio.NioPipeline

getChannel, onFailure, owner, start

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Detail

inputBuffer

protected ByteBuffer inputBuffer

Constructor Detail

NioInboundPipeline

public NioInboundPipeline(NioChannel channel,
                          NioThread owner,
                          ChannelErrorHandler errorHandler,
                          ILogger logger,
                          IOBalancer balancer,
                          ChannelInitializer initializer)

Method Detail

load

public long load()

Description copied from interface: MigratablePipeline

Get 'load' recorded by the current pipeline. It can be used to calculate whether this pipeline should be migrated to a different NioThread

Returns:

total load recorded by this pipeline

getNormalFramesReadCounter

public SwCounter getNormalFramesReadCounter()

getPriorityFramesReadCounter

public SwCounter getPriorityFramesReadCounter()

lastReadTimeMillis

public long lastReadTimeMillis()

requestMigration

public void requestMigration(NioThread newOwner)

Migrates this Pipeline to a new NioThread. The migration logic is rather simple:

• Submit a de-registration task to a current NioThread
• The de-registration task submits a registration task to the new NioThread

Parameters:

newOwner - target NioThread this pipeline migrates to

process

public void process()
             throws Exception

Description copied from class: NioPipeline

Called when there are bytes available for reading, or space available to write. Any exception that leads to a termination of the connection like an IOException should not be handled in the handle method but should be propagated. The reason behind this is that the handle logic already is complicated enough and by pulling it out the flow will be easier to understand.

Specified by:

process in class NioPipeline

Throws:

Exception

publishMetrics

public void publishMetrics()

Specified by:

publishMetrics in class NioPipeline

close

public void close()

toString

public String toString()

Overrides:

toString in class Object