com.hazelcast.internal.networking.nio

Class AbstractHandler

java.lang.Object

com.hazelcast.internal.networking.nio.AbstractHandler

All Implemented Interfaces:

MigratableHandler, SelectionHandler, Closeable, AutoCloseable

Direct Known Subclasses:

NioChannelReader, NioChannelWriter

public abstract class AbstractHandler
extends Object
implements SelectionHandler, MigratableHandler, Closeable

Field Summary

Fields

Modifier and Type	Field and Description
protected Channel	channel
protected SwCounter	completedMigrations
protected SwCounter	handleCount
protected NioThread	ioThread
protected static int	LOAD_BALANCING_BYTE
protected static int	LOAD_BALANCING_FRAME
protected static int	LOAD_BALANCING_HANDLE
protected static int	LOAD_TYPE
protected ILogger	logger
protected SelectionKey	selectionKey

Method Summary

Modifier and Type	Method and Description
Channel	getChannel()
NioThread	getOwner() Get NioThread currently owning this handler.
void	onFailure(Throwable e) Is called when the SelectionHandler.handle() throws an exception.
protected abstract void	publish()
void	start()

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.nio.SelectionHandler

handle

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

getLoad, requestMigration

Methods inherited from interface java.io.Closeable

close

Field Detail

LOAD_BALANCING_HANDLE

protected static final int LOAD_BALANCING_HANDLE

See Also:

Constant Field Values

LOAD_BALANCING_BYTE

protected static final int LOAD_BALANCING_BYTE

See Also:

Constant Field Values

LOAD_BALANCING_FRAME

protected static final int LOAD_BALANCING_FRAME

See Also:

Constant Field Values

LOAD_TYPE

protected static final int LOAD_TYPE

handleCount

protected final SwCounter handleCount

completedMigrations

protected final SwCounter completedMigrations

logger

protected final ILogger logger

channel

protected final Channel channel

ioThread

protected NioThread ioThread

selectionKey

protected SelectionKey selectionKey

Method Detail

getChannel

public Channel getChannel()

getOwner

public NioThread getOwner()

Description copied from interface: MigratableHandler

Get NioThread 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

start

public void start()

publish

protected abstract void publish()

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