Class BinaryCASCommand
java.lang.Object
net.rubyeye.xmemcached.command.Command
net.rubyeye.xmemcached.command.binary.BaseBinaryCommand
net.rubyeye.xmemcached.command.binary.BinaryCASCommand
- All Implemented Interfaces:
WriteMessage, StoreCommand
CAS binary protocol implementation
-
Field Summary
Fields inherited from class BaseBinaryCommand
cas, decodeStatus, DEFAULT_VBUCKET_ID, expTime, EXTRAS_LENGTH, opaque, opCode, responseExtrasLength, responseKeyLength, responseStatus, responseTotalBodyLength, value, vbucketIdFields 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
ConstructorsConstructorDescriptionBinaryCASCommand(String key, byte[] keyBytes, CommandType cmdType, CountDownLatch latch, int exp, long cas, Object value, boolean noreply, Transcoder transcoder) -
Method Summary
Methods inherited from class BaseBinaryCommand
decode, encode, fillExtras, fillKey, fillValue, finish, getCas, getExpTime, getExtrasLength, getKeyLength, getOpaque, getOpCode, getResponseStatus, getTranscoder, getValue, getValueLength, readCAS, readExtras, readHeader, readKey, readOpaque, readOpCode, readStatus, readValue, setCas, setExpTime, setOpaque, setOpCode, setResponseStatus, setTranscoder, setValueMethods 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
-
Constructor Details
-
BinaryCASCommand
public BinaryCASCommand(String key, byte[] keyBytes, CommandType cmdType, CountDownLatch latch, int exp, long cas, Object value, boolean noreply, Transcoder transcoder)
-
-
Method Details
-
getCasValue
protected long getCasValue()- Overrides:
getCasValuein classBaseBinaryCommand
-