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
public class BinarySetMultiCommand extends BaseBinaryCommand implements MergeCommandsAware
A command for holding getkq commands
-
-
Field Summary
Fields Modifier and Type Field Description private boolean
finished
private java.util.Map<java.lang.Object,Command>
mergeCommands
private java.lang.Integer
responseOpaque
-
Fields 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
Constructors Constructor Description BinarySetMultiCommand(java.lang.String key, CommandType cmdType, java.util.concurrent.CountDownLatch latch)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
encode()
protected boolean
finish()
java.util.Map<java.lang.Object,Command>
getMergeCommands()
protected void
readHeader(java.nio.ByteBuffer buffer)
optimistic,if response status is greater than zero,then skip buffer to next response,set result to be false.protected boolean
readOpaque(java.nio.ByteBuffer buffer)
protected boolean
readOpCode(java.nio.ByteBuffer buffer)
void
setMergeCommands(java.util.Map<java.lang.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 Detail
-
finished
private boolean finished
-
responseOpaque
private java.lang.Integer responseOpaque
-
mergeCommands
private java.util.Map<java.lang.Object,Command> mergeCommands
-
-
Constructor Detail
-
BinarySetMultiCommand
public BinarySetMultiCommand(java.lang.String key, CommandType cmdType, java.util.concurrent.CountDownLatch latch)
-
-
Method Detail
-
readOpCode
protected boolean readOpCode(java.nio.ByteBuffer buffer)
- Overrides:
readOpCode
in classBaseBinaryCommand
-
readHeader
protected void readHeader(java.nio.ByteBuffer buffer)
optimistic,if response status is greater than zero,then skip buffer to next response,set result to be false.- Overrides:
readHeader
in classBaseBinaryCommand
-
getMergeCommands
public java.util.Map<java.lang.Object,Command> getMergeCommands()
- Specified by:
getMergeCommands
in interfaceMergeCommandsAware
-
setMergeCommands
public void setMergeCommands(java.util.Map<java.lang.Object,Command> mergeCommands)
- Specified by:
setMergeCommands
in interfaceMergeCommandsAware
-
encode
public void encode()
- Overrides:
encode
in classBaseBinaryCommand
-
finish
protected boolean finish()
- Overrides:
finish
in classBaseBinaryCommand
-
readOpaque
protected boolean readOpaque(java.nio.ByteBuffer buffer)
- Overrides:
readOpaque
in classBaseBinaryCommand
-
-