com.hazelcast.internal.networking.nio

Class NioPipeline

java.lang.Object

com.hazelcast.internal.networking.nio.NioPipeline

All Implemented Interfaces:

MigratablePipeline, Runnable

Direct Known Subclasses:

NioInboundPipeline, NioOutboundPipeline

public abstract class NioPipeline
extends Object
implements MigratablePipeline, Runnable

Field Summary

Fields

Modifier and Type	Field and Description
protected NioChannel	channel
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
protected SocketChannel	socketChannel

Method Summary

Modifier and Type	Method and Description
Channel	getChannel()
protected abstract Iterable<? extends ChannelHandler>	handlers() Returns an Iterable that can iterate over each ChannelHandler of the pipeline.
void	onError(Throwable error) Is called when the process() throws a Throwable.
NioThread	owner() Returns the NioThread owning this pipeline.
void	requestMigration(NioThread newOwner) Migrates this pipeline to a different owner.
void	run()

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

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

logger

protected final ILogger logger

channel

protected final NioChannel channel

socketChannel

protected final SocketChannel socketChannel

owner

protected volatile NioThread owner

selectionKey

protected SelectionKey selectionKey

Method Detail

getChannel

public Channel getChannel()

owner

public NioThread owner()

Returns the NioThread owning this pipeline. It can be null when the pipeline is being migrated between threads.

Owner is the thread executing the pipeline.

Specified by:

owner in interface MigratablePipeline

Returns:

thread owning the pipeline or null when the pipeline is being migrated

run

public final void run()

Specified by:

run in interface Runnable

onError

public void onError(Throwable error)

Is called when the process() throws a Throwable.

This method should only be called by the current owner.

The idiom to use a pipeline is: try{ pipeline.process(); } catch(Throwable t) { pipeline.onError(t); }

Parameters:

error -

handlers

protected abstract Iterable<? extends ChannelHandler> handlers()

Returns an Iterable that can iterate over each ChannelHandler of the pipeline.

This method is called only by the onError(Throwable).

Returns:

the Iterable.

requestMigration

public final void requestMigration(NioThread newOwner)

Migrates this pipeline to a different owner. The migration logic is rather simple:

• Submit a de-registration task to a current NioThread
• The de-registration task submits a registration task to the new NioThread

Specified by:

requestMigration in interface MigratablePipeline

Parameters:

newOwner - target NioThread this handler migrates to