com.hazelcast.spi.impl.operationparker.impl

Class OperationParkerImpl

java.lang.Object

com.hazelcast.spi.impl.operationparker.impl.OperationParkerImpl

All Implemented Interfaces:

MetricsProvider, OperationParker, LiveOperationsTracker

public class OperationParkerImpl
extends Object
implements OperationParker, LiveOperationsTracker, MetricsProvider

Field Summary

Fields inherited from interface com.hazelcast.spi.impl.operationparker.OperationParker

SERVICE_NAME

Constructor Summary

Constructors

Constructor and Description
OperationParkerImpl(NodeEngineImpl nodeEngine)

Method Summary

Modifier and Type	Method and Description
void	cancelParkedOperations(String serviceName, Object objectId, Throwable cause)
int	getParkQueueCount()
int	getTotalParkedOperationCount()
int	getTotalValidWaitingOperationCount()
void	onClientDisconnected(String clientUuid)
void	onMemberLeft(MemberImpl leftMember)
void	onPartitionMigrate(Address thisAddress, MigrationInfo migrationInfo) Invalidates all parked operations for the migrated partition and sends a PartitionMigratingException as a response.
void	park(BlockingOperation op) Parks the Operation until it is unparked by a OperationParker.unpark(Notifier) call or by a timeout specified by the BlockingOperation.getWaitTimeout().
void	populate(LiveOperations liveOperations) Populate the LiveOperations
void	provideMetrics(MetricsRegistry registry)
void	reset()
void	shutdown()
String	toString()
void	unpark(Notifier notifier) Unparks the parked BlockingOperation operation by rescheduling it on the OperationExecutor A parked operation registered with the Notifier.getNotifiedKey() will be notified and deregistered.

Methods inherited from class java.lang.Object

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

Constructor Detail

OperationParkerImpl

public OperationParkerImpl(NodeEngineImpl nodeEngine)

Method Detail

provideMetrics

public void provideMetrics(MetricsRegistry registry)

Specified by:

provideMetrics in interface MetricsProvider

populate

public void populate(LiveOperations liveOperations)

Description copied from interface: LiveOperationsTracker

Populate the LiveOperations

Specified by:

populate in interface LiveOperationsTracker

Parameters:

liveOperations - the LiveOperations to populate.

park

public void park(BlockingOperation op)

Description copied from interface: OperationParker

Parks the Operation until it is unparked by a OperationParker.unpark(Notifier) call or by a timeout specified by the BlockingOperation.getWaitTimeout(). After the BlockingOperation is parked, this method returns; it doesn't wait. BlockingOperation operation will be registered using WaitNotifyKey returned from method BlockingOperation.getWaitKey(). If wait time-outs, BlockingOperation.onWaitExpire() method is called. This method should be called in the thread executes the actual BlockingOperation operation.

Specified by:

park in interface OperationParker

Parameters:

op - operation which will wait for notification

unpark

public void unpark(Notifier notifier)

Description copied from interface: OperationParker

Unparks the parked BlockingOperation operation by rescheduling it on the OperationExecutor A parked operation registered with the Notifier.getNotifiedKey() will be notified and deregistered. This method has no effect if there isn't any operation registered for related WaitNotifyKey. This method should be called in the thread that executes the actual Notifier operation.

Specified by:

unpark in interface OperationParker

Parameters:

notifier - operation which will unpark a corresponding waiting operation

getParkQueueCount

public int getParkQueueCount()

getTotalParkedOperationCount

public int getTotalParkedOperationCount()

getTotalValidWaitingOperationCount

public int getTotalValidWaitingOperationCount()

onMemberLeft

public void onMemberLeft(MemberImpl leftMember)

onClientDisconnected

public void onClientDisconnected(String clientUuid)

onPartitionMigrate

public void onPartitionMigrate(Address thisAddress,
                               MigrationInfo migrationInfo)

Invalidates all parked operations for the migrated partition and sends a PartitionMigratingException as a response. Invoked on the migration destination. This is executed under partition migration lock!

cancelParkedOperations

public void cancelParkedOperations(String serviceName,
                                   Object objectId,
                                   Throwable cause)

Specified by:

cancelParkedOperations in interface OperationParker

reset

public void reset()

shutdown

public void shutdown()

toString

public String toString()

Overrides:

toString in class Object