class org.apache.drill.exec.rpc.BasicServer$1 extends io.netty.channel.ChannelInitializer
{
final org.apache.drill.exec.rpc.RpcConfig val$rpcMapping;
final org.apache.drill.exec.rpc.BasicServer this$0;
void <init>(org.apache.drill.exec.rpc.BasicServer, org.apache.drill.exec.rpc.RpcConfig)
{
org.apache.drill.exec.rpc.BasicServer$1 v;
org.apache.drill.exec.rpc.BasicServer v;
org.apache.drill.exec.rpc.RpcConfig v;
v := @this: org.apache.drill.exec.rpc.BasicServer$1;
v := @parameter: org.apache.drill.exec.rpc.BasicServer;
v := @parameter: org.apache.drill.exec.rpc.RpcConfig;
v.<org.apache.drill.exec.rpc.BasicServer$1: org.apache.drill.exec.rpc.BasicServer this$0> = v;
v.<org.apache.drill.exec.rpc.BasicServer$1: org.apache.drill.exec.rpc.RpcConfig val$rpcMapping> = v;
specialinvoke v.<io.netty.channel.ChannelInitializer: void <init>()>();
return;
}
protected void initChannel(io.netty.channel.socket.SocketChannel) throws java.lang.Exception
{
org.apache.drill.exec.rpc.RpcBus$InboundHandler v;
org.apache.drill.exec.memory.BufferAllocator v;
org.apache.drill.exec.rpc.BasicServer v, v, v, v, v, v, v, v, v, v, v, v;
org.apache.drill.exec.rpc.RpcConfig v, v, v, v;
org.apache.drill.exec.rpc.BasicServer$1 v;
org.apache.drill.exec.rpc.BasicServer$LoggingReadTimeoutHandler v;
io.netty.channel.socket.SocketChannel v;
boolean v, v;
org.apache.drill.exec.rpc.RpcDecoder v;
org.apache.drill.exec.rpc.BasicServer$ServerHandshakeHandler v;
io.netty.channel.ChannelPipeline v;
org.apache.drill.exec.rpc.RpcExceptionHandler v;
org.apache.drill.exec.rpc.ProtobufLengthDecoder v;
org.apache.drill.exec.rpc.OutOfMemoryHandler v;
org.apache.drill.exec.rpc.RpcEncoder v;
org.apache.drill.exec.rpc.ServerConnection v;
int v;
java.lang.String v, v, v, v;
io.netty.util.concurrent.GenericFutureListener v;
io.netty.channel.ChannelFuture v;
v := @this: org.apache.drill.exec.rpc.BasicServer$1;
v := @parameter: io.netty.channel.socket.SocketChannel;
v = v.<org.apache.drill.exec.rpc.BasicServer$1: org.apache.drill.exec.rpc.BasicServer this$0>;
v = virtualinvoke v.<org.apache.drill.exec.rpc.BasicServer: org.apache.drill.exec.rpc.ServerConnection initRemoteConnection(io.netty.channel.socket.SocketChannel)>(v);
v = interfaceinvoke v.<io.netty.channel.socket.SocketChannel: io.netty.channel.ChannelFuture closeFuture()>();
v = v.<org.apache.drill.exec.rpc.BasicServer$1: org.apache.drill.exec.rpc.BasicServer this$0>;
v = virtualinvoke v.<org.apache.drill.exec.rpc.BasicServer: io.netty.util.concurrent.GenericFutureListener getCloseHandler(io.netty.channel.socket.SocketChannel,org.apache.drill.exec.rpc.RemoteConnection)>(v, v);
interfaceinvoke v.<io.netty.channel.ChannelFuture: io.netty.channel.ChannelFuture addListener(io.netty.util.concurrent.GenericFutureListener)>(v);
v = interfaceinvoke v.<io.netty.channel.socket.SocketChannel: io.netty.channel.ChannelPipeline pipeline()>();
v = v.<org.apache.drill.exec.rpc.BasicServer$1: org.apache.drill.exec.rpc.BasicServer this$0>;
v = virtualinvoke v.<org.apache.drill.exec.rpc.BasicServer: boolean isSslEnabled()>();
if v == 0 goto label;
v = v.<org.apache.drill.exec.rpc.BasicServer$1: org.apache.drill.exec.rpc.BasicServer this$0>;
virtualinvoke v.<org.apache.drill.exec.rpc.BasicServer: void setupSSL(io.netty.channel.ChannelPipeline)>(v);
label:
v = v.<org.apache.drill.exec.rpc.BasicServer$1: org.apache.drill.exec.rpc.BasicServer this$0>;
v = interfaceinvoke v.<org.apache.drill.exec.rpc.ServerConnection: org.apache.drill.exec.memory.BufferAllocator getAllocator()>();
v = v.<org.apache.drill.exec.rpc.BasicServer$1: org.apache.drill.exec.rpc.BasicServer this$0>;
v = virtualinvoke v.<org.apache.drill.exec.rpc.BasicServer: org.apache.drill.exec.rpc.OutOfMemoryHandler getOutOfMemoryHandler()>();
v = virtualinvoke v.<org.apache.drill.exec.rpc.BasicServer: org.apache.drill.exec.rpc.ProtobufLengthDecoder getDecoder(org.apache.drill.exec.memory.BufferAllocator,org.apache.drill.exec.rpc.OutOfMemoryHandler)>(v, v);
interfaceinvoke v.<io.netty.channel.ChannelPipeline: io.netty.channel.ChannelPipeline addLast(java.lang.String,io.netty.channel.ChannelHandler)>("protocol-decoder", v);
v = new org.apache.drill.exec.rpc.RpcDecoder;
v = v.<org.apache.drill.exec.rpc.BasicServer$1: org.apache.drill.exec.rpc.BasicServer this$0>;
v = v.<org.apache.drill.exec.rpc.BasicServer: org.apache.drill.exec.rpc.RpcConfig rpcConfig>;
v = virtualinvoke v.<org.apache.drill.exec.rpc.RpcConfig: java.lang.String getName()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("s-\u0001");
specialinvoke v.<org.apache.drill.exec.rpc.RpcDecoder: void <init>(java.lang.String)>(v);
interfaceinvoke v.<io.netty.channel.ChannelPipeline: io.netty.channel.ChannelPipeline addLast(java.lang.String,io.netty.channel.ChannelHandler)>("message-decoder", v);
v = new org.apache.drill.exec.rpc.RpcEncoder;
v = v.<org.apache.drill.exec.rpc.BasicServer$1: org.apache.drill.exec.rpc.BasicServer this$0>;
v = v.<org.apache.drill.exec.rpc.BasicServer: org.apache.drill.exec.rpc.RpcConfig rpcConfig>;
v = virtualinvoke v.<org.apache.drill.exec.rpc.RpcConfig: java.lang.String getName()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("s-\u0001");
specialinvoke v.<org.apache.drill.exec.rpc.RpcEncoder: void <init>(java.lang.String)>(v);
interfaceinvoke v.<io.netty.channel.ChannelPipeline: io.netty.channel.ChannelPipeline addLast(java.lang.String,io.netty.channel.ChannelHandler)>("protocol-encoder", v);
v = v.<org.apache.drill.exec.rpc.BasicServer$1: org.apache.drill.exec.rpc.BasicServer this$0>;
v = virtualinvoke v.<org.apache.drill.exec.rpc.BasicServer: org.apache.drill.exec.rpc.BasicServer$ServerHandshakeHandler getHandshakeHandler(org.apache.drill.exec.rpc.ServerConnection)>(v);
interfaceinvoke v.<io.netty.channel.ChannelPipeline: io.netty.channel.ChannelPipeline addLast(java.lang.String,io.netty.channel.ChannelHandler)>("handshake-handler", v);
v = v.<org.apache.drill.exec.rpc.BasicServer$1: org.apache.drill.exec.rpc.RpcConfig val$rpcMapping>;
v = virtualinvoke v.<org.apache.drill.exec.rpc.RpcConfig: boolean hasTimeout()>();
if v == 0 goto label;
v = new org.apache.drill.exec.rpc.BasicServer$LoggingReadTimeoutHandler;
v = v.<org.apache.drill.exec.rpc.BasicServer$1: org.apache.drill.exec.rpc.BasicServer this$0>;
v = v.<org.apache.drill.exec.rpc.BasicServer$1: org.apache.drill.exec.rpc.RpcConfig val$rpcMapping>;
v = virtualinvoke v.<org.apache.drill.exec.rpc.RpcConfig: int getTimeout()>();
specialinvoke v.<org.apache.drill.exec.rpc.BasicServer$LoggingReadTimeoutHandler: void <init>(org.apache.drill.exec.rpc.BasicServer,org.apache.drill.exec.rpc.ServerConnection,int)>(v, v, v);
interfaceinvoke v.<io.netty.channel.ChannelPipeline: io.netty.channel.ChannelPipeline addLast(java.lang.String,io.netty.channel.ChannelHandler)>("timeout-handler", v);
label:
v = new org.apache.drill.exec.rpc.RpcBus$InboundHandler;
v = v.<org.apache.drill.exec.rpc.BasicServer$1: org.apache.drill.exec.rpc.BasicServer this$0>;
specialinvoke v.<org.apache.drill.exec.rpc.RpcBus$InboundHandler: void <init>(org.apache.drill.exec.rpc.RpcBus,org.apache.drill.exec.rpc.RemoteConnection)>(v, v);
interfaceinvoke v.<io.netty.channel.ChannelPipeline: io.netty.channel.ChannelPipeline addLast(java.lang.String,io.netty.channel.ChannelHandler)>("message-handler", v);
v = new org.apache.drill.exec.rpc.RpcExceptionHandler;
specialinvoke v.<org.apache.drill.exec.rpc.RpcExceptionHandler: void <init>(org.apache.drill.exec.rpc.RemoteConnection)>(v);
interfaceinvoke v.<io.netty.channel.ChannelPipeline: io.netty.channel.ChannelPipeline addLast(java.lang.String,io.netty.channel.ChannelHandler)>("exception-handler", v);
v = v.<org.apache.drill.exec.rpc.BasicServer$1: org.apache.drill.exec.rpc.BasicServer this$0>;
v.<org.apache.drill.exec.rpc.BasicServer: boolean connect> = 1;
return;
}
}