Class ConcatenationOperationImpl

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

All Implemented Interfaces:

ConcatenationOperation, KeyedOperation, Operation, VBucketAware

class ConcatenationOperationImpl
extends SingleKeyOperationImpl
implements ConcatenationOperation

Field Summary

Fields

Modifier and Type	Field	Description
private static final int	APPEND
private final long	cas
private final ConcatenationType	catType
private final byte[]	data
private static final int	PREPEND

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
ConcatenationOperationImpl(ConcatenationType t, String k, byte[] d, long c, OperationCallback cb)

Method Summary

Modifier and Type	Method	Description
private static byte	cmdMap(ConcatenationType t)
long	getCasValue()	Get the CAS value sent with this operation.
byte[]	getData()	Get the bytes to be set during this operation.
ConcatenationType	getStoreType()	Get the concatenation type 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, decodePayload, 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

APPEND

private static final int APPEND

See Also:

• Constant Field Values

PREPEND

private static final int PREPEND

See Also:

• Constant Field Values

cas

private final long cas

catType

private final ConcatenationType catType

data

private final byte[] data

Constructor Details

ConcatenationOperationImpl

public ConcatenationOperationImpl(ConcatenationType t,
 String k,
 byte[] d,
 long c,
 OperationCallback cb)

Method Details

cmdMap

private static byte cmdMap(ConcatenationType 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: ConcatenationOperation

Get the CAS value sent with this operation.

Specified by:

getCasValue in interface ConcatenationOperation

getData

public byte[] getData()

Description copied from interface: ConcatenationOperation

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 ConcatenationOperation

getStoreType

public ConcatenationType getStoreType()

Description copied from interface: ConcatenationOperation

Get the concatenation type for this operation.

Specified by:

getStoreType in interface ConcatenationOperation

toString

public String toString()

Overrides:

toString in class SingleKeyOperationImpl