Package org.apache.bookkeeper.replication

Class AutoRecoveryMain

java.lang.Object

org.apache.bookkeeper.replication.AutoRecoveryMain

public class AutoRecoveryMain
extends Object

Class to start/stop the AutoRecovery daemons Auditor and ReplicationWorker.

TODO: eliminate the direct usage of zookeeper here {@link https://github.com/apache/bookkeeper/issues/1332}

Field Summary

Fields

Modifier and Type	Field	Description
(package private) final AuditorElector	auditorElector
(package private) final BookKeeper	bkc
(package private) final org.apache.bookkeeper.replication.AutoRecoveryMain.AutoRecoveryDeathWatcher	deathWatcher
(package private) int	exitCode
(package private) final ReplicationWorker	replicationWorker

Constructor Summary

Constructors

Constructor	Description
AutoRecoveryMain(ServerConfiguration conf)
AutoRecoveryMain(ServerConfiguration conf, StatsLogger statsLogger)

Method Summary

Modifier and Type	Method	Description
static LifecycleComponentStack	buildAutoRecoveryServer(BookieConfiguration conf)
(package private) static int	doMain(String[] args)
Auditor	getAuditor()
ReplicationWorker	getReplicationWorker()
boolean	isAutoRecoveryRunning()	Is auto-recovery service running?
void	join()
static void	main(String[] args)
void	setExceptionHandler(Thread.UncaughtExceptionHandler exceptionHandler)	Currently the uncaught exception handler is used for DeathWatcher to notify lifecycle management that a bookie is dead for some reasons.
void	shutdown()
void	start()

Methods inherited from class java.lang.Object

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

Field Details

bkc

final BookKeeper bkc

auditorElector

final AuditorElector auditorElector

replicationWorker

final ReplicationWorker replicationWorker

deathWatcher

final org.apache.bookkeeper.replication.AutoRecoveryMain.AutoRecoveryDeathWatcher deathWatcher

exitCode

int exitCode

Constructor Details

AutoRecoveryMain

public AutoRecoveryMain(ServerConfiguration conf)
                 throws IOException,
InterruptedException,
org.apache.zookeeper.KeeperException,
ReplicationException.UnavailableException,
ReplicationException.CompatibilityException

Throws:

IOException

InterruptedException

org.apache.zookeeper.KeeperException

ReplicationException.UnavailableException

ReplicationException.CompatibilityException

AutoRecoveryMain

public AutoRecoveryMain(ServerConfiguration conf,
 StatsLogger statsLogger)
                 throws IOException,
InterruptedException,
org.apache.zookeeper.KeeperException,
ReplicationException.UnavailableException,
ReplicationException.CompatibilityException

Throws:

IOException

InterruptedException

org.apache.zookeeper.KeeperException

ReplicationException.UnavailableException

ReplicationException.CompatibilityException

Method Details

start

public void start()

join

public void join()
          throws InterruptedException

Throws:

InterruptedException

shutdown

public void shutdown()

setExceptionHandler

public void setExceptionHandler(Thread.UncaughtExceptionHandler exceptionHandler)

Currently the uncaught exception handler is used for DeathWatcher to notify lifecycle management that a bookie is dead for some reasons.

in future, we can register this exceptionHandler to critical threads so when those threads are dead, it will automatically trigger lifecycle management to shutdown the process.

getAuditor

public Auditor getAuditor()

getReplicationWorker

public ReplicationWorker getReplicationWorker()

isAutoRecoveryRunning

public boolean isAutoRecoveryRunning()

Is auto-recovery service running?

main

public static void main(String[] args)

doMain

static int doMain(String[] args)

buildAutoRecoveryServer

public static LifecycleComponentStack buildAutoRecoveryServer(BookieConfiguration conf)
                                                       throws Exception

Throws:

Exception