Package org.apache.bookkeeper.client

Class PendingReadLacOp

java.lang.Object

org.apache.bookkeeper.client.PendingReadLacOp

All Implemented Interfaces:

BookkeeperInternalCallbacks.ReadLacCallback

class PendingReadLacOp
extends Object
implements BookkeeperInternalCallbacks.ReadLacCallback

This represents a pending ReadLac operation.

LAC is stored in two places on bookies. 1. WriteLac operation sends Explicit LAC and is stored in memory on each bookie. 2. Each AddEntry operation piggy-backs LAC which is stored on bookie's disk.

This operation returns both of those entries and we pick the latest LAC out of available answers.

This is an optional protocol operations to facilitate tailing readers to be up to date with the writer. This is best effort to get latest LAC from bookies, and doesn't affect the correctness of the protocol.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
(package private) static interface	PendingReadLacOp.LacCallback

Field Summary

Fields

Modifier and Type	Field	Description
(package private) BookieClient	bookieClient
(package private) PendingReadLacOp.LacCallback	cb
(package private) boolean	completed
(package private) final DistributionSchedule.QuorumCoverageSet	coverageSet
(package private) final List<BookieId>	currentEnsemble
(package private) int	lastSeenError
(package private) LedgerHandle	lh
(package private) static final org.slf4j.Logger	LOG
(package private) long	maxLac
(package private) int	numResponsesPending

Constructor Summary

Constructors

Constructor	Description
PendingReadLacOp(LedgerHandle lh, BookieClient bookieClient, List<BookieId> ensemble, PendingReadLacOp.LacCallback cb)

Method Summary

Modifier and Type	Method	Description
void	initiate()
void	readLacComplete(int rc, long ledgerId, io.netty.buffer.ByteBuf lacBuffer, io.netty.buffer.ByteBuf lastEntryBuffer, 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

LedgerHandle lh

bookieClient

BookieClient bookieClient

cb

PendingReadLacOp.LacCallback cb

numResponsesPending

int numResponsesPending

completed

volatile boolean completed

lastSeenError

int lastSeenError

coverageSet

final DistributionSchedule.QuorumCoverageSet coverageSet

maxLac

long maxLac

currentEnsemble

final List<BookieId> currentEnsemble

Constructor Details

PendingReadLacOp

PendingReadLacOp(LedgerHandle lh,
 BookieClient bookieClient,
 List<BookieId> ensemble,
 PendingReadLacOp.LacCallback cb)

Method Details

initiate

public void initiate()

readLacComplete

public void readLacComplete(int rc,
 long ledgerId,
 io.netty.buffer.ByteBuf lacBuffer,
 io.netty.buffer.ByteBuf lastEntryBuffer,
 Object ctx)

Specified by:

readLacComplete in interface BookkeeperInternalCallbacks.ReadLacCallback