public class GetAndTouchOperationImpl extends BaseOperationImpl implements GetAndTouchOperation
GetAndTouchOperation.Callback
Modifier and Type | Field and Description |
---|---|
protected static byte[] |
CRLF |
protected int |
exp |
callback, CANCELLED, notMyVbucketNodes, TIMED_OUT
Constructor and Description |
---|
GetAndTouchOperationImpl(String c,
int e,
GetAndTouchOperation.Callback cb,
String k) |
Modifier and Type | Method and Description |
---|---|
byte[] |
getErrorMsg()
Returns the raw bytes of the error message content.
|
int |
getExpiration()
Get the expiration to set in case of a new entry.
|
Collection<String> |
getKeys()
Get the keys this GetOperation is looking for.
|
protected net.spy.memcached.protocol.ascii.OperationReadType |
getReadType() |
void |
handleLine(String line) |
void |
handleRead(ByteBuffer b)
Handle a raw data read.
|
void |
initialize()
Initialize this operation.
|
protected OperationStatus |
matchStatus(String line,
OperationStatus... statii)
Match the status line provided against one of the given OperationStatus
objects.
|
void |
readFromBuffer(ByteBuffer data)
Read data from the given byte buffer and dispatch to the appropriate read
mechanism.
|
protected void |
setArguments(ByteBuffer bb,
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.
|
String |
toString() |
protected void |
wasCancelled()
This is called on each subclass whenever an operation was cancelled.
|
addClone, cancel, getBuffer, getCallback, getCloneCount, getException, getHandlingNode, getState, getWriteCompleteTimestamp, handleError, hasErrored, isCancelled, isTimedOut, isTimedOut, isTimedOutUnsent, setBuffer, setCallback, setCloneCount, setHandlingNode, timeOut, transitionState, writeComplete, writing
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
getKeys
addClone, cancel, getBuffer, getCallback, getCloneCount, getErrorMsg, getException, getHandlingNode, getState, getWriteCompleteTimestamp, handleRead, hasErrored, initialize, isCancelled, isTimedOut, isTimedOut, isTimedOutUnsent, readFromBuffer, setCloneCount, setHandlingNode, timeOut, writeComplete, writing
public GetAndTouchOperationImpl(String c, int e, GetAndTouchOperation.Callback cb, String k)
public int getExpiration()
GetAndTouchOperation
getExpiration
in interface GetAndTouchOperation
public final Collection<String> getKeys()
public final void handleLine(String line)
public final void handleRead(ByteBuffer b)
Operation
handleRead
in interface Operation
handleRead
in class BaseOperationImpl
public final void initialize()
Operation
initialize
in interface Operation
initialize
in class BaseOperationImpl
protected final void wasCancelled()
BaseOperationImpl
wasCancelled
in class BaseOperationImpl
protected final OperationStatus matchStatus(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(ByteBuffer bb, Object... args)
public void readFromBuffer(ByteBuffer data) throws IOException
Operation
readFromBuffer
in interface Operation
readFromBuffer
in class BaseOperationImpl
IOException
public byte[] getErrorMsg()
Operation
getErrorMsg
in interface Operation
Copyright © 2024. All rights reserved.