Package org.apache.bookkeeper.client

Class ReadOpBase

java.lang.Object

org.apache.bookkeeper.client.ReadOpBase

All Implemented Interfaces:

Runnable

Direct Known Subclasses:

BatchedReadOp, PendingReadOp

public abstract class ReadOpBase
extends Object
implements Runnable

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
(package private) class	ReadOpBase.LedgerEntryRequest
protected static class	ReadOpBase.ReadContext

Field Summary

Fields

Modifier and Type	Field	Description
protected boolean	allowFailFast
protected ClientContext	clientCtx
protected final AtomicBoolean	complete
(package private) final long	endEntryId
protected final CompletableFuture<LedgerEntries>	future
protected final Set<BookieId>	heardFromHosts
protected final BitSet	heardFromHostsBitSet
protected final boolean	isRecoveryRead
(package private) LedgerHandle	lh
(package private) long	numPendingEntries
protected long	requestTimeNanos
protected final int	requiredBookiesMissingEntryForRecovery
protected final Set<BookieId>	sentToHosts
protected ScheduledFuture<?>	speculativeTask
protected final long	startEntryId

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	ReadOpBase(LedgerHandle lh, ClientContext clientCtx, long startEntryId, long endEntryId, boolean isRecoveryRead)

Method Summary

Modifier and Type	Method	Description
(package private) void	allowFailFastOnUnwritableChannel()
protected void	cancelSpeculativeTask(boolean mayInterruptIfRunning)
(package private) CompletableFuture<LedgerEntries>	future()
protected LedgerMetadata	getLedgerMetadata()
ScheduledFuture<?>	getSpeculativeTask()
(package private) abstract void	initiate()
void	run()
void	submit()
protected abstract void	submitCallback(int code)

Methods inherited from class java.lang.Object

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

Field Details

speculativeTask

protected ScheduledFuture<?> speculativeTask

future

protected final CompletableFuture<LedgerEntries> future

heardFromHosts

protected final Set<BookieId> heardFromHosts

heardFromHostsBitSet

protected final BitSet heardFromHostsBitSet

sentToHosts

protected final Set<BookieId> sentToHosts

lh

LedgerHandle lh

clientCtx

protected ClientContext clientCtx

startEntryId

protected final long startEntryId

requestTimeNanos

protected long requestTimeNanos

requiredBookiesMissingEntryForRecovery

protected final int requiredBookiesMissingEntryForRecovery

isRecoveryRead

protected final boolean isRecoveryRead

complete

protected final AtomicBoolean complete

allowFailFast

protected boolean allowFailFast

numPendingEntries

long numPendingEntries

endEntryId

final long endEntryId

Constructor Details

ReadOpBase

protected ReadOpBase(LedgerHandle lh,
 ClientContext clientCtx,
 long startEntryId,
 long endEntryId,
 boolean isRecoveryRead)

Method Details

getLedgerMetadata

protected LedgerMetadata getLedgerMetadata()

cancelSpeculativeTask

protected void cancelSpeculativeTask(boolean mayInterruptIfRunning)

getSpeculativeTask

public ScheduledFuture<?> getSpeculativeTask()

future

CompletableFuture<LedgerEntries> future()

allowFailFastOnUnwritableChannel

void allowFailFastOnUnwritableChannel()

submit

public void submit()

run

public void run()

Specified by:

run in interface Runnable

initiate

abstract void initiate()

submitCallback

protected abstract void submitCallback(int code)