Package org.apache.bookkeeper.replication

Class AuditorPlacementPolicyCheckTask

java.lang.Object

org.apache.bookkeeper.replication.AuditorTask

org.apache.bookkeeper.replication.AuditorPlacementPolicyCheckTask

All Implemented Interfaces:

java.lang.Runnable

public class AuditorPlacementPolicyCheckTask
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
AuditorPlacementPolicyCheckTask(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	doPlacementPolicyCheck(java.lang.Long ledgerId, org.apache.zookeeper.AsyncCallback.VoidCallback iterCallback, Versioned<LedgerMetadata> metadataVer)
java.util.concurrent.atomic.AtomicInteger	getNumOfClosedLedgersAuditedInPlacementPolicyCheck()
java.util.concurrent.atomic.AtomicInteger	getNumOfLedgersFoundNotAdheringInPlacementPolicyCheck()
java.util.concurrent.atomic.AtomicInteger	getNumOfLedgersFoundSoftlyAdheringInPlacementPolicyCheck()
java.util.concurrent.atomic.AtomicInteger	getNumOfURLedgersElapsedRecoveryGracePeriod()
long	getUnderreplicatedLedgerRecoveryGracePeriod()
(package private) void	placementPolicyCheck()
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

AuditorPlacementPolicyCheckTask

AuditorPlacementPolicyCheckTask(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

placementPolicyCheck

void placementPolicyCheck()
                   throws ReplicationException.BKAuditException

Throws:

ReplicationException.BKAuditException

doPlacementPolicyCheck

void doPlacementPolicyCheck(java.lang.Long ledgerId,
                            org.apache.zookeeper.AsyncCallback.VoidCallback iterCallback,
                            Versioned<LedgerMetadata> metadataVer)

getUnderreplicatedLedgerRecoveryGracePeriod

public long getUnderreplicatedLedgerRecoveryGracePeriod()

getNumOfLedgersFoundNotAdheringInPlacementPolicyCheck

public java.util.concurrent.atomic.AtomicInteger getNumOfLedgersFoundNotAdheringInPlacementPolicyCheck()

getNumOfLedgersFoundSoftlyAdheringInPlacementPolicyCheck

public java.util.concurrent.atomic.AtomicInteger getNumOfLedgersFoundSoftlyAdheringInPlacementPolicyCheck()

getNumOfClosedLedgersAuditedInPlacementPolicyCheck

public java.util.concurrent.atomic.AtomicInteger getNumOfClosedLedgersAuditedInPlacementPolicyCheck()

getNumOfURLedgersElapsedRecoveryGracePeriod

public java.util.concurrent.atomic.AtomicInteger getNumOfURLedgersElapsedRecoveryGracePeriod()