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
-
Nested Class Summary
Nested classes/interfaces inherited from interface net.spy.memcached.ops.StoreOperation
StoreOperation.Callback
-
Field Summary
FieldsModifier and TypeFieldDescriptionprivate static final byte
(package private) static final byte
private final long
private final byte[]
private final int
(package private) static final int
private final int
private static final byte
(package private) static final byte
private static final byte
(package private) static final byte
private final StoreType
Fields inherited from class net.spy.memcached.protocol.binary.SingleKeyOperationImpl
key
Fields inherited from class net.spy.memcached.protocol.binary.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 net.spy.memcached.protocol.BaseOperationImpl
callback, CANCELLED, notMyVbucketNodes, TIMED_OUT
-
Constructor Summary
ConstructorsConstructorDescriptionStoreOperationImpl
(StoreType t, String k, int f, int e, byte[] d, long c, StoreOperation.Callback cb) -
Method Summary
Modifier and TypeMethodDescriptionprivate static byte
protected void
decodePayload
(byte[] pl) Decode the given payload for this command.long
Get the CAS value advised for this operation.byte[]
getData()
Get the bytes to be set during this operation.int
Get the expiration value to be set.int
getFlags()
Get the flags to be set.Get the store type used by this operation.void
Initialize this operation.toString()
Methods inherited from class net.spy.memcached.protocol.binary.SingleKeyOperationImpl
addNotMyVbucketNode, getKeys, getNotMyVbucketNodes, getVBucket, setNotMyVbucketNodes, setVBucket
Methods inherited from class net.spy.memcached.protocol.binary.OperationImpl
decodeByte, decodeInt, decodeLong, decodeShort, decodeUnsignedInt, finishedPayload, generateOpaque, getErrorMsg, getStatusForErrorCode, opaqueIsValid, prepareBuffer, readFromBuffer, resetInput
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, wasCancelled, writeComplete, writing
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.KeyedOperation
getKeys
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 Details
-
SET
private static final byte SET- See Also:
-
ADD
private static final byte ADD- See Also:
-
REPLACE
private static final byte REPLACE- See Also:
-
SETQ
static final byte SETQ- See Also:
-
ADDQ
static final byte ADDQ- See Also:
-
REPLACEQ
static final byte REPLACEQ- See Also:
-
EXTRA_LEN
static final int EXTRA_LEN- See Also:
-
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
-
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 interfaceOperation
- Specified by:
initialize
in classBaseOperationImpl
-
getCasValue
public long getCasValue()Description copied from interface:CASOperation
Get the CAS value advised for this operation.- Specified by:
getCasValue
in interfaceCASOperation
-
getExpiration
public int getExpiration()Description copied from interface:StoreOperation
Get the expiration value to be set.- Specified by:
getExpiration
in interfaceCASOperation
- Specified by:
getExpiration
in interfaceStoreOperation
-
getFlags
public int getFlags()Description copied from interface:StoreOperation
Get the flags to be set.- Specified by:
getFlags
in interfaceCASOperation
- Specified by:
getFlags
in interfaceStoreOperation
-
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 interfaceCASOperation
- Specified by:
getData
in interfaceStoreOperation
-
getStoreType
Description copied from interface:StoreOperation
Get the store type used by this operation.- Specified by:
getStoreType
in interfaceCASOperation
- Specified by:
getStoreType
in interfaceStoreOperation
-
decodePayload
protected void decodePayload(byte[] pl) Description copied from class:OperationImpl
Decode the given payload for this command.- Overrides:
decodePayload
in classOperationImpl
- Parameters:
pl
- the payload.
-
toString
- Overrides:
toString
in classSingleKeyOperationImpl
-