Package net.rubyeye.xmemcached.command.binary

Class BinaryGetMultiCommand

java.lang.Object

net.rubyeye.xmemcached.command.Command

net.rubyeye.xmemcached.command.binary.BaseBinaryCommand

net.rubyeye.xmemcached.command.binary.BinaryGetMultiCommand

All Implemented Interfaces:

WriteMessage, MapReturnValueAware, MergeCommandsAware, StoreCommand

public class BinaryGetMultiCommand
extends BaseBinaryCommand
implements MergeCommandsAware, MapReturnValueAware

A command for holding getkq commands

Author:

dennis

Field Summary

Fields inherited from class net.rubyeye.xmemcached.command.binary.BaseBinaryCommand

cas, decodeStatus, expTime, 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
BinaryGetMultiCommand(String key, CommandType cmdType, CountDownLatch latch)

Method Summary

Modifier and Type	Method	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)

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, readOpaque, readStatus, 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

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

BinaryGetMultiCommand

public BinaryGetMultiCommand(String key,
                             CommandType cmdType,
                             CountDownLatch latch)

Method Detail

getReturnValues

public Map<String,CachedData> getReturnValues()

Specified by:

getReturnValues in interface MapReturnValueAware

readOpCode

protected boolean readOpCode(ByteBuffer buffer)

Overrides:

readOpCode in class BaseBinaryCommand

readHeader

protected void readHeader(ByteBuffer buffer)

optimistic,if response status is greater than zero,then skip buffer to next response,set result as null

Overrides:

readHeader in class BaseBinaryCommand

encode

public void encode()

Overrides:

encode in class BaseBinaryCommand

finish

protected boolean finish()

Overrides:

finish in class BaseBinaryCommand

readKey

protected boolean readKey(ByteBuffer buffer,
                          int keyLength)

Overrides:

readKey in class BaseBinaryCommand

readValue

protected boolean readValue(ByteBuffer buffer,
                            int bodyLength,
                            int keyLength,
                            int extrasLength)

Overrides:

readValue in class BaseBinaryCommand

readExtras

protected boolean readExtras(ByteBuffer buffer,
                             int extrasLength)

Overrides:

readExtras in class BaseBinaryCommand

readCAS

protected long readCAS(ByteBuffer buffer)

Overrides:

readCAS in class BaseBinaryCommand

getMergeCommands

public Map<Object,Command> getMergeCommands()

Specified by:

getMergeCommands in interface MergeCommandsAware

setMergeCommands

public void setMergeCommands(Map<Object,Command> mergeCommands)

Specified by:

setMergeCommands in interface MergeCommandsAware