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

Field Summary

Fields

Modifier and Type	Field	Description
private boolean	finished
private Map<Object,Command>	mergeCommands
private Integer	responseOpaque

Fields inherited from class BaseBinaryCommand

cas, decodeStatus, DEFAULT_VBUCKET_ID, expTime, EXTRAS_LENGTH, opaque, opCode, responseExtrasLength, responseKeyLength, responseStatus, responseTotalBodyLength, value, vbucketId

Fields inherited from class 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 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 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 Object

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

Field Details

finished

private boolean finished

responseOpaque

private Integer responseOpaque

mergeCommands

private Map<Object,Command> mergeCommands

Constructor Details

BinarySetMultiCommand

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

Method Details

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