Package org.apache.bookkeeper.client
Class ListenerBasedPendingReadOp
- java.lang.Object
-
- org.apache.bookkeeper.client.ReadOpBase
-
- org.apache.bookkeeper.client.PendingReadOp
-
- org.apache.bookkeeper.client.ListenerBasedPendingReadOp
-
- All Implemented Interfaces:
java.lang.Runnable
,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.ParallelReadRequest, PendingReadOp.SequenceReadRequest, PendingReadOp.SingleLedgerEntryRequest
-
Nested classes/interfaces inherited from class org.apache.bookkeeper.client.ReadOpBase
ReadOpBase.LedgerEntryRequest, ReadOpBase.ReadContext
-
-
Field Summary
Fields Modifier and Type Field Description (package private) java.lang.Object
ctx
(package private) BookkeeperInternalCallbacks.ReadEntryListener
listener
-
Fields inherited from class org.apache.bookkeeper.client.PendingReadOp
parallelRead, seq
-
Fields inherited from class org.apache.bookkeeper.client.ReadOpBase
allowFailFast, clientCtx, complete, endEntryId, future, heardFromHosts, heardFromHostsBitSet, isRecoveryRead, lh, numPendingEntries, requestTimeNanos, requiredBookiesMissingEntryForRecovery, sentToHosts, speculativeTask, startEntryId
-
-
Constructor Summary
Constructors Constructor Description ListenerBasedPendingReadOp(LedgerHandle lh, ClientContext clientCtx, long startEntryId, long endEntryId, BookkeeperInternalCallbacks.ReadEntryListener listener, java.lang.Object ctx, boolean isRecoveryRead)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected void
submitCallback(int code)
-
Methods inherited from class org.apache.bookkeeper.client.PendingReadOp
initiate, parallelRead, readEntryComplete, sendReadTo
-
Methods inherited from class org.apache.bookkeeper.client.ReadOpBase
allowFailFastOnUnwritableChannel, cancelSpeculativeTask, future, getLedgerMetadata, getSpeculativeTask, run, submit
-
-
-
-
Field Detail
-
listener
final BookkeeperInternalCallbacks.ReadEntryListener listener
-
ctx
final java.lang.Object ctx
-
-
Constructor Detail
-
ListenerBasedPendingReadOp
ListenerBasedPendingReadOp(LedgerHandle lh, ClientContext clientCtx, long startEntryId, long endEntryId, BookkeeperInternalCallbacks.ReadEntryListener listener, java.lang.Object ctx, boolean isRecoveryRead)
-
-
Method Detail
-
submitCallback
protected void submitCallback(int code)
- Overrides:
submitCallback
in classPendingReadOp
-
-