Package 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.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 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
-
-
Constructor Summary
Constructors Constructor 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
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
allowFailFastOnUnwritableChannel, cancelSpeculativeTask, future, getLedgerMetadata, getSpeculativeTask, initiate, parallelRead, readEntryComplete, run, sendReadTo, submit
-
-
-
-
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 classPendingReadOp
-
-