org.apache.bookkeeper.client

Class LedgerChecker

java.lang.Object

org.apache.bookkeeper.client.LedgerChecker

public class LedgerChecker
extends java.lang.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 and Description
(package private) static class	LedgerChecker.InvalidFragmentException

Field Summary

Fields

Modifier and Type	Field and Description
org.apache.bookkeeper.proto.BookieClient	bookieClient
BookieWatcher	bookieWatcher
(package private) java.util.concurrent.Semaphore	semaphore

Constructor Summary

Constructors

Constructor and Description
LedgerChecker(org.apache.bookkeeper.proto.BookieClient client, BookieWatcher watcher)
LedgerChecker(org.apache.bookkeeper.proto.BookieClient client, BookieWatcher watcher, int inFlightReadEntryNum)
LedgerChecker(BookKeeper bkc)
LedgerChecker(BookKeeper bkc, int inFlightReadEntryNum)

Method Summary

Modifier and Type	Method and Description
void	acquirePermit() Acquires a permit from permit manager, blocking until all are available.
void	checkLedger(LedgerHandle lh, org.apache.bookkeeper.proto.BookkeeperInternalCallbacks.GenericCallback<java.util.Set<LedgerFragment>> cb) Check that all the fragments in the passed in ledger, and report those which are missing.
void	checkLedger(LedgerHandle lh, org.apache.bookkeeper.proto.BookkeeperInternalCallbacks.GenericCallback<java.util.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 Detail

bookieClient

public final org.apache.bookkeeper.proto.BookieClient bookieClient

bookieWatcher

public final BookieWatcher bookieWatcher

semaphore

final java.util.concurrent.Semaphore semaphore

Constructor Detail

LedgerChecker

public LedgerChecker(BookKeeper bkc)

LedgerChecker

public LedgerChecker(org.apache.bookkeeper.proto.BookieClient client,
                     BookieWatcher watcher)

LedgerChecker

public LedgerChecker(BookKeeper bkc,
                     int inFlightReadEntryNum)

LedgerChecker

public LedgerChecker(org.apache.bookkeeper.proto.BookieClient client,
                     BookieWatcher watcher,
                     int inFlightReadEntryNum)

Method Detail

acquirePermit

public void acquirePermit()
                   throws java.lang.InterruptedException

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

Throws:

java.lang.InterruptedException

releasePermit

public void releasePermit()

Release a given permit.

checkLedger

public void checkLedger(LedgerHandle lh,
                        org.apache.bookkeeper.proto.BookkeeperInternalCallbacks.GenericCallback<java.util.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,
                        org.apache.bookkeeper.proto.BookkeeperInternalCallbacks.GenericCallback<java.util.Set<LedgerFragment>> cb,
                        long percentageOfLedgerFragmentToBeVerified)