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

class ObserveOperationImpl
extends SingleKeyOperationImpl
implements ObserveOperation

Nested Class Summary

Nested classes/interfaces inherited from interface ObserveOperation

ObserveOperation.Callback

Field Summary

Fields

Modifier and Type	Field	Description
private final long	cas
private static final byte	CMD
private final int	index
private byte	keystate
private long	retCas

Fields inherited from class SingleKeyOperationImpl

key

Fields inherited from class 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 BaseOperationImpl

callback, CANCELLED, notMyVbucketNodes, TIMED_OUT

Constructor Summary

Constructors

Constructor	Description
ObserveOperationImpl(String k, long c, int i, OperationCallback cb)

Method Summary

Modifier and Type	Method	Description
protected void	decodePayload(byte[] pl)	Decode the given payload for this command.
long	getCasValue()	Get the CAS value advised for this operation.
int	getIndex()	Get the index advised for this operation.
void	initialize()	Initialize this operation.
String	toString()

Methods inherited from class SingleKeyOperationImpl

addNotMyVbucketNode, getKeys, getNotMyVbucketNodes, getVBucket, setNotMyVbucketNodes, setVBucket

Methods inherited from class OperationImpl

decodeByte, decodeInt, decodeLong, decodeShort, decodeUnsignedInt, finishedPayload, generateOpaque, getErrorMsg, getStatusForErrorCode, opaqueIsValid, prepareBuffer, readFromBuffer, resetInput

Methods inherited from class 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 SpyObject

getLogger

Methods inherited from class Object

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

Methods inherited from interface KeyedOperation

getKeys

Methods inherited from interface 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:

• Constant Field Values

cas

private final long cas

index

private final int index

keystate

private byte keystate

retCas

private long retCas

Constructor Details

ObserveOperationImpl

public ObserveOperationImpl(String k,
 long c,
 int i,
 OperationCallback cb)

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 interface Operation

Specified by:

initialize in class BaseOperationImpl

toString

public String toString()

Overrides:

toString in class SingleKeyOperationImpl

decodePayload

protected void decodePayload(byte[] pl)

Description copied from class: OperationImpl

Decode the given payload for this command.

Overrides:

decodePayload in class OperationImpl

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 interface ObserveOperation

getIndex

public int getIndex()

Description copied from interface: ObserveOperation

Get the index advised for this operation.

Specified by:

getIndex in interface ObserveOperation