Class ControlServer
java.lang.Object
org.apache.drill.exec.rpc.RpcBus<T,SC>
org.apache.drill.exec.rpc.BasicServer<BitControl.RpcType,ControlConnection>
org.apache.drill.exec.rpc.control.ControlServer
- All Implemented Interfaces:
Closeable
,AutoCloseable
-
Nested Class Summary
Nested classes/interfaces inherited from class org.apache.drill.exec.rpc.BasicServer
BasicServer.ServerHandshakeHandler<T extends com.google.protobuf.MessageLite>
Nested classes/interfaces inherited from class org.apache.drill.exec.rpc.RpcBus
RpcBus.ChannelClosedHandler, RpcBus.InboundHandler
-
Field Summary
-
Constructor Summary
ConstructorDescriptionControlServer
(ControlConnectionConfig config, ConnectionManagerRegistry connectionRegistry) -
Method Summary
Modifier and TypeMethodDescriptionprotected io.netty.util.concurrent.GenericFutureListener<io.netty.channel.ChannelFuture>
getCloseHandler
(io.netty.channel.socket.SocketChannel ch, ControlConnection connection) protected ProtobufLengthDecoder
getDecoder
(BufferAllocator allocator, OutOfMemoryHandler outOfMemoryHandler) getHandshakeHandler
(ControlConnection connection) com.google.protobuf.MessageLite
getResponseDefaultInstance
(int rpcType) protected ControlConnection
initRemoteConnection
(io.netty.channel.socket.SocketChannel channel) Methods inherited from class org.apache.drill.exec.rpc.BasicServer
bind, close, closeSSL, getOutOfMemoryHandler, handle, isSslEnabled, setSslChannel, setupSSL
-
Constructor Details
-
ControlServer
-
-
Method Details
-
getResponseDefaultInstance
- Specified by:
getResponseDefaultInstance
in classBasicServer<BitControl.RpcType,
ControlConnection> - Throws:
RpcException
-
getCloseHandler
protected io.netty.util.concurrent.GenericFutureListener<io.netty.channel.ChannelFuture> getCloseHandler(io.netty.channel.socket.SocketChannel ch, ControlConnection connection) - Overrides:
getCloseHandler
in classRpcBus<BitControl.RpcType,
ControlConnection>
-
initRemoteConnection
- Overrides:
initRemoteConnection
in classBasicServer<BitControl.RpcType,
ControlConnection>
-
getHandshakeHandler
protected BasicServer.ServerHandshakeHandler<BitControl.BitControlHandshake> getHandshakeHandler(ControlConnection connection) - Specified by:
getHandshakeHandler
in classBasicServer<BitControl.RpcType,
ControlConnection>
-
getDecoder
protected ProtobufLengthDecoder getDecoder(BufferAllocator allocator, OutOfMemoryHandler outOfMemoryHandler) - Specified by:
getDecoder
in classBasicServer<BitControl.RpcType,
ControlConnection>
-