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:

MigratableHandler, Closeable, AutoCloseable

public final class NioInboundPipeline
extends NioPipeline

When the NioThread receives a read event from the Selector, then the handle() 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, handleCount, ioThread, LOAD_BALANCING_BYTE, LOAD_BALANCING_FRAME, LOAD_BALANCING_HANDLE, LOAD_TYPE, logger, selectionKey

Constructor Summary

Constructors

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

Method Summary

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

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

getChannel, getOwner, onFailure, 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 ioThread,
                          ILogger logger,
                          IOBalancer balancer,
                          ChannelInitializer initializer)

Method Detail

getLoad

public long getLoad()

Description copied from interface: MigratableHandler

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

Returns:

total load recorded by this handler

getNormalFramesReadCounter

public SwCounter getNormalFramesReadCounter()

getPriorityFramesReadCounter

public SwCounter getPriorityFramesReadCounter()

lastReadTimeMillis

public long lastReadTimeMillis()

requestMigration

public void requestMigration(NioThread newOwner)

Migrates this handler 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 handler migrates to

handle

public void handle()
            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:

handle in class NioPipeline

Throws:

Exception

publish

public void publish()

Specified by:

publish in class NioPipeline

close

public void close()

toString

public String toString()

Overrides:

toString in class Object