Package org.apache.bookkeeper.client
Class TryReadLastConfirmedOp
java.lang.Object
org.apache.bookkeeper.client.TryReadLastConfirmedOp
- All Implemented Interfaces:
BookkeeperInternalCallbacks.ReadEntryCallback
class TryReadLastConfirmedOp
extends Object
implements BookkeeperInternalCallbacks.ReadEntryCallback
This op is try to read last confirmed without involving quorum coverage checking.
Use
ReadLastConfirmedOp if you need quorum coverage checking.-
Field Summary
FieldsModifier and TypeFieldDescription(package private) final BookieClient(package private) final ReadLastConfirmedOp.LastConfirmedDataCallback(package private) boolean(package private) boolean(package private) final LedgerHandle(package private) static final org.slf4j.Logger(package private) DigestManager.RecoveryData(package private) int -
Constructor Summary
ConstructorsConstructorDescriptionTryReadLastConfirmedOp(LedgerHandle lh, BookieClient bookieClient, List<BookieId> ensemble, ReadLastConfirmedOp.LastConfirmedDataCallback cb, long lac) -
Method Summary
Modifier and TypeMethodDescriptionvoidinitiate()voidreadEntryComplete(int rc, long ledgerId, long entryId, io.netty.buffer.ByteBuf buffer, Object ctx)
-
Field Details
-
LOG
static final org.slf4j.Logger LOG -
lh
-
bookieClient
-
cb
-
numResponsesPending
int numResponsesPending -
hasValidResponse
volatile boolean hasValidResponse -
completed
volatile boolean completed -
maxRecoveredData
DigestManager.RecoveryData maxRecoveredData -
currentEnsemble
-
-
Constructor Details
-
TryReadLastConfirmedOp
TryReadLastConfirmedOp(LedgerHandle lh, BookieClient bookieClient, List<BookieId> ensemble, ReadLastConfirmedOp.LastConfirmedDataCallback cb, long lac)
-
-
Method Details
-
initiate
public void initiate() -
readEntryComplete
public void readEntryComplete(int rc, long ledgerId, long entryId, io.netty.buffer.ByteBuf buffer, Object ctx) - Specified by:
readEntryCompletein interfaceBookkeeperInternalCallbacks.ReadEntryCallback
-