Inherited by OperationImpl, and OperationImpl.

Public Member Functions | |
| BaseOperationImpl () | |
| final void | cancel () |
| final ByteBuffer | getBuffer () |
| final OperationCallback | getCallback () |
| final OperationException | getException () |
| final OperationState | getState () |
| void | handleRead (ByteBuffer data) |
| final boolean | hasErrored () |
| abstract void | initialize () |
| final boolean | isCancelled () |
| abstract void | readFromBuffer (ByteBuffer data) throws IOException |
| final void | writeComplete () |
Static Public Attributes | |
| static final OperationStatus | CANCELLED |
Protected Member Functions | |
| void | handleError (OperationErrorType eType, String line) throws IOException |
| final void | setBuffer (ByteBuffer to) |
| void | setCallback (OperationCallback to) |
| final void | transitionState (OperationState newState) |
| void | wasCancelled () |
Protected Attributes | |
| OperationCallback | callback = null |
Private Attributes | |
| boolean | cancelled = false |
| ByteBuffer | cmd = null |
| OperationState | state = OperationState.WRITING |
| final void cancel | ( | ) |
| final ByteBuffer getBuffer | ( | ) |
| final OperationCallback getCallback | ( | ) |
Get the operation callback associated with this operation.
| final OperationException getException | ( | ) |
| final OperationState getState | ( | ) |
| void handleError | ( | OperationErrorType | eType, | |
| String | line | |||
| ) | throws IOException [protected] |
| void handleRead | ( | ByteBuffer | data | ) |
Reimplemented in BaseGetOpImpl.
| final boolean hasErrored | ( | ) |
| abstract void initialize | ( | ) | [pure virtual] |
Implemented in BaseGetOpImpl, BaseStoreOperationImpl, CASOperationImpl, DeleteOperationImpl, FlushOperationImpl, MutatorOperationImpl, StatsOperationImpl, VersionOperationImpl, ConcatenationOperationImpl, DeleteOperationImpl, FlushOperationImpl, GetOperationImpl, MultiGetOperationImpl, MutatorOperationImpl, NoopOperationImpl, StoreOperationImpl, and VersionOperationImpl.
| final boolean isCancelled | ( | ) |
| abstract void readFromBuffer | ( | ByteBuffer | data | ) | throws IOException [pure virtual] |
Implemented in OperationImpl, and OperationImpl.
| final void setBuffer | ( | ByteBuffer | to | ) | [protected] |
Set the write buffer for this operation.
| void setCallback | ( | OperationCallback | to | ) | [protected] |
Set the callback for this instance.
| final void transitionState | ( | OperationState | newState | ) | [protected] |
Transition the state of this operation to the given state.
| void wasCancelled | ( | ) | [protected] |
This is called on each subclass whenever an operation was cancelled.
Reimplemented in BaseGetOpImpl, BaseStoreOperationImpl, CASOperationImpl, MutatorOperationImpl, and StatsOperationImpl.
| final void writeComplete | ( | ) |
OperationCallback callback = null [protected] |
boolean cancelled = false [private] |
final OperationStatus CANCELLED [static] |
Initial value:
new CancelledOperationStatus()
Reimplemented in BaseGetOpImpl, and OperationImpl.
OperationState state = OperationState.WRITING [private] |
1.5.8