class org.apache.zookeeper.ClientCnxnSocketNetty$ZKClientPipelineFactory extends io.netty.channel.ChannelInitializer
{
private io.netty.handler.ssl.SslContext sslContext;
private final java.lang.String host;
private final int port;
final org.apache.zookeeper.ClientCnxnSocketNetty this$0;
private void <init>(org.apache.zookeeper.ClientCnxnSocketNetty, java.lang.String, int)
{
org.apache.zookeeper.ClientCnxnSocketNetty$ZKClientPipelineFactory v;
org.apache.zookeeper.ClientCnxnSocketNetty v;
int v;
java.lang.String v;
v := @this: org.apache.zookeeper.ClientCnxnSocketNetty$ZKClientPipelineFactory;
v := @parameter: org.apache.zookeeper.ClientCnxnSocketNetty;
v := @parameter: java.lang.String;
v := @parameter: int;
v.<org.apache.zookeeper.ClientCnxnSocketNetty$ZKClientPipelineFactory: org.apache.zookeeper.ClientCnxnSocketNetty this$0> = v;
specialinvoke v.<io.netty.channel.ChannelInitializer: void <init>()>();
v.<org.apache.zookeeper.ClientCnxnSocketNetty$ZKClientPipelineFactory: io.netty.handler.ssl.SslContext sslContext> = null;
v.<org.apache.zookeeper.ClientCnxnSocketNetty$ZKClientPipelineFactory: java.lang.String host> = v;
v.<org.apache.zookeeper.ClientCnxnSocketNetty$ZKClientPipelineFactory: int port> = v;
return;
}
protected void initChannel(io.netty.channel.socket.SocketChannel) throws java.lang.Exception
{
org.apache.zookeeper.ClientCnxnSocketNetty$ZKClientPipelineFactory v;
org.apache.zookeeper.ClientCnxnSocketNetty v, v;
io.netty.channel.ChannelPipeline v;
org.apache.zookeeper.client.ZKClientConfig v;
io.netty.channel.socket.SocketChannel v;
boolean v;
org.apache.zookeeper.ClientCnxnSocketNetty$ZKClientHandler v;
v := @this: org.apache.zookeeper.ClientCnxnSocketNetty$ZKClientPipelineFactory;
v := @parameter: io.netty.channel.socket.SocketChannel;
v = interfaceinvoke v.<io.netty.channel.socket.SocketChannel: io.netty.channel.ChannelPipeline pipeline()>();
v = v.<org.apache.zookeeper.ClientCnxnSocketNetty$ZKClientPipelineFactory: org.apache.zookeeper.ClientCnxnSocketNetty this$0>;
v = v.<org.apache.zookeeper.ClientCnxnSocketNetty: org.apache.zookeeper.client.ZKClientConfig clientConfig>;
v = virtualinvoke v.<org.apache.zookeeper.client.ZKClientConfig: boolean getBoolean(java.lang.String)>("zookeeper.client.secure");
if v == 0 goto label;
specialinvoke v.<org.apache.zookeeper.ClientCnxnSocketNetty$ZKClientPipelineFactory: void initSSL(io.netty.channel.ChannelPipeline)>(v);
label:
v = new org.apache.zookeeper.ClientCnxnSocketNetty$ZKClientHandler;
v = v.<org.apache.zookeeper.ClientCnxnSocketNetty$ZKClientPipelineFactory: org.apache.zookeeper.ClientCnxnSocketNetty this$0>;
specialinvoke v.<org.apache.zookeeper.ClientCnxnSocketNetty$ZKClientHandler: void <init>(org.apache.zookeeper.ClientCnxnSocketNetty)>(v);
interfaceinvoke v.<io.netty.channel.ChannelPipeline: io.netty.channel.ChannelPipeline addLast(java.lang.String,io.netty.channel.ChannelHandler)>("handler", v);
return;
}
private synchronized void initSSL(io.netty.channel.ChannelPipeline) throws org.apache.zookeeper.common.X509Exception$KeyManagerException, org.apache.zookeeper.common.X509Exception$TrustManagerException, javax.net.ssl.SSLException
{
java.lang.Throwable v;
org.apache.zookeeper.ClientCnxnSocketNetty v;
io.netty.buffer.ByteBufAllocator v;
int v;
java.lang.String v;
org.apache.zookeeper.client.ZKClientConfig v;
org.apache.zookeeper.common.ClientX509Util v;
org.apache.zookeeper.ClientCnxnSocketNetty$ZKClientPipelineFactory v;
org.slf4j.Logger v;
io.netty.handler.ssl.SslContext v, v, v;
io.netty.channel.ChannelPipeline v;
io.netty.channel.Channel v, v;
io.netty.handler.ssl.SslHandler v;
v := @this: org.apache.zookeeper.ClientCnxnSocketNetty$ZKClientPipelineFactory;
v := @parameter: io.netty.channel.ChannelPipeline;
v = v.<org.apache.zookeeper.ClientCnxnSocketNetty$ZKClientPipelineFactory: io.netty.handler.ssl.SslContext sslContext>;
if v != null goto label;
v = new org.apache.zookeeper.common.ClientX509Util;
specialinvoke v.<org.apache.zookeeper.common.ClientX509Util: void <init>()>();
label:
v = v.<org.apache.zookeeper.ClientCnxnSocketNetty$ZKClientPipelineFactory: org.apache.zookeeper.ClientCnxnSocketNetty this$0>;
v = v.<org.apache.zookeeper.ClientCnxnSocketNetty: org.apache.zookeeper.client.ZKClientConfig clientConfig>;
v = virtualinvoke v.<org.apache.zookeeper.common.ClientX509Util: io.netty.handler.ssl.SslContext createNettySslContextForClient(org.apache.zookeeper.common.ZKConfig)>(v);
v.<org.apache.zookeeper.ClientCnxnSocketNetty$ZKClientPipelineFactory: io.netty.handler.ssl.SslContext sslContext> = v;
label:
virtualinvoke v.<org.apache.zookeeper.common.ClientX509Util: void close()>();
goto label;
label:
v := @caughtexception;
throw v;
label:
v = v.<org.apache.zookeeper.ClientCnxnSocketNetty$ZKClientPipelineFactory: io.netty.handler.ssl.SslContext sslContext>;
v = interfaceinvoke v.<io.netty.channel.ChannelPipeline: io.netty.channel.Channel channel()>();
v = interfaceinvoke v.<io.netty.channel.Channel: io.netty.buffer.ByteBufAllocator alloc()>();
v = v.<org.apache.zookeeper.ClientCnxnSocketNetty$ZKClientPipelineFactory: java.lang.String host>;
v = v.<org.apache.zookeeper.ClientCnxnSocketNetty$ZKClientPipelineFactory: int port>;
v = virtualinvoke v.<io.netty.handler.ssl.SslContext: io.netty.handler.ssl.SslHandler newHandler(io.netty.buffer.ByteBufAllocator,java.lang.String,int)>(v, v, v);
interfaceinvoke v.<io.netty.channel.ChannelPipeline: io.netty.channel.ChannelPipeline addLast(java.lang.String,io.netty.channel.ChannelHandler)>("ssl", v);
v = <org.apache.zookeeper.ClientCnxnSocketNetty: org.slf4j.Logger LOG>;
v = interfaceinvoke v.<io.netty.channel.ChannelPipeline: io.netty.channel.Channel channel()>();
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String,java.lang.Object)>("SSL handler added for channel: {}", v);
return;
catch java.lang.Throwable from label to label with label;
}
}