com.hazelcast.concurrent.lock

Class LockStoreImpl

java.lang.Object

com.hazelcast.concurrent.lock.LockStoreImpl

All Implemented Interfaces:

LockStore, DataSerializable

public final class LockStoreImpl
extends Object
implements DataSerializable, LockStore

Constructor Summary

Constructors

Constructor and Description
LockStoreImpl()
LockStoreImpl(LockService lockService, ObjectNamespace name, EntryTaskScheduler entryTaskScheduler, int backupCount, int asyncBackupCount)

Method Summary

Modifier and Type	Method and Description
void	addAwait(Data key, String conditionId, String caller, long threadId)
boolean	canAcquireLock(Data key, String caller, long threadId)
void	clear()
boolean	extendLeaseTime(Data key, String caller, long threadId, long leaseTime)
boolean	forceUnlock(Data key)
int	getAsyncBackupCount()
int	getBackupCount()
com.hazelcast.concurrent.lock.LockResourceImpl	getLock(Data key)
int	getLockCount(Data key)
int	getLockedEntryCount()
Set<Data>	getLockedKeys()
Collection<LockResource>	getLocks()
ObjectNamespace	getNamespace()
WaitNotifyKey	getNotifiedKey(Data key)
String	getOwnerInfo(Data key)
long	getRemainingLeaseTime(Data key)
int	getTotalBackupCount()
int	getVersion(Data key)
boolean	hasLock()
boolean	hasSignalKey(ConditionKey conditionKey)
boolean	isLocked(Data key)
boolean	isLockedBy(Data key, String caller, long threadId)
boolean	lock(Data key, String caller, long threadId, long referenceId, long leaseTime)
AwaitOperation	pollExpiredAwaitOp(Data key)
void	readData(ObjectDataInput in) Reads fields from the input stream
void	registerExpiredAwaitOp(AwaitOperation awaitResponse)
void	removeAwait(Data key, String conditionId, String caller, long threadId)
void	removeSignalKey(ConditionKey conditionKey)
boolean	shouldBlockReads(Data key)
void	signal(Data key, String conditionId, int maxSignalCount, String objectName)
String	toString()
boolean	txnLock(Data key, String caller, long threadId, long referenceId, long leaseTime, boolean blockReads)
boolean	unlock(Data key, String caller, long threadId, long referenceId)
void	writeData(ObjectDataOutput out) Writes object fields to output stream

Methods inherited from class java.lang.Object

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

Constructor Detail

LockStoreImpl

public LockStoreImpl()

LockStoreImpl

public LockStoreImpl(LockService lockService,
                     ObjectNamespace name,
                     EntryTaskScheduler entryTaskScheduler,
                     int backupCount,
                     int asyncBackupCount)

Method Detail

lock

public boolean lock(Data key,
                    String caller,
                    long threadId,
                    long referenceId,
                    long leaseTime)

Specified by:

lock in interface LockStore

txnLock

public boolean txnLock(Data key,
                       String caller,
                       long threadId,
                       long referenceId,
                       long leaseTime,
                       boolean blockReads)

Specified by:

txnLock in interface LockStore

extendLeaseTime

public boolean extendLeaseTime(Data key,
                               String caller,
                               long threadId,
                               long leaseTime)

Specified by:

extendLeaseTime in interface LockStore

getLock

public com.hazelcast.concurrent.lock.LockResourceImpl getLock(Data key)

isLocked

public boolean isLocked(Data key)

Specified by:

isLocked in interface LockStore

isLockedBy

public boolean isLockedBy(Data key,
                          String caller,
                          long threadId)

Specified by:

isLockedBy in interface LockStore

getLockCount

public int getLockCount(Data key)

Specified by:

getLockCount in interface LockStore

getLockedEntryCount

public int getLockedEntryCount()

Specified by:

getLockedEntryCount in interface LockStore

getRemainingLeaseTime

public long getRemainingLeaseTime(Data key)

Specified by:

getRemainingLeaseTime in interface LockStore

canAcquireLock

public boolean canAcquireLock(Data key,
                              String caller,
                              long threadId)

Specified by:

canAcquireLock in interface LockStore

shouldBlockReads

public boolean shouldBlockReads(Data key)

Specified by:

shouldBlockReads in interface LockStore

unlock

public boolean unlock(Data key,
                      String caller,
                      long threadId,
                      long referenceId)

Specified by:

unlock in interface LockStore

forceUnlock

public boolean forceUnlock(Data key)

Specified by:

forceUnlock in interface LockStore

getVersion

public int getVersion(Data key)

getLocks

public Collection<LockResource> getLocks()

getLockedKeys

public Set<Data> getLockedKeys()

Specified by:

getLockedKeys in interface LockStore

hasLock

public boolean hasLock()

clear

public void clear()

getNamespace

public ObjectNamespace getNamespace()

getBackupCount

public int getBackupCount()

getAsyncBackupCount

public int getAsyncBackupCount()

getTotalBackupCount

public int getTotalBackupCount()

addAwait

public void addAwait(Data key,
                     String conditionId,
                     String caller,
                     long threadId)

removeAwait

public void removeAwait(Data key,
                        String conditionId,
                        String caller,
                        long threadId)

signal

public void signal(Data key,
                   String conditionId,
                   int maxSignalCount,
                   String objectName)

getNotifiedKey

public WaitNotifyKey getNotifiedKey(Data key)

removeSignalKey

public void removeSignalKey(ConditionKey conditionKey)

hasSignalKey

public boolean hasSignalKey(ConditionKey conditionKey)

registerExpiredAwaitOp

public void registerExpiredAwaitOp(AwaitOperation awaitResponse)

pollExpiredAwaitOp

public AwaitOperation pollExpiredAwaitOp(Data key)

getOwnerInfo

public String getOwnerInfo(Data key)

Specified by:

getOwnerInfo in interface LockStore

writeData

public void writeData(ObjectDataOutput out)
               throws IOException

Description copied from interface: DataSerializable

Writes object fields to output stream

Specified by:

writeData in interface DataSerializable

Parameters:

out - output

Throws:

IOException

readData

public void readData(ObjectDataInput in)
              throws IOException

Description copied from interface: DataSerializable

Reads fields from the input stream

Specified by:

readData in interface DataSerializable

Parameters:

in - input

Throws:

IOException

toString

public String toString()

Overrides:

toString in class Object