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

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

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

BinaryGetMultiCommand(java.lang.String key, CommandType cmdType, java.util.concurrent.CountDownLatch latch)

Method Summary

void	encode()
protected boolean	finish()
java.util.Map<java.lang.Object,Command>	getMergeCommands()
java.util.Map<java.lang.String,CachedData>	getReturnValues()
protected long	readCAS(java.nio.ByteBuffer buffer)
protected boolean	readExtras(java.nio.ByteBuffer buffer, int extrasLength)
protected void	readHeader(java.nio.ByteBuffer buffer) optimistic,if response status is greater than zero,then skip buffer to next response,set result as null
protected boolean	readKey(java.nio.ByteBuffer buffer, int keyLength)
protected boolean	readOpCode(java.nio.ByteBuffer buffer)
protected boolean	readValue(java.nio.ByteBuffer buffer, int bodyLength, int keyLength, int extrasLength)
void	setMergeCommands(java.util.Map<java.lang.Object,Command> mergeCommands)

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

decode, fillCAS, fillExtras, fillHeader, fillKey, fillValue, getCas, getExpTime, getExtrasLength, getKeyLength, getOpCode, getResponseStatus, getTranscoder, getValue, getValueLength, readOpaque, readStatus, setCas, setExpTime, setOpCode, setResponseStatus, setTranscoder, setValue

Methods inherited from class net.rubyeye.xmemcached.command.Command

cancel, countDownLatch, decodeError, decodeError, decodeError, decodeError, getCommandType, getException, getIoBuffer, getKey, getKeyBytes, getLatch, getMergeCount, getMessage, getResult, getStatus, getWriteBuffer, getWriteFuture, isCancel, isNoreply, isWriting, 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(java.lang.String key,
                             CommandType cmdType,
                             java.util.concurrent.CountDownLatch latch)

Method Detail

getReturnValues

public java.util.Map<java.lang.String,CachedData> getReturnValues()

Specified by:

getReturnValues in interface MapReturnValueAware

readOpCode

protected boolean readOpCode(java.nio.ByteBuffer buffer)

Overrides:

readOpCode in class BaseBinaryCommand

readHeader

protected void readHeader(java.nio.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(java.nio.ByteBuffer buffer,
                          int keyLength)

Overrides:

readKey in class BaseBinaryCommand

readValue

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

Overrides:

readValue in class BaseBinaryCommand

readExtras

protected boolean readExtras(java.nio.ByteBuffer buffer,
                             int extrasLength)

Overrides:

readExtras in class BaseBinaryCommand

readCAS

protected long readCAS(java.nio.ByteBuffer buffer)

Overrides:

readCAS in class BaseBinaryCommand

getMergeCommands

public java.util.Map<java.lang.Object,Command> getMergeCommands()

Specified by:

getMergeCommands in interface MergeCommandsAware

setMergeCommands

public void setMergeCommands(java.util.Map<java.lang.Object,Command> mergeCommands)

Specified by:

setMergeCommands in interface MergeCommandsAware