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>, RaftNodeLifecycleAwareService, SessionAwareService, LiveOperationsTracker, ManagedService

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
AcquireResult	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)
protected RaftSemaphoreRegistry	createNewRegistry(CPGroupId groupId) Creates a registry for the given Raft group.
ISemaphore	createProxy(String proxyName) Creates a proxy for a CP data structure.
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

destroyRaftObject, expireWaitKeys, getAttachedSessions, getLiveOperations, getOrInitRegistry, getRegistryOrNull, heartbeatSession, init, initImpl, notifyWaitKeys, onCPSubsystemRestart, onRaftGroupDestroyed, onRaftNodeSteppedDown, 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 AcquireResult 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>

createProxy

public ISemaphore 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