Class OptimizedSetImpl
java.lang.Object
net.spy.memcached.compat.SpyObject
net.spy.memcached.protocol.BaseOperationImpl
net.spy.memcached.protocol.binary.OperationImpl
net.spy.memcached.protocol.binary.MultiKeyOperationImpl
net.spy.memcached.protocol.binary.OptimizedSetImpl
- All Implemented Interfaces:
KeyedOperation
,Operation
,VBucketAware
Optimized Set operation for folding a bunch of sets together.
-
Nested Class Summary
Nested Classes -
Field Summary
FieldsModifier and TypeFieldDescriptionprivate int
private final Map
<Integer, OperationCallback> private static final OperationCallback
private final List
<CASOperation> private final int
Fields inherited from class net.spy.memcached.protocol.binary.MultiKeyOperationImpl
vbmap
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
ConstructorsConstructorDescriptionOptimizedSetImpl
(CASOperation firstStore) Construct an optimized get starting with the given get operation. -
Method Summary
Modifier and TypeMethodDescriptionvoid
int
bytes()
private static byte
protected void
finishedPayload
(byte[] pl) void
Initialize this operation.protected boolean
Validate an opaque value from the header.int
size()
Methods inherited from class net.spy.memcached.protocol.binary.MultiKeyOperationImpl
addNotMyVbucketNode, getKeys, getNotMyVbucketNodes, getVBucket, setNotMyVbucketNodes, setVBucket, toString
Methods inherited from class net.spy.memcached.protocol.binary.OperationImpl
decodeByte, decodeInt, decodeLong, decodePayload, decodeShort, decodeUnsignedInt, generateOpaque, getErrorMsg, getStatusForErrorCode, 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.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
-
NOOP_CALLBACK
-
terminalOpaque
private final int terminalOpaque -
callbacks
-
ops
-
byteCount
private int byteCount
-
-
Constructor Details
-
OptimizedSetImpl
Construct an optimized get starting with the given get operation.
-
-
Method Details
-
addOperation
-
size
public int size() -
bytes
public int bytes() -
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
-
cmdMap
-
finishedPayload
- Overrides:
finishedPayload
in classOperationImpl
- Throws:
IOException
-
opaqueIsValid
protected boolean opaqueIsValid()Description copied from class:OperationImpl
Validate an opaque value from the header. This may be overridden from a subclass where the opaque isn't expected to always be the same as the request opaque.- Overrides:
opaqueIsValid
in classOperationImpl
-