com.hazelcast.internal.networking.nio

Class NioPipeline

java.lang.Object

com.hazelcast.internal.networking.nio.NioPipeline

All Implemented Interfaces:

MigratablePipeline, Closeable, AutoCloseable

Direct Known Subclasses:

NioInboundPipeline, NioOutboundPipeline

public abstract class NioPipeline
extends Object
implements MigratablePipeline, Closeable

Field Summary

Fields

Modifier and Type	Field and Description
protected Channel	channel
protected SwCounter	completedMigrations
protected static int	LOAD_BALANCING_BYTE
protected static int	LOAD_BALANCING_FRAME
protected static int	LOAD_BALANCING_HANDLE
protected int	loadType
protected ILogger	logger
protected NioThread	owner
protected SwCounter	processCount
protected SelectionKey	selectionKey

Method Summary

Modifier and Type	Method and Description
Channel	getChannel()
void	onFailure(Throwable e) Is called when the process() throws an exception.
NioThread	owner() Get NioThread currently owning this pipeline.
abstract void	process() Called when there are bytes available for reading, or space available to write.
protected abstract void	publishMetrics()
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.MigratablePipeline

load, 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

loadType

protected final int loadType

processCount

protected final SwCounter processCount

completedMigrations

protected final SwCounter completedMigrations

logger

protected final ILogger logger

channel

protected final Channel channel

owner

protected NioThread owner

selectionKey

protected SelectionKey selectionKey

Method Detail

getChannel

public Channel getChannel()

owner

public NioThread owner()

Description copied from interface: MigratablePipeline

Get NioThread currently owning this pipeline. Pipeline owner is a thread running this pipeline. IOBalancer can decide to migrate a pipeline to another owner.

Specified by:

owner in interface MigratablePipeline

Returns:

current owner

start

public void start()

publishMetrics

protected abstract void publishMetrics()

process

public abstract void process()
                      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 process() throws an exception. The idiom to use a pipeline is: try{ pipeline.handle(); } catch(Throwable t) { pipeline.onFailure(t); }

Parameters:

e -