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:

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) final Object	ctx
(package private) final 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, Object ctx, boolean isRecoveryRead)

Method Summary

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

Methods inherited from class java.lang.Object

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

Field Details

listener

final BookkeeperInternalCallbacks.ReadEntryListener listener

ctx

final Object ctx

Constructor Details

ListenerBasedPendingReadOp

ListenerBasedPendingReadOp(LedgerHandle lh,
 ClientContext clientCtx,
 long startEntryId,
 long endEntryId,
 BookkeeperInternalCallbacks.ReadEntryListener listener,
 Object ctx,
 boolean isRecoveryRead)

Method Details

submitCallback

protected void submitCallback(int code)

Overrides:

submitCallback in class PendingReadOp