Package org.apache.bookkeeper.client

Class LedgerChecker

java.lang.Object

org.apache.bookkeeper.client.LedgerChecker

public class LedgerChecker
extends Object

A utility class to check the complete ledger and finds the UnderReplicated fragments if any.

NOTE: This class is tended to be used by this project only. External users should not rely on it directly.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
(package private) static class	LedgerChecker.InvalidFragmentException

Field Summary

Fields

Modifier and Type	Field	Description
final BookieClient	bookieClient
final BookieWatcher	bookieWatcher
(package private) final Semaphore	semaphore

Constructor Summary

Constructors

Constructor	Description
LedgerChecker(BookKeeper bkc)
LedgerChecker(BookKeeper bkc, int inFlightReadEntryNum)
LedgerChecker(BookieClient client, BookieWatcher watcher)
LedgerChecker(BookieClient client, BookieWatcher watcher, int inFlightReadEntryNum)

Method Summary

Modifier and Type	Method	Description
void	acquirePermit()	Acquires a permit from permit manager, blocking until all are available.
void	checkLedger(LedgerHandle lh, BookkeeperInternalCallbacks.GenericCallback<Set<LedgerFragment>> cb)	Check that all the fragments in the passed in ledger, and report those which are missing.
void	checkLedger(LedgerHandle lh, BookkeeperInternalCallbacks.GenericCallback<Set<LedgerFragment>> cb, long percentageOfLedgerFragmentToBeVerified)
void	releasePermit()	Release a given permit.

Methods inherited from class java.lang.Object

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

Field Details

bookieClient

public final BookieClient bookieClient

bookieWatcher

public final BookieWatcher bookieWatcher

semaphore

final Semaphore semaphore

Constructor Details

LedgerChecker

public LedgerChecker(BookKeeper bkc)

LedgerChecker

public LedgerChecker(BookieClient client,
 BookieWatcher watcher)

LedgerChecker

public LedgerChecker(BookKeeper bkc,
 int inFlightReadEntryNum)

LedgerChecker

public LedgerChecker(BookieClient client,
 BookieWatcher watcher,
 int inFlightReadEntryNum)

Method Details

acquirePermit

public void acquirePermit()
                   throws InterruptedException

Acquires a permit from permit manager, blocking until all are available.

Throws:

InterruptedException

releasePermit

public void releasePermit()

Release a given permit.

checkLedger

public void checkLedger(LedgerHandle lh,
 BookkeeperInternalCallbacks.GenericCallback<Set<LedgerFragment>> cb)

Check that all the fragments in the passed in ledger, and report those which are missing.

checkLedger

public void checkLedger(LedgerHandle lh,
 BookkeeperInternalCallbacks.GenericCallback<Set<LedgerFragment>> cb,
 long percentageOfLedgerFragmentToBeVerified)