com.hazelcast.internal.networking.nonblocking

Class AbstractHandler

java.lang.Object

com.hazelcast.internal.networking.nonblocking.AbstractHandler

All Implemented Interfaces:

MigratableHandler, SelectionHandler

Direct Known Subclasses:

NonBlockingSocketReader, NonBlockingSocketWriter

public abstract class AbstractHandler
extends Object
implements SelectionHandler, MigratableHandler

Field Summary

Fields

Modifier and Type	Field and Description
protected SocketConnection	connection
protected SwCounter	eventCount
protected NonBlockingIOThread	ioThread
protected ILogger	logger
protected SelectionKey	selectionKey
protected SocketChannelWrapper	socketChannel

Constructor Summary

Constructors

Constructor and Description
AbstractHandler(SocketConnection connection, NonBlockingIOThread ioThread, int initialOps, ILogger logger, IOBalancer ioBalancer)

Method Summary

Modifier and Type	Method and Description
long	getEventCount() Get number of events recorded by the current handler.
NonBlockingIOThread	getOwner() Get NonBlockingIOThread currently owning this handler.
protected SelectionKey	getSelectionKey()
SocketChannelWrapper	getSocketChannel()
void	onFailure(Throwable e) Is called when the SelectionHandler.handle() throws an exception.

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.hazelcast.internal.networking.nonblocking.SelectionHandler

handle

Methods inherited from interface com.hazelcast.internal.networking.nonblocking.MigratableHandler

requestMigration

Field Detail

eventCount

protected final SwCounter eventCount

logger

protected final ILogger logger

socketChannel

protected final SocketChannelWrapper socketChannel

connection

protected final SocketConnection connection

ioThread

protected NonBlockingIOThread ioThread

selectionKey

protected SelectionKey selectionKey

Constructor Detail

AbstractHandler

public AbstractHandler(SocketConnection connection,
                       NonBlockingIOThread ioThread,
                       int initialOps,
                       ILogger logger,
                       IOBalancer ioBalancer)

Method Detail

getSocketChannel

public SocketChannelWrapper getSocketChannel()

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 NonBlockingIOThread

Specified by:

getEventCount in interface MigratableHandler

Returns:

total number of events recorded by this handler

getOwner

public NonBlockingIOThread getOwner()

Description copied from interface: MigratableHandler

Get NonBlockingIOThread currently owning this handler. Handler owner is a thread running this handler. IOBalancer can decide to migrate a handler to another owner.

Specified by:

getOwner in interface MigratableHandler

Returns:

current owner

getSelectionKey

protected SelectionKey getSelectionKey()
                                throws IOException

Throws:

IOException

onFailure

public void onFailure(Throwable e)

Description copied from interface: SelectionHandler

Is called when the SelectionHandler.handle() throws an exception. The idiom to use a handler is: try{ handler.handle(); } catch(Throwable t) { handler.onFailure(t); }

Specified by:

onFailure in interface SelectionHandler