com.hazelcast.spi.impl.waitnotifyservice.impl

Class WaitNotifyServiceImpl

java.lang.Object

com.hazelcast.spi.impl.waitnotifyservice.impl.WaitNotifyServiceImpl

All Implemented Interfaces:

WaitNotifyService, LiveOperationsTracker

public class WaitNotifyServiceImpl
extends Object
implements WaitNotifyService, LiveOperationsTracker

Field Summary

Fields inherited from interface com.hazelcast.spi.impl.waitnotifyservice.WaitNotifyService

SERVICE_NAME

Constructor Summary

Constructors

Constructor and Description
WaitNotifyServiceImpl(NodeEngineImpl nodeEngine)

Method Summary

Methods

Modifier and Type	Method and Description
void	await(BlockingOperation blockingOperation) Causes the current operation to wait in WaitNotifyService until it is notified by a Notifier operation or timeout specified by BlockingOperation.getWaitTimeout() passes.
void	cancelWaitingOps(String serviceName, Object objectId, Throwable cause)
int	getAwaitQueueCount()
int	getTotalValidWaitingOperationCount()
int	getTotalWaitingOperationCount()
void	notify(Notifier notifier) Notifies the waiting BlockingOperation operation to wake-up and continue executing.
void	onClientDisconnected(String clientUuid)
void	onMemberLeft(MemberImpl leftMember)
void	onPartitionMigrate(Address thisAddress, MigrationInfo migrationInfo)
void	populate(LiveOperations liveOperations) Populate the LiveOperations
void	reset()
void	shutdown()
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

WaitNotifyServiceImpl

public WaitNotifyServiceImpl(NodeEngineImpl nodeEngine)

Method Detail

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.

await

public void await(BlockingOperation blockingOperation)

Description copied from interface: WaitNotifyService

Causes the current operation to wait in WaitNotifyService until it is notified by a Notifier operation or timeout specified by BlockingOperation.getWaitTimeout() passes.

BlockingOperation operation will be registered using WaitNotifyKey returned from method BlockingOperation.getWaitKey().

When operation is notified, it's re-executed by related scheduled mechanism.

If wait time-outs, BlockingOperation.onWaitExpire() method is called.

This method should be called in the thread executes the actual BlockingOperation operation.

Specified by:

await in interface WaitNotifyService

Parameters:

blockingOperation - operation which will wait for notification

notify

public void notify(Notifier notifier)

Description copied from interface: WaitNotifyService

Notifies the waiting BlockingOperation operation to wake-up and continue executing.

A waiting 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 executes the actual Notifier operation.

Specified by:

notify in interface WaitNotifyService

Parameters:

notifier - operation which will notify a corresponding waiting operation

getAwaitQueueCount

public int getAwaitQueueCount()

getTotalWaitingOperationCount

public int getTotalWaitingOperationCount()

getTotalValidWaitingOperationCount

public int getTotalValidWaitingOperationCount()

onMemberLeft

public void onMemberLeft(MemberImpl leftMember)

onClientDisconnected

public void onClientDisconnected(String clientUuid)

onPartitionMigrate

public void onPartitionMigrate(Address thisAddress,
                      MigrationInfo migrationInfo)

cancelWaitingOps

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

Specified by:

cancelWaitingOps in interface WaitNotifyService

reset

public void reset()

shutdown

public void shutdown()

toString

public String toString()

Overrides:

toString in class Object