Package net.spy.memcached.protocol.ascii

Class MutatorOperationImpl

java.lang.Object

net.spy.memcached.compat.SpyObject

net.spy.memcached.protocol.BaseOperationImpl

net.spy.memcached.protocol.ascii.OperationImpl

net.spy.memcached.protocol.ascii.MutatorOperationImpl

All Implemented Interfaces:

KeyedOperation, MutatorOperation, Operation

final class MutatorOperationImpl
extends OperationImpl
implements MutatorOperation

Operation for mutating integers inside of memcached.

Field Summary

Fields

Modifier and Type	Field	Description
private long	amount
private java.lang.String	key
private Mutator	mutator
private static OperationStatus	NOT_FOUND
static int	OVERHEAD

Fields inherited from class net.spy.memcached.protocol.ascii.OperationImpl

CRLF

Fields inherited from class net.spy.memcached.protocol.BaseOperationImpl

callback, CANCELLED, notMyVbucketNodes, TIMED_OUT

Constructor Summary

Constructors

Constructor	Description
MutatorOperationImpl(Mutator m, java.lang.String k, long amt, OperationCallback c)

Method Summary

Modifier and Type	Method	Description
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.
java.util.Collection<java.lang.String>	getKeys()	Get the keys requested in this GetOperation.
Mutator	getType()	Get the mutator type used for this operation.
void	handleLine(java.lang.String line)
void	initialize()	Initialize this operation.
java.lang.String	toString()
protected void	wasCancelled()	This is called on each subclass whenever an operation was cancelled.

Methods inherited from class net.spy.memcached.protocol.ascii.OperationImpl

classifyError, getErrorMsg, getReadType, matchStatus, readFromBuffer, setArguments, setReadType

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, writeComplete, writing

Methods inherited from class net.spy.memcached.compat.SpyObject

getLogger

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

addClone, cancel, getBuffer, getCallback, getCloneCount, getErrorMsg, getException, getHandlingNode, getState, getWriteCompleteTimestamp, handleRead, hasErrored, isCancelled, isTimedOut, isTimedOut, isTimedOutUnsent, readFromBuffer, setCloneCount, setHandlingNode, timeOut, writeComplete, writing

Field Detail

OVERHEAD

public static final int OVERHEAD

See Also:

Constant Field Values

NOT_FOUND

private static final OperationStatus NOT_FOUND

mutator

private final Mutator mutator

key

private final java.lang.String key

amount

private final long amount

Constructor Detail

MutatorOperationImpl

public MutatorOperationImpl(Mutator m,
                            java.lang.String k,
                            long amt,
                            OperationCallback c)

Method Detail

handleLine

public void handleLine(java.lang.String line)

Specified by:

handleLine in class OperationImpl

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

wasCancelled

protected void wasCancelled()

Description copied from class: BaseOperationImpl

This is called on each subclass whenever an operation was cancelled.

Overrides:

wasCancelled in class BaseOperationImpl

getKeys

public java.util.Collection<java.lang.String> getKeys()

Description copied from interface: KeyedOperation

Get the keys requested in this GetOperation.

Specified by:

getKeys in interface KeyedOperation

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 java.lang.String toString()

Overrides:

toString in class java.lang.Object