com.hazelcast.client.cp.internal.datastructures.lock

Class RaftFencedLockProxy

java.lang.Object

com.hazelcast.client.spi.ClientProxy

com.hazelcast.client.cp.internal.datastructures.lock.RaftFencedLockProxy

All Implemented Interfaces:

DistributedObject, FencedLock, Lock

public class RaftFencedLockProxy
extends ClientProxy
implements FencedLock

Client-side proxy of Raft-based FencedLock API

Field Summary

Fields inherited from class com.hazelcast.client.spi.ClientProxy

name

Fields inherited from interface com.hazelcast.cp.lock.FencedLock

INVALID_FENCE

Constructor Summary

Constructors

Constructor and Description
RaftFencedLockProxy(ClientContext context, RaftGroupId groupId, String proxyName, String objectName)

Method Summary

Modifier and Type	Method and Description
long	getFence()
CPGroupId	getGroupId()
int	getLockCount()
boolean	isLocked()
boolean	isLockedByCurrentThread()
void	lock()
long	lockAndGetFence()
void	lockInterruptibly()
Condition	newCondition()
void	onDestroy() Called before proxy is destroyed.
protected void	postDestroy() Called after proxy is destroyed.
boolean	tryLock()
boolean	tryLock(long time, TimeUnit unit)
long	tryLockAndGetFence()
long	tryLockAndGetFence(long time, TimeUnit unit)
void	unlock()

Methods inherited from class com.hazelcast.client.spi.ClientProxy

deregisterListener, destroy, destroyLocally, destroyRemotely, equals, getClient, getConnectedServerVersion, getContext, getDistributedObjectName, getId, getName, getPartitionKey, getSerializationService, getServiceName, hashCode, invoke, invoke, invokeOnAddress, invokeOnPartition, invokeOnPartitionInterruptibly, onInitialize, onShutdown, preDestroy, registerListener, setContext, toData, toObject

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.hazelcast.core.DistributedObject

destroy, getName, getPartitionKey, getServiceName

Constructor Detail

RaftFencedLockProxy

public RaftFencedLockProxy(ClientContext context,
                           RaftGroupId groupId,
                           String proxyName,
                           String objectName)

Method Detail

lock

public void lock()

Specified by:

lock in interface FencedLock

Specified by:

lock in interface Lock

lockInterruptibly

public void lockInterruptibly()
                       throws InterruptedException

Specified by:

lockInterruptibly in interface FencedLock

Specified by:

lockInterruptibly in interface Lock

Throws:

InterruptedException

lockAndGetFence

public long lockAndGetFence()

Specified by:

lockAndGetFence in interface FencedLock

tryLock

public boolean tryLock()

Specified by:

tryLock in interface FencedLock

Specified by:

tryLock in interface Lock

tryLockAndGetFence

public long tryLockAndGetFence()

Specified by:

tryLockAndGetFence in interface FencedLock

tryLock

public boolean tryLock(long time,
                       TimeUnit unit)

Specified by:

tryLock in interface FencedLock

Specified by:

tryLock in interface Lock

tryLockAndGetFence

public long tryLockAndGetFence(long time,
                               TimeUnit unit)

Specified by:

tryLockAndGetFence in interface FencedLock

unlock

public void unlock()

Specified by:

unlock in interface FencedLock

Specified by:

unlock in interface Lock

getFence

public long getFence()

Specified by:

getFence in interface FencedLock

isLocked

public boolean isLocked()

Specified by:

isLocked in interface FencedLock

isLockedByCurrentThread

public boolean isLockedByCurrentThread()

Specified by:

isLockedByCurrentThread in interface FencedLock

getLockCount

public int getLockCount()

Specified by:

getLockCount in interface FencedLock

getGroupId

public CPGroupId getGroupId()

Specified by:

getGroupId in interface FencedLock

newCondition

public Condition newCondition()

Specified by:

newCondition in interface FencedLock

Specified by:

newCondition in interface Lock

onDestroy

public void onDestroy()

Description copied from class: ClientProxy

Called before proxy is destroyed. Overriding implementations should clean/release resources created during initialization.

Overrides:

onDestroy in class ClientProxy

postDestroy

protected void postDestroy()

Description copied from class: ClientProxy

Called after proxy is destroyed.

Overrides:

postDestroy in class ClientProxy