public class org.apache.zookeeper.server.quorum.LearnerHandler extends org.apache.zookeeper.server.ZooKeeperThread { private static final org.slf4j.Logger LOG; public static final java.lang.String LEADER_CLOSE_SOCKET_ASYNC; public static final boolean closeSocketAsync; protected final java.net.Socket sock; java.util.concurrent.atomic.AtomicBoolean sockBeingClosed; final org.apache.zookeeper.server.quorum.LearnerMaster learnerMaster; volatile long tickOfNextAckDeadline; protected long sid; protected int version; final java.util.concurrent.LinkedBlockingQueue queuedPackets; private final java.util.concurrent.atomic.AtomicLong queuedPacketsSize; protected final java.util.concurrent.atomic.AtomicLong packetsReceived; protected final java.util.concurrent.atomic.AtomicLong packetsSent; protected final java.util.concurrent.atomic.AtomicLong requestsReceived; protected volatile long lastZxid; protected final java.util.Date established; private final int markerPacketInterval; private java.util.concurrent.atomic.AtomicInteger packetCounter; private org.apache.zookeeper.server.quorum.LearnerHandler$SyncLimitCheck syncLimitCheck; private org.apache.jute.BinaryInputArchive ia; private org.apache.jute.BinaryOutputArchive oa; private final java.io.BufferedInputStream bufferedInput; private java.io.BufferedOutputStream bufferedOutput; protected final org.apache.zookeeper.server.util.MessageTracker messageTracker; private volatile boolean sendingThreadStarted; public static final java.lang.String FORCE_SNAP_SYNC; private boolean forceSnapSync; private boolean needOpPacket; private long leaderLastZxid; private org.apache.zookeeper.server.quorum.LearnerSyncThrottler syncThrottler; final org.apache.zookeeper.server.quorum.QuorumPacket proposalOfDeath; private org.apache.zookeeper.server.quorum.QuorumPeer$LearnerType learnerType; public java.net.Socket getSocket() { org.apache.zookeeper.server.quorum.LearnerHandler v; java.net.Socket v; v := @this: org.apache.zookeeper.server.quorum.LearnerHandler; v = v.; return v; } long getSid() { org.apache.zookeeper.server.quorum.LearnerHandler v; long v; v := @this: org.apache.zookeeper.server.quorum.LearnerHandler; v = v.; return v; } java.lang.String getRemoteAddress() { org.apache.zookeeper.server.quorum.LearnerHandler v; java.net.Socket v, v; java.net.SocketAddress v; java.lang.String v; v := @this: org.apache.zookeeper.server.quorum.LearnerHandler; v = v.; if v != null goto label; v = ""; goto label; label: v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); label: return v; } int getVersion() { int v; org.apache.zookeeper.server.quorum.LearnerHandler v; v := @this: org.apache.zookeeper.server.quorum.LearnerHandler; v = v.; return v; } public synchronized long getLastZxid() { org.apache.zookeeper.server.quorum.LearnerHandler v; long v; v := @this: org.apache.zookeeper.server.quorum.LearnerHandler; v = v.; return v; } public java.util.Date getEstablished() { org.apache.zookeeper.server.quorum.LearnerHandler v; java.lang.Object v; java.util.Date v; v := @this: org.apache.zookeeper.server.quorum.LearnerHandler; v = v.; v = virtualinvoke v.(); return v; } protected void setOutputArchive(org.apache.jute.BinaryOutputArchive) { org.apache.zookeeper.server.quorum.LearnerHandler v; org.apache.jute.BinaryOutputArchive v; v := @this: org.apache.zookeeper.server.quorum.LearnerHandler; v := @parameter: org.apache.jute.BinaryOutputArchive; v. = v; return; } protected void setBufferedOutput(java.io.BufferedOutputStream) { org.apache.zookeeper.server.quorum.LearnerHandler v; java.io.BufferedOutputStream v; v := @this: org.apache.zookeeper.server.quorum.LearnerHandler; v := @parameter: java.io.BufferedOutputStream; v. = v; return; } void (java.net.Socket, java.io.BufferedInputStream, org.apache.zookeeper.server.quorum.LearnerMaster) throws java.io.IOException { java.io.DataInputStream v; java.net.Socket v; java.io.BufferedInputStream v; java.net.SocketAddress v, v; java.util.Date v; java.util.concurrent.atomic.AtomicBoolean v; javax.security.sasl.SaslException v; org.apache.zookeeper.server.util.MessageTracker v; org.apache.zookeeper.server.quorum.QuorumPacket v; java.util.concurrent.atomic.AtomicInteger v; org.apache.zookeeper.server.quorum.QuorumPeer$LearnerType v; int v; java.lang.String v, v, v; org.apache.zookeeper.server.quorum.LearnerHandler$SyncLimitCheck v; boolean v; org.slf4j.Logger v, v; org.apache.zookeeper.server.quorum.auth.QuorumAuthServer v; java.io.IOException v; java.util.concurrent.LinkedBlockingQueue v; org.apache.zookeeper.server.quorum.LearnerMaster v; org.apache.zookeeper.server.quorum.LearnerHandler v; java.util.concurrent.atomic.AtomicLong v, v, v, v; v := @this: org.apache.zookeeper.server.quorum.LearnerHandler; v := @parameter: java.net.Socket; v := @parameter: java.io.BufferedInputStream; v := @parameter: org.apache.zookeeper.server.quorum.LearnerMaster; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("LearnerHandler-\u0001"); specialinvoke v.(java.lang.String)>(v); v = new java.util.concurrent.atomic.AtomicBoolean; specialinvoke v.(boolean)>(0); v. = v; v. = 0L; v. = 1; v = new java.util.concurrent.LinkedBlockingQueue; specialinvoke v.()>(); v. = v; v = new java.util.concurrent.atomic.AtomicLong; specialinvoke v.()>(); v. = v; v = new java.util.concurrent.atomic.AtomicLong; specialinvoke v.()>(); v. = v; v = new java.util.concurrent.atomic.AtomicLong; specialinvoke v.()>(); v. = v; v = new java.util.concurrent.atomic.AtomicLong; specialinvoke v.()>(); v. = v; v. = -1L; v = new java.util.Date; specialinvoke v.()>(); v. = v; v. = 1000; v = new java.util.concurrent.atomic.AtomicInteger; specialinvoke v.()>(); v. = v; v = new org.apache.zookeeper.server.quorum.LearnerHandler$SyncLimitCheck; specialinvoke v.(org.apache.zookeeper.server.quorum.LearnerHandler)>(v); v. = v; v. = 0; v. = 0; v. = 1; v. = null; v = new org.apache.zookeeper.server.quorum.QuorumPacket; specialinvoke v.()>(); v. = v; v = ; v. = v; v. = v; v. = v; v. = v; v = staticinvoke ("zookeeper.forceSnapshotSync"); if v == 0 goto label; v. = 1; v = ; interfaceinvoke v.("Forcing snapshot sync is enabled"); label: v = virtualinvoke v.(); if v == null goto label; v = new java.io.DataInputStream; specialinvoke v.(java.io.InputStream)>(v); interfaceinvoke v.(v, v); label: goto label; label: v := @caughtexception; v = ; v = virtualinvoke v.(); interfaceinvoke v.("Server failed to authenticate quorum learner, addr: {}, closing connection", v, v); virtualinvoke v.(); v = new javax.security.sasl.SaslException; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("Authentication failure: \u0001"); specialinvoke v.(java.lang.String)>(v); throw v; label: v = new org.apache.zookeeper.server.util.MessageTracker; v = ; specialinvoke v.(int)>(v); v. = v; return; catch java.io.IOException from label to label with label; } public java.lang.String toString() { java.net.Socket v; long v; java.util.concurrent.LinkedBlockingQueue v; org.apache.zookeeper.server.quorum.LearnerHandler v; int v; java.lang.StringBuilder v, v, v, v, v; java.lang.String v; boolean v; v := @this: org.apache.zookeeper.server.quorum.LearnerHandler; v = new java.lang.StringBuilder; specialinvoke v.()>(); v = virtualinvoke v.("LearnerHandler "); v = v.; virtualinvoke v.(v); v = virtualinvoke v.(" tickOfNextAckDeadline:"); v = virtualinvoke v.(); virtualinvoke v.(v); v = virtualinvoke v.(" synced?:"); v = virtualinvoke v.(); virtualinvoke v.(v); v = virtualinvoke v.(" queuedPacketLength:"); v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); v = virtualinvoke v.(); return v; } public org.apache.zookeeper.server.quorum.QuorumPeer$LearnerType getLearnerType() { org.apache.zookeeper.server.quorum.LearnerHandler v; org.apache.zookeeper.server.quorum.QuorumPeer$LearnerType v; v := @this: org.apache.zookeeper.server.quorum.LearnerHandler; v = v.; return v; } private void sendPackets() throws java.lang.InterruptedException { org.apache.jute.BinaryOutputArchive v; org.apache.zookeeper.server.util.MessageTracker v; org.apache.zookeeper.metrics.SummarySet v, v; org.apache.zookeeper.server.quorum.QuorumPacket v, v; byte v; boolean v, v; java.util.concurrent.LinkedBlockingQueue v, v, v; org.apache.zookeeper.server.quorum.LearnerHandler v; long v, v, v, v, v, v, v, v, v, v, v, v, v; java.io.BufferedOutputStream v; org.apache.zookeeper.server.ServerMetrics v, v; int v, v, v, v; java.lang.String v, v; org.apache.zookeeper.server.quorum.LearnerHandler$SyncLimitCheck v; org.slf4j.Logger v, v, v; java.io.IOException v; java.util.concurrent.atomic.AtomicLong v, v; java.lang.Object v; v := @this: org.apache.zookeeper.server.quorum.LearnerHandler; label: v = v.; v = virtualinvoke v.(); if v != null goto label; v = v.; virtualinvoke v.(); v = v.; virtualinvoke v.(); label: v = staticinvoke (); v = v.; v = v.; v = staticinvoke (v); v = v.; v = virtualinvoke v.(); interfaceinvoke v.(v, v); v = v instanceof org.apache.zookeeper.server.quorum.LearnerHandler$MarkerQuorumPacket; if v == 0 goto label; v = staticinvoke (); v = v.; v = v.; v = staticinvoke (v); v = staticinvoke (); v = v.; v = v - v; v = v / 1000000L; interfaceinvoke v.(v, v); label: goto label; label: v = v.; v = staticinvoke (v); v = neg v; virtualinvoke v.(v); v = v.; if v == v goto label; label: v = virtualinvoke v.(); if v != 2 goto label; v = v.; v = virtualinvoke v.(); v = staticinvoke (); virtualinvoke v.(v, v); label: v = ; v = interfaceinvoke v.(); if v == 0 goto label; v = 16L; v = virtualinvoke v.(); if v != 5 goto label; v = 128L; label: v = ; staticinvoke (v, v, 111, v); label: v = virtualinvoke v.(); v = v cmp 0L; if v <= 0 goto label; v = virtualinvoke v.(); v. = v; label: v = v.; virtualinvoke v.(v, "packet"); v = v.; virtualinvoke v.(); v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); label: goto label; label: v := @caughtexception; v = ; interfaceinvoke v.("Exception while sending packets in LearnerHandler", 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; catch java.io.IOException from label to label with label; } public static java.lang.String packetToString(org.apache.zookeeper.server.quorum.QuorumPacket) { byte[] v; java.io.DataInputStream v; org.slf4j.Logger v; java.io.IOException v; long v, v; org.apache.zookeeper.server.quorum.QuorumPacket v; java.io.ByteArrayInputStream v; int v, v; java.lang.String v, v, v, v; v := @parameter: org.apache.zookeeper.server.quorum.QuorumPacket; v = null; v = virtualinvoke v.(); tableswitch(v) { case 1: goto label; case 2: goto label; case 3: goto label; case 4: goto label; case 5: goto label; case 6: goto label; case 7: goto label; case 8: goto label; case 9: goto label; case 10: goto label; case 11: goto label; case 12: goto label; case 13: goto label; case 14: goto label; case 15: goto label; case 16: goto label; case 17: goto label; case 18: goto label; case 19: goto label; default: goto label; }; label: v = "ACK"; goto label; label: v = "COMMIT"; goto label; label: v = "FOLLOWERINFO"; goto label; label: v = "NEWLEADER"; goto label; label: v = "PING"; goto label; label: v = "PROPOSAL"; goto label; label: v = "REQUEST"; goto label; label: v = "REVALIDATE"; v = new java.io.ByteArrayInputStream; v = virtualinvoke v.(); specialinvoke v.(byte[])>(v); v = new java.io.DataInputStream; specialinvoke v.(java.io.InputStream)>(v); label: v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) (" sessionid = \u0001"); label: goto label; label: v := @caughtexception; v = ; interfaceinvoke v.("Unexpected exception", v); goto label; label: v = "UPTODATE"; goto label; label: v = "DIFF"; goto label; label: v = "TRUNC"; goto label; label: v = "SNAP"; goto label; label: v = "ACKEPOCH"; goto label; label: v = "SYNC"; goto label; label: v = "INFORM"; goto label; label: v = "COMMITANDACTIVATE"; goto label; label: v = "INFORMANDACTIVATE"; goto label; label: v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("UNKNOWN\u0001"); label: v = null; if v == null goto label; v = virtualinvoke v.(); v = staticinvoke (v); v = dynamicinvoke "makeConcatWithConstants" (v, v, v) ("\u \u \u0001"); label: return v; catch java.io.IOException from label to label with label; } public void run() { java.io.BufferedInputStream v; org.apache.zookeeper.metrics.Counter v, v, v, v; java.lang.Integer v; org.apache.zookeeper.server.quorum.StateSummary v, v, v; org.apache.zookeeper.server.quorum.LearnerHandler v; org.apache.zookeeper.server.quorum.LearnerSyncRequest v; org.apache.jute.BinaryOutputArchive v, v, v, v, v, v; java.io.ByteArrayInputStream v; java.io.DataInputStream 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, v, v, v, v, v, v, v, v; org.apache.jute.BinaryInputArchive v, v, v, v, v; org.apache.zookeeper.server.RequestRecord v, v; java.lang.Exception v; java.lang.String v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; java.net.SocketAddress v; org.apache.zookeeper.metrics.Summary v, v, v, v; boolean v, v, v, v, v; org.apache.zookeeper.server.Request v, v; java.util.List v, v; java.io.OutputStream v; byte[] v, v, v, v, v, v; byte v; java.lang.Long v, v, v, v, v, v; org.apache.zookeeper.server.quorum.LearnerMaster 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; java.lang.Object[] v; long 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; java.io.IOException v, v, v; java.util.concurrent.atomic.AtomicLong v, v; org.slf4j.Logger 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.apache.zookeeper.server.util.MessageTracker v, v, v, v, v, v, v, v, v, v, v, v, v; org.apache.zookeeper.server.quorum.QuorumPacket v, v, v, v, v, v, v, v, v; java.lang.Throwable v, v; org.apache.zookeeper.server.ZKDatabase v, v; java.io.BufferedOutputStream v, v, v, v, v, v; org.apache.zookeeper.server.ServerMetrics v, v, v, v, v, v, v, v; org.apache.zookeeper.server.quorum.LearnerHandler$SyncLimitCheck v, v; java.nio.ByteBuffer v, v, v, v, v; org.apache.zookeeper.server.quorum.QuorumPeer$LearnerType v, v, v, v, v; org.apache.zookeeper.server.quorum.SyncThrottleException v; java.util.concurrent.LinkedBlockingQueue v, v; java.net.Socket v, v, v, v; org.apache.zookeeper.server.quorum.LearnerSyncThrottler v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; java.lang.InterruptedException v; v := @this: org.apache.zookeeper.server.quorum.LearnerHandler; label: v = v.; virtualinvoke v.(v); v = v.; v = virtualinvoke v.(); v. = v; v = v.; v = staticinvoke (v); v. = v; v = new java.io.BufferedOutputStream; v = v.; v = virtualinvoke v.(); specialinvoke v.(java.io.OutputStream)>(v); v. = v; v = v.; v = staticinvoke (v); v. = v; v = new org.apache.zookeeper.server.quorum.QuorumPacket; specialinvoke v.()>(); v = v.; virtualinvoke v.(v, "packet"); v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); v = virtualinvoke v.(); if v == 11 goto label; v = virtualinvoke v.(); if v == 16 goto label; v = ; v = virtualinvoke v.(); interfaceinvoke v.("First packet {} is not FOLLOWERINFO or OBSERVERINFO!", v); label: v = v.; if v == null goto label; v = v.; virtualinvoke v.(); v. = null; label: v = virtualinvoke v.(); v = ; interfaceinvoke v.("******* GOODBYE {} ********", v); v = v.; virtualinvoke v.(v); virtualinvoke v.(); return; label: v = v.; v = v instanceof org.apache.zookeeper.server.quorum.ObserverMaster; if v == 0 goto label; v = virtualinvoke v.(); if v == 16 goto label; v = new java.io.IOException; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("Non observer attempting to connect to ObserverMaster. type = \u0001"); specialinvoke v.(java.lang.String)>(v); throw v; label: v = virtualinvoke v.(); if v == null goto label; v = staticinvoke (v); v = lengthof v; if v < 8 goto label; v = virtualinvoke v.(); v. = v; label: v = lengthof v; if v < 12 goto label; v = virtualinvoke v.(); v. = v; label: v = lengthof v; if v < 20 goto label; v = virtualinvoke v.(); v = v.; v = virtualinvoke v.(); v = v cmp v; if v <= 0 goto label; v = new java.io.IOException; specialinvoke v.(java.lang.String)>("Follower is ahead of the leader (has a later activated configuration)"); throw v; label: v = v.; v = virtualinvoke v.(); v. = v; label: v = v.; v = v.; v = virtualinvoke v.(v); v = virtualinvoke v.(); if v == 0 goto label; v = ; v = v.; v = staticinvoke (v); v = v.; v = virtualinvoke v.(); v = staticinvoke (v); interfaceinvoke v.("Follower sid: {} not in the current config {}", v, v); goto label; label: v = ; v = v.; v = staticinvoke (v); interfaceinvoke v.("Follower sid: {} : info : {}", v, v); label: v = virtualinvoke v.(); if v != 16 goto label; v = ; v. = v; label: v = v.; v = v.; virtualinvoke v.(v, v); v = virtualinvoke v.(); v = staticinvoke (v); v = virtualinvoke v.(); v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(v, v); v = staticinvoke (v, 0L); v = virtualinvoke v.(); if v >= 65536 goto label; v = staticinvoke (v); v = new org.apache.zookeeper.server.quorum.StateSummary; specialinvoke v.(long,long)>(v, v); v = v; v = v.; v = virtualinvoke v.(); virtualinvoke v.(v, v); goto label; label: v = newarray (byte)[4]; v = staticinvoke (v); virtualinvoke v.(65536); v = new org.apache.zookeeper.server.quorum.QuorumPacket; specialinvoke v.(int,long,byte[],java.util.List)>(17, v, v, null); v = v.; virtualinvoke v.(v, "packet"); v = v.; virtualinvoke v.(17); v = v.; virtualinvoke v.(); v = new org.apache.zookeeper.server.quorum.QuorumPacket; specialinvoke v.()>(); v = v.; virtualinvoke v.(v, "packet"); v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); v = virtualinvoke v.(); if v == 18 goto label; v = ; v = virtualinvoke v.(); interfaceinvoke v.("{} is not ACKEPOCH", v); label: v = v.; if v == null goto label; v = v.; virtualinvoke v.(); v. = null; label: v = virtualinvoke v.(); v = ; interfaceinvoke v.("******* GOODBYE {} ********", v); v = v.; virtualinvoke v.(v); virtualinvoke v.(); return; label: v = virtualinvoke v.(); v = staticinvoke (v); v = new org.apache.zookeeper.server.quorum.StateSummary; v = virtualinvoke v.(); v = virtualinvoke v.(); specialinvoke v.(long,long)>(v, v); v = v; v = v.; v = virtualinvoke v.(); virtualinvoke v.(v, v); label: v = virtualinvoke v.(); v = v.; v = virtualinvoke v.(v, v); v = virtualinvoke v.(); v = ; if v == v goto label; v = 1; goto label; label: v = 0; label: if v == 0 goto label; v = v.; v = virtualinvoke v.(); v. = v; v = v.; virtualinvoke v.(v); v = staticinvoke (); v = v.; v = v.; v = virtualinvoke v.(); interfaceinvoke v.(v); label: v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); v = v.; v = new org.apache.zookeeper.server.quorum.QuorumPacket; specialinvoke v.(int,long,byte[],java.util.List)>(15, v, null, null); virtualinvoke v.(v, "packet"); v = v.; virtualinvoke v.(15); v = v.; virtualinvoke v.(); v = ; v = newarray (java.lang.Object)[5]; v = staticinvoke (v); v[0] = v; v = v.; v = staticinvoke (v); v[1] = v; v = staticinvoke (v); v[2] = v; v = v.; v = virtualinvoke v.(); v = staticinvoke (v); v[3] = v; if v == 0 goto label; v = "exempt"; goto label; label: v = "not exempt"; label: v[4] = v; interfaceinvoke v.("Sending snapshot last zxid of peer is 0x{}, zxid of leader is 0x{}, send zxid of db as 0x{}, {} concurrent snapshot sync, snapshot sync was {} from throttle", v); v = v.; v = virtualinvoke v.(); v = v.; virtualinvoke v.(v); v = v.; virtualinvoke v.("BenWasHere", "signature"); v = v.; virtualinvoke v.(); label: v = staticinvoke (); v = v.; interfaceinvoke v.(1L); goto label; label: v := @caughtexception; v = staticinvoke (); v = v.; interfaceinvoke v.(1L); throw v; label: v = v.; v = virtualinvoke v.(); v. = v; v = v.; virtualinvoke v.(v); v = staticinvoke (); v = v.; v = v.; v = virtualinvoke v.(); interfaceinvoke v.(v); v = staticinvoke (); v = v.; interfaceinvoke v.(1L); label: v = ; v = v.; v = staticinvoke (v); interfaceinvoke v.("Sending NEWLEADER message to {}", v); v = virtualinvoke v.(); if v >= 65536 goto label; v = new org.apache.zookeeper.server.quorum.QuorumPacket; specialinvoke v.(int,long,byte[],java.util.List)>(10, v, null, null); v = v.; virtualinvoke v.(v, "packet"); goto label; label: v = new org.apache.zookeeper.server.quorum.QuorumPacket; v = v.; v = virtualinvoke v.(); specialinvoke v.(int,long,byte[],java.util.List)>(10, v, v, null); v = v.; virtualinvoke v.(v); label: v = v.; virtualinvoke v.(); virtualinvoke v.(); v = new org.apache.zookeeper.server.quorum.QuorumPacket; specialinvoke v.()>(); v = v.; virtualinvoke v.(v, "packet"); v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); v = virtualinvoke v.(); if v == 3 goto label; v = ; v = staticinvoke (v); interfaceinvoke v.("Next packet was supposed to be an ACK, but received packet: {}", v); label: v = v.; if v == null goto label; v = v.; virtualinvoke v.(); v. = null; label: v = virtualinvoke v.(); v = ; interfaceinvoke v.("******* GOODBYE {} ********", v); v = v.; virtualinvoke v.(v); virtualinvoke v.(); return; label: v = ; v = v.; v = staticinvoke (v); interfaceinvoke v.("Received NEWLEADER-ACK message from {}", v); v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.(v, v); v = v.; virtualinvoke v.(); v = v.; virtualinvoke v.(); if v == 0 goto label; v = staticinvoke (); v = v.; v = v.; v = virtualinvoke v.(); interfaceinvoke v.(v); goto label; label: v = staticinvoke (); v = v.; v = v.; v = virtualinvoke v.(); interfaceinvoke v.(v); label: v. = null; v = v.; v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; virtualinvoke v.(); v =