Class BinarySetMultiCommand
java.lang.Object
net.rubyeye.xmemcached.command.Command
net.rubyeye.xmemcached.command.binary.BaseBinaryCommand
net.rubyeye.xmemcached.command.binary.BinarySetMultiCommand
- All Implemented Interfaces:
WriteMessage
,MergeCommandsAware
,StoreCommand
A command for holding getkq commands
-
Field Summary
FieldsFields inherited from class net.rubyeye.xmemcached.command.binary.BaseBinaryCommand
cas, decodeStatus, DEFAULT_VBUCKET_ID, expTime, EXTRAS_LENGTH, opaque, opCode, responseExtrasLength, responseKeyLength, responseStatus, responseTotalBodyLength, value, vbucketId
Fields inherited from class net.rubyeye.xmemcached.command.Command
cancel, commandType, exception, ioBuffer, key, keyBytes, latch, mergeCount, noreply, REQUEST_MAGIC_NUMBER, RESPONSE_MAGIC_NUMBER, result, status, transcoder, writeFuture
-
Constructor Summary
ConstructorsConstructorDescriptionBinarySetMultiCommand
(String key, CommandType cmdType, CountDownLatch latch) -
Method Summary
Modifier and TypeMethodDescriptionvoid
encode()
protected boolean
finish()
protected void
readHeader
(ByteBuffer buffer) optimistic,if response status is greater than zero,then skip buffer to next response,set result to be false.protected boolean
readOpaque
(ByteBuffer buffer) protected boolean
readOpCode
(ByteBuffer buffer) void
setMergeCommands
(Map<Object, Command> mergeCommands) Methods inherited from class net.rubyeye.xmemcached.command.binary.BaseBinaryCommand
decode, fillExtras, fillKey, fillValue, getCas, getCasValue, getExpTime, getExtrasLength, getKeyLength, getOpaque, getOpCode, getResponseStatus, getTranscoder, getValue, getValueLength, readCAS, readExtras, readKey, readStatus, readValue, setCas, setExpTime, setOpaque, setOpCode, setResponseStatus, setTranscoder, setValue
Methods inherited from class net.rubyeye.xmemcached.command.Command
cancel, countDownLatch, decodeError, decodeError, decodeError, decodeError, getCommandType, getCopiedMergeCount, getException, getIoBuffer, getKey, getKeyBytes, getLatch, getMergeCount, getMessage, getResult, getStatus, getWriteBuffer, getWriteFuture, isAdded, isCancel, isNoreply, isWriting, setAdded, setCommandType, setException, setIoBuffer, setKey, setKeyBytes, setLatch, setMergeCount, setNoreply, setResult, setStatus, setWriteBuffer, setWriteFuture, toString, writing
-
Field Details
-
finished
private boolean finished -
responseOpaque
-
mergeCommands
-
-
Constructor Details
-
BinarySetMultiCommand
-
-
Method Details
-
readOpCode
- Overrides:
readOpCode
in classBaseBinaryCommand
-
readHeader
optimistic,if response status is greater than zero,then skip buffer to next response,set result to be false.- Overrides:
readHeader
in classBaseBinaryCommand
-
getMergeCommands
- Specified by:
getMergeCommands
in interfaceMergeCommandsAware
-
setMergeCommands
- Specified by:
setMergeCommands
in interfaceMergeCommandsAware
-
encode
public void encode()- Overrides:
encode
in classBaseBinaryCommand
-
finish
protected boolean finish()- Overrides:
finish
in classBaseBinaryCommand
-
readOpaque
- Overrides:
readOpaque
in classBaseBinaryCommand
-