com.hazelcast.internal.networking.nio

Interface MigratablePipeline

All Known Implementing Classes:

NioInboundPipeline, NioOutboundPipeline, NioPipeline

public interface MigratablePipeline

A NioPipeline that supports migration between NioThread instances. This API is called by the IOBalancer.

Method Summary

Modifier and Type	Method and Description
long	load() Get 'load' recorded by the current pipeline.
NioThread	owner() Get NioThread currently owning this pipeline.
void	requestMigration(NioThread newOwner) Requests the MigratablePipeline to move to the new NioThread.

Method Detail

requestMigration

void requestMigration(NioThread newOwner)

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.

Parameters:

newOwner - the NioThread that is going to own this MigratablePipeline

owner

NioThread owner()

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

Returns:

current owner

load

long load()

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

Returns:

total load recorded by this pipeline