Package org.apache.bookkeeper.proto

Class BookieNettyServer

java.lang.Object

org.apache.bookkeeper.proto.BookieNettyServer

class BookieNettyServer
extends java.lang.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) io.netty.channel.EventLoopGroup	acceptorGroup
(package private) io.netty.channel.group.ChannelGroup	allChannels
(package private) BookieAuthProvider.Factory	authProviderFactory
(package private) java.net.InetSocketAddress	bindAddress
(package private) BookieSocketAddress	bookieAddress
(package private) BookieId	bookieId
(package private) ServerConfiguration	conf
static java.lang.String	CONSOLIDATION_HANDLER_NAME
(package private) io.netty.channel.EventLoopGroup	eventLoopGroup
(package private) java.util.concurrent.atomic.AtomicBoolean	isClosed
(package private) java.util.concurrent.atomic.AtomicBoolean	isRunning
(package private) io.netty.channel.EventLoopGroup	jvmEventLoopGroup
(package private) int	maxFrameSize
(package private) com.google.protobuf.ExtensionRegistry	registry
(package private) RequestProcessor	requestProcessor
(package private) boolean	suspended
(package private) java.lang.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 Detail

CONSOLIDATION_HANDLER_NAME

public static final java.lang.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 java.util.concurrent.atomic.AtomicBoolean isRunning

isClosed

final java.util.concurrent.atomic.AtomicBoolean isClosed

suspensionLock

final java.lang.Object suspensionLock

suspended

volatile boolean suspended

allChannels

io.netty.channel.group.ChannelGroup allChannels

bookieAddress

final BookieSocketAddress bookieAddress

bookieId

final BookieId bookieId

bindAddress

final java.net.InetSocketAddress bindAddress

authProviderFactory

final BookieAuthProvider.Factory authProviderFactory

registry

final com.google.protobuf.ExtensionRegistry registry

Constructor Detail

BookieNettyServer

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

Throws:

java.io.IOException

org.apache.zookeeper.KeeperException

java.lang.InterruptedException

BookieException

Method Detail

setRequestProcessor

public BookieNettyServer setRequestProcessor(RequestProcessor processor)

isRunning

boolean isRunning()

suspendProcessing

void suspendProcessing()

resumeProcessing

void resumeProcessing()

start

void start()
    throws java.lang.InterruptedException

Throws:

java.lang.InterruptedException

shutdown

void shutdown()