com.hazelcast.internal.networking.nio

Class NioOutboundPipeline

java.lang.Object

com.hazelcast.internal.networking.nio.NioPipeline

com.hazelcast.internal.networking.nio.NioOutboundPipeline

All Implemented Interfaces:

MigratablePipeline, Closeable, AutoCloseable, Runnable

public final class NioOutboundPipeline
extends NioPipeline
implements Runnable

Field Summary

Fields

Modifier and Type	Field and Description
Queue<OutboundFrame>	urgentWriteQueue
Queue<OutboundFrame>	writeQueue

Fields inherited from class com.hazelcast.internal.networking.nio.NioPipeline

channel, completedMigrations, LOAD_BALANCING_BYTE, LOAD_BALANCING_FRAME, LOAD_BALANCING_HANDLE, LOAD_TYPE, logger, owner, processCount, selectionKey

Constructor Summary

Constructors

Constructor and Description
NioOutboundPipeline(NioChannel channel, NioThread owner, ChannelErrorHandler errorHandler, ILogger logger, IOBalancer balancer, ChannelInitializer initializer)

Method Summary

Modifier and Type	Method and Description
long	bytesPending()
void	close()
void	flush()
long	lastWriteTimeMillis()
long	load() Get 'load' recorded by the current pipeline.
long	priorityBytesPending()
void	process() Called when there are bytes available for reading, or space available to write.
protected void	publishMetrics()
void	requestMigration(NioThread newOwner) Requests the MigratablePipeline to move to the new NioThread.
void	run()
String	toString()
int	totalFramesPending()
void	write(OutboundFrame frame)

Methods inherited from class com.hazelcast.internal.networking.nio.NioPipeline

getChannel, onFailure, owner, start

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Detail

writeQueue

public final Queue<OutboundFrame> writeQueue

urgentWriteQueue

public final Queue<OutboundFrame> urgentWriteQueue

Constructor Detail

NioOutboundPipeline

public NioOutboundPipeline(NioChannel channel,
                           NioThread owner,
                           ChannelErrorHandler errorHandler,
                           ILogger logger,
                           IOBalancer balancer,
                           ChannelInitializer initializer)

Method Detail

load

public long load()

Description copied from interface: MigratablePipeline

Get 'load' recorded by the current pipeline. It can be used to calculate whether this pipeline should be migrated to a different NioThread

Specified by:

load in interface MigratablePipeline

Returns:

total load recorded by this pipeline

totalFramesPending

public int totalFramesPending()

lastWriteTimeMillis

public long lastWriteTimeMillis()

bytesPending

public long bytesPending()

priorityBytesPending

public long priorityBytesPending()

flush

public void flush()

write

public void write(OutboundFrame frame)

process

public void process()
             throws Exception

Description copied from class: NioPipeline

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.

Specified by:

process in class NioPipeline

Throws:

Exception

run

public void run()

Specified by:

run in interface Runnable

close

public void close()

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

requestMigration

public void requestMigration(NioThread newOwner)

Description copied from interface: MigratablePipeline

Requests the MigratablePipeline to move to the new NioThread. This call will not wait for the migration to complete. This method can be called by any thread, and will probably be called by the IOBalancer. Call is ignored when pipeline is moving to the same NioThread.

Specified by:

requestMigration in interface MigratablePipeline

Parameters:

newOwner - the NioThread that is going to own this MigratablePipeline

toString

public String toString()

Overrides:

toString in class Object

publishMetrics

protected void publishMetrics()

Specified by:

publishMetrics in class NioPipeline