Package org.apache.bookkeeper.client

Class ForceLedgerOp

java.lang.Object

org.apache.bookkeeper.client.ForceLedgerOp

All Implemented Interfaces:

Runnable, BookkeeperInternalCallbacks.ForceLedgerCallback

class ForceLedgerOp
extends Object
implements Runnable, BookkeeperInternalCallbacks.ForceLedgerCallback

This represents a request to sync the ledger on every bookie.

Field Summary

Fields

Modifier and Type	Field	Description
(package private) DistributionSchedule.AckSet	ackSet
(package private) final BookieClient	bookieClient
(package private) final CompletableFuture<Void>	cb
(package private) boolean	completed
(package private) final List<BookieId>	currentEnsemble
(package private) long	currentNonDurableLastAddConfirmed
(package private) boolean	errored
(package private) int	lastSeenError
(package private) final LedgerHandle	lh

Constructor Summary

Constructors

Constructor	Description
ForceLedgerOp(LedgerHandle lh, BookieClient bookieClient, List<BookieId> ensemble, CompletableFuture<Void> cb)

Method Summary

Modifier and Type	Method	Description
void	forceLedgerComplete(int rc, long ledgerId, BookieId addr, Object ctx)
(package private) void	initiate()
void	run()
(package private) void	sendForceLedgerRequest(int bookieIndex)

Methods inherited from class java.lang.Object

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

Field Details

cb

final CompletableFuture<Void> cb

ackSet

DistributionSchedule.AckSet ackSet

completed

boolean completed

errored

boolean errored

lastSeenError

int lastSeenError

currentEnsemble

final List<BookieId> currentEnsemble

currentNonDurableLastAddConfirmed

long currentNonDurableLastAddConfirmed

lh

final LedgerHandle lh

bookieClient

final BookieClient bookieClient

Constructor Details

ForceLedgerOp

ForceLedgerOp(LedgerHandle lh,
 BookieClient bookieClient,
 List<BookieId> ensemble,
 CompletableFuture<Void> cb)

Method Details

sendForceLedgerRequest

void sendForceLedgerRequest(int bookieIndex)

run

public void run()

Specified by:

run in interface Runnable

initiate

void initiate()

forceLedgerComplete

public void forceLedgerComplete(int rc,
 long ledgerId,
 BookieId addr,
 Object ctx)

Specified by:

forceLedgerComplete in interface BookkeeperInternalCallbacks.ForceLedgerCallback