public class BinarySetMultiCommand extends BaseBinaryCommand implements MergeCommandsAware
cas, decodeStatus, expTime, opaque, opCode, responseExtrasLength, responseKeyLength, responseStatus, responseTotalBodyLength, value, vbucketId
cancel, commandType, exception, ioBuffer, key, keyBytes, latch, mergeCount, noreply, REQUEST_MAGIC_NUMBER, RESPONSE_MAGIC_NUMBER, result, status, transcoder, writeFuture
Constructor and Description |
---|
BinarySetMultiCommand(String key,
CommandType cmdType,
CountDownLatch latch) |
Modifier and Type | Method and Description |
---|---|
void |
encode() |
protected boolean |
finish() |
Map<Object,Command> |
getMergeCommands() |
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) |
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
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
public BinarySetMultiCommand(String key, CommandType cmdType, CountDownLatch latch)
protected boolean readOpCode(ByteBuffer buffer)
readOpCode
in class BaseBinaryCommand
protected void readHeader(ByteBuffer buffer)
readHeader
in class BaseBinaryCommand
public Map<Object,Command> getMergeCommands()
getMergeCommands
in interface MergeCommandsAware
public void setMergeCommands(Map<Object,Command> mergeCommands)
setMergeCommands
in interface MergeCommandsAware
public void encode()
encode
in class BaseBinaryCommand
protected boolean finish()
finish
in class BaseBinaryCommand
protected boolean readOpaque(ByteBuffer buffer)
readOpaque
in class BaseBinaryCommand
Copyright © 2021. All rights reserved.