net.spy.memcached.protocol.binary

Class OperationImpl

java.lang.Object

net.spy.memcached.compat.SpyObject

net.spy.memcached.protocol.BaseOperationImpl

net.spy.memcached.protocol.binary.OperationImpl

All Implemented Interfaces:

Operation

Direct Known Subclasses:

GetAndTouchOperationImpl, GetlOperationImpl, GetsOperationImpl, KeyStatsOperationImpl, MultiGetOperationImpl, OptimizedSetImpl, ReplicaGetOperationImpl, ReplicaGetsOperationImpl, SASLBaseOperationImpl, StatsOperationImpl, TapOperationImpl, TouchOperationImpl

public abstract class OperationImpl
extends BaseOperationImpl
implements Operation

Base class for binary operations.

Field Summary

Fields inherited from class net.spy.memcached.protocol.BaseOperationImpl

CANCELLED, TIMED_OUT

Method Summary

Methods

Modifier and Type	Method and Description
byte[]	getErrorMsg() Returns the raw bytes of the error message content.
void	readFromBuffer(java.nio.ByteBuffer buffer) Read from the incoming ByteBuffer.
java.lang.String	toString()

Methods inherited from class net.spy.memcached.protocol.BaseOperationImpl

addClone, cancel, getBuffer, getCallback, getCloneCount, getException, getHandlingNode, getState, getWriteCompleteTimestamp, handleRead, hasErrored, initialize, isCancelled, isTimedOut, isTimedOut, isTimedOutUnsent, setCloneCount, setHandlingNode, timeOut, writeComplete, writing

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface net.spy.memcached.ops.Operation

addClone, cancel, getBuffer, getCallback, getCloneCount, getException, getHandlingNode, getState, getWriteCompleteTimestamp, handleRead, hasErrored, initialize, isCancelled, isTimedOut, isTimedOut, isTimedOutUnsent, setCloneCount, setHandlingNode, timeOut, writeComplete, writing

Method Detail

readFromBuffer

public void readFromBuffer(java.nio.ByteBuffer buffer)
                    throws java.io.IOException

Read from the incoming ByteBuffer. Reading from the buffer is done in stages, depending on how much data can be read at once. First, the header is read and then parsed (24 bytes, indicated by MIN_RECV_PACKET). Then, the payload is read (if one is available for this operation and can be loaded fully).

Specified by:

readFromBuffer in interface Operation

Specified by:

readFromBuffer in class BaseOperationImpl

Parameters:

buffer - the buffer to read from.

Throws:

java.io.IOException - if an error happened during parsing/reading.

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

getErrorMsg

public byte[] getErrorMsg()

Description copied from interface: Operation

Returns the raw bytes of the error message content.

Specified by:

getErrorMsg in interface Operation

Returns:

the raw error message content.