net.rubyeye.xmemcached.command.binary

Class BinaryGetCommand

java.lang.Object

net.rubyeye.xmemcached.command.Command

net.rubyeye.xmemcached.command.binary.BaseBinaryCommand

net.rubyeye.xmemcached.command.binary.BinaryGetCommand

All Implemented Interfaces:

WriteMessage, AssocCommandAware, StoreCommand

Direct Known Subclasses:

BinaryGetAndTouchCommand

public class BinaryGetCommand
extends BaseBinaryCommand
implements AssocCommandAware

Implements get/getq,getk/getkq protocol

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 and Description
BinaryGetCommand(String key, byte[] keyBytes, CommandType cmdType, CountDownLatch latch, OpCode opCode, boolean noreply)

Method Summary

Methods

Modifier and Type	Method and Description
protected void	fillExtras(CachedData data)
protected void	fillValue(CachedData data)
protected boolean	finish()
List<Command>	getAssocCommands()
protected byte	getExtrasLength()
String	getResponseKey()
protected int	getValueLength(CachedData data)
protected long	readCAS(ByteBuffer buffer)
protected boolean	readExtras(ByteBuffer buffer, int extrasLength)
protected void	readHeader(ByteBuffer buffer) Optimistic,if the value length is 0,then skip remaining buffer,set result as null
protected boolean	readKey(ByteBuffer buffer, int keyLength)
protected boolean	readValue(ByteBuffer buffer, int bodyLength, int keyLength, int extrasLength)
void	setAssocCommands(List<Command> assocCommands)
void	setResponseKey(String responseKey)

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

decode, encode, fillKey, getCas, getCasValue, getExpTime, getKeyLength, getOpaque, getOpCode, getResponseStatus, getTranscoder, getValue, readOpaque, readOpCode, 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

BinaryGetCommand

public BinaryGetCommand(String key,
                byte[] keyBytes,
                CommandType cmdType,
                CountDownLatch latch,
                OpCode opCode,
                boolean noreply)

Method Detail

getResponseKey

public final String getResponseKey()

setResponseKey

public final void setResponseKey(String responseKey)

getAssocCommands

public final List<Command> getAssocCommands()

Specified by:

getAssocCommands in interface AssocCommandAware

setAssocCommands

public final void setAssocCommands(List<Command> assocCommands)

Specified by:

setAssocCommands in interface AssocCommandAware

readHeader

protected void readHeader(ByteBuffer buffer)

Optimistic,if the value length is 0,then skip remaining buffer,set result as null

Overrides:

readHeader 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

fillExtras

protected void fillExtras(CachedData data)

Overrides:

fillExtras in class BaseBinaryCommand

fillValue

protected void fillValue(CachedData data)

Overrides:

fillValue in class BaseBinaryCommand

getExtrasLength

protected byte getExtrasLength()

Overrides:

getExtrasLength in class BaseBinaryCommand

getValueLength

protected int getValueLength(CachedData data)

Overrides:

getValueLength in class BaseBinaryCommand

readCAS

protected long readCAS(ByteBuffer buffer)

Overrides:

readCAS in class BaseBinaryCommand