com.hazelcast.internal.networking.nio

Class NioChannelWriter

java.lang.Object

com.hazelcast.internal.networking.nio.AbstractHandler

com.hazelcast.internal.networking.nio.NioChannelWriter

All Implemented Interfaces:

MigratableHandler, SelectionHandler, Closeable, AutoCloseable, Runnable

public final class NioChannelWriter
extends AbstractHandler
implements Runnable

Field Summary

Fields

Modifier and Type	Field and Description
Queue<OutboundFrame>	urgentWriteQueue
Queue<OutboundFrame>	writeQueue

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
NioChannelWriter(NioChannel channel, NioThread ioThread, ILogger logger, IOBalancer balancer, ChannelInitializer initializer)

Method Summary

Modifier and Type	Method and Description
long	bytesPending()
void	close()
void	flush()
long	getLoad() Get 'load' recorded by the current handler.
void	handle() Called when there are bytes available for reading, or space available to write.
long	lastWriteTimeMillis()
long	priorityBytesPending()
protected void	publish()
void	requestMigration(NioThread newOwner) Requests the MigratableHandler to move to the new NioThread.
void	run()
String	toString()
int	totalFramesPending()
void	write(OutboundFrame frame)

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

writeQueue

public final Queue<OutboundFrame> writeQueue

urgentWriteQueue

public final Queue<OutboundFrame> urgentWriteQueue

Constructor Detail

NioChannelWriter

public NioChannelWriter(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

Specified by:

getLoad in interface MigratableHandler

Returns:

total load recorded by this handler

totalFramesPending

public int totalFramesPending()

lastWriteTimeMillis

public long lastWriteTimeMillis()

bytesPending

public long bytesPending()

priorityBytesPending

public long priorityBytesPending()

flush

public void flush()

write

public void write(OutboundFrame frame)

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.

Specified by:

handle in interface SelectionHandler

Throws:

Exception

run

public void run()

Specified by:

run in interface Runnable

close

public void close()

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

requestMigration

public void requestMigration(NioThread newOwner)

Description copied from interface: MigratableHandler

Requests the MigratableHandler to move to the new NioThread. This call will not wait for the migration to complete. This method can be called by any thread, and will probably be called by the IOBalancer. Call is ignored when handler is moving to the same NioThread.

Specified by:

requestMigration in interface MigratableHandler

Parameters:

newOwner - the NioThread that is going to own this MigratableHandler

toString

public String toString()

Overrides:

toString in class Object

publish

protected void publish()

Specified by:

publish in class AbstractHandler