com.hazelcast.spi.impl.operationparker.impl

Class WaitSet

java.lang.Object

com.hazelcast.spi.impl.operationparker.impl.WaitSet

All Implemented Interfaces:

LiveOperationsTracker, Iterable<com.hazelcast.spi.impl.operationparker.impl.WaitSetEntry>

public class WaitSet
extends Object
implements LiveOperationsTracker, Iterable<com.hazelcast.spi.impl.operationparker.impl.WaitSetEntry>

The WaitSet is a effectively a set of operations waiting for some condition. For example it could be a set of lock-operations that are waiting for a lock to come available.

Constructor Summary

Constructors

Constructor and Description
WaitSet(ILogger logger, NodeEngine nodeEngine, Map<WaitNotifyKey,WaitSet> waitSetMap, Queue<com.hazelcast.spi.impl.operationparker.impl.WaitSetEntry> delayQueue)

Method Summary

Modifier and Type	Method and Description
void	cancelAll(String serviceName, Object objectId, Throwable cause)
void	cancelAll(String callerUuid, Throwable cause)
void	invalidateAll(String callerUuid)
Iterator<com.hazelcast.spi.impl.operationparker.impl.WaitSetEntry>	iterator()
void	onShutdown()
void	park(BlockingOperation op)
void	populate(LiveOperations liveOperations) Populate the LiveOperations
int	size()
int	totalValidWaitingOperationCount()
void	unpark(Notifier notifier, WaitNotifyKey key)

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Constructor Detail

WaitSet

public WaitSet(ILogger logger,
               NodeEngine nodeEngine,
               Map<WaitNotifyKey,WaitSet> waitSetMap,
               Queue<com.hazelcast.spi.impl.operationparker.impl.WaitSetEntry> delayQueue)

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.

park

public void park(BlockingOperation op)

unpark

public void unpark(Notifier notifier,
                   WaitNotifyKey key)

onShutdown

public void onShutdown()

invalidateAll

public void invalidateAll(String callerUuid)

cancelAll

public void cancelAll(String callerUuid,
                      Throwable cause)

cancelAll

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

size

public int size()

totalValidWaitingOperationCount

public int totalValidWaitingOperationCount()

iterator

public Iterator<com.hazelcast.spi.impl.operationparker.impl.WaitSetEntry> iterator()

Specified by:

iterator in interface Iterable<com.hazelcast.spi.impl.operationparker.impl.WaitSetEntry>