Package org.apache.bookkeeper.client

Class ReadLastConfirmedOp

java.lang.Object

org.apache.bookkeeper.client.ReadLastConfirmedOp

All Implemented Interfaces:

BookkeeperInternalCallbacks.ReadEntryCallback

class ReadLastConfirmedOp
extends Object
implements BookkeeperInternalCallbacks.ReadEntryCallback

This class encapsulated the read last confirmed operation.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
(package private) static interface	ReadLastConfirmedOp.LastConfirmedDataCallback	Wrapper to get all recovered data from the request.

Field Summary

Fields

Modifier and Type	Field	Description
(package private) static final org.slf4j.Logger	LOG

Constructor Summary

Constructors

Constructor	Description
ReadLastConfirmedOp(BookieClient bookieClient, DistributionSchedule schedule, DigestManager digestManager, long ledgerId, List<BookieId> ensemble, byte[] ledgerKey, ReadLastConfirmedOp.LastConfirmedDataCallback cb)

Method Summary

Modifier and Type	Method	Description
(package private) int	getNumResponsesPending()
void	initiate()
void	initiateWithFencing()
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

Constructor Details

ReadLastConfirmedOp

public ReadLastConfirmedOp(BookieClient bookieClient,
 DistributionSchedule schedule,
 DigestManager digestManager,
 long ledgerId,
 List<BookieId> ensemble,
 byte[] ledgerKey,
 ReadLastConfirmedOp.LastConfirmedDataCallback cb)

Method Details

initiate

public void initiate()

initiateWithFencing

public void initiateWithFencing()

readEntryComplete

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

Specified by:

readEntryComplete in interface BookkeeperInternalCallbacks.ReadEntryCallback

getNumResponsesPending

int getNumResponsesPending()