Class MutatorOperationImpl

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

All Implemented Interfaces:

KeyedOperation, MutatorOperation, Operation, VBucketAware

class MutatorOperationImpl
extends SingleKeyOperationImpl
implements MutatorOperation

Field Summary

Fields

Modifier and Type	Field	Description
private final long	by
private static final byte	CMD_DECR
private static final byte	CMD_INCR
private final long	def
private final int	exp
private final Mutator	mutator

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
MutatorOperationImpl(Mutator m, String k, long b, long d, int e, OperationCallback cb)

Method Summary

Modifier and Type	Method	Description
protected void	decodePayload(byte[] pl)	Decode the given payload for this command.
long	getBy()	Get the amount we're mutating by.
long	getDefault()	Get the default value (for when there's no value to mutate).
int	getExpiration()	Get the expiration to set in case of a new entry.
Mutator	getType()	Get the mutator type used 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_INCR

private static final byte CMD_INCR

See Also:

• Constant Field Values

CMD_DECR

private static final byte CMD_DECR

See Also:

• Constant Field Values

mutator

private final Mutator mutator

by

private final long by

exp

private final int exp

def

private final long def

Constructor Details

MutatorOperationImpl

public MutatorOperationImpl(Mutator m,
 String k,
 long b,
 long d,
 int e,
 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

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.

getBy

public long getBy()

Description copied from interface: MutatorOperation

Get the amount we're mutating by.

Specified by:

getBy in interface MutatorOperation

getDefault

public long getDefault()

Description copied from interface: MutatorOperation

Get the default value (for when there's no value to mutate).

Specified by:

getDefault in interface MutatorOperation

getExpiration

public int getExpiration()

Description copied from interface: MutatorOperation

Get the expiration to set in case of a new entry.

Specified by:

getExpiration in interface MutatorOperation

getType

public Mutator getType()

Description copied from interface: MutatorOperation

Get the mutator type used for this operation.

Specified by:

getType in interface MutatorOperation

toString

public String toString()

Overrides:

toString in class SingleKeyOperationImpl