com.hazelcast.cp.internal.datastructures.lock

Class RaftLockService

java.lang.Object

com.hazelcast.cp.internal.datastructures.spi.blocking.AbstractBlockingService<LockInvocationKey,RaftLock,com.hazelcast.cp.internal.datastructures.lock.RaftLockRegistry>

com.hazelcast.cp.internal.datastructures.lock.RaftLockService

All Implemented Interfaces:

RaftManagedService, RaftRemoteService, SnapshotAwareService<com.hazelcast.cp.internal.datastructures.lock.RaftLockRegistry>, RaftGroupLifecycleAwareService, SessionAwareService, LiveOperationsTracker, ManagedService, RemoteService

public class RaftLockService
extends AbstractBlockingService<LockInvocationKey,RaftLock,com.hazelcast.cp.internal.datastructures.lock.RaftLockRegistry>

Contains Raft-based lock 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
RaftLockService(NodeEngine nodeEngine)

Method Summary

Modifier and Type	Method and Description
AcquireResult	acquire(CPGroupId groupId, String name, LockInvocationKey key)
DistributedObject	createDistributedObject(String proxyName) Creates a distributed object.
protected com.hazelcast.cp.internal.datastructures.lock.RaftLockRegistry	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.
RaftLockOwnershipState	getLockOwnershipState(CPGroupId groupId, String name)
protected void	initImpl() Subclasses can implement their custom initialization logic here
protected void	onRegistryRestored(com.hazelcast.cp.internal.datastructures.lock.RaftLockRegistry registry)
boolean	release(CPGroupId groupId, long commitIndex, String name, LockEndpoint endpoint, UUID invocationUid)
protected String	serviceName() Returns name of the service.
AcquireResult	tryAcquire(CPGroupId groupId, String name, LockInvocationKey key, long timeoutMs)

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

addLiveOperation, destroyRaftObject, expireWaitKeys, getAttachedSessions, getLiveOperations, getOrInitRegistry, getRegistryOrNull, heartbeatSession, init, notifyWaitKeys, onCPSubsystemRestart, onGroupDestroy, 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

RaftLockService

public RaftLockService(NodeEngine nodeEngine)

Method Detail

initImpl

protected void initImpl()

Description copied from class: AbstractBlockingService

Subclasses can implement their custom initialization logic here

Overrides:

initImpl in class AbstractBlockingService<LockInvocationKey,RaftLock,com.hazelcast.cp.internal.datastructures.lock.RaftLockRegistry>

acquire

public AcquireResult acquire(CPGroupId groupId,
                             String name,
                             LockInvocationKey key)

tryAcquire

public AcquireResult tryAcquire(CPGroupId groupId,
                                String name,
                                LockInvocationKey key,
                                long timeoutMs)

release

public boolean release(CPGroupId groupId,
                       long commitIndex,
                       String name,
                       LockEndpoint endpoint,
                       UUID invocationUid)

getLockOwnershipState

public RaftLockOwnershipState getLockOwnershipState(CPGroupId groupId,
                                                    String name)

createNewRegistry

protected com.hazelcast.cp.internal.datastructures.lock.RaftLockRegistry createNewRegistry(CPGroupId groupId)

Description copied from class: AbstractBlockingService

Creates a registry for the given Raft group.

Specified by:

createNewRegistry in class AbstractBlockingService<LockInvocationKey,RaftLock,com.hazelcast.cp.internal.datastructures.lock.RaftLockRegistry>

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<LockInvocationKey,RaftLock,com.hazelcast.cp.internal.datastructures.lock.RaftLockRegistry>

onRegistryRestored

protected void onRegistryRestored(com.hazelcast.cp.internal.datastructures.lock.RaftLockRegistry registry)

Overrides:

onRegistryRestored in class AbstractBlockingService<LockInvocationKey,RaftLock,com.hazelcast.cp.internal.datastructures.lock.RaftLockRegistry>

serviceName

protected String serviceName()

Description copied from class: AbstractBlockingService

Returns name of the service.

Specified by:

serviceName in class AbstractBlockingService<LockInvocationKey,RaftLock,com.hazelcast.cp.internal.datastructures.lock.RaftLockRegistry>

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