Package org.apache.bookkeeper.replication

Class AuditorReplicasCheckTask

java.lang.Object

org.apache.bookkeeper.replication.AuditorTask

org.apache.bookkeeper.replication.AuditorReplicasCheckTask

All Implemented Interfaces:

java.lang.Runnable

public class AuditorReplicasCheckTask
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
AuditorReplicasCheckTask(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) boolean	checkUnderReplicationForReplicasCheck(long ledgerInRange, org.apache.zookeeper.AsyncCallback.VoidCallback mcbForThisLedgerRange)
(package private) void	replicasCheck()
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

AuditorReplicasCheckTask

AuditorReplicasCheckTask(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 Detail

runTask

protected void runTask()

Specified by:

runTask in class AuditorTask

shutdown

public void shutdown()

Specified by:

shutdown in class AuditorTask

replicasCheck

void replicasCheck()
            throws ReplicationException.BKAuditException

Throws:

ReplicationException.BKAuditException

checkUnderReplicationForReplicasCheck

boolean checkUnderReplicationForReplicasCheck(long ledgerInRange,
                                              org.apache.zookeeper.AsyncCallback.VoidCallback mcbForThisLedgerRange)