Package org.apache.bookkeeper.client

Class ReadLastConfirmedAndEntryOp

java.lang.Object

org.apache.bookkeeper.client.ReadLastConfirmedAndEntryOp

All Implemented Interfaces:

SpeculativeRequestExecutor, BookkeeperInternalCallbacks.ReadEntryCallback

class ReadLastConfirmedAndEntryOp
extends Object
implements BookkeeperInternalCallbacks.ReadEntryCallback, SpeculativeRequestExecutor

Long poll read operation.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
(package private) static interface	ReadLastConfirmedAndEntryOp.LastConfirmedAndEntryCallback	Wrapper to get all recovered data from the request.
(package private) class	ReadLastConfirmedAndEntryOp.ParallelReadRequest
(package private) class	ReadLastConfirmedAndEntryOp.ReadLACAndEntryRequest
(package private) class	ReadLastConfirmedAndEntryOp.SequenceReadRequest

Field Summary

Fields

Modifier and Type	Field	Description
(package private) final BitSet	emptyResponsesFromHostsBitSet
(package private) final BitSet	heardFromHostsBitSet
(package private) static final org.slf4j.Logger	LOG
(package private) final int	maxMissedReadsAllowed
(package private) boolean	parallelRead
(package private) ReadLastConfirmedAndEntryOp.ReadLACAndEntryRequest	request
(package private) final AtomicBoolean	requestComplete
(package private) final long	requestTimeNano

Constructor Summary

Constructors

Constructor	Description
ReadLastConfirmedAndEntryOp(LedgerHandle lh, ClientContext clientCtx, List<BookieId> ensemble, ReadLastConfirmedAndEntryOp.LastConfirmedAndEntryCallback cb, long prevEntryId, long timeOutInMillis)

Method Summary

Modifier and Type	Method	Description
protected void	cancelSpeculativeTask(boolean mayInterruptIfRunning)
protected LedgerMetadata	getLedgerMetadata()
void	initiate()
com.google.common.util.concurrent.ListenableFuture<Boolean>	issueSpeculativeRequest()	Speculative Read Logic.
(package private) ReadLastConfirmedAndEntryOp	parallelRead(boolean enabled)
void	readEntryComplete(int rc, long ledgerId, long entryId, io.netty.buffer.ByteBuf buffer, Object ctx)
(package private) void	sendReadTo(int bookieIndex, BookieId to, ReadLastConfirmedAndEntryOp.ReadLACAndEntryRequest entry)
String	toString()

Methods inherited from class java.lang.Object

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

Field Details

LOG

static final org.slf4j.Logger LOG

request

ReadLastConfirmedAndEntryOp.ReadLACAndEntryRequest request

heardFromHostsBitSet

final BitSet heardFromHostsBitSet

emptyResponsesFromHostsBitSet

final BitSet emptyResponsesFromHostsBitSet

maxMissedReadsAllowed

final int maxMissedReadsAllowed

parallelRead

boolean parallelRead

requestComplete

final AtomicBoolean requestComplete

requestTimeNano

final long requestTimeNano

Constructor Details

ReadLastConfirmedAndEntryOp

ReadLastConfirmedAndEntryOp(LedgerHandle lh,
 ClientContext clientCtx,
 List<BookieId> ensemble,
 ReadLastConfirmedAndEntryOp.LastConfirmedAndEntryCallback cb,
 long prevEntryId,
 long timeOutInMillis)

Method Details

getLedgerMetadata

protected LedgerMetadata getLedgerMetadata()

parallelRead

ReadLastConfirmedAndEntryOp parallelRead(boolean enabled)

cancelSpeculativeTask

protected void cancelSpeculativeTask(boolean mayInterruptIfRunning)

issueSpeculativeRequest

public com.google.common.util.concurrent.ListenableFuture<Boolean> issueSpeculativeRequest()

Speculative Read Logic.

Specified by:

issueSpeculativeRequest in interface SpeculativeRequestExecutor

Returns:

whether more speculative requests should be issued

initiate

public void initiate()

sendReadTo

void sendReadTo(int bookieIndex,
 BookieId to,
 ReadLastConfirmedAndEntryOp.ReadLACAndEntryRequest entry)
         throws InterruptedException

Throws:

InterruptedException

readEntryComplete

public void readEntryComplete(int rc,
 long ledgerId,
 long entryId,
 io.netty.buffer.ByteBuf buffer,
 Object ctx)

Specified by:

readEntryComplete in interface BookkeeperInternalCallbacks.ReadEntryCallback

toString

public String toString()

Overrides:

toString in class Object