Package net.rubyeye.xmemcached.command.binary

Class BinarySetMultiCommand

java.lang.Object

net.rubyeye.xmemcached.command.Command

net.rubyeye.xmemcached.command.binary.BaseBinaryCommand

net.rubyeye.xmemcached.command.binary.BinarySetMultiCommand

All Implemented Interfaces:

WriteMessage, MergeCommandsAware, StoreCommand

public class BinarySetMultiCommand
extends BaseBinaryCommand
implements MergeCommandsAware

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, 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
BinarySetMultiCommand(String key, CommandType cmdType, CountDownLatch latch)

Method Summary

Modifier and Type	Method	Description
void	encode()
protected boolean	finish()
Map<Object,Command>	getMergeCommands()
protected void	readHeader(ByteBuffer buffer)	optimistic,if response status is greater than zero,then skip buffer to next response,set result to be false.
protected boolean	readOpaque(ByteBuffer buffer)
protected boolean	readOpCode(ByteBuffer buffer)
void	setMergeCommands(Map<Object,Command> mergeCommands)

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

decode, fillExtras, fillKey, fillValue, getCas, getCasValue, getExpTime, getExtrasLength, getKeyLength, getOpaque, getOpCode, getResponseStatus, getTranscoder, getValue, getValueLength, readCAS, readExtras, readKey, readStatus, readValue, 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

BinarySetMultiCommand

public BinarySetMultiCommand(String key,
                             CommandType cmdType,
                             CountDownLatch latch)

Method Detail

readOpCode

protected boolean readOpCode(ByteBuffer buffer)

Overrides:

readOpCode in class BaseBinaryCommand

readHeader

protected void readHeader(ByteBuffer buffer)

optimistic,if response status is greater than zero,then skip buffer to next response,set result to be false.

Overrides:

readHeader in class BaseBinaryCommand

getMergeCommands

public Map<Object,Command> getMergeCommands()

Specified by:

getMergeCommands in interface MergeCommandsAware

setMergeCommands

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

Specified by:

setMergeCommands in interface MergeCommandsAware

encode

public void encode()

Overrides:

encode in class BaseBinaryCommand

finish

protected boolean finish()

Overrides:

finish in class BaseBinaryCommand

readOpaque

protected boolean readOpaque(ByteBuffer buffer)

Overrides:

readOpaque in class BaseBinaryCommand