Package org.apache.bookkeeper.proto

Class BookieServer

java.lang.Object

org.apache.bookkeeper.proto.BookieServer

public class BookieServer
extends Object

Implements the server-side part of the BookKeeper protocol.

Field Summary

Fields

Modifier and Type	Field	Description
(package private) final ServerConfiguration	conf
(package private) org.apache.bookkeeper.proto.BookieServer.DeathWatcher	deathWatcher
(package private) int	exitCode
(package private) BookieNettyServer	nettyServer
(package private) UncleanShutdownDetection	uncleanShutdownDetection

Constructor Summary

Constructors

Constructor	Description
BookieServer(ServerConfiguration conf, Bookie bookie, StatsLogger statsLogger, io.netty.buffer.ByteBufAllocator allocator, UncleanShutdownDetection uncleanShutdownDetection)

Method Summary

Modifier and Type	Method	Description
Bookie	getBookie()
BookieId	getBookieId()
BookieRequestProcessor	getBookieRequestProcessor()
int	getExitCode()
BookieSocketAddress	getLocalAddress()
boolean	isBookieRunning()	Whether bookie is running?
boolean	isRunning()
void	join()
static void	main(String[] args)	Legacy Method to run bookie server.
static BookieServer	newBookieServer(ServerConfiguration conf, Bookie bookie, StatsLogger statsLogger, io.netty.buffer.ByteBufAllocator allocator, UncleanShutdownDetection uncleanShutdownDetection)
void	resumeProcessing()	Resume processing requests in the bookie (for testing).
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()
void	suspendProcessing()	Suspend processing of requests in the bookie (for testing).
String	toString()

Methods inherited from class java.lang.Object

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

Field Details

conf

final ServerConfiguration conf

nettyServer

BookieNettyServer nettyServer

deathWatcher

org.apache.bookkeeper.proto.BookieServer.DeathWatcher deathWatcher

uncleanShutdownDetection

UncleanShutdownDetection uncleanShutdownDetection

exitCode

int exitCode

Constructor Details

BookieServer

public BookieServer(ServerConfiguration conf,
 Bookie bookie,
 StatsLogger statsLogger,
 io.netty.buffer.ByteBufAllocator allocator,
 UncleanShutdownDetection uncleanShutdownDetection)
             throws IOException,
org.apache.zookeeper.KeeperException,
InterruptedException,
BookieException,
ReplicationException.UnavailableException,
ReplicationException.CompatibilityException,
SecurityException

Throws:

IOException

org.apache.zookeeper.KeeperException

InterruptedException

BookieException

ReplicationException.UnavailableException

ReplicationException.CompatibilityException

SecurityException

Method Details

newBookieServer

public static BookieServer newBookieServer(ServerConfiguration conf,
 Bookie bookie,
 StatsLogger statsLogger,
 io.netty.buffer.ByteBufAllocator allocator,
 UncleanShutdownDetection uncleanShutdownDetection)
                                    throws ReplicationException.CompatibilityException,
ReplicationException.UnavailableException,
SecurityException,
IOException,
InterruptedException,
org.apache.zookeeper.KeeperException,
BookieException

Throws:

ReplicationException.CompatibilityException

ReplicationException.UnavailableException

SecurityException

IOException

InterruptedException

org.apache.zookeeper.KeeperException

BookieException

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.

start

public void start()
           throws InterruptedException,
IOException

Throws:

InterruptedException

IOException

getLocalAddress

public BookieSocketAddress getLocalAddress()
                                    throws UnknownHostException

Throws:

UnknownHostException

getBookieId

public BookieId getBookieId()
                     throws UnknownHostException

Throws:

UnknownHostException

getBookie

public Bookie getBookie()

getBookieRequestProcessor

public BookieRequestProcessor getBookieRequestProcessor()

suspendProcessing

public void suspendProcessing()

Suspend processing of requests in the bookie (for testing).

resumeProcessing

public void resumeProcessing()

Resume processing requests in the bookie (for testing).

shutdown

public void shutdown()

isRunning

public boolean isRunning()

isBookieRunning

public boolean isBookieRunning()

Whether bookie is running?

Returns:

true if bookie is running, otherwise return false

join

public void join()
          throws InterruptedException

Throws:

InterruptedException

getExitCode

public int getExitCode()

main

public static void main(String[] args)

Legacy Method to run bookie server.

toString

public String toString()

Overrides:

toString in class Object