public class LockOperation extends AbstractLockOperation implements BlockingOperation, BackupAwareOperation, MutatingOperation
ANY_THREAD, isClient, key, leaseTime, namespace, response, threadIdGENERIC_PARTITION_ID| Constructor and Description |
|---|
LockOperation() |
LockOperation(ObjectNamespace namespace,
Data key,
long threadId,
long leaseTime,
long timeout) |
LockOperation(ObjectNamespace namespace,
Data key,
long threadId,
long leaseTime,
long timeout,
long referenceId,
boolean isClient) |
| Modifier and Type | Method and Description |
|---|---|
Operation |
getBackupOperation()
Creates the
BackupOperation responsible for making the backup. |
int |
getClassId()
Returns type identifier for this class.
|
WaitNotifyKey |
getWaitKey() |
void |
onWaitExpire() |
void |
run()
Runs the operation.
|
boolean |
shouldBackup()
Checks if a backup needs to be made.
|
boolean |
shouldWait() |
getAsyncBackupCount, getFactoryId, getKey, getLockStore, getName, getReferenceCallId, getResponse, getServiceName, getServiceNamespace, getSyncBackupCount, interceptLockOperation, onSetCallId, readInternal, setAsyncBackup, setReferenceCallId, toString, writeInternalafterRun, beforeRun, call, executedLocally, getCallerAddress, getCallerUuid, getCallId, getCallTimeout, getClientCallId, getConnection, getInvocationTime, getLogger, getNodeEngine, getOperationResponseHandler, getPartitionId, getReplicaIndex, getService, getWaitTimeout, isUrgent, logError, onExecutionFailure, onInvocationException, readData, requiresExplicitServiceName, returnsResponse, sendResponse, setCallerUuid, setClientCallId, setNodeEngine, setOperationResponseHandler, setPartitionId, setReplicaIndex, setService, setServiceName, setValidateTarget, setWaitTimeout, toString, validatesTarget, writeDataclone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitgetWaitTimeoutgetAsyncBackupCount, getSyncBackupCountgetPartitionIdreadData, writeDatapublic LockOperation()
public LockOperation(ObjectNamespace namespace, Data key, long threadId, long leaseTime, long timeout)
public LockOperation(ObjectNamespace namespace, Data key, long threadId, long leaseTime, long timeout, long referenceId, boolean isClient)
public void run()
throws Exception
OperationOperation.run() or Operation.call() method should be implemented; not both.
Runs after wait-support, supposed to do actual operationrun in class OperationExceptionOperation.call()public Operation getBackupOperation()
BackupAwareOperationBackupOperation responsible for making the backup.getBackupOperation in interface BackupAwareOperationBackupOperation responsible for making the backup.public boolean shouldBackup()
BackupAwareOperationIf a call has not made any change, e.g. an AtomicLong increment with 0, no backup needs to be made.
shouldBackup in interface BackupAwareOperationpublic final WaitNotifyKey getWaitKey()
getWaitKey in interface BlockingOperationpublic final boolean shouldWait()
shouldWait in interface BlockingOperationpublic final void onWaitExpire()
onWaitExpire in interface BlockingOperationpublic int getClassId()
IdentifiedDataSerializablegetClassId in interface IdentifiedDataSerializableCopyright © 2019 Hazelcast, Inc.. All rights reserved.