com.hazelcast.cp.internal.datastructures.countdownlatch

Class CountDownLatchService

java.lang.Object

com.hazelcast.cp.internal.datastructures.spi.AbstractCPMigrationAwareService

com.hazelcast.cp.internal.datastructures.spi.blocking.AbstractBlockingService<AwaitInvocationKey,CountDownLatch,CountDownLatchRegistry>

com.hazelcast.cp.internal.datastructures.countdownlatch.CountDownLatchService

All Implemented Interfaces:

RaftManagedService, RaftRemoteService, SnapshotAwareService<CountDownLatchRegistry>, RaftNodeLifecycleAwareService, SessionAwareService, ManagedService, LiveOperationsTracker, MigrationAwareService

public class CountDownLatchService
extends AbstractBlockingService<AwaitInvocationKey,CountDownLatch,CountDownLatchRegistry>

Contains Raft-based count down latch instances

Field Summary

Fields

Modifier and Type	Field and Description
static String	SERVICE_NAME Name of the service

Fields inherited from class com.hazelcast.cp.internal.datastructures.spi.blocking.AbstractBlockingService

logger, raftService, WAIT_TIMEOUT_TASK_UPPER_BOUND_MILLIS

Fields inherited from class com.hazelcast.cp.internal.datastructures.spi.AbstractCPMigrationAwareService

nodeEngine

Constructor Summary

Constructors

Constructor and Description
CountDownLatchService(NodeEngine nodeEngine)

Method Summary

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)

Methods inherited from class com.hazelcast.cp.internal.datastructures.spi.blocking.AbstractBlockingService

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

Methods inherited from class com.hazelcast.cp.internal.datastructures.spi.AbstractCPMigrationAwareService

beforeMigration, commitMigration, prepareReplicationOperation, rollbackMigration

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.hazelcast.spi.partition.MigrationAwareService

beforeMigration, commitMigration, prepareReplicationOperation, rollbackMigration

Field Detail

SERVICE_NAME

public static final String SERVICE_NAME

Name of the service

See Also:

Constant Field Values

Constructor Detail

CountDownLatchService

public CountDownLatchService(NodeEngine nodeEngine)

Method Detail

trySetCount

public boolean trySetCount(CPGroupId groupId,
                           String name,
                           int count)

countDown

public int countDown(CPGroupId groupId,
                     String name,
                     UUID invocationUuid,
                     int expectedRound)

await

public boolean await(CPGroupId groupId,
                     String name,
                     AwaitInvocationKey key,
                     long timeoutMillis)

getRemainingCount

public int getRemainingCount(CPGroupId groupId,
                             String name)

getRound

public int getRound(CPGroupId groupId,
                    String name)

createNewRegistry

protected CountDownLatchRegistry createNewRegistry(CPGroupId groupId)

Description copied from class: AbstractBlockingService

Creates a registry for the given Raft group.

Specified by:

createNewRegistry in class AbstractBlockingService<AwaitInvocationKey,CountDownLatch,CountDownLatchRegistry>

expiredWaitKeyResponse

protected Object expiredWaitKeyResponse()

Description copied from class: AbstractBlockingService

Creates the response object that will be sent for a expired wait key.

Specified by:

expiredWaitKeyResponse in class AbstractBlockingService<AwaitInvocationKey,CountDownLatch,CountDownLatchRegistry>

serviceName

protected String serviceName()

Description copied from class: AbstractBlockingService

Returns name of the service.

Specified by:

serviceName in class AbstractBlockingService<AwaitInvocationKey,CountDownLatch,CountDownLatchRegistry>

createProxy

public ICountDownLatch createProxy(String proxyName)

Description copied from interface: RaftRemoteService

Creates a proxy for a CP data structure. This method is called outside of the Raft layer.

Parameters:

proxyName - the name of the CP data structure

Returns:

the created proxy