Package org.apache.bookkeeper.proto

Class BookieNettyServer

java.lang.Object

org.apache.bookkeeper.proto.BookieNettyServer

class BookieNettyServer
extends Object

Netty server for serving bookie requests.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
(package private) class	BookieNettyServer.BookieSideConnectionPeerContextHandler

Field Summary

Fields

Modifier and Type	Field	Description
(package private) final io.netty.channel.EventLoopGroup	acceptorGroup
(package private) io.netty.channel.group.ChannelGroup	allChannels
(package private) final BookieAuthProvider.Factory	authProviderFactory
(package private) final InetSocketAddress	bindAddress
(package private) final BookieSocketAddress	bookieAddress
(package private) final BookieId	bookieId
(package private) final ServerConfiguration	conf
static final String	CONSOLIDATION_HANDLER_NAME
(package private) final io.netty.channel.EventLoopGroup	eventLoopGroup
(package private) final AtomicBoolean	isClosed
(package private) final AtomicBoolean	isRunning
(package private) final io.netty.channel.EventLoopGroup	jvmEventLoopGroup
(package private) final int	maxFrameSize
(package private) final com.google.protobuf.ExtensionRegistry	registry
(package private) RequestProcessor	requestProcessor
(package private) boolean	suspended
(package private) final Object	suspensionLock

Constructor Summary

Constructors

Constructor	Description
BookieNettyServer(ServerConfiguration conf, RequestProcessor processor, io.netty.buffer.ByteBufAllocator allocator)

Method Summary

Modifier and Type	Method	Description
(package private) boolean	isRunning()
(package private) void	resumeProcessing()
BookieNettyServer	setRequestProcessor(RequestProcessor processor)
(package private) void	shutdown()
(package private) void	start()
(package private) void	suspendProcessing()

Methods inherited from class java.lang.Object

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

Field Details

CONSOLIDATION_HANDLER_NAME

public static final String CONSOLIDATION_HANDLER_NAME

See Also:

• Constant Field Values

maxFrameSize

final int maxFrameSize

conf

final ServerConfiguration conf

eventLoopGroup

final io.netty.channel.EventLoopGroup eventLoopGroup

acceptorGroup

final io.netty.channel.EventLoopGroup acceptorGroup

jvmEventLoopGroup

final io.netty.channel.EventLoopGroup jvmEventLoopGroup

requestProcessor

RequestProcessor requestProcessor

isRunning

final AtomicBoolean isRunning

isClosed

final AtomicBoolean isClosed

suspensionLock

final Object suspensionLock

suspended

volatile boolean suspended

allChannels

io.netty.channel.group.ChannelGroup allChannels

bookieAddress

final BookieSocketAddress bookieAddress

bookieId

final BookieId bookieId

bindAddress

final InetSocketAddress bindAddress

authProviderFactory

final BookieAuthProvider.Factory authProviderFactory

registry

final com.google.protobuf.ExtensionRegistry registry

Constructor Details

BookieNettyServer

BookieNettyServer(ServerConfiguration conf,
 RequestProcessor processor,
 io.netty.buffer.ByteBufAllocator allocator)
           throws IOException,
org.apache.zookeeper.KeeperException,
InterruptedException,
BookieException

Throws:

IOException

org.apache.zookeeper.KeeperException

InterruptedException

BookieException

Method Details

setRequestProcessor

public BookieNettyServer setRequestProcessor(RequestProcessor processor)

isRunning

boolean isRunning()

suspendProcessing

void suspendProcessing()

resumeProcessing

void resumeProcessing()

start

void start()
    throws InterruptedException

Throws:

InterruptedException

shutdown

void shutdown()