Package org.apache.bookkeeper.proto
Class BookieNettyServer
java.lang.Object
org.apache.bookkeeper.proto.BookieNettyServer
Netty server for serving bookie requests.
-
Nested Class Summary
Nested ClassesModifier and TypeClassDescription(package private) class -
Field Summary
FieldsModifier and TypeFieldDescription(package private) final io.netty.channel.EventLoopGroup(package private) io.netty.channel.group.ChannelGroup(package private) final BookieAuthProvider.Factory(package private) final InetSocketAddress(package private) final BookieSocketAddress(package private) final BookieId(package private) final ServerConfigurationstatic final String(package private) final io.netty.channel.EventLoopGroup(package private) final AtomicBoolean(package private) final AtomicBoolean(package private) final io.netty.channel.EventLoopGroup(package private) final int(package private) final com.google.protobuf.ExtensionRegistry(package private) RequestProcessor(package private) boolean(package private) final Object -
Constructor Summary
ConstructorsConstructorDescriptionBookieNettyServer(ServerConfiguration conf, RequestProcessor processor, io.netty.buffer.ByteBufAllocator allocator) -
Method Summary
Modifier and TypeMethodDescription(package private) boolean(package private) voidsetRequestProcessor(RequestProcessor processor) (package private) voidshutdown()(package private) voidstart()(package private) void
-
Field Details
-
CONSOLIDATION_HANDLER_NAME
- See Also:
-
maxFrameSize
final int maxFrameSize -
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
-
isClosed
-
suspensionLock
-
suspended
volatile boolean suspended -
allChannels
io.netty.channel.group.ChannelGroup allChannels -
bookieAddress
-
bookieId
-
bindAddress
-
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:
IOExceptionorg.apache.zookeeper.KeeperExceptionInterruptedExceptionBookieException
-
-
Method Details
-
setRequestProcessor
-
isRunning
boolean isRunning() -
suspendProcessing
void suspendProcessing() -
resumeProcessing
void resumeProcessing() -
start
- Throws:
InterruptedException
-
shutdown
void shutdown()
-