Class ObserveOperationImpl
java.lang.Object
net.spy.memcached.compat.SpyObject
net.spy.memcached.protocol.BaseOperationImpl
net.spy.memcached.protocol.binary.OperationImpl
net.spy.memcached.protocol.binary.SingleKeyOperationImpl
net.spy.memcached.protocol.binary.ObserveOperationImpl
- All Implemented Interfaces:
KeyedOperation
,ObserveOperation
,Operation
,VBucketAware
-
Nested Class Summary
Nested classes/interfaces inherited from interface net.spy.memcached.ops.ObserveOperation
ObserveOperation.Callback
-
Field Summary
FieldsModifier and TypeFieldDescriptionprivate final long
private static final byte
private final int
private byte
private long
Fields inherited from class net.spy.memcached.protocol.binary.SingleKeyOperationImpl
key
Fields inherited from class net.spy.memcached.protocol.binary.OperationImpl
DUMMY_OPCODE, EMPTY_BYTES, ERR_2BIG, ERR_BUSY, ERR_DELTA_BADVAL, ERR_EXISTS, ERR_INTERNAL, ERR_INVAL, ERR_NO_MEM, ERR_NOT_FOUND, ERR_NOT_MY_VBUCKET, ERR_NOT_STORED, ERR_NOT_SUPPORTED, ERR_TEMP_FAIL, ERR_UNKNOWN_COMMAND, errorCode, keyLen, MIN_RECV_PACKET, opaque, REQ_MAGIC, RES_MAGIC, responseCas, responseCmd, responseOpaque, STATUS_OK, SUCCESS, vbucket
Fields inherited from class net.spy.memcached.protocol.BaseOperationImpl
callback, CANCELLED, notMyVbucketNodes, TIMED_OUT
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionprotected void
decodePayload
(byte[] pl) Decode the given payload for this command.long
Get the CAS value advised for this operation.int
getIndex()
Get the index advised for this operation.void
Initialize this operation.toString()
Methods inherited from class net.spy.memcached.protocol.binary.SingleKeyOperationImpl
addNotMyVbucketNode, getKeys, getNotMyVbucketNodes, getVBucket, setNotMyVbucketNodes, setVBucket
Methods inherited from class net.spy.memcached.protocol.binary.OperationImpl
decodeByte, decodeInt, decodeLong, decodeShort, decodeUnsignedInt, finishedPayload, generateOpaque, getErrorMsg, getStatusForErrorCode, opaqueIsValid, prepareBuffer, readFromBuffer, resetInput
Methods inherited from class net.spy.memcached.protocol.BaseOperationImpl
addClone, cancel, getBuffer, getCallback, getCloneCount, getException, getHandlingNode, getState, getWriteCompleteTimestamp, handleError, handleRead, hasErrored, isCancelled, isTimedOut, isTimedOut, isTimedOutUnsent, setBuffer, setCallback, setCloneCount, setHandlingNode, timeOut, transitionState, wasCancelled, writeComplete, writing
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
Methods inherited from interface net.spy.memcached.ops.KeyedOperation
getKeys
Methods inherited from interface net.spy.memcached.ops.Operation
addClone, cancel, getBuffer, getCallback, getCloneCount, getErrorMsg, getException, getHandlingNode, getState, getWriteCompleteTimestamp, handleRead, hasErrored, isCancelled, isTimedOut, isTimedOut, isTimedOutUnsent, readFromBuffer, setCloneCount, setHandlingNode, timeOut, writeComplete, writing
-
Field Details
-
CMD
private static final byte CMD- See Also:
-
cas
private final long cas -
index
private final int index -
keystate
private byte keystate -
retCas
private long retCas
-
-
Constructor Details
-
ObserveOperationImpl
-
-
Method Details
-
initialize
public void initialize()Description copied from interface:Operation
Initialize this operation. This is used to prepare output byte buffers and stuff.- Specified by:
initialize
in interfaceOperation
- Specified by:
initialize
in classBaseOperationImpl
-
toString
- Overrides:
toString
in classSingleKeyOperationImpl
-
decodePayload
protected void decodePayload(byte[] pl) Description copied from class:OperationImpl
Decode the given payload for this command.- Overrides:
decodePayload
in classOperationImpl
- Parameters:
pl
- the payload.
-
getCasValue
public long getCasValue()Description copied from interface:ObserveOperation
Get the CAS value advised for this operation.- Specified by:
getCasValue
in interfaceObserveOperation
-
getIndex
public int getIndex()Description copied from interface:ObserveOperation
Get the index advised for this operation.- Specified by:
getIndex
in interfaceObserveOperation
-