Package org.apache.bookkeeper.replication

Class AuditorCheckAllLedgersTask

java.lang.Object

org.apache.bookkeeper.replication.AuditorTask

org.apache.bookkeeper.replication.AuditorCheckAllLedgersTask

All Implemented Interfaces:

java.lang.Runnable

public class AuditorCheckAllLedgersTask
extends AuditorTask

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.bookkeeper.replication.AuditorTask

AuditorTask.ShutdownTaskHandler

Field Summary

Fields inherited from class org.apache.bookkeeper.replication.AuditorTask

admin, auditorStats, conf, ledgerManager, ledgerUnderreplicationManager

Constructor Summary

Constructors

Constructor	Description
AuditorCheckAllLedgersTask(ServerConfiguration conf, AuditorStats auditorStats, BookKeeperAdmin admin, LedgerManager ledgerManager, LedgerUnderreplicationManager ledgerUnderreplicationManager, AuditorTask.ShutdownTaskHandler shutdownTaskHandler, java.util.function.BiConsumer<java.util.concurrent.atomic.AtomicBoolean,java.lang.Throwable> hasAuditCheckTask)

Method Summary

Modifier and Type	Method	Description
(package private) void	checkAllLedgers()	List all the ledgers and check them individually.
protected void	runTask()
void	shutdown()

Methods inherited from class org.apache.bookkeeper.replication.AuditorTask

getAvailableBookies, getBookKeeper, getBookKeeperAdmin, hasBookieCheckTask, isLedgerReplicationEnabled, publishSuspectedLedgersAsync, run, submitShutdownTask

Methods inherited from class java.lang.Object

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

Constructor Detail

AuditorCheckAllLedgersTask

AuditorCheckAllLedgersTask(ServerConfiguration conf,
                           AuditorStats auditorStats,
                           BookKeeperAdmin admin,
                           LedgerManager ledgerManager,
                           LedgerUnderreplicationManager ledgerUnderreplicationManager,
                           AuditorTask.ShutdownTaskHandler shutdownTaskHandler,
                           java.util.function.BiConsumer<java.util.concurrent.atomic.AtomicBoolean,java.lang.Throwable> hasAuditCheckTask)
                    throws ReplicationException.UnavailableException

Throws:

ReplicationException.UnavailableException

Method Detail

runTask

protected void runTask()

Specified by:

runTask in class AuditorTask

shutdown

public void shutdown()

Specified by:

shutdown in class AuditorTask

checkAllLedgers

void checkAllLedgers()
              throws BKException,
                     java.io.IOException,
                     java.lang.InterruptedException

List all the ledgers and check them individually. This should not be run very often.

Throws:

BKException

java.io.IOException

java.lang.InterruptedException