Package net.rubyeye.xmemcached.command.text

Class TextGetCommand

java.lang.Object

net.rubyeye.xmemcached.command.Command

net.rubyeye.xmemcached.command.text.TextGetCommand

All Implemented Interfaces:

WriteMessage, AssocCommandAware, MapReturnValueAware, MergeCommandsAware

Direct Known Subclasses:

KestrelGetCommand, TextGetMultiCommand, TextGetOneCommand

public abstract class TextGetCommand
extends Command
implements MergeCommandsAware, AssocCommandAware, MapReturnValueAware

Abstract get command for text protocol

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static enum	TextGetCommand.ParseStatus

Field Summary

Fields

Modifier and Type	Field	Description
private static final char[]	A_SPACE
protected List<Command>	assocCommands	When MemcachedClient merge get commands,those commans which have the same key will be merged into one get command.The result command's assocCommands contains all these commands with the same key.
private String	currentReturnKey
private static final char[]	EMPTY_CHARS
protected Map<Object,Command>	mergeCommands
private int	offset
private TextGetCommand.ParseStatus	parseStatus
protected Map<String,CachedData>	returnValues
protected boolean	wasFirst

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
TextGetCommand(String key, byte[] keyBytes, CommandType cmdType, CountDownLatch latch)

Method Summary

Modifier and Type	Method	Description
final boolean	decode(MemcachedTCPSession session, ByteBuffer buffer)
abstract void	dispatch()
void	encode()
final List<Command>	getAssocCommands()
private String	getItem(ByteBuffer buffer, char token, char[] others)
final Map<Object,Command>	getMergeCommands()
TextGetCommand.ParseStatus	getParseStatus()
final Map<String,CachedData>	getReturnValues()
private String	getString(byte[] keyBytes)
private boolean	isIn(byte b, char[] others)
final void	setAssocCommands(List<Command> assocCommands)
final void	setMergeCommands(Map<Object,Command> mergeCommands)
void	setParseStatus(TextGetCommand.ParseStatus parseStatus)
final void	setReturnValues(Map<String,CachedData> returnValues)

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, getTranscoder, getWriteBuffer, getWriteFuture, isAdded, isCancel, isNoreply, isWriting, setAdded, setCommandType, setException, setIoBuffer, setKey, setKeyBytes, setLatch, setMergeCount, setNoreply, setResult, setStatus, setTranscoder, setWriteBuffer, setWriteFuture, toString, writing

Methods inherited from class java.lang.Object

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

Field Details

A_SPACE

private static final char[] A_SPACE

EMPTY_CHARS

private static final char[] EMPTY_CHARS

returnValues

protected Map<String,CachedData> returnValues

currentReturnKey

private String currentReturnKey

offset

private int offset

assocCommands

protected List<Command> assocCommands

When MemcachedClient merge get commands,those commans which have the same key will be merged into one get command.The result command's assocCommands contains all these commands with the same key.

mergeCommands

protected Map<Object,Command> mergeCommands

parseStatus

private TextGetCommand.ParseStatus parseStatus

wasFirst

protected boolean wasFirst

Constructor Details

TextGetCommand

public TextGetCommand(String key,
 byte[] keyBytes,
 CommandType cmdType,
 CountDownLatch latch)

Method Details

getMergeCommands

public final Map<Object,Command> getMergeCommands()

Specified by:

getMergeCommands in interface MergeCommandsAware

setMergeCommands

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

Specified by:

setMergeCommands in interface MergeCommandsAware

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

getParseStatus

public TextGetCommand.ParseStatus getParseStatus()

setParseStatus

public void setParseStatus(TextGetCommand.ParseStatus parseStatus)

decode

public final boolean decode(MemcachedTCPSession session,
 ByteBuffer buffer)

Specified by:

decode in class Command

getItem

private String getItem(ByteBuffer buffer,
 char token,
 char[] others)

isIn

private boolean isIn(byte b,
 char[] others)

getString

private String getString(byte[] keyBytes)

getReturnValues

public final Map<String,CachedData> getReturnValues()

Specified by:

getReturnValues in interface MapReturnValueAware

setReturnValues

public final void setReturnValues(Map<String,CachedData> returnValues)

dispatch

public abstract void dispatch()

encode

public void encode()

Specified by:

encode in class Command