com.hazelcast.internal.networking.nio

Class NioChannelReader

java.lang.Object

com.hazelcast.internal.networking.nio.AbstractHandler

com.hazelcast.internal.networking.nio.NioChannelReader

All Implemented Interfaces:

MigratableHandler, SelectionHandler, Closeable, AutoCloseable

public final class NioChannelReader
extends AbstractHandler

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.AbstractHandler

channel, completedMigrations, handleCount, ioThread, LOAD_BALANCING_BYTE, LOAD_BALANCING_FRAME, LOAD_BALANCING_HANDLE, LOAD_TYPE, logger, selectionKey

Constructor Summary

Constructors

Constructor and Description
NioChannelReader(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.AbstractHandler

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

NioChannelReader

public NioChannelReader(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 interface: SelectionHandler

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.

Throws:

Exception

publish

public void publish()

Specified by:

publish in class AbstractHandler

close

public void close()

toString

public String toString()

Overrides:

toString in class Object