Package 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

Field Summary

Fields

Modifier and Type	Field	Description
private List<Command>	assocCommands
private String	responseKey
private CachedData	responseValue

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

Method Summary

Modifier and Type	Method	Description
protected void	fillExtras(CachedData data)
protected void	fillValue(CachedData data)
protected boolean	finish()
final List<Command>	getAssocCommands()
protected byte	getExtrasLength()
final 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)
final void	setAssocCommands(List<Command> assocCommands)
final 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

Field Details

responseKey

private String responseKey

responseValue

private CachedData responseValue

assocCommands

private List<Command> assocCommands

Constructor Details

BinaryGetCommand

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

Method Details

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