com.hazelcast.cp.internal.datastructures.semaphore

Class RaftSemaphoreService

java.lang.Object

com.hazelcast.cp.internal.datastructures.spi.blocking.AbstractBlockingService<AcquireInvocationKey,RaftSemaphore,RaftSemaphoreRegistry>

com.hazelcast.cp.internal.datastructures.semaphore.RaftSemaphoreService

All Implemented Interfaces:

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

public class RaftSemaphoreService
extends AbstractBlockingService<AcquireInvocationKey,RaftSemaphore,RaftSemaphoreRegistry>

Contains Raft-based semaphore 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
RaftSemaphoreService(NodeEngine nodeEngine)

Method Summary

Modifier and Type	Method and Description
boolean	acquirePermits(CPGroupId groupId, String name, AcquireInvocationKey key, long timeoutMs)
int	availablePermits(CPGroupId groupId, String name)
boolean	changePermits(CPGroupId groupId, long commitIndex, String name, SemaphoreEndpoint endpoint, UUID invocationUid, int permits)
DistributedObject	createDistributedObject(String proxyName) Creates a distributed object.
protected RaftSemaphoreRegistry	createNewRegistry(CPGroupId groupId) Creates a registry for the given Raft group.
void	destroyDistributedObject(String objectName) Destroys a distributed object.
int	drainPermits(CPGroupId groupId, String name, long commitIndex, SemaphoreEndpoint endpoint, UUID invocationUid)
protected Object	expiredWaitKeyResponse() Creates the response object that will be sent for a expired wait key.
boolean	initSemaphore(CPGroupId groupId, String name, int permits)
void	releasePermits(CPGroupId groupId, long commitIndex, String name, SemaphoreEndpoint endpoint, UUID invocationUid, int permits)
protected String	serviceName() Returns name of the service.

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

RaftSemaphoreService

public RaftSemaphoreService(NodeEngine nodeEngine)

Method Detail

initSemaphore

public boolean initSemaphore(CPGroupId groupId,
                             String name,
                             int permits)

availablePermits

public int availablePermits(CPGroupId groupId,
                            String name)

acquirePermits

public boolean acquirePermits(CPGroupId groupId,
                              String name,
                              AcquireInvocationKey key,
                              long timeoutMs)

releasePermits

public void releasePermits(CPGroupId groupId,
                           long commitIndex,
                           String name,
                           SemaphoreEndpoint endpoint,
                           UUID invocationUid,
                           int permits)

drainPermits

public int drainPermits(CPGroupId groupId,
                        String name,
                        long commitIndex,
                        SemaphoreEndpoint endpoint,
                        UUID invocationUid)

changePermits

public boolean changePermits(CPGroupId groupId,
                             long commitIndex,
                             String name,
                             SemaphoreEndpoint endpoint,
                             UUID invocationUid,
                             int permits)

createNewRegistry

protected RaftSemaphoreRegistry createNewRegistry(CPGroupId groupId)

Description copied from class: AbstractBlockingService

Creates a registry for the given Raft group.

Specified by:

createNewRegistry in class AbstractBlockingService<AcquireInvocationKey,RaftSemaphore,RaftSemaphoreRegistry>

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<AcquireInvocationKey,RaftSemaphore,RaftSemaphoreRegistry>

serviceName

protected String serviceName()

Description copied from class: AbstractBlockingService

Returns name of the service.

Specified by:

serviceName in class AbstractBlockingService<AcquireInvocationKey,RaftSemaphore,RaftSemaphoreRegistry>

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