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

Fields

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

Constructor Summary

Constructors

Constructor	Description
TryReadLastConfirmedOp(LedgerHandle lh, BookieClient bookieClient, 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, Object ctx)

Methods inherited from class java.lang.Object

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

Field Details

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 List<BookieId> 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:

readEntryComplete in interface BookkeeperInternalCallbacks.ReadEntryCallback