com.hazelcast.internal.networking.nio

Class NioPipeline

java.lang.Object

com.hazelcast.internal.networking.nio.NioPipeline

All Implemented Interfaces:

MigratableHandler, Closeable, AutoCloseable

Direct Known Subclasses:

NioInboundPipeline, NioOutboundPipeline

public abstract class NioPipeline
extends Object
implements 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.
abstract void	handle() Called when there are bytes available for reading, or space available to write.
void	onFailure(Throwable e) Is called when the 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.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()

handle

public abstract void handle()
                     throws Exception

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.

Throws:

Exception

onFailure

public void onFailure(Throwable e)

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

Parameters:

e -