public class org.apache.zookeeper.server.NettyServerCnxn extends org.apache.zookeeper.server.ServerCnxn { private static final org.slf4j.Logger LOG; private final io.netty.channel.Channel channel; private io.netty.buffer.CompositeByteBuf queuedBuffer; private final java.util.concurrent.atomic.AtomicBoolean throttled; private java.nio.ByteBuffer bb; private final java.nio.ByteBuffer bbLen; private long sessionId; private int sessionTimeout; private java.security.cert.Certificate[] clientChain; private volatile boolean closingChannel; private final org.apache.zookeeper.server.NettyServerCnxnFactory factory; private boolean initialized; public int readIssuedAfterReadComplete; private volatile org.apache.zookeeper.server.NettyServerCnxn$HandshakeState handshakeState; private final io.netty.util.concurrent.GenericFutureListener onSendBufferDoneListener; void (io.netty.channel.Channel, org.apache.zookeeper.server.ZooKeeperServer, org.apache.zookeeper.server.NettyServerCnxnFactory) { java.net.SocketAddress v; java.util.concurrent.atomic.AtomicBoolean v; org.apache.zookeeper.server.NettyServerCnxn$HandshakeState v; java.nio.ByteBuffer v; java.net.InetAddress v; org.apache.zookeeper.Login v, v; org.apache.zookeeper.server.NettyServerCnxnFactory v, v; java.lang.String v; io.netty.util.concurrent.GenericFutureListener v; io.netty.channel.Channel v; org.apache.zookeeper.server.ZooKeeperServer v; org.apache.zookeeper.server.NettyServerCnxn v; org.apache.zookeeper.server.ZooKeeperSaslServer v; org.apache.zookeeper.data.Id v; v := @this: org.apache.zookeeper.server.NettyServerCnxn; v := @parameter: io.netty.channel.Channel; v := @parameter: org.apache.zookeeper.server.ZooKeeperServer; v := @parameter: org.apache.zookeeper.server.NettyServerCnxnFactory; specialinvoke v.(org.apache.zookeeper.server.ZooKeeperServer)>(v); v = new java.util.concurrent.atomic.AtomicBoolean; specialinvoke v.(boolean)>(0); v. = v; v = staticinvoke (4); v. = v; v = ; v. = v; v = staticinvoke (v); v. = v; v. = v; v. = 0; v. = v; v = v.; v = v.; if v == null goto label; v = new org.apache.zookeeper.server.ZooKeeperSaslServer; v = v.; specialinvoke v.(org.apache.zookeeper.Login)>(v); v. = v; label: v = interfaceinvoke v.(); v = virtualinvoke v.(); v = new org.apache.zookeeper.data.Id; v = virtualinvoke v.(); specialinvoke v.(java.lang.String,java.lang.String)>("ip", v); virtualinvoke v.(v); return; } public void close(org.apache.zookeeper.server.ServerCnxn$DisconnectReason) { org.apache.zookeeper.server.ServerCnxn$DisconnectReason v; org.apache.zookeeper.server.NettyServerCnxn v; v := @this: org.apache.zookeeper.server.NettyServerCnxn; v := @parameter: org.apache.zookeeper.server.ServerCnxn$DisconnectReason; v. = v; virtualinvoke v.(); return; } public void close() { java.net.SocketAddress v; org.apache.zookeeper.metrics.Counter v; org.apache.zookeeper.server.NettyServerCnxn$1 v; java.lang.Integer v; java.lang.Runnable v; java.net.InetAddress v; org.apache.zookeeper.server.NettyServerCnxnFactory v, v, v, v, v; boolean v, v, v; java.util.Set v, v; io.netty.channel.EventLoop v; long v, v; io.netty.buffer.ByteBuf v; org.apache.zookeeper.server.ServerMetrics v; int v; java.lang.String v, v; org.slf4j.Logger v, v, v; io.netty.channel.ChannelFuture v; io.netty.channel.Channel v, v, v, v, v, v; org.apache.zookeeper.server.ZooKeeperServer v, v; org.apache.zookeeper.server.NettyServerCnxn v; v := @this: org.apache.zookeeper.server.NettyServerCnxn; v. = 1; v = ; v = v.; v = staticinvoke (v); interfaceinvoke v.("close called for session id: 0x{}", v); virtualinvoke v.(); v = v.; virtualinvoke v.(v); v = v.; v = v.; v = interfaceinvoke v.(v); if v != 0 goto label; v = ; v = v.; v = v.; v = interfaceinvoke v.(); v = staticinvoke (v); interfaceinvoke v.("cnxns size:{}", v); v = v.; v = interfaceinvoke v.(); if v == 0 goto label; v = v.; interfaceinvoke v.(); label: return; label: v = ; v = v.; v = staticinvoke (v); interfaceinvoke v.("close in progress for session id: 0x{}", v); v = v.; virtualinvoke v.(v); v = v.; v = v.; v = interfaceinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.(v, v); v = v.; if v == null goto label; v = v.; virtualinvoke v.(v); label: v = v.; v = interfaceinvoke v.(); if v == 0 goto label; v = v.; v = ; v = interfaceinvoke v.(v); v = new org.apache.zookeeper.server.NettyServerCnxn$1; specialinvoke v.(org.apache.zookeeper.server.NettyServerCnxn)>(v); interfaceinvoke v.(v); goto label; label: v = staticinvoke (); v = v.; interfaceinvoke v.(1L); v = v.; v = interfaceinvoke v.(); v = staticinvoke (v); interfaceinvoke v.(v); label: return; } public long getSessionId() { long v; org.apache.zookeeper.server.NettyServerCnxn v; v := @this: org.apache.zookeeper.server.NettyServerCnxn; v = v.; return v; } public int getSessionTimeout() { int v; org.apache.zookeeper.server.NettyServerCnxn v; v := @this: org.apache.zookeeper.server.NettyServerCnxn; v = v.; return v; } public void process(org.apache.zookeeper.WatchedEvent) { org.apache.zookeeper.metrics.Counter v; long v, v; org.apache.zookeeper.server.ServerMetrics v; int v, v; java.lang.String v, v; boolean v; org.slf4j.Logger v, v, v; java.io.IOException v; org.apache.zookeeper.WatchedEvent v; java.net.InetSocketAddress v; org.apache.zookeeper.proto.WatcherEvent v; org.apache.zookeeper.server.NettyServerCnxn v; org.apache.zookeeper.proto.ReplyHeader v; v := @this: org.apache.zookeeper.server.NettyServerCnxn; v := @parameter: org.apache.zookeeper.WatchedEvent; v = new org.apache.zookeeper.proto.ReplyHeader; v = virtualinvoke v.(); v = (int) -1; specialinvoke v.(int,long,int)>(v, v, 0); v = ; v = interfaceinvoke v.(); if v == 0 goto label; v = ; v = v.; v = staticinvoke (v); v = dynamicinvoke "makeConcatWithConstants" (v, v, v) ("Deliver event \u to 0x\u through \u0001"); staticinvoke (v, 64L, v); label: v = virtualinvoke v.(); label: v = virtualinvoke v.(v, v, "notification"); v = staticinvoke (); v = v.; interfaceinvoke v.(v); label: goto label; label: v := @caughtexception; v = ; v = virtualinvoke v.(); interfaceinvoke v.("Problem sending to {}", v, v); virtualinvoke v.(); label: return; catch java.io.IOException from label to label with label; } public int sendResponse(org.apache.zookeeper.proto.ReplyHeader, org.apache.jute.Record, java.lang.String, java.lang.String, org.apache.zookeeper.data.Stat, int) throws java.io.IOException { java.nio.ByteBuffer[] v; org.apache.jute.Record v; org.apache.zookeeper.data.Stat v; java.nio.ByteBuffer v, v; io.netty.channel.Channel v; org.apache.zookeeper.server.NettyServerCnxn v; int v, v; java.lang.String v, v; org.apache.zookeeper.proto.ReplyHeader v; boolean v, v; v := @this: org.apache.zookeeper.server.NettyServerCnxn; v := @parameter: org.apache.zookeeper.proto.ReplyHeader; v := @parameter: org.apache.jute.Record; v := @parameter: java.lang.String; v := @parameter: java.lang.String; v := @parameter: org.apache.zookeeper.data.Stat; v := @parameter: int; v = v.; if v != 0 goto label; v = v.; v = interfaceinvoke v.(); if v != 0 goto label; label: return 0; label: v = virtualinvoke v.(v, v, v, v, v, v); v = v[0]; v = virtualinvoke v.(); v = v[0]; virtualinvoke v.(); virtualinvoke v.(v); virtualinvoke v.(v); return v; } public void setSessionId(long) { long v; org.apache.zookeeper.server.NettyServerCnxn v; org.apache.zookeeper.server.NettyServerCnxnFactory v; v := @this: org.apache.zookeeper.server.NettyServerCnxn; v := @parameter: long; v. = v; v = v.; virtualinvoke v.(v, v); return; } public transient void sendBuffer(java.nio.ByteBuffer[]) { java.nio.ByteBuffer[] v; io.netty.util.concurrent.GenericFutureListener v; java.nio.ByteBuffer v, v; io.netty.channel.ChannelFuture v; io.netty.channel.Channel v; org.apache.zookeeper.server.ServerCnxn$DisconnectReason v; org.apache.zookeeper.server.NettyServerCnxn v; io.netty.buffer.ByteBuf v; int v; v := @this: org.apache.zookeeper.server.NettyServerCnxn; v := @parameter: java.nio.ByteBuffer[]; v = lengthof v; if v != 1 goto label; v = v[0]; v = ; if v != v goto label; v = ; virtualinvoke v.(v); return; label: v = v.; v = staticinvoke (v); v = interfaceinvoke v.(v); v = v.; interfaceinvoke v.(v); return; } private boolean checkFourLetterWord(io.netty.channel.Channel, io.netty.buffer.ByteBuf, int) { org.apache.zookeeper.server.command.SetTraceMaskCommand v; java.net.SocketAddress v; long v; java.nio.ByteBuffer v; io.netty.buffer.ByteBuf v; org.apache.zookeeper.server.NettyServerCnxnFactory v; int v, v; java.lang.String v, v; boolean v, v, v; java.io.PrintWriter v; org.apache.zookeeper.server.command.NopCommand v; org.slf4j.Logger v, v; java.io.BufferedWriter v; io.netty.channel.Channel v; org.apache.zookeeper.server.ZooKeeperServer v; org.apache.zookeeper.server.NettyServerCnxn v; io.netty.channel.ChannelConfig v; org.apache.zookeeper.server.NettyServerCnxn$SendBufferWriter v; org.apache.zookeeper.server.command.CommandExecutor v; v := @this: org.apache.zookeeper.server.NettyServerCnxn; v := @parameter: io.netty.channel.Channel; v := @parameter: io.netty.buffer.ByteBuf; v := @parameter: int; v = staticinvoke (v); if v != 0 goto label; return 0; label: v = staticinvoke (v); v = interfaceinvoke v.(); interfaceinvoke v.(0); virtualinvoke v.(4L); v = new java.io.PrintWriter; v = new java.io.BufferedWriter; v = new org.apache.zookeeper.server.NettyServerCnxn$SendBufferWriter; specialinvoke v.(org.apache.zookeeper.server.NettyServerCnxn)>(v); specialinvoke v.(java.io.Writer)>(v); specialinvoke v.(java.io.Writer)>(v); v = staticinvoke (v); if v != 0 goto label; v = ; interfaceinvoke v.("Command {} is not executed because it is not in the whitelist.", v); v = new org.apache.zookeeper.server.command.NopCommand; v = dynamicinvoke "makeConcatWithConstants" (v) ("\u is not executed because it is not in the whitelist."); specialinvoke v.(java.io.PrintWriter,org.apache.zookeeper.server.ServerCnxn,java.lang.String)>(v, v, v); virtualinvoke v.(); return 1; label: v = ; v = interfaceinvoke v.(); interfaceinvoke v.("Processing {} command from {}", v, v); v = ; if v != v goto label; v = staticinvoke (8); virtualinvoke v.(v); virtualinvoke v.(); v = virtualinvoke v.(); staticinvoke (v); v = new org.apache.zookeeper.server.command.SetTraceMaskCommand; specialinvoke v.(java.io.PrintWriter,org.apache.zookeeper.server.ServerCnxn,long)>(v, v, v); virtualinvoke v.(); return 1; label: v = new org.apache.zookeeper.server.command.CommandExecutor; specialinvoke v.()>(); v = v.; v = v.; v = virtualinvoke v.(v, v, v, v, v); return v; } private void checkIsInEventLoop(java.lang.String) { io.netty.channel.Channel v; java.lang.IllegalStateException v; org.apache.zookeeper.server.NettyServerCnxn v; java.lang.String v, v; io.netty.channel.EventLoop v; boolean v; v := @this: org.apache.zookeeper.server.NettyServerCnxn; v := @parameter: java.lang.String; v = v.; v = interfaceinvoke v.(); v = interfaceinvoke v.(); if v != 0 goto label; v = new java.lang.IllegalStateException; v = dynamicinvoke "makeConcatWithConstants" (v) ("\u0001() called from non-EventLoop thread"); specialinvoke v.(java.lang.String)>(v); throw v; label: return; } private void appendToQueuedBuffer(io.netty.buffer.ByteBuf) { org.apache.zookeeper.metrics.Summary v; io.netty.buffer.CompositeByteBuf v, v, v, v, v; org.apache.zookeeper.server.NettyServerCnxn v; io.netty.buffer.ByteBuf v; org.apache.zookeeper.server.ServerMetrics v; int v, v, v; v := @this: org.apache.zookeeper.server.NettyServerCnxn; v := @parameter: io.netty.buffer.ByteBuf; specialinvoke v.("appendToQueuedBuffer"); v = v.; v = virtualinvoke v.(); v = v.; v = virtualinvoke v.(); if v != v goto label; v = v.; virtualinvoke v.(); label: v = v.; virtualinvoke v.(1, v); v = staticinvoke (); v = v.; v = v.; v = virtualinvoke v.(); interfaceinvoke v.(v); return; } void processMessage(io.netty.buffer.ByteBuf) { io.netty.buffer.ByteBufAllocator v, v; boolean v, v, v, v, v, v, v; io.netty.buffer.CompositeByteBuf v, v, v, v, v, v, v, v, v; java.util.concurrent.atomic.AtomicBoolean v; long v, v, v, v; io.netty.buffer.ByteBuf v, v, v, v; int v, v; java.lang.String v, v, v, v, v, v, v; org.slf4j.Logger v, v, v, v, v, v, v, v, v, v, v, v, v; io.netty.channel.Channel v, v; org.apache.zookeeper.server.NettyServerCnxn v; v := @this: org.apache.zookeeper.server.NettyServerCnxn; v := @parameter: io.netty.buffer.ByteBuf; specialinvoke v.("processMessage"); v = ; v = v.; v = staticinvoke (v); v = v.; interfaceinvoke v.("0x{} queuedBuffer: {}", v, v); v = ; v = interfaceinvoke v.(); if v == 0 goto label; v = ; v = v.; v = staticinvoke (v); v = staticinvoke (v); interfaceinvoke v.("0x{} buf {}", v, v); label: v = v.; v = virtualinvoke v.(); if v == 0 goto label; v = ; interfaceinvoke v.("Received message while throttled"); v = v.; if v != null goto label; v = ; interfaceinvoke v.("allocating queue"); v = v.; v = interfaceinvoke v.(); v = interfaceinvoke v.(); v. = v; label: v = virtualinvoke v.(); specialinvoke v.(v); v = ; v = interfaceinvoke v.(); if v == 0 goto label; v = ; v = v.; v = staticinvoke (v); v = v.; v = staticinvoke (v); interfaceinvoke v.("0x{} queuedBuffer {}", v, v); goto label; label: v = ; interfaceinvoke v.("not throttled"); v = v.; if v == null goto label; v = virtualinvoke v.(); specialinvoke v.(v); virtualinvoke v.(); goto label; label: specialinvoke v.(v); v = v.; if v != 0 goto label; v = virtualinvoke v.(); if v == 0 goto label; v = ; v = interfaceinvoke v.(); if v == 0 goto label; v = ; interfaceinvoke v.("Before copy {}", v); label: v = v.; if v != null goto label; v = v.; v = interfaceinvoke v.(); v = interfaceinvoke v.(); v. = v; label: v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(v, v); specialinvoke v.(v); v = ; v = interfaceinvoke v.(); if v == 0 goto label; v = ; v = v.; interfaceinvoke v.("Copy is {}", v); v = ; v = v.; v = staticinvoke (v); v = v.; v = staticinvoke (v); interfaceinvoke v.("0x{} queuedBuffer {}", v, v); label: return; } void processQueuedBuffer() { long v; java.lang.String v, v; boolean v, v, v; org.slf4j.Logger v, v, v, v, v, v; io.netty.buffer.CompositeByteBuf v, v, v, v, v; org.apache.zookeeper.server.NettyServerCnxn v; v := @this: org.apache.zookeeper.server.NettyServerCnxn; specialinvoke v.("processQueuedBuffer"); v = v.; if v == null goto label; v = ; v = interfaceinvoke v.(); if v == 0 goto label; v = ; v = v.; v = staticinvoke (v); v = v.; v = staticinvoke (v); interfaceinvoke v.("processing queue 0x{} queuedBuffer {}", v, v); label: v = v.; specialinvoke v.(v); v = v.; if v == 0 goto label; v = ; interfaceinvoke v.("Processed queue - channel closed, dropping remaining bytes"); goto label; label: v = v.; v = virtualinvoke v.(); if v != 0 goto label; v = ; interfaceinvoke v.("Processed queue - no bytes remaining"); specialinvoke v.(); goto label; label: v = ; interfaceinvoke v.("Processed queue - bytes remaining"); v = v.; virtualinvoke v.(); goto label; label: v = ; interfaceinvoke v.("queue empty"); label: return; } public void releaseQueuedBuffer() { io.netty.buffer.CompositeByteBuf v, v; org.apache.zookeeper.server.NettyServerCnxn v; v := @this: org.apache.zookeeper.server.NettyServerCnxn; specialinvoke v.("releaseQueuedBuffer"); v = v.; if v == null goto label; v = v.; virtualinvoke v.(); v. = null; label: return; } private void receiveMessage(io.netty.buffer.ByteBuf) { org.apache.zookeeper.metrics.Counter v; java.lang.Integer v, v, v, v, v, v, v; org.apache.zookeeper.server.ByteBufferInputStream v; java.lang.Object[] v, v; long v, v, v, v, v; java.io.IOException v, v, v; org.apache.zookeeper.server.ZooKeeperServer v, v; org.apache.zookeeper.server.ClientCnxnLimitException v; org.apache.zookeeper.proto.RequestHeader v; java.util.concurrent.atomic.AtomicBoolean v; int v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; org.slf4j.Logger v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; org.apache.jute.BinaryInputArchive v; org.apache.zookeeper.server.RequestRecord v; org.apache.zookeeper.proto.ConnectRequest v; org.apache.zookeeper.server.ServerMetrics v; java.lang.String v, v, v, v, v, v, v, v, v, v; io.netty.channel.Channel v; java.nio.ByteBuffer v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; boolean v, v, v, v, v, v, v, v, v, v, v, v; java.net.InetSocketAddress v, v, v, v; org.apache.zookeeper.compat.ProtocolManager v; org.apache.zookeeper.server.ServerCnxn$DisconnectReason v, v, v; io.netty.buffer.ByteBuf v, v, v, v, v; org.apache.zookeeper.server.NettyServerCnxn v; v := @this: org.apache.zookeeper.server.NettyServerCnxn; v := @parameter: io.netty.buffer.ByteBuf; specialinvoke v.("receiveMessage"); label: v = virtualinvoke v.(); if v == 0 goto label; v = v.; v = virtualinvoke v.(); if v != 0 goto label; v = v.; if v == null goto label; v = ; v = interfaceinvoke v.(); if v == 0 goto label; v = ; v = newarray (java.lang.Object)[3]; v = virtualinvoke v.(); v = staticinvoke (v); v[0] = v; v = v.; v = virtualinvoke v.(); v = staticinvoke (v); v[1] = v; v = v.; v[2] = v; interfaceinvoke v.("message readable {} bb len {} {}", v); v = v.; v = virtualinvoke v.(); virtualinvoke v.(); v = ; v = v.; v = staticinvoke (v); v = staticinvoke (v); v = staticinvoke (v); interfaceinvoke v.("0x{} bb {}", v, v); label: v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); if v <= v goto label; v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); v = v + v; v = v.; virtualinvoke v.(v); label: v = v.; virtualinvoke v.(v); v = v.; v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); v = ; v = interfaceinvoke v.(); if v == 0 goto label; v = ; v = newarray (java.lang.Object)[3]; v = virtualinvoke v.(); v = staticinvoke (v); v[0] = v; v = v.; v = virtualinvoke v.(); v = staticinvoke (v); v[1] = v; v = v.; v[2] = v; interfaceinvoke v.("after readBytes message readable {} bb len {} {}", v); v = v.; v = virtualinvoke v.(); virtualinvoke v.(); v = ; v = v.; v = staticinvoke (v); v = staticinvoke (v); v = staticinvoke (v); interfaceinvoke v.("after readbytes 0x{} bb {}", v, v); label: v = v.; v = virtualinvoke v.(); if v != 0 goto label; v = v.; virtualinvoke v.(); v = v.; v = virtualinvoke v.(); v = 4 + v; virtualinvoke v.(v); v = v.; if v == null goto label; v = virtualinvoke v.(); if v != 0 goto label; label: v = new java.io.IOException; specialinvoke v.(java.lang.String)>("ZK down"); throw v; label: v = v.; if v == 0 goto label; v = new org.apache.zookeeper.proto.RequestHeader; specialinvoke v.()>(); v = v.; staticinvoke (v, v); v = v.; v = virtualinvoke v.(); v = staticinvoke (v); virtualinvoke v.(v, v, v); goto label; label: v = ; v = virtualinvoke v.(); interfaceinvoke v.("got conn req request from {}", v); v = new org.apache.zookeeper.server.ByteBufferInputStream; v = v.; specialinvoke v.(java.nio.ByteBuffer)>(v); v = staticinvoke (v); v = v.; v = virtualinvoke v.(v); virtualinvoke v.(v, v); v. = 1; label: v. = null; goto label; label: v = ; v = interfaceinvoke v.(); if v == 0 goto label; v = ; v = virtualinvoke v.(); v = staticinvoke (v); v = v.; v = virtualinvoke v.(); v = staticinvoke (v); interfaceinvoke v.("message readable {} bblenrem {}", v, v); v = v.; v = virtualinvoke v.(); virtualinvoke v.(); v = ; v = v.; v = staticinvoke (v); v = staticinvoke (v); v = staticinvoke (v); interfaceinvoke v.("0x{} bbLen {}", v, v); label: v = virtualinvoke v.(); v = v.; v = virtualinvoke v.(); if v >= v goto label; v = v.; v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); v = v + v; virtualinvoke v.(v); label: v = v.; virtualinvoke v.(v); v = v.; v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; v = virtualinvoke v.(); if v != 0 goto label; v = v.; virtualinvoke v.(); v = ; v = interfaceinvoke v.(); if v == 0 goto label; v = ; v = v.; v = staticinvoke (v); v = v.; v = staticinvoke (v); v = staticinvoke (v); interfaceinvoke v.("0x{} bbLen {}", v, v); label: v = v.; v = virtualinvoke v.(); v = ; v = interfaceinvoke v.(); if v == 0 goto label; v = ; v = v.; v = staticinvoke (v); v = staticinvoke