com.hazelcast.cp.internal.datastructures.countdownlatch

Class RaftCountDownLatchService

java.lang.Object

com.hazelcast.cp.internal.datastructures.spi.blocking.AbstractBlockingService<AwaitInvocationKey,RaftCountDownLatch,RaftCountDownLatchRegistry>

com.hazelcast.cp.internal.datastructures.countdownlatch.RaftCountDownLatchService

All Implemented Interfaces:

RaftManagedService, RaftRemoteService, SnapshotAwareService<RaftCountDownLatchRegistry>, RaftGroupLifecycleAwareService, SessionAwareService, LiveOperationsTracker, ManagedService, RemoteService

public class RaftCountDownLatchService
extends AbstractBlockingService<AwaitInvocationKey,RaftCountDownLatch,RaftCountDownLatchRegistry>

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, nodeEngine, raftService, WAIT_TIMEOUT_TASK_UPPER_BOUND_MILLIS

Constructor Summary

Constructors

Constructor and Description
RaftCountDownLatchService(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)
DistributedObject	createDistributedObject(String proxyName) Creates a distributed object.
protected RaftCountDownLatchRegistry	createNewRegistry(CPGroupId groupId) Creates a registry for the given Raft group.
void	destroyDistributedObject(String objectName) Destroys a distributed object.
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

addLiveOperation, destroyRaftObject, expireWaitKeys, getAttachedSessions, getLiveOperations, getOrInitRegistry, getRegistryOrNull, heartbeatSession, init, initImpl, notifyWaitKeys, onCPSubsystemRestart, onGroupDestroy, onRegistryRestored, onSessionClose, populate, reset, restoreSnapshot, scheduleTimeout, setSessionAccessor, shutdown, shutdownImpl, takeSnapshot

Methods inherited from class java.lang.Object

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

Field Detail

SERVICE_NAME

public static final String SERVICE_NAME

Name of the service

See Also:

Constant Field Values

Constructor Detail

RaftCountDownLatchService

public RaftCountDownLatchService(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 RaftCountDownLatchRegistry createNewRegistry(CPGroupId groupId)

Description copied from class: AbstractBlockingService

Creates a registry for the given Raft group.

Specified by:

createNewRegistry in class AbstractBlockingService<AwaitInvocationKey,RaftCountDownLatch,RaftCountDownLatchRegistry>

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,RaftCountDownLatch,RaftCountDownLatchRegistry>

serviceName

protected String serviceName()

Description copied from class: AbstractBlockingService

Returns name of the service.

Specified by:

serviceName in class AbstractBlockingService<AwaitInvocationKey,RaftCountDownLatch,RaftCountDownLatchRegistry>

createDistributedObject

public DistributedObject createDistributedObject(String proxyName)

Description copied from interface: RemoteService

Creates a distributed object.

Parameters:

proxyName - the name for the created distributed object

Returns:

the created distributed object

destroyDistributedObject

public void destroyDistributedObject(String objectName)

Description copied from interface: RemoteService

Destroys a distributed object.

Parameters:

objectName - the name of the distributed object to destroy