com.hazelcast.nio.tcp.nonblocking

Class AbstractHandler

java.lang.Object

com.hazelcast.nio.tcp.nonblocking.AbstractHandler

All Implemented Interfaces:

MigratableHandler, SelectionHandler

Direct Known Subclasses:

NonBlockingSocketReader, NonBlockingSocketWriter

public abstract class AbstractHandler
extends Object
implements MigratableHandler

Field Summary

Fields

Modifier and Type	Field and Description
protected TcpIpConnection	connection
protected TcpIpConnectionManager	connectionManager
protected IOService	ioService
protected NonBlockingIOThread	ioThread
protected ILogger	logger
protected SelectionKey	selectionKey
protected SocketChannelWrapper	socketChannel

Constructor Summary

Constructors

Constructor and Description
AbstractHandler(TcpIpConnection connection, NonBlockingIOThread ioThread, int initialOps)

Method Summary

Methods

Modifier and Type	Method and Description
NonBlockingIOThread	getOwner() Get NonBlockingIOThread currently owning this handler.
protected SelectionKey	getSelectionKey()
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.nio.tcp.nonblocking.MigratableHandler

getEventCount, requestMigration

Methods inherited from interface com.hazelcast.nio.tcp.nonblocking.SelectionHandler

handle

Field Detail

logger

protected final ILogger logger

socketChannel

protected final SocketChannelWrapper socketChannel

connection

protected final TcpIpConnection connection

connectionManager

protected final TcpIpConnectionManager connectionManager

ioService

protected final IOService ioService

ioThread

protected NonBlockingIOThread ioThread

selectionKey

protected SelectionKey selectionKey

Constructor Detail

AbstractHandler

public AbstractHandler(TcpIpConnection connection,
               NonBlockingIOThread ioThread,
               int initialOps)

Method Detail

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