public class ConcatenationOperationImpl extends BaseOperationImpl implements ConcatenationOperation
Modifier and Type | Field and Description |
---|---|
protected static byte[] |
CRLF |
protected byte[] |
data |
protected int |
exp |
protected int |
flags |
protected java.lang.String |
key |
protected java.lang.String |
type |
callback, CANCELLED, notMyVbucketNodes, TIMED_OUT
Constructor and Description |
---|
ConcatenationOperationImpl(ConcatenationType t,
java.lang.String k,
byte[] d,
OperationCallback cb) |
Modifier and Type | Method and Description |
---|---|
long |
getCasValue()
Get the CAS value sent with this operation.
|
byte[] |
getData() |
int |
getExpiration() |
int |
getFlags() |
java.util.Collection<java.lang.String> |
getKeys() |
protected net.spy.memcached.protocol.ascii.OperationReadType |
getReadType() |
ConcatenationType |
getStoreType()
Get the concatenation type for this operation.
|
void |
handleLine(java.lang.String line) |
void |
initialize()
Initialize this operation.
|
protected OperationStatus |
matchStatus(java.lang.String line,
OperationStatus... statii)
Match the status line provided against one of the given OperationStatus
objects.
|
void |
readFromBuffer(java.nio.ByteBuffer data)
Read data from the given byte buffer and dispatch to the appropriate read
mechanism.
|
protected void |
setArguments(java.nio.ByteBuffer bb,
java.lang.Object... args)
Set some arguments for an operation into the given byte buffer.
|
protected void |
setReadType(net.spy.memcached.protocol.ascii.OperationReadType to)
Set the read type of this operation.
|
java.lang.String |
toString() |
protected void |
wasCancelled()
This is called on each subclass whenever an operation was cancelled.
|
cancel, getBuffer, getCallback, getException, getHandlingNode, getState, handleError, handleRead, hasErrored, isCancelled, isTimedOut, isTimedOut, isTimedOutUnsent, setBuffer, setCallback, setHandlingNode, timeOut, transitionState, writeComplete, writing
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
getData
getKeys
cancel, getBuffer, getCallback, getException, getHandlingNode, getState, handleRead, hasErrored, initialize, isCancelled, isTimedOut, isTimedOut, isTimedOutUnsent, readFromBuffer, setHandlingNode, timeOut, writeComplete, writing
protected final java.lang.String type
protected final java.lang.String key
protected final int flags
protected final int exp
protected final byte[] data
protected static final byte[] CRLF
public ConcatenationOperationImpl(ConcatenationType t, java.lang.String k, byte[] d, OperationCallback cb)
public long getCasValue()
ConcatenationOperation
getCasValue
in interface ConcatenationOperation
public ConcatenationType getStoreType()
ConcatenationOperation
getStoreType
in interface ConcatenationOperation
public void handleLine(java.lang.String line)
public void initialize()
Operation
initialize
in interface Operation
initialize
in class BaseOperationImpl
protected void wasCancelled()
BaseOperationImpl
wasCancelled
in class BaseOperationImpl
public java.util.Collection<java.lang.String> getKeys()
public int getFlags()
public int getExpiration()
public byte[] getData()
public java.lang.String toString()
toString
in class java.lang.Object
protected final OperationStatus matchStatus(java.lang.String line, OperationStatus... statii)
line
- the current linestatii
- several status objectsprotected final net.spy.memcached.protocol.ascii.OperationReadType getReadType()
protected final void setReadType(net.spy.memcached.protocol.ascii.OperationReadType to)
protected final void setArguments(java.nio.ByteBuffer bb, java.lang.Object... args)
public void readFromBuffer(java.nio.ByteBuffer data) throws java.io.IOException
Operation
readFromBuffer
in interface Operation
readFromBuffer
in class BaseOperationImpl
java.io.IOException
Copyright © 2006-2009 Dustin Sallings, 2009-2013 Couchbase, Inc.