public class oadd.org.apache.zookeeper.server.NettyServerCnxn extends oadd.org.apache.zookeeper.server.ServerCnxn { private static final org.slf4j.Logger LOG; private final oadd.io.netty.channel.Channel channel; private oadd.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.util.concurrent.atomic.AtomicLong outstandingCount; private java.security.cert.Certificate[] clientChain; private volatile boolean closingChannel; private volatile oadd.org.apache.zookeeper.server.ZooKeeperServer zkServer; private final oadd.org.apache.zookeeper.server.NettyServerCnxnFactory factory; private boolean initialized; private final oadd.io.netty.util.concurrent.GenericFutureListener onSendBufferDoneListener; void (oadd.io.netty.channel.Channel, oadd.org.apache.zookeeper.server.ZooKeeperServer, oadd.org.apache.zookeeper.server.NettyServerCnxnFactory) { oadd.org.apache.zookeeper.server.ZooKeeperSaslServer v; oadd.org.apache.zookeeper.Login v, v; oadd.io.netty.channel.Channel v; oadd.org.apache.zookeeper.server.NettyServerCnxn v; java.util.concurrent.atomic.AtomicBoolean v; oadd.org.apache.zookeeper.server.ZooKeeperServer v; java.nio.ByteBuffer v; java.util.concurrent.atomic.AtomicLong v; oadd.io.netty.util.concurrent.GenericFutureListener v; oadd.org.apache.zookeeper.server.NettyServerCnxnFactory v, v; v := @this: oadd.org.apache.zookeeper.server.NettyServerCnxn; v := @parameter: oadd.io.netty.channel.Channel; v := @parameter: oadd.org.apache.zookeeper.server.ZooKeeperServer; v := @parameter: oadd.org.apache.zookeeper.server.NettyServerCnxnFactory; specialinvoke v.()>(); v = new java.util.concurrent.atomic.AtomicBoolean; specialinvoke v.(boolean)>(0); v. = v; v = staticinvoke (4); v. = v; v = new java.util.concurrent.atomic.AtomicLong; specialinvoke v.()>(); v. = v; v = staticinvoke (v); v. = v; v. = v; v. = 0; v. = v; v. = v; v = v.; v = v.; if v == null goto label; v = new oadd.org.apache.zookeeper.server.ZooKeeperSaslServer; v = v.; specialinvoke v.(oadd.org.apache.zookeeper.Login)>(v); v. = v; label: return; } public void close() { java.net.SocketAddress v; oadd.io.netty.channel.EventLoop v; java.lang.Integer v; java.lang.Runnable v; java.net.InetAddress v; boolean v, v, v, v, v; oadd.io.netty.channel.Channel v, v, v, v; java.util.Set v, v; oadd.org.apache.zookeeper.server.NettyServerCnxnFactory v, v, v, v; oadd.org.apache.zookeeper.server.NettyServerCnxn v; long v, v; oadd.org.apache.zookeeper.server.ZooKeeperServer v, v; int v; java.lang.String v, v; oadd.io.netty.buffer.ByteBuf v; org.slf4j.Logger v, v, v, v, v, v; oadd.io.netty.channel.ChannelFuture v; oadd.org.apache.zookeeper.server.NettyServerCnxn$1 v; v := @this: oadd.org.apache.zookeeper.server.NettyServerCnxn; v. = 1; v = ; v = interfaceinvoke v.(); if v == 0 goto label; v = ; v = v.; v = staticinvoke (v); interfaceinvoke v.("close called for sessionid:0x{}", v); label: v = v.; virtualinvoke v.(v); v = v.; v = v.; v = interfaceinvoke v.(v); if v != 0 goto label; v = ; v = interfaceinvoke v.(); if v == 0 goto label; v = ; v = v.; v = v.; v = interfaceinvoke v.(); v = staticinvoke (v); interfaceinvoke v.("cnxns size:{}", v); label: return; label: v = ; v = interfaceinvoke v.(); if v == 0 goto label; v = ; v = v.; v = staticinvoke (v); interfaceinvoke v.("close in progress for sessionid:0x{}", v); label: 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 oadd.org.apache.zookeeper.server.NettyServerCnxn$1; specialinvoke v.(oadd.org.apache.zookeeper.server.NettyServerCnxn)>(v); interfaceinvoke v.(v); goto label; label: v = v.; v = interfaceinvoke v.(); v = staticinvoke (v); interfaceinvoke v.(v); label: return; } public long getSessionId() { oadd.org.apache.zookeeper.server.NettyServerCnxn v; long v; v := @this: oadd.org.apache.zookeeper.server.NettyServerCnxn; v = v.; return v; } public int getSessionTimeout() { int v; oadd.org.apache.zookeeper.server.NettyServerCnxn v; v := @this: oadd.org.apache.zookeeper.server.NettyServerCnxn; v = v.; return v; } public void process(oadd.org.apache.zookeeper.WatchedEvent) { oadd.org.apache.zookeeper.server.NettyServerCnxn v; long v; oadd.org.apache.zookeeper.WatchedEvent v; int v; java.lang.String v, v, v; boolean v, v; org.slf4j.Logger v, v, v, v; java.io.IOException v; java.net.InetSocketAddress v; oadd.org.apache.zookeeper.proto.WatcherEvent v; oadd.org.apache.zookeeper.proto.ReplyHeader v; v := @this: oadd.org.apache.zookeeper.server.NettyServerCnxn; v := @parameter: oadd.org.apache.zookeeper.WatchedEvent; v = new oadd.org.apache.zookeeper.proto.ReplyHeader; v = (int) -1; specialinvoke v.(int,long,int)>(v, -1L, 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: virtualinvoke v.(v, v, "notification"); label: goto label; label: v := @caughtexception; v = ; v = interfaceinvoke v.(); if v == 0 goto label; v = ; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("Problem sending to \u0001"); interfaceinvoke v.(v, v); label: virtualinvoke v.(); label: return; catch java.io.IOException from label to label with label; } public void sendResponse(oadd.org.apache.zookeeper.proto.ReplyHeader, oadd.org.apache.jute.Record, java.lang.String) throws java.io.IOException { oadd.org.apache.jute.Record v; oadd.io.netty.channel.Channel v; oadd.org.apache.zookeeper.server.NettyServerCnxn v; long v; oadd.org.apache.zookeeper.server.ZooKeeperServer v; java.util.concurrent.atomic.AtomicLong v; int v; java.lang.String v; oadd.org.apache.zookeeper.proto.ReplyHeader v; boolean v, v, v; v := @this: oadd.org.apache.zookeeper.server.NettyServerCnxn; v := @parameter: oadd.org.apache.zookeeper.proto.ReplyHeader; v := @parameter: oadd.org.apache.jute.Record; v := @parameter: java.lang.String; v = v.; if v != 0 goto label; v = v.; v = interfaceinvoke v.(); if v != 0 goto label; label: return; label: specialinvoke v.(v, v, v); v = virtualinvoke v.(); if v <= 0 goto label; v = v.; v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(v); if v != 0 goto label; virtualinvoke v.(); label: return; } public void setSessionId(long) { oadd.org.apache.zookeeper.server.NettyServerCnxn v; long v; v := @this: oadd.org.apache.zookeeper.server.NettyServerCnxn; v := @parameter: long; v. = v; return; } public void sendBuffer(java.nio.ByteBuffer) { oadd.io.netty.util.concurrent.GenericFutureListener v; oadd.io.netty.channel.Channel v; oadd.org.apache.zookeeper.server.NettyServerCnxn v; oadd.io.netty.channel.ChannelFuture v; oadd.io.netty.buffer.ByteBuf v; java.nio.ByteBuffer v, v; v := @this: oadd.org.apache.zookeeper.server.NettyServerCnxn; v := @parameter: java.nio.ByteBuffer; v = ; if v != v goto label; virtualinvoke v.(); return; label: v = v.; v = staticinvoke (v); v = interfaceinvoke v.(v); v = v.; interfaceinvoke v.(v); return; } private boolean checkFourLetterWord(oadd.io.netty.channel.Channel, oadd.io.netty.buffer.ByteBuf, int) { java.net.SocketAddress v; oadd.org.apache.zookeeper.server.NettyServerCnxn v; long v; oadd.org.apache.zookeeper.server.command.NopCommand v; oadd.io.netty.channel.ChannelConfig v; oadd.org.apache.zookeeper.server.ZooKeeperServer v; java.nio.ByteBuffer v; oadd.org.apache.zookeeper.server.command.SetTraceMaskCommand v; int v, v; java.lang.String v, v; oadd.io.netty.buffer.ByteBuf v; boolean v, v, v; java.io.PrintWriter v; oadd.org.apache.zookeeper.server.command.CommandExecutor v; org.slf4j.Logger v, v; java.io.BufferedWriter v; oadd.io.netty.channel.Channel v; oadd.org.apache.zookeeper.server.NettyServerCnxnFactory v; oadd.org.apache.zookeeper.server.NettyServerCnxn$SendBufferWriter v; v := @this: oadd.org.apache.zookeeper.server.NettyServerCnxn; v := @parameter: oadd.io.netty.channel.Channel; v := @parameter: oadd.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.(); v = new java.io.PrintWriter; v = new java.io.BufferedWriter; v = new oadd.org.apache.zookeeper.server.NettyServerCnxn$SendBufferWriter; specialinvoke v.(oadd.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 oadd.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,oadd.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 oadd.org.apache.zookeeper.server.command.SetTraceMaskCommand; specialinvoke v.(java.io.PrintWriter,oadd.org.apache.zookeeper.server.ServerCnxn,long)>(v, v, v); virtualinvoke v.(); return 1; label: v = new oadd.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) { java.lang.IllegalStateException v; oadd.io.netty.channel.EventLoop v; oadd.io.netty.channel.Channel v; oadd.org.apache.zookeeper.server.NettyServerCnxn v; java.lang.String v, v; boolean v; v := @this: oadd.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(oadd.io.netty.buffer.ByteBuf) { oadd.io.netty.buffer.CompositeByteBuf v, v, v, v; oadd.org.apache.zookeeper.server.NettyServerCnxn v; int v, v; oadd.io.netty.buffer.ByteBuf v; v := @this: oadd.org.apache.zookeeper.server.NettyServerCnxn; v := @parameter: oadd.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); return; } void processMessage(oadd.io.netty.buffer.ByteBuf) { oadd.io.netty.buffer.ByteBufAllocator v, v; boolean v, v, v, v, v, v, v, v; oadd.io.netty.channel.Channel v, v; oadd.io.netty.buffer.CompositeByteBuf v, v, v, v, v, v, v, v, v; oadd.org.apache.zookeeper.server.NettyServerCnxn v; java.util.concurrent.atomic.AtomicBoolean v; long v, v, v, v; int v, v; java.lang.String v, v, v, v, v, v, v; oadd.io.netty.buffer.ByteBuf v, v, v, v; org.slf4j.Logger v, v, v, v, v, v, v, v, v, v, v, v, v, v; v := @this: oadd.org.apache.zookeeper.server.NettyServerCnxn; v := @parameter: oadd.io.netty.buffer.ByteBuf; specialinvoke v.("processMessage"); v = ; v = interfaceinvoke v.(); if v == 0 goto label; v = ; v = v.; v = staticinvoke (v); v = v.; interfaceinvoke v.("0x{} queuedBuffer: {}", v, v); label: 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() { oadd.io.netty.buffer.CompositeByteBuf v, v, v, v, v; oadd.org.apache.zookeeper.server.NettyServerCnxn v; long v; java.lang.String v, v; boolean v, v, v; org.slf4j.Logger v, v, v, v, v, v; v := @this: oadd.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() { oadd.org.apache.zookeeper.server.NettyServerCnxn v; oadd.io.netty.buffer.CompositeByteBuf v, v; v := @this: oadd.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(oadd.io.netty.buffer.ByteBuf) { java.lang.Integer v, v, v, v, v, v, v; java.lang.Object[] v, v; long v, v, v, v, v, v; oadd.org.apache.zookeeper.server.ZooKeeperServer v; java.lang.String v, v, v, v, v, v, v, v, v, v, v; java.io.IOException v, v, v; java.util.concurrent.atomic.AtomicLong 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; boolean v, v, v, v, v, v, v, v, v, v, v, v, v; oadd.io.netty.channel.Channel v; java.net.InetSocketAddress v, v; oadd.org.apache.zookeeper.server.NettyServerCnxn 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; oadd.io.netty.buffer.ByteBuf 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 := @this: oadd.org.apache.zookeeper.server.NettyServerCnxn; v := @parameter: oadd.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; virtualinvoke v.(); v = v.; virtualinvoke 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 = v.; virtualinvoke v.(v, v); v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(v); if v == 0 goto label; specialinvoke v.(); goto label; label: v = ; v = interfaceinvoke v.(); if v == 0 goto label; v = ; v = virtualinvoke v.(); interfaceinvoke v.("got conn req request from {}", v); label: 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 (v); interfaceinvoke v.("0x{} bbLen len is {}", v, v); label: v = v.; virtualinvoke v.(); v = v.; if v != 0 goto label; v = v.; v = specialinvoke v.(v, v, v); if v == 0 goto label; label: return; label: if v < 0 goto label; v = ; if v <= v goto label; label: v = new java.io.IOException; v = dynamicinvoke "makeConcatWithConstants" (v) ("Len error \u0001"); specialinvoke v.(java.lang.String)>(v); throw v; label: v = staticinvoke (v); v. = v; goto label; label: v := @caughtexception; v = ; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("Closing connection to \u0001"); interfaceinvoke v.(v, v); virtualinvoke v.(); label: return; catch java.io.IOException from label to label with label; catch java.io.IOException from label to label with label; } public void disableRecv() { org.slf4j.Logger v, v; oadd.io.netty.channel.Channel v; oadd.org.apache.zookeeper.server.NettyServerCnxn v; java.util.concurrent.atomic.AtomicBoolean v; oadd.io.netty.channel.ChannelPipeline v; oadd.org.apache.zookeeper.server.NettyServerCnxn$AutoReadEvent v; boolean v, v; v := @this: oadd.org.apache.zookeeper.server.NettyServerCnxn; v = v.