Class StoreOperationImpl

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.StoreOperationImpl

All Implemented Interfaces:

CASOperation, KeyedOperation, Operation, StoreOperation, VBucketAware

class StoreOperationImpl
extends SingleKeyOperationImpl
implements StoreOperation, CASOperation

Nested Class Summary

Nested classes/interfaces inherited from interface StoreOperation

StoreOperation.Callback

Field Summary

Fields

Modifier and Type	Field	Description
private static final byte	ADD
(package private) static final byte	ADDQ
private final long	cas
private final byte[]	data
private final int	exp
(package private) static final int	EXTRA_LEN
private final int	flags
private static final byte	REPLACE
(package private) static final byte	REPLACEQ
private static final byte	SET
(package private) static final byte	SETQ
private final StoreType	storeType

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
StoreOperationImpl(StoreType t, String k, int f, int e, byte[] d, long c, StoreOperation.Callback cb)

Method Summary

Modifier and Type	Method	Description
private static byte	cmdMap(StoreType t)
protected void	decodePayload(byte[] pl)	Decode the given payload for this command.
long	getCasValue()	Get the CAS value advised for this operation.
byte[]	getData()	Get the bytes to be set during this operation.
int	getExpiration()	Get the expiration value to be set.
int	getFlags()	Get the flags to be set.
StoreType	getStoreType()	Get the store type used by 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

SET

private static final byte SET

See Also:

• Constant Field Values

ADD

private static final byte ADD

See Also:

• Constant Field Values

REPLACE

private static final byte REPLACE

See Also:

• Constant Field Values

SETQ

static final byte SETQ

See Also:

• Constant Field Values

ADDQ

static final byte ADDQ

See Also:

• Constant Field Values

REPLACEQ

static final byte REPLACEQ

See Also:

• Constant Field Values

EXTRA_LEN

static final int EXTRA_LEN

See Also:

• Constant Field Values

storeType

private final StoreType storeType

flags

private final int flags

exp

private final int exp

cas

private final long cas

data

private final byte[] data

Constructor Details

StoreOperationImpl

public StoreOperationImpl(StoreType t,
 String k,
 int f,
 int e,
 byte[] d,
 long c,
 StoreOperation.Callback cb)

Method Details

cmdMap

private static byte cmdMap(StoreType t)

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

getCasValue

public long getCasValue()

Description copied from interface: CASOperation

Get the CAS value advised for this operation.

Specified by:

getCasValue in interface CASOperation

getExpiration

public int getExpiration()

Description copied from interface: StoreOperation

Get the expiration value to be set.

Specified by:

getExpiration in interface CASOperation

Specified by:

getExpiration in interface StoreOperation

getFlags

public int getFlags()

Description copied from interface: StoreOperation

Get the flags to be set.

Specified by:

getFlags in interface CASOperation

Specified by:

getFlags in interface StoreOperation

getData

public byte[] getData()

Description copied from interface: StoreOperation

Get the bytes to be set during this operation.

Note, this returns an exact reference to the bytes and the data must not be modified.

Specified by:

getData in interface CASOperation

Specified by:

getData in interface StoreOperation

getStoreType

public StoreType getStoreType()

Description copied from interface: StoreOperation

Get the store type used by this operation.

Specified by:

getStoreType in interface CASOperation

Specified by:

getStoreType in interface StoreOperation

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.

toString

public String toString()

Overrides:

toString in class SingleKeyOperationImpl