public class BinaryGetMultiCommand extends BaseBinaryCommand implements MergeCommandsAware, MapReturnValueAware
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 |
---|
BinaryGetMultiCommand(String key,
CommandType cmdType,
CountDownLatch latch) |
Modifier and Type | Method and Description |
---|---|
void |
encode() |
protected boolean |
finish() |
Map<Object,Command> |
getMergeCommands() |
Map<String,CachedData> |
getReturnValues() |
protected long |
readCAS(ByteBuffer buffer) |
protected boolean |
readExtras(ByteBuffer buffer,
int extrasLength) |
protected void |
readHeader(ByteBuffer buffer)
optimistic,if response status is greater than zero,then skip buffer to next response,set result
as null
|
protected boolean |
readKey(ByteBuffer buffer,
int keyLength) |
protected boolean |
readOpCode(ByteBuffer buffer) |
protected boolean |
readValue(ByteBuffer buffer,
int bodyLength,
int keyLength,
int extrasLength) |
void |
setMergeCommands(Map<Object,Command> mergeCommands) |
decode, fillExtras, fillKey, fillValue, getCas, getCasValue, getExpTime, getExtrasLength, getKeyLength, getOpaque, getOpCode, getResponseStatus, getTranscoder, getValue, getValueLength, readOpaque, readStatus, 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 BinaryGetMultiCommand(String key, CommandType cmdType, CountDownLatch latch)
public Map<String,CachedData> getReturnValues()
getReturnValues
in interface MapReturnValueAware
protected boolean readOpCode(ByteBuffer buffer)
readOpCode
in class BaseBinaryCommand
protected void readHeader(ByteBuffer buffer)
readHeader
in class BaseBinaryCommand
public void encode()
encode
in class BaseBinaryCommand
protected boolean finish()
finish
in class BaseBinaryCommand
protected boolean readKey(ByteBuffer buffer, int keyLength)
readKey
in class BaseBinaryCommand
protected boolean readValue(ByteBuffer buffer, int bodyLength, int keyLength, int extrasLength)
readValue
in class BaseBinaryCommand
protected boolean readExtras(ByteBuffer buffer, int extrasLength)
readExtras
in class BaseBinaryCommand
protected long readCAS(ByteBuffer buffer)
readCAS
in class BaseBinaryCommand
public Map<Object,Command> getMergeCommands()
getMergeCommands
in interface MergeCommandsAware
public void setMergeCommands(Map<Object,Command> mergeCommands)
setMergeCommands
in interface MergeCommandsAware
Copyright © 2021. All rights reserved.