com.hazelcast.concurrent.lock.operations
public class LocalLockCleanupOperation extends UnlockOperation implements Notifier, BackupAwareOperation
Modifier and Type | Field and Description |
---|---|
static int |
ANY_THREAD |
static long |
DEFAULT_LOCK_TTL |
protected Data |
key |
protected ObjectNamespace |
namespace |
protected Object |
response |
protected long |
threadId |
protected long |
ttl |
CALL_ID_LOCAL_SKIPPED, GENERIC_PARTITION_ID
Constructor and Description |
---|
LocalLockCleanupOperation() |
LocalLockCleanupOperation(ObjectNamespace namespace,
Data key,
long threadId) |
Modifier and Type | Method and Description |
---|---|
int |
getAsyncBackupCount() |
int |
getFactoryId()
Returns DataSerializableFactory factory id for this class.
|
Data |
getKey() |
protected LockStoreImpl |
getLockStore() |
Object |
getResponse() |
String |
getServiceName() |
int |
getSyncBackupCount() |
protected void |
readInternal(ObjectDataInput in) |
void |
setAsyncBackup(boolean asyncBackup) |
boolean |
shouldBackup()
Checks if a backup needs to be made.
|
protected void |
writeInternal(ObjectDataOutput out) |
afterRun, forceUnlock, getBackupOperation, getId, getNotifiedKey, run, shouldNotify, unlock
beforeRun, returnsResponse
getCallerAddress, getCallerUuid, getCallId, getCallTimeout, getConnection, getInvocationTime, getLogger, getNodeEngine, getPartitionId, getReplicaIndex, getResponseHandler, getService, getWaitTimeout, isUrgent, logError, onException, readData, setCallerUuid, setNodeEngine, setPartitionId, setReplicaIndex, setResponseHandler, setService, setServiceName, setValidateTarget, setWaitTimeout, toString, validatesTarget, writeData
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
getNotifiedKey, shouldNotify
getAsyncBackupCount, getBackupOperation, getSyncBackupCount
getPartitionId
readData, writeData
public static final long DEFAULT_LOCK_TTL
public static final int ANY_THREAD
protected ObjectNamespace namespace
protected Data key
protected long threadId
protected long ttl
protected transient Object response
public LocalLockCleanupOperation()
public LocalLockCleanupOperation(ObjectNamespace namespace, Data key, long threadId)
public boolean shouldBackup()
BackupAwareOperation
shouldBackup
in interface BackupAwareOperation
shouldBackup
in class UnlockOperation
protected void writeInternal(ObjectDataOutput out) throws IOException
writeInternal
in class UnlockOperation
IOException
protected void readInternal(ObjectDataInput in) throws IOException
readInternal
in class UnlockOperation
IOException
public final Object getResponse()
getResponse
in class AbstractOperation
protected final LockStoreImpl getLockStore()
public final int getSyncBackupCount()
public final int getAsyncBackupCount()
public final void setAsyncBackup(boolean asyncBackup)
public final String getServiceName()
getServiceName
in class Operation
public final Data getKey()
public int getFactoryId()
IdentifiedDataSerializable
getFactoryId
in interface IdentifiedDataSerializable
Copyright © 2015 Hazelcast, Inc.. All Rights Reserved.