Class MultiGetOperationImpl
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.MultiGetOperationImpl
- All Implemented Interfaces:
GetOperation
,KeyedOperation
,Operation
,VBucketAware
- Direct Known Subclasses:
OptimizedGetImpl
-
Nested Class Summary
Nested classes/interfaces inherited from interface net.spy.memcached.ops.GetOperation
GetOperation.Callback
-
Field Summary
FieldsModifier and TypeFieldDescriptionprivate static final byte
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
Constructors -
Method Summary
Modifier and TypeMethodDescriptionprotected int
Add a key (and return its new opaque value).protected void
finishedPayload
(byte[] pl) Returns the keys to redistribute.void
Initialize this operation.protected boolean
Validate an opaque value from the header.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.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
-
CMD_GETQ
private static final byte CMD_GETQ- See Also:
-
keys
-
bkeys
-
rkeys
-
terminalOpaque
private final int terminalOpaque -
retryKeys
-
-
Constructor Details
-
MultiGetOperationImpl
-
-
Method Details
-
addKey
Add a key (and return its new opaque value). -
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
-
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
-
getRetryKeys
Returns the keys to redistribute.- Returns:
- the keys to retry.
-