public class org.apache.zookeeper.server.quorum.QuorumCnxManager extends java.lang.Object { private static final org.slf4j.Logger LOG; static final int RECV_CAPACITY; static final int SEND_CAPACITY; static final int PACKETMAXSIZE; private java.util.concurrent.atomic.AtomicLong observerCounter; public static final long PROTOCOL_VERSION_V1; public static final long PROTOCOL_VERSION_V2; public static final int maxBuffer; private int cnxTO; final org.apache.zookeeper.server.quorum.QuorumPeer self; final long mySid; final int socketTimeout; final java.util.Map view; final boolean listenOnAllIPs; private java.util.concurrent.ThreadPoolExecutor connectionExecutor; private final java.util.Set inprogressConnections; private org.apache.zookeeper.server.quorum.auth.QuorumAuthServer authServer; private org.apache.zookeeper.server.quorum.auth.QuorumAuthLearner authLearner; private boolean quorumSaslAuthEnabled; private java.util.concurrent.atomic.AtomicInteger connectionThreadCnt; final java.util.concurrent.ConcurrentHashMap senderWorkerMap; final java.util.concurrent.ConcurrentHashMap queueSendMap; final java.util.concurrent.ConcurrentHashMap lastMessageSent; public final java.util.concurrent.BlockingQueue recvQueue; volatile boolean shutdown; public final org.apache.zookeeper.server.quorum.QuorumCnxManager$Listener listener; private java.util.concurrent.atomic.AtomicInteger threadCnt; private final boolean tcpKeepAlive; static final java.util.function.Supplier DEFAULT_SOCKET_FACTORY; private static java.util.function.Supplier SOCKET_FACTORY; static void setSocketFactory(java.util.function.Supplier) { java.util.function.Supplier v; v := @parameter: java.util.function.Supplier; = v; return; } public void (org.apache.zookeeper.server.quorum.QuorumPeer, long, java.util.Map, org.apache.zookeeper.server.quorum.auth.QuorumAuthServer, org.apache.zookeeper.server.quorum.auth.QuorumAuthLearner, int, boolean, int, boolean) { org.apache.zookeeper.server.quorum.QuorumPeer v; org.apache.zookeeper.util.CircularBlockingQueue v; long v; java.util.HashSet v; java.util.concurrent.atomic.AtomicInteger v, v; java.util.Map v; int v, v, v; java.lang.String v; boolean v, v, v; org.apache.zookeeper.server.quorum.auth.QuorumAuthServer v; java.util.concurrent.ConcurrentHashMap v, v, v; java.util.Set v; org.apache.zookeeper.server.quorum.QuorumCnxManager v; java.util.concurrent.atomic.AtomicLong v; org.apache.zookeeper.server.quorum.QuorumCnxManager$Listener v, v; org.apache.zookeeper.server.quorum.auth.QuorumAuthLearner v; v := @this: org.apache.zookeeper.server.quorum.QuorumCnxManager; v := @parameter: org.apache.zookeeper.server.quorum.QuorumPeer; v := @parameter: long; v := @parameter: java.util.Map; v := @parameter: org.apache.zookeeper.server.quorum.auth.QuorumAuthServer; v := @parameter: org.apache.zookeeper.server.quorum.auth.QuorumAuthLearner; v := @parameter: int; v := @parameter: boolean; v := @parameter: int; v := @parameter: boolean; specialinvoke v.()>(); v = new java.util.concurrent.atomic.AtomicLong; specialinvoke v.(long)>(-1L); v. = v; v. = 5000; v = new java.util.HashSet; specialinvoke v.()>(); v = staticinvoke (v); v. = v; v = new java.util.concurrent.atomic.AtomicInteger; specialinvoke v.(int)>(0); v. = v; v. = 0; v = new java.util.concurrent.atomic.AtomicInteger; specialinvoke v.(int)>(0); v. = v; v = staticinvoke ("zookeeper.tcpKeepAlive"); v. = v; v = new org.apache.zookeeper.util.CircularBlockingQueue; specialinvoke v.(int)>(100); v. = v; v = new java.util.concurrent.ConcurrentHashMap; specialinvoke v.()>(); v. = v; v = new java.util.concurrent.ConcurrentHashMap; specialinvoke v.()>(); v. = v; v = new java.util.concurrent.ConcurrentHashMap; specialinvoke v.()>(); v. = v; v = staticinvoke ("zookeeper.cnxTimeout"); if v == null goto label; v = staticinvoke (v); v. = v; label: v. = v; v. = v; v. = v; v. = v; v. = v; v. = v; v. = v; v. = v; specialinvoke v.(v, v); v = new org.apache.zookeeper.server.quorum.QuorumCnxManager$Listener; specialinvoke v.(org.apache.zookeeper.server.quorum.QuorumCnxManager)>(v); v. = v; v = v.; virtualinvoke v.("QuorumPeerListener"); return; } private void initializeConnectionExecutor(long, int) { java.util.concurrent.SynchronousQueue v; java.util.concurrent.ThreadPoolExecutor v, v; long v; java.lang.ThreadGroup v; org.apache.zookeeper.server.quorum.QuorumCnxManager v; java.lang.SecurityManager v; java.util.concurrent.TimeUnit v; java.util.concurrent.atomic.AtomicInteger v; java.lang.Thread v; int v; java.util.concurrent.ThreadFactory v; v := @this: org.apache.zookeeper.server.quorum.QuorumCnxManager; v := @parameter: long; v := @parameter: int; v = new java.util.concurrent.atomic.AtomicInteger; specialinvoke v.(int)>(1); v = staticinvoke (); if v == null goto label; v = virtualinvoke v.(); goto label; label: v = staticinvoke (); v = virtualinvoke v.(); label: v = staticinvoke (v, v, v); v = new java.util.concurrent.ThreadPoolExecutor; v = ; v = new java.util.concurrent.SynchronousQueue; specialinvoke v.()>(); specialinvoke v.(int,int,long,java.util.concurrent.TimeUnit,java.util.concurrent.BlockingQueue,java.util.concurrent.ThreadFactory)>(3, v, 60L, v, v, v); v. = v; v = v.; virtualinvoke v.(1); return; } public void testInitiateConnection(long) { org.apache.zookeeper.server.quorum.QuorumPeer v; org.slf4j.Logger v; long v; org.apache.zookeeper.server.quorum.QuorumCnxManager v; org.apache.zookeeper.server.quorum.MultipleAddresses v; java.lang.Long v, v, v; java.util.Map v; java.lang.Object v; v := @this: org.apache.zookeeper.server.quorum.QuorumCnxManager; v := @parameter: long; v = ; v = staticinvoke (v); interfaceinvoke v.("Opening channel to server {}", v); v = v.; v = virtualinvoke v.(); v = staticinvoke (v); v = interfaceinvoke v.(v); v = v.; v = staticinvoke (v); virtualinvoke v.(v, v); return; } public void initiateConnection(org.apache.zookeeper.server.quorum.MultipleAddresses, java.lang.Long) { org.apache.zookeeper.server.quorum.QuorumPeer v, v; java.net.SocketAddress v, v; java.lang.Integer v; java.net.InetAddress v; java.lang.Long v; org.apache.zookeeper.common.QuorumX509Util v; boolean v, v; java.net.InetSocketAddress v; org.apache.zookeeper.server.quorum.QuorumCnxManager v; java.lang.Exception v; org.apache.zookeeper.common.X509Exception v; java.net.Socket v; java.lang.Object[] v, v, v, v, v; java.util.function.Supplier v; javax.net.ssl.SSLSession v, v; int v, v; java.lang.String v, v; org.slf4j.Logger v, v, v, v, v, v; java.io.IOException v; org.apache.zookeeper.server.quorum.MultipleAddresses v; java.lang.Object v; v := @this: org.apache.zookeeper.server.quorum.QuorumCnxManager; v := @parameter: org.apache.zookeeper.server.quorum.MultipleAddresses; v := @parameter: java.lang.Long; v = null; label: v = ; interfaceinvoke v.("Opening channel to server {}", v); v = v.; v = virtualinvoke v.(); if v == 0 goto label; v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); goto label; label: v = ; v = interfaceinvoke v.(); label: specialinvoke v.(v); v = virtualinvoke v.(); v = v.; virtualinvoke v.(v, v); v = v instanceof javax.net.ssl.SSLSocket; if v == 0 goto label; virtualinvoke v.(); v = ; v = newarray (java.lang.Object)[3]; v = virtualinvoke v.(); v[0] = v; v = virtualinvoke v.(); v = interfaceinvoke v.(); v[1] = v; v = virtualinvoke v.(); v = interfaceinvoke v.(); v[2] = v; interfaceinvoke v.("SSL handshake complete with {} - {} - {}", v); label: v = ; v = newarray (java.lang.Object)[3]; v[0] = v; v = virtualinvoke v.(); v[1] = v; v = virtualinvoke v.(); v = staticinvoke (v); v[2] = v; interfaceinvoke v.("Connected to server {} using election address: {}:{}", v); label: goto label; label: v := @caughtexception; v = ; v = newarray (java.lang.Object)[3]; v[0] = v; v[1] = v; v[2] = v; interfaceinvoke v.("Cannot open secure channel to {} at election address {}", v); specialinvoke v.(v); return; label: v := @caughtexception; v = ; v = newarray (java.lang.Object)[3]; v[0] = v; v[1] = v; v[2] = v; interfaceinvoke v.("Cannot open channel to {} at election address {}", v); specialinvoke v.(v); return; label: specialinvoke v.(v, v); label: goto label; label: v := @caughtexception; v = ; v = newarray (java.lang.Object)[3]; v[0] = v; v = virtualinvoke v.(); v[1] = v; v[2] = v; interfaceinvoke v.("Exception while connecting, id: {}, addr: {}, closing learner connection", v); specialinvoke v.(v); label: return; catch org.apache.zookeeper.common.X509Exception from label to label with label; catch java.nio.channels.UnresolvedAddressException from label to label with label; catch java.io.IOException from label to label with label; catch java.io.IOException from label to label with label; } public boolean initiateConnectionAsync(org.apache.zookeeper.server.quorum.MultipleAddresses, java.lang.Long) { java.lang.Throwable v; org.slf4j.Logger v, v; java.util.concurrent.ThreadPoolExecutor v; java.util.Set v, v; org.apache.zookeeper.server.quorum.QuorumCnxManager v; org.apache.zookeeper.server.quorum.MultipleAddresses v; org.apache.zookeeper.server.quorum.QuorumCnxManager$QuorumConnectionReqThread v; java.lang.Long v; java.util.concurrent.atomic.AtomicInteger v; boolean v; v := @this: org.apache.zookeeper.server.quorum.QuorumCnxManager; v := @parameter: org.apache.zookeeper.server.quorum.MultipleAddresses; v := @parameter: java.lang.Long; v = v.; v = interfaceinvoke v.(v); if v != 0 goto label; v = ; interfaceinvoke v.("Connection request to server id: {} is already in progress, so skipping this request", v); return 1; label: v = v.; v = new org.apache.zookeeper.server.quorum.QuorumCnxManager$QuorumConnectionReqThread; specialinvoke v.(org.apache.zookeeper.server.quorum.QuorumCnxManager,org.apache.zookeeper.server.quorum.MultipleAddresses,java.lang.Long)>(v, v, v); virtualinvoke v.(v); v = v.; virtualinvoke v.(); label: goto label; label: v := @caughtexception; v = v.; interfaceinvoke v.(v); v = ; interfaceinvoke v.("Exception while submitting quorum connection request", v); return 0; label: return 1; catch java.lang.Throwable from label to label with label; } private boolean startConnection(java.net.Socket, java.lang.Long) throws java.io.IOException { org.apache.zookeeper.server.quorum.QuorumPeer v, v, v, v, v, v, v, v, v; byte[] v; java.io.BufferedInputStream v; org.apache.zookeeper.server.quorum.QuorumCnxManager$SendWorker v; byte v, v; java.io.DataOutputStream v; java.lang.Long v, v, v, v; java.util.Map v; java.util.stream.Collector v; boolean v; java.util.Collection v; java.util.concurrent.ConcurrentHashMap v, v, v; java.net.InetSocketAddress v; org.apache.zookeeper.server.quorum.QuorumCnxManager v; java.util.stream.Stream v, v; java.net.InetSocketAddress[] v; java.io.DataInputStream v; java.net.Socket v; org.apache.zookeeper.util.CircularBlockingQueue v; long v, v, v, v, v, v, v; java.util.function.Function v; java.io.BufferedOutputStream v; int v; java.lang.String v; java.io.OutputStream v; org.slf4j.Logger v, v, v, v; java.io.IOException v; org.apache.zookeeper.server.quorum.QuorumCnxManager$RecvWorker v; org.apache.zookeeper.server.quorum.MultipleAddresses v, v; org.apache.zookeeper.server.quorum.auth.QuorumAuthLearner v; java.lang.Object v, v, v; java.io.InputStream v; v := @this: org.apache.zookeeper.server.quorum.QuorumCnxManager; v := @parameter: java.net.Socket; v := @parameter: java.lang.Long; v = ; v = v.; v = virtualinvoke v.(); v = staticinvoke (v); interfaceinvoke v.("startConnection (myId:{} --> sid:{})", v, v); label: v = new java.io.BufferedOutputStream; v = virtualinvoke v.(); specialinvoke v.(java.io.OutputStream)>(v); v = new java.io.DataOutputStream; specialinvoke v.(java.io.OutputStream)>(v); v = v.; v = virtualinvoke v.(); if v == 0 goto label; v = -65535L; goto label; label: v = -65536L; label: virtualinvoke v.(v); v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); v = v cmp -65535L; if v != 0 goto label; v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); goto label; label: v = newarray (java.net.InetSocketAddress)[1]; v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); v[0] = v; v = staticinvoke (v); label: v = interfaceinvoke v.(); v = staticinvoke (); v = interfaceinvoke v.(v); v = staticinvoke ("|"); v = interfaceinvoke v.(v); v = virtualinvoke v.(); v = lengthof v; virtualinvoke v.(v); virtualinvoke v.(v); virtualinvoke v.(); v = new java.io.DataInputStream; v = new java.io.BufferedInputStream; v = virtualinvoke v.(); specialinvoke v.(java.io.InputStream)>(v); specialinvoke v.(java.io.InputStream)>(v); label: goto label; label: v := @caughtexception; v = ; interfaceinvoke v.("Ignoring exception reading or writing challenge: ", v); specialinvoke v.(v); return 0; label: v = v.; v = virtualinvoke v.(); v = interfaceinvoke v.(v); if v == null goto label; v = v.; v = v.; interfaceinvoke v.(v, v); label: v = virtualinvoke v.(); v = v.; v = virtualinvoke v.(); v = v cmp v; if v <= 0 goto label; v = ; v = v.; v = virtualinvoke v.(); v = staticinvoke (v); interfaceinvoke v.("Have smaller server identifier, so dropping the connection: (myId:{} --> sid:{})", v, v); specialinvoke v.(v); goto label; label: v = ; v = v.; v = virtualinvoke v.(); v = staticinvoke (v); interfaceinvoke v.("Have larger server identifier, so keeping the connection: (myId:{} --> sid:{})", v, v); v = new org.apache.zookeeper.server.quorum.QuorumCnxManager$SendWorker; specialinvoke v.(org.apache.zookeeper.server.quorum.QuorumCnxManager,java.net.Socket,java.lang.Long)>(v, v, v); v = new org.apache.zookeeper.server.quorum.QuorumCnxManager$RecvWorker; specialinvoke v.(org.apache.zookeeper.server.quorum.QuorumCnxManager,java.net.Socket,java.io.DataInputStream,java.lang.Long,org.apache.zookeeper.server.quorum.QuorumCnxManager$SendWorker)>(v, v, v, v, v); virtualinvoke v.(v); v = v.; v = virtualinvoke v.(v); if v == null goto label; virtualinvoke v.(); label: v = v.; virtualinvoke v.(v, v); v = v.; v = new org.apache.zookeeper.util.CircularBlockingQueue; specialinvoke v.(int)>(1); virtualinvoke v.(v, v); virtualinvoke v.(); virtualinvoke v.(); return 1; label: return 0; catch java.io.IOException from label to label with label; } public void receiveConnection(java.net.Socket) { java.io.DataInputStream v; java.net.Socket v; java.io.BufferedInputStream v; org.slf4j.Logger v, v, v; java.net.SocketAddress v, v; java.io.IOException v; org.apache.zookeeper.server.quorum.QuorumCnxManager v; java.io.InputStream v; v := @this: org.apache.zookeeper.server.quorum.QuorumCnxManager; v := @parameter: java.net.Socket; label: v = new java.io.DataInputStream; v = new java.io.BufferedInputStream; v = virtualinvoke v.(); specialinvoke v.(java.io.InputStream)>(v); specialinvoke v.(java.io.InputStream)>(v); v = ; v = virtualinvoke v.(); interfaceinvoke v.("Sync handling of connection request received from: {}", v); specialinvoke v.(v, v); label: goto label; label: v := @caughtexception; v = ; v = virtualinvoke v.(); interfaceinvoke v.("Exception handling connection, addr: {}, closing server connection", v); v = ; interfaceinvoke v.("Exception details: ", v); specialinvoke v.(v); label: return; catch java.io.IOException from label to label with label; } public void receiveConnectionAsync(java.net.Socket) { java.lang.Throwable v; java.net.Socket v; org.slf4j.Logger v, v, v; java.net.SocketAddress v, v; java.util.concurrent.ThreadPoolExecutor v; org.apache.zookeeper.server.quorum.QuorumCnxManager$QuorumConnectionReceiverThread v; org.apache.zookeeper.server.quorum.QuorumCnxManager v; java.util.concurrent.atomic.AtomicInteger v; v := @this: org.apache.zookeeper.server.quorum.QuorumCnxManager; v := @parameter: java.net.Socket; label: v = ; v = virtualinvoke v.(); interfaceinvoke v.("Async handling of connection request received from: {}", v); v = v.; v = new org.apache.zookeeper.server.quorum.QuorumCnxManager$QuorumConnectionReceiverThread; specialinvoke v.(org.apache.zookeeper.server.quorum.QuorumCnxManager,java.net.Socket)>(v, v); virtualinvoke v.(v); v = v.; virtualinvoke v.(); label: goto label; label: v := @caughtexception; v = ; v = virtualinvoke v.(); interfaceinvoke v.("Exception handling connection, addr: {}, closing server connection", v); v = ; interfaceinvoke v.("Exception details: ", v); specialinvoke v.(v); label: return; catch java.lang.Throwable from label to label with label; } private void handleConnection(java.net.Socket, java.io.DataInputStream) throws java.io.IOException { org.apache.zookeeper.server.quorum.QuorumPeer v, v, v, v; org.apache.zookeeper.server.quorum.QuorumCnxManager$SendWorker v; byte v, v, v, v; java.lang.Long v, v, v; java.time.Duration v; boolean v; org.apache.zookeeper.server.quorum.QuorumCnxManager$InitialMessage v; java.util.concurrent.ConcurrentHashMap v, v, v, v; org.apache.zookeeper.server.quorum.QuorumCnxManager v; java.util.List v, v; java.io.DataInputStream v; java.net.Socket v; org.apache.zookeeper.util.CircularBlockingQueue v; long v, v, v, v, v, v, v, v, v, v, v; int v; java.lang.String v; org.slf4j.Logger v, v, v, v, v, v; org.apache.zookeeper.server.quorum.auth.QuorumAuthServer v; java.io.IOException v; org.apache.zookeeper.server.quorum.QuorumCnxManager$RecvWorker v; java.util.concurrent.atomic.AtomicLong v; org.apache.zookeeper.server.quorum.MultipleAddresses v, v; org.apache.zookeeper.server.quorum.QuorumCnxManager$InitialMessage$InitialMessageException v; java.lang.Object v, v; v := @this: org.apache.zookeeper.server.quorum.QuorumCnxManager; v := @parameter: java.net.Socket; v := @parameter: java.io.DataInputStream; v = null; label: v = virtualinvoke v.(); v = staticinvoke (v); v = virtualinvoke v.(); v = v cmp 0L; if v < 0 goto label; v = v; goto label; label: v = staticinvoke (v, v); v = v.; v = v.; v = interfaceinvoke v.(); if v != 0 goto label; v = new org.apache.zookeeper.server.quorum.MultipleAddresses; v = v.; v = v.; v = virtualinvoke v.(); v = staticinvoke (v); specialinvoke v.(java.util.Collection,java.time.Duration)>(v, v); v = v; label: v = ; v = v.; v = virtualinvoke v.(); v = staticinvoke (v); v = virtualinvoke v.(); interfaceinvoke v.("Initial message parsed by {}: {}", v, v); label: goto label; label: v := @caughtexception; v = ; interfaceinvoke v.("Initial message parsing error!", v); specialinvoke v.(v); label: return; label: v = virtualinvoke v.(); v = v cmp 9223372036854775807L; if v != 0 goto label; v = v.; v = virtualinvoke v.(); v = staticinvoke (v); v = ; interfaceinvoke v.("Setting arbitrary identifier to observer: {}", v); label: goto label; label: v := @caughtexception; v = ; interfaceinvoke v.("Exception reading or writing challenge", v); specialinvoke v.(v); return; label: v = v.; interfaceinvoke v.(v, v); v = virtualinvoke v.(); v = v.; v = virtualinvoke v.(); v = v cmp v; if v >= 0 goto label; v = v.; v = virtualinvoke v.(v); if v == null goto label; virtualinvoke v.(); label: v = ; interfaceinvoke v.("Create new connection to server: {}", v); specialinvoke v.(v); if v == null goto label; v = virtualinvoke v.(); virtualinvoke v.(v, v); goto label; label: v = virtualinvoke v.(); virtualinvoke v.(v); goto label; label: v = virtualinvoke v.(); v = v.; v = virtualinvoke v.(); v = v cmp v; if v != 0 goto label; v = ; interfaceinvoke v.("We got a connection request from a server with our own ID. This should be either a configuration error, or a bug."); goto label; label: v = new org.apache.zookeeper.server.quorum.QuorumCnxManager$SendWorker; specialinvoke v.(org.apache.zookeeper.server.quorum.QuorumCnxManager,java.net.Socket,java.lang.Long)>(v, v, v); v = new org.apache.zookeeper.server.quorum.QuorumCnxManager$RecvWorker; specialinvoke v.(org.apache.zookeeper.server.quorum.QuorumCnxManager,java.net.Socket,java.io.DataInputStream,java.lang.Long,org.apache.zookeeper.server.quorum.QuorumCnxManager$SendWorker)>(v, v, v, v, v); virtualinvoke v.(v); v = v.; v = virtualinvoke v.(v); if v == null goto label; virtualinvoke v.(); label: v = v.; virtualinvoke v.(v, v); v = v.; v = new org.apache.zookeeper.util.CircularBlockingQueue; specialinvoke v.(int)>(1); virtualinvoke v.(v, v); virtualinvoke v.(); virtualinvoke v.(); label: return; catch org.apache.zookeeper.server.quorum.QuorumCnxManager$InitialMessage$InitialMessageException from label to label with label; catch java.io.IOException from label to label with label; catch java.io.IOException from label to label with label; } public void toSend(java.lang.Long, java.nio.ByteBuffer) { java.util.concurrent.ConcurrentHashMap v; long v, v, v, v; java.util.function.Function v; org.apache.zookeeper.server.quorum.QuorumCnxManager v; java.nio.ByteBuffer v, v; org.apache.zookeeper.server.quorum.QuorumCnxManager$Message v; byte v; java.lang.Long v; java.lang.Object v; v := @this: org.apache.zookeeper.server.quorum.QuorumCnxManager; v := @parameter: java.lang.Long; v := @parameter: java.nio.ByteBuffer; v = v.; v = virtualinvoke v.(); v = v cmp v; if v != 0 goto label; virtualinvoke v.(0); v = new org.apache.zookeeper.server.quorum.QuorumCnxManager$Message; v = virtualinvoke v.(); v = virtualinvoke v.(); specialinvoke v.(java.nio.ByteBuffer,long)>(v, v); virtualinvoke v.(v); goto label; label: v = v.; v = staticinvoke (); v = virtualinvoke v.(v, v); specialinvoke v.(v, v); v = virtualinvoke v.(); virtualinvoke v.(v); label: return; } synchronized boolean connectOne(long, org.apache.zookeeper.server.quorum.MultipleAddresses) { org.apache.zookeeper.server.quorum.QuorumPeer v, v; long v; java.lang.Long v, v, v, v; int v; boolean v, v, v; org.slf4j.Logger v; java.util.concurrent.ConcurrentHashMap v, v; org.apache.zookeeper.server.quorum.QuorumCnxManager v; org.apache.zookeeper.server.quorum.MultipleAddresses v; java.lang.Object v, v; v := @this: org.apache.zookeeper.server.quorum.QuorumCnxManager; v := @parameter: long; v := @parameter: org.apache.zookeeper.server.quorum.MultipleAddresses; v = v.; v = staticinvoke (v); v = virtualinvoke v.(v); if v == null goto label; v = ; v = staticinvoke (v); interfaceinvoke v.("There is a connection already for server {}", v); v = v.; v = virtualinvoke v.(); if v == 0 goto label; v = virtualinvoke v.(); if v <= 1 goto label; v = v.; v = virtualinvoke v.(); if v == 0 goto label; v = v.; v = staticinvoke (v); v = virtualinvoke v.(v); virtualinvoke v.(); label: return 1; label: v = staticinvoke (v); v = virtualinvoke v.(v, v); return v; } synchronized void connectOne(long) { org.apache.zookeeper.server.quorum.QuorumPeer v, v, v, v, v, v, v, v; java.lang.Long v, v, v, v, v, v, v, v, v, v, v, v, v, v; java.util.Map v, v; boolean v, v, v, v, v, v, v, v; java.util.concurrent.ConcurrentHashMap v, v; org.apache.zookeeper.server.quorum.QuorumCnxManager v; java.lang.Throwable v; org.apache.zookeeper.server.quorum.flexible.QuorumVerifier v; long v, v, v; org.slf4j.Logger v, v, v, v; org.apache.zookeeper.server.quorum.MultipleAddresses v, v, v, v; java.lang.Object v, v, v, v, v, v, v; v := @this: org.apache.zookeeper.server.quorum.QuorumCnxManager; v := @parameter: long; v = v.; v = staticinvoke (v); v = virtualinvoke v.(v); if v == null goto label; v = ; v = staticinvoke (v); interfaceinvoke v.("There is a connection already for server {}", v); v = v.; v = virtualinvoke v.(); if v == 0 goto label; v = v.; v = virtualinvoke v.(); if v == 0 goto label; v = v.; v = staticinvoke (v); v = virtualinvoke v.(v); virtualinvoke v.(); label: return; label: v = v.; v = v.; entermonitor v; label: v = 0; v = v.; virtualinvoke v.(v); v = v.; v = virtualinvoke v.(); v = v.; v = virtualinvoke v.(); v = interfaceinvoke v.(); v = staticinvoke (v); v = interfaceinvoke v.(v); if v == 0 goto label; v = 1; v = ; v = v.; v = virtualinvoke v.(); v = staticinvoke (v); v = staticinvoke (v); interfaceinvoke v.("Server {} knows {} already, it is in the lastCommittedView", v, v); v = staticinvoke (v); v = interfaceinvoke v.(v); v = v.; v = virtualinvoke v.(v, v); if v == 0 goto label; exitmonitor v; label: return; label: v = staticinvoke (v); v = interfaceinvoke v.(v); if v == 0 goto label; if v == 0 goto label; v = staticinvoke (v); v = interfaceinvoke v.(v); v = v.; v = staticinvoke (v); v = interfaceinvoke v.(v); v = v.; v = virtualinvoke v.(v); if v != 0 goto label; label: v = 1; v = ; v = v.; v = virtualinvoke v.(); v = staticinvoke (v); v = staticinvoke (v); interfaceinvoke v.("Server {} knows {} already, it is in the lastProposedView", v, v); v = staticinvoke (v); v = interfaceinvoke v.(v); v = v.; v = virtualinvoke v.(v, v); if v == 0 goto label; exitmonitor v; label: return; label: if v != 0 goto label; v = ; v = staticinvoke (v); interfaceinvoke v.("Invalid server id: {} ", v); label: exitmonitor v; label: goto label; label: v := @caughtexception; exitmonitor v; throw v; label: return; catch java.lang.Throwable from label to label with label; catch java.lang.Throwable from label to label with label; catch java.lang.Throwable from label to label with label; } public void connectAll() { java.util.Enumeration v; java.util.concurrent.ConcurrentHashMap v; java.lang.Object v; long v; org.apache.zookeeper.server.quorum.QuorumCnxManager v; boolean v; v := @this: org.apache.zookeeper.server.quorum.QuorumCnxManager; v = v.; v = virtualinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.(v); goto label; label: return; } boolean haveDelivered() { org.slf4j.Logger v; java.util.Iterator v; java.util.Collection v; java.util.concurrent.ConcurrentHashMap v; java.lang.Integer v; org.apache.zookeeper.server.quorum.QuorumCnxManager v; int v; java.lang.Object v; boolean v; v := @this: org.apache.zookeeper.server.quorum.QuorumCnxManager; v = v.; v = virtualinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = interfaceinvoke v.(); v = ; v = staticinvoke (v); interfaceinvoke v.("Queue size: {}", v); if v != 0 goto label; return 1; label: return 0; } public void halt() { org.slf4j.Logger v, v; java.util.concurrent.ThreadPoolExecutor v, v; java.util.Set v; org.apache.zookeeper.server.quorum.QuorumCnxManager v; org.apache.zookeeper.server.quorum.QuorumCnxManager$Listener v, v; java.lang.InterruptedException v; v := @this: org.apache.zookeeper.server.quorum.QuorumCnxManager; v. = 1; v = ; interfaceinvoke v.("Halting listener"); v = v.; virtualinvoke v.(); label: v = v.; virtualinvoke v.(); label: goto label; label: v := @caughtexception; v = ; interfaceinvoke v.("Got interrupted before joining the listener", v); label: virtualinvoke v.(); v = v.; if v == null goto label; v = v.; virtualinvoke v.(); label: v = v.; interfaceinvoke v.(); specialinvoke v.(); return; catch java.lang.InterruptedException from label to label with label; } public void softHalt() { org.apache.zookeeper.server.quorum.QuorumPeer v; org.slf4j.Logger v; java.util.Iterator v; java.util.Collection v; java.util.concurrent.ConcurrentHashMap v; long v; org.apache.zookeeper.server.quorum.QuorumCnxManager v; java.lang.Long v; java.lang.Object v; boolean v; v := @this: org.apache.zookeeper.server.quorum.QuorumCnxManager; v = v.; v = virtualinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = ; v = v.; v = virtualinvoke v.(); v = staticinvoke (v); interfaceinvoke v.("Server {} is soft-halting sender towards: {}", v, v); virtualinvoke v.(); goto label; label: return; } private void setSockOpts(java.net.Socket) throws java.net.SocketException { java.net.Socket v; int v; org.apache.zookeeper.server.quorum.QuorumCnxManager v; boolean v; v := @this: org.apache.zookeeper.server.quorum.QuorumCnxManager; v := @parameter: java.net.Socket; virtualinvoke v.