Package net.rubyeye.xmemcached.command.binary

Class BaseBinaryCommand

java.lang.Object

net.rubyeye.xmemcached.command.Command

net.rubyeye.xmemcached.command.binary.BaseBinaryCommand

All Implemented Interfaces:

WriteMessage, StoreCommand

Direct Known Subclasses:

BinaryAppendPrependCommand, BinaryAuthListMechanismsCommand, BinaryAuthStartCommand, BinaryAuthStepCommand, BinaryAWSElasticCacheConfigCommand, BinaryCASCommand, BinaryDeleteCommand, BinaryFlushAllCommand, BinaryGetCommand, BinaryGetMultiCommand, BinaryIncrDecrCommand, BinaryNoopCommand, BinaryQuitCommand, BinarySetMultiCommand, BinaryStatsCommand, BinaryStoreCommand, BinaryTouchCommand, BinaryVerbosityCommand, BinaryVersionCommand

public abstract class BaseBinaryCommand
extends Command
implements StoreCommand

Base Binary command.

Author:

dennis

Field Summary

Fields

Modifier and Type	Field	Description
protected long	cas
protected BinaryDecodeStatus	decodeStatus
protected int	expTime
protected int	opaque
protected OpCode	opCode
protected int	responseExtrasLength
protected int	responseKeyLength
protected ResponseStatus	responseStatus
protected int	responseTotalBodyLength
protected Object	value
protected short	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
BaseBinaryCommand(String key, byte[] keyBytes, CommandType cmdType, CountDownLatch latch, int exp, long cas, Object value, boolean noreply, Transcoder transcoder)

Method Summary

Modifier and Type	Method	Description
boolean	decode(MemcachedTCPSession session, ByteBuffer buffer)
void	encode()
protected void	fillExtras(CachedData data)
protected void	fillKey()
protected void	fillValue(CachedData data)
protected boolean	finish()
long	getCas()
protected long	getCasValue()
int	getExpTime()
protected byte	getExtrasLength()
protected short	getKeyLength()
int	getOpaque()
OpCode	getOpCode()
ResponseStatus	getResponseStatus()
Transcoder	getTranscoder()
Object	getValue()
protected int	getValueLength(CachedData data)
protected long	readCAS(ByteBuffer buffer)
protected boolean	readExtras(ByteBuffer buffer, int extrasLength)
protected void	readHeader(ByteBuffer buffer)
protected boolean	readKey(ByteBuffer buffer, int keyLength)
protected boolean	readOpaque(ByteBuffer buffer)
protected boolean	readOpCode(ByteBuffer buffer)
protected void	readStatus(ByteBuffer buffer)
protected boolean	readValue(ByteBuffer buffer, int bodyLength, int keyLength, int extrasLength)
void	setCas(long cas)
void	setExpTime(int exp)
void	setOpaque(int opaque)
void	setOpCode(OpCode opCode)
void	setResponseStatus(ResponseStatus responseStatus)
void	setTranscoder(Transcoder transcoder)
void	setValue(Object value)

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 Detail

expTime

protected int expTime

cas

protected long cas

value

protected Object value

opCode

protected OpCode opCode

decodeStatus

protected BinaryDecodeStatus decodeStatus

responseKeyLength

protected int responseKeyLength

responseExtrasLength

protected int responseExtrasLength

responseTotalBodyLength

protected int responseTotalBodyLength

responseStatus

protected ResponseStatus responseStatus

opaque

protected int opaque

vbucketId

protected short vbucketId

Constructor Detail

BaseBinaryCommand

public BaseBinaryCommand(String key,
                         byte[] keyBytes,
                         CommandType cmdType,
                         CountDownLatch latch,
                         int exp,
                         long cas,
                         Object value,
                         boolean noreply,
                         Transcoder transcoder)

Method Detail

getExpTime

public final int getExpTime()

setExpTime

public final void setExpTime(int exp)

getCas

public final long getCas()

getOpaque

public int getOpaque()

setOpaque

public void setOpaque(int opaque)

setCas

public final void setCas(long cas)

getValue

public final Object getValue()

Specified by:

getValue in interface StoreCommand

setValue

public final void setValue(Object value)

Specified by:

setValue in interface StoreCommand

getTranscoder

public final Transcoder getTranscoder()

Overrides:

getTranscoder in class Command

setTranscoder

public final void setTranscoder(Transcoder transcoder)

Overrides:

setTranscoder in class Command

decode

public boolean decode(MemcachedTCPSession session,
                      ByteBuffer buffer)

Specified by:

decode in class Command

finish

protected boolean finish()

readHeader

protected void readHeader(ByteBuffer buffer)

readOpaque

protected boolean readOpaque(ByteBuffer buffer)

readCAS

protected long readCAS(ByteBuffer buffer)

readKey

protected boolean readKey(ByteBuffer buffer,
                          int keyLength)

readValue

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

readExtras

protected boolean readExtras(ByteBuffer buffer,
                             int extrasLength)

readStatus

protected void readStatus(ByteBuffer buffer)

getOpCode

public final OpCode getOpCode()

setOpCode

public final void setOpCode(OpCode opCode)

getResponseStatus

public final ResponseStatus getResponseStatus()

setResponseStatus

public final void setResponseStatus(ResponseStatus responseStatus)

readOpCode

protected boolean readOpCode(ByteBuffer buffer)

encode

public void encode()

Specified by:

encode in class Command

fillValue

protected void fillValue(CachedData data)

fillKey

protected void fillKey()

fillExtras

protected void fillExtras(CachedData data)

getCasValue

protected long getCasValue()

getValueLength

protected int getValueLength(CachedData data)

getKeyLength

protected short getKeyLength()

getExtrasLength

protected byte getExtrasLength()