com.hazelcast.nio.tcp

Class WriteHandler

java.lang.Object

com.hazelcast.nio.tcp.AbstractSelectionHandler

com.hazelcast.nio.tcp.WriteHandler

All Implemented Interfaces:

MigratableHandler, SelectionHandler, Runnable

public final class WriteHandler
extends AbstractSelectionHandler
implements Runnable

The writing side of the TcpIpConnection.

Field Summary

Fields inherited from class com.hazelcast.nio.tcp.AbstractSelectionHandler

connection, connectionManager, ioSelector, logger, selector, socketChannel

Method Summary

Methods

Modifier and Type	Method and Description
long	getEventCount() Get number of events recorded by the current handler.
SocketWriter	getSocketWriter()
void	handle()
void	offer(SocketWritable packet)
void	requestMigration(IOSelector newOwner) Requests the MigratableHandler to move to the new IOSelector.
void	run()
void	shutdown()

Methods inherited from class com.hazelcast.nio.tcp.AbstractSelectionHandler

getOwner, getSelectionKey

Methods inherited from class java.lang.Object

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

Method Detail

getSocketWriter

public SocketWriter getSocketWriter()

offer

public void offer(SocketWritable packet)

getEventCount

public long getEventCount()

Description copied from interface: MigratableHandler

Get number of events recorded by the current handler. It can be used to calculate whether this handler should be migrated to a different IOSelector

Specified by:

getEventCount in interface MigratableHandler

Returns:

total number of events recorded by this handler

handle

public void handle()

Specified by:

handle in interface SelectionHandler

run

public void run()

Specified by:

run in interface Runnable

shutdown

public void shutdown()

requestMigration

public void requestMigration(IOSelector newOwner)

Description copied from interface: MigratableHandler

Requests the MigratableHandler to move to the new IOSelector. 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 IOSelector.

Specified by:

requestMigration in interface MigratableHandler

Parameters:

newOwner - the IOSelector that is going to own this MigratableHandler