com.hazelcast.concurrent.lock.operations
Class SignalBackupOperation
java.lang.Object
com.hazelcast.spi.Operation
com.hazelcast.spi.AbstractOperation
com.hazelcast.concurrent.lock.operations.SignalBackupOperation
- All Implemented Interfaces:
- DataSerializable, IdentifiedDataSerializable, BackupOperation, RemotePropagatable<Operation>, PartitionAwareOperation
public class SignalBackupOperation
- extends AbstractOperation
- implements BackupOperation
Methods inherited from class com.hazelcast.spi.Operation |
getCallerAddress, getCallerUuid, getCallId, getCallTimeout, getConnection, getExecutorName, getInvocationTime, getLogger, getNodeEngine, getPartitionId, getReplicaIndex, getResponseHandler, getService, getWaitTimeout, isUrgent, logError, onException, readData, setCallerUuid, setExecutorName, setNodeEngine, setPartitionId, setReplicaIndex, setResponseHandler, setService, setServiceName, setValidateTarget, setWaitTimeout, toString, validatesTarget, writeData |
all
protected boolean all
conditionId
protected String conditionId
awaitCount
protected transient int awaitCount
DEFAULT_LOCK_TTL
public static final long DEFAULT_LOCK_TTL
- See Also:
- Constant Field Values
ANY_THREAD
public static final int ANY_THREAD
- See Also:
- Constant Field Values
namespace
protected ObjectNamespace namespace
key
protected Data key
threadId
protected long threadId
ttl
protected long ttl
response
protected transient Object response
SignalBackupOperation
public SignalBackupOperation()
SignalBackupOperation
public SignalBackupOperation(ObjectNamespace namespace,
Data key,
long threadId,
String conditionId,
boolean all)
getId
public int getId()
- Description copied from interface:
IdentifiedDataSerializable
- Returns type identifier for this class. Id should be unique per DataSerializableFactory.
- Specified by:
getId
in interface IdentifiedDataSerializable
- Returns:
- type id
run
public void run()
throws Exception
- Specified by:
run
in class Operation
- Throws:
Exception
writeInternal
protected void writeInternal(ObjectDataOutput out)
throws IOException
- Throws:
IOException
readInternal
protected void readInternal(ObjectDataInput in)
throws IOException
- Throws:
IOException
getResponse
public final Object getResponse()
- Overrides:
getResponse
in class AbstractOperation
getLockStore
protected final LockStoreImpl getLockStore()
getSyncBackupCount
public final int getSyncBackupCount()
getAsyncBackupCount
public final int getAsyncBackupCount()
setAsyncBackup
public final void setAsyncBackup(boolean asyncBackup)
getServiceName
public final String getServiceName()
- Overrides:
getServiceName
in class Operation
getKey
public final Data getKey()
getFactoryId
public int getFactoryId()
- Description copied from interface:
IdentifiedDataSerializable
- Returns DataSerializableFactory factory id for this class.
- Specified by:
getFactoryId
in interface IdentifiedDataSerializable
- Returns:
- factory id
Copyright © 2015 Hazelcast, Inc.. All Rights Reserved.