org.apache.bookkeeper.client

Class ListenerBasedPendingReadOp

java.lang.Object

org.apache.bookkeeper.client.PendingReadOp

org.apache.bookkeeper.client.ListenerBasedPendingReadOp

All Implemented Interfaces:

java.lang.Runnable, org.apache.bookkeeper.common.util.SafeRunnable, org.apache.bookkeeper.proto.BookkeeperInternalCallbacks.ReadEntryCallback

Direct Known Subclasses:

LedgerRecoveryOp.RecoveryReadOp

class ListenerBasedPendingReadOp
extends PendingReadOp

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.bookkeeper.client.PendingReadOp

PendingReadOp.LedgerEntryRequest, PendingReadOp.ParallelReadRequest, PendingReadOp.SequenceReadRequest

Field Summary

Fields

Modifier and Type	Field and Description
(package private) java.lang.Object	ctx
(package private) org.apache.bookkeeper.proto.BookkeeperInternalCallbacks.ReadEntryListener	listener

Fields inherited from class org.apache.bookkeeper.client.PendingReadOp

allowFailFast, clientCtx, complete, endEntryId, isRecoveryRead, lh, numPendingEntries, parallelRead, requestTimeNanos, requiredBookiesMissingEntryForRecovery, seq, startEntryId

Fields inherited from interface org.apache.bookkeeper.common.util.SafeRunnable

LOGGER

Constructor Summary

Constructors

Constructor and Description
ListenerBasedPendingReadOp(LedgerHandle lh, ClientContext clientCtx, long startEntryId, long endEntryId, org.apache.bookkeeper.proto.BookkeeperInternalCallbacks.ReadEntryListener listener, java.lang.Object ctx, boolean isRecoveryRead)

Method Summary

Modifier and Type	Method and Description
protected void	submitCallback(int code)

Methods inherited from class org.apache.bookkeeper.client.PendingReadOp

allowFailFastOnUnwritableChannel, cancelSpeculativeTask, future, getLedgerMetadata, getSpeculativeTask, initiate, parallelRead, readEntryComplete, safeRun, sendReadTo, submit

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.bookkeeper.common.util.SafeRunnable

run, safeRun, safeRun

Field Detail

listener

final org.apache.bookkeeper.proto.BookkeeperInternalCallbacks.ReadEntryListener listener

ctx

final java.lang.Object ctx

Constructor Detail

ListenerBasedPendingReadOp

ListenerBasedPendingReadOp(LedgerHandle lh,
                           ClientContext clientCtx,
                           long startEntryId,
                           long endEntryId,
                           org.apache.bookkeeper.proto.BookkeeperInternalCallbacks.ReadEntryListener listener,
                           java.lang.Object ctx,
                           boolean isRecoveryRead)

Method Detail

submitCallback

protected void submitCallback(int code)

Overrides:

submitCallback in class PendingReadOp