public class CountDownLatchService extends AbstractBlockingService<AwaitInvocationKey,CountDownLatch,CountDownLatchRegistry>
Modifier and Type | Field and Description |
---|---|
static String |
SERVICE_NAME
Name of the service
|
logger, raftService, WAIT_TIMEOUT_TASK_UPPER_BOUND_MILLIS
nodeEngine
Constructor and Description |
---|
CountDownLatchService(NodeEngine nodeEngine) |
Modifier and Type | Method and Description |
---|---|
boolean |
await(CPGroupId groupId,
String name,
AwaitInvocationKey key,
long timeoutMillis) |
int |
countDown(CPGroupId groupId,
String name,
UUID invocationUuid,
int expectedRound) |
protected CountDownLatchRegistry |
createNewRegistry(CPGroupId groupId)
Creates a registry for the given Raft group.
|
ICountDownLatch |
createProxy(String proxyName)
Creates a proxy for a CP data structure.
|
protected Object |
expiredWaitKeyResponse()
Creates the response object that will be sent for a expired wait key.
|
int |
getRemainingCount(CPGroupId groupId,
String name) |
int |
getRound(CPGroupId groupId,
String name) |
protected String |
serviceName()
Returns name of the service.
|
boolean |
trySetCount(CPGroupId groupId,
String name,
int count) |
clearPartitionReplica, destroyRaftObject, expireWaitKeys, getAttachedSessions, getBackupCount, getGroupIdSet, getLiveOperations, getOrInitRegistry, getRegistryOrNull, getSnapshotMap, heartbeatSession, init, initImpl, notifyWaitKeys, onCPSubsystemRestart, onRaftGroupDestroyed, onRaftNodeSteppedDown, onRegistryRestored, onSessionClose, populate, reset, restoreSnapshot, scheduleTimeout, setSessionAccessor, shutdown, shutdownImpl, takeSnapshot
beforeMigration, commitMigration, prepareReplicationOperation, rollbackMigration
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
beforeMigration, commitMigration, prepareReplicationOperation, rollbackMigration
public static final String SERVICE_NAME
public CountDownLatchService(NodeEngine nodeEngine)
public int countDown(CPGroupId groupId, String name, UUID invocationUuid, int expectedRound)
public boolean await(CPGroupId groupId, String name, AwaitInvocationKey key, long timeoutMillis)
protected CountDownLatchRegistry createNewRegistry(CPGroupId groupId)
AbstractBlockingService
createNewRegistry
in class AbstractBlockingService<AwaitInvocationKey,CountDownLatch,CountDownLatchRegistry>
protected Object expiredWaitKeyResponse()
AbstractBlockingService
expiredWaitKeyResponse
in class AbstractBlockingService<AwaitInvocationKey,CountDownLatch,CountDownLatchRegistry>
protected String serviceName()
AbstractBlockingService
serviceName
in class AbstractBlockingService<AwaitInvocationKey,CountDownLatch,CountDownLatchRegistry>
public ICountDownLatch createProxy(String proxyName)
RaftRemoteService
proxyName
- the name of the CP data structureCopyright © 2019 Hazelcast, Inc.. All rights reserved.