Class TapOperationImpl

java.lang.Object

net.spy.memcached.compat.SpyObject

net.spy.memcached.protocol.BaseOperationImpl

net.spy.memcached.protocol.binary.OperationImpl

net.spy.memcached.protocol.binary.TapOperationImpl

All Implemented Interfaces:

Operation, TapOperation

Direct Known Subclasses:

TapAckOperationImpl, TapBackfillOperationImpl, TapCustomOperationImpl, TapDumpOperationImpl

public abstract class TapOperationImpl
extends OperationImpl
implements TapOperation

Abstract implementation of a tap operation.

Nested Class Summary

Nested classes/interfaces inherited from interface TapOperation

TapOperation.Callback

Field Summary

Fields

Modifier and Type	Field	Description
private int	bodylen
private int	bytesProcessed
(package private) static final byte	CMD
private byte[]	header
private byte[]	message

Fields inherited from class OperationImpl

DUMMY_OPCODE, EMPTY_BYTES, ERR_2BIG, ERR_BUSY, ERR_DELTA_BADVAL, ERR_EXISTS, ERR_INTERNAL, ERR_INVAL, ERR_NO_MEM, ERR_NOT_FOUND, ERR_NOT_MY_VBUCKET, ERR_NOT_STORED, ERR_NOT_SUPPORTED, ERR_TEMP_FAIL, ERR_UNKNOWN_COMMAND, errorCode, keyLen, MIN_RECV_PACKET, opaque, REQ_MAGIC, RES_MAGIC, responseCas, responseCmd, responseOpaque, STATUS_OK, SUCCESS, vbucket

Fields inherited from class BaseOperationImpl

callback, CANCELLED, notMyVbucketNodes, TIMED_OUT

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	TapOperationImpl(OperationCallback cb)

Method Summary

Modifier and Type	Method	Description
abstract void	initialize()	Initialize this operation.
void	readFromBuffer(ByteBuffer data)	Read from the incoming ByteBuffer.

Methods inherited from class OperationImpl

decodeByte, decodeInt, decodeLong, decodePayload, decodeShort, decodeUnsignedInt, finishedPayload, generateOpaque, getErrorMsg, getStatusForErrorCode, opaqueIsValid, prepareBuffer, resetInput, toString

Methods inherited from class BaseOperationImpl

addClone, cancel, getBuffer, getCallback, getCloneCount, getException, getHandlingNode, getState, getWriteCompleteTimestamp, handleError, handleRead, hasErrored, isCancelled, isTimedOut, isTimedOut, isTimedOutUnsent, setBuffer, setCallback, setCloneCount, setHandlingNode, timeOut, transitionState, wasCancelled, writeComplete, writing

Methods inherited from class SpyObject

getLogger

Methods inherited from class Object

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

Methods inherited from interface Operation

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

Methods inherited from interface TapOperation

streamClosed

Field Details

bytesProcessed

private int bytesProcessed

bodylen

private int bodylen

header

private byte[] header

message

private byte[] message

CMD

static final byte CMD

See Also:

• Constant Field Values

Constructor Details

TapOperationImpl

protected TapOperationImpl(OperationCallback cb)

Method Details

initialize

public abstract void initialize()

Description copied from interface: Operation

Initialize this operation. This is used to prepare output byte buffers and stuff.

Specified by:

initialize in interface Operation

Specified by:

initialize in class BaseOperationImpl

readFromBuffer

public void readFromBuffer(ByteBuffer data)
                    throws IOException

Description copied from class: OperationImpl

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 OperationImpl.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

Overrides:

readFromBuffer in class OperationImpl

Parameters:

data - the buffer to read from.

Throws:

IOException - if an error happened during parsing/reading.