Package org.apache.bookkeeper.client

Class TryReadLastConfirmedOp

java.lang.Object

org.apache.bookkeeper.client.TryReadLastConfirmedOp

All Implemented Interfaces:

BookkeeperInternalCallbacks.ReadEntryCallback

class TryReadLastConfirmedOp
extends java.lang.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

Fields

Modifier and Type	Field	Description
(package private) BookieClient	bookieClient
(package private) ReadLastConfirmedOp.LastConfirmedDataCallback	cb
(package private) boolean	completed
(package private) java.util.List<BookieId>	currentEnsemble
(package private) boolean	hasValidResponse
(package private) LedgerHandle	lh
(package private) static org.slf4j.Logger	LOG
(package private) DigestManager.RecoveryData	maxRecoveredData
(package private) int	numResponsesPending

Constructor Summary

Constructors

Constructor	Description
TryReadLastConfirmedOp(LedgerHandle lh, BookieClient bookieClient, java.util.List<BookieId> ensemble, ReadLastConfirmedOp.LastConfirmedDataCallback cb, long lac)

Method Summary

Modifier and Type	Method	Description
void	initiate()
void	readEntryComplete(int rc, long ledgerId, long entryId, io.netty.buffer.ByteBuf buffer, java.lang.Object ctx)

Methods inherited from class java.lang.Object

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

Field Detail

LOG

static final org.slf4j.Logger LOG

lh

final LedgerHandle lh

bookieClient

final BookieClient bookieClient

cb

final ReadLastConfirmedOp.LastConfirmedDataCallback cb

numResponsesPending

int numResponsesPending

hasValidResponse

volatile boolean hasValidResponse

completed

volatile boolean completed

maxRecoveredData

DigestManager.RecoveryData maxRecoveredData

currentEnsemble

final java.util.List<BookieId> currentEnsemble

Constructor Detail

TryReadLastConfirmedOp

TryReadLastConfirmedOp(LedgerHandle lh,
                       BookieClient bookieClient,
                       java.util.List<BookieId> ensemble,
                       ReadLastConfirmedOp.LastConfirmedDataCallback cb,
                       long lac)

Method Detail

initiate

public void initiate()

readEntryComplete

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

Specified by:

readEntryComplete in interface BookkeeperInternalCallbacks.ReadEntryCallback