Class AuditorBookieCheckTask
java.lang.Object
org.apache.bookkeeper.replication.AuditorTask
org.apache.bookkeeper.replication.AuditorBookieCheckTask
- All Implemented Interfaces:
Runnable
-
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
ConstructorsConstructorDescriptionAuditorBookieCheckTask(ServerConfiguration conf, AuditorStats auditorStats, BookKeeperAdmin admin, LedgerManager ledgerManager, LedgerUnderreplicationManager ledgerUnderreplicationManager, AuditorTask.ShutdownTaskHandler shutdownTaskHandler, BookieLedgerIndexer bookieLedgerIndexer, BiConsumer<AtomicBoolean, Throwable> hasAuditCheckTask, BiConsumer<Void, Throwable> submitCheckTask) -
Method Summary
Modifier and TypeMethodDescription(package private) voidprotected voidrunTask()voidshutdown()(package private) voidstartAudit(boolean shutDownTask) Start running the actual audit task.protected voidMethods inherited from class org.apache.bookkeeper.replication.AuditorTask
getAvailableBookies, getBookKeeper, getBookKeeperAdmin, hasBookieCheckTask, isLedgerReplicationEnabled, publishSuspectedLedgersAsync, run, submitShutdownTask
-
Constructor Details
-
AuditorBookieCheckTask
public AuditorBookieCheckTask(ServerConfiguration conf, AuditorStats auditorStats, BookKeeperAdmin admin, LedgerManager ledgerManager, LedgerUnderreplicationManager ledgerUnderreplicationManager, AuditorTask.ShutdownTaskHandler shutdownTaskHandler, BookieLedgerIndexer bookieLedgerIndexer, BiConsumer<AtomicBoolean, Throwable> hasAuditCheckTask, BiConsumer<Void, Throwable> submitCheckTask)
-
-
Method Details
-
runTask
protected void runTask()- Specified by:
runTaskin classAuditorTask
-
shutdown
public void shutdown()- Specified by:
shutdownin classAuditorTask
-
startAudit
void startAudit(boolean shutDownTask) Start running the actual audit task.- Parameters:
shutDownTask- A boolean that indicates whether or not to schedule shutdown task on any failure
-
auditBookies
-
waitIfLedgerReplicationDisabled
protected void waitIfLedgerReplicationDisabled() throws ReplicationException.UnavailableException, InterruptedException
-