public class org.apache.zookeeper.server.PrepRequestProcessor extends org.apache.zookeeper.server.ZooKeeperCriticalThread implements org.apache.zookeeper.server.RequestProcessor { private static final org.slf4j.Logger LOG; private static boolean failCreate; java.util.concurrent.LinkedBlockingQueue submittedRequests; private final org.apache.zookeeper.server.RequestProcessor nextProcessor; private final boolean digestEnabled; private org.apache.zookeeper.server.DigestCalculator digestCalculator; org.apache.zookeeper.server.ZooKeeperServer zks; public void (org.apache.zookeeper.server.ZooKeeperServer, org.apache.zookeeper.server.RequestProcessor) { org.apache.zookeeper.server.DigestCalculator v; long v; java.util.concurrent.LinkedBlockingQueue v; org.apache.zookeeper.server.PrepRequestProcessor v; org.apache.zookeeper.server.ZooKeeperServer v; int v; org.apache.zookeeper.server.ZooKeeperServerListener v; java.lang.String v; org.apache.zookeeper.server.RequestProcessor v; boolean v, v; v := @this: org.apache.zookeeper.server.PrepRequestProcessor; v := @parameter: org.apache.zookeeper.server.ZooKeeperServer; v := @parameter: org.apache.zookeeper.server.RequestProcessor; v = virtualinvoke v.(); v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v, v) ("ProcessThread(sid:\u cport:\u):"); v = virtualinvoke v.(); specialinvoke v.(java.lang.String,org.apache.zookeeper.server.ZooKeeperServerListener)>(v, v); v = new java.util.concurrent.LinkedBlockingQueue; specialinvoke v.()>(); v. = v; v. = v; v. = v; v = staticinvoke (); v. = v; v = v.; if v == 0 goto label; v = new org.apache.zookeeper.server.DigestCalculator; specialinvoke v.()>(); v. = v; label: return; } public static void setFailCreate(boolean) { boolean v; v := @parameter: boolean; = v; return; } public void run() { java.lang.Object[] v; long v, v, v, v, v, v; org.apache.zookeeper.metrics.Summary v, v; java.lang.Long v; org.apache.zookeeper.server.ServerMetrics v, v; int v, v; java.lang.Boolean v; java.lang.String v, v; boolean v, v; org.slf4j.Logger v, v, v, v; java.util.concurrent.LinkedBlockingQueue v, v; java.lang.Exception v; org.apache.zookeeper.server.PrepRequestProcessor v; org.apache.zookeeper.server.Request v; org.apache.zookeeper.server.ZooKeeperServer v, v; java.lang.Object v; v := @this: org.apache.zookeeper.server.PrepRequestProcessor; v = ; v = newarray (java.lang.Object)[2]; v = v.; v = virtualinvoke v.(); v = staticinvoke (v); v[0] = v; v = v.; v = v.; v = staticinvoke (v); v[1] = v; v = staticinvoke ("PrepRequestProcessor (sid:%d) started, reconfigEnabled=%s", v); interfaceinvoke v.(v); label: v = staticinvoke (); v = v.; v = v.; v = virtualinvoke v.(); interfaceinvoke v.(v); v = v.; v = virtualinvoke v.(); v = staticinvoke (); v = v.; v = staticinvoke (); v = v.; v = v - v; interfaceinvoke v.(v); v = ; v = interfaceinvoke v.(); if v == 0 goto label; v = 2L; v = v.; if v != 11 goto label; v = 8L; label: v = ; staticinvoke (v, v, 80, v, ""); label: v = ; if v == v goto label; v = staticinvoke (); v. = v; virtualinvoke v.(v); goto label; label: v := @caughtexception; v = virtualinvoke v.(); virtualinvoke v.(v, v); label: v = ; interfaceinvoke v.("PrepRequestProcessor exited loop!"); return; catch java.lang.Exception from label to label with label; } private org.apache.zookeeper.server.ZooKeeperServer$ChangeRecord getRecordForPath(java.lang.String) throws org.apache.zookeeper.KeeperException$NoNodeException { java.lang.Throwable v, v; byte[] v; org.apache.zookeeper.server.DigestCalculator v; org.apache.zookeeper.server.ZKDatabase v, v; long v; org.apache.zookeeper.server.ZooKeeperServer$ChangeRecord v; java.util.Deque v; org.apache.zookeeper.KeeperException$NoNodeException v; org.apache.zookeeper.server.ZooKeeperServer$PrecalculatedDigest v; java.util.Map v; int v; org.apache.zookeeper.data.StatPersisted v, v; java.lang.String v; boolean v; org.apache.zookeeper.server.DataNode v; java.util.Set v; org.apache.zookeeper.server.PrepRequestProcessor v; org.apache.zookeeper.server.ZooKeeperServer v, v, v, v; java.util.List v; java.lang.Object v; v := @this: org.apache.zookeeper.server.PrepRequestProcessor; v := @parameter: java.lang.String; v = v.; v = v.; entermonitor v; label: v = v.; v = v.; v = interfaceinvoke v.(v); if v != null goto label; v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(v); if v == null goto label; entermonitor v; label: v = virtualinvoke v.(); exitmonitor v; label: goto label; label: v := @caughtexception; exitmonitor v; throw v; label: v = new org.apache.zookeeper.server.ZooKeeperServer$ChangeRecord; v = v.; v = interfaceinvoke v.(); v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(v); specialinvoke v.(long,java.lang.String,org.apache.zookeeper.data.StatPersisted,int,java.util.List)>(-1L, v, v, v, v); v = v; v = v.; if v == 0 goto label; v = new org.apache.zookeeper.server.ZooKeeperServer$PrecalculatedDigest; v = v.; v = virtualinvoke v.(v, v); specialinvoke v.(long,long)>(v, 0L); v. = v; label: v = virtualinvoke v.(); v. = v; label: exitmonitor v; label: goto label; label: v := @caughtexception; exitmonitor v; throw v; label: if v == null goto label; v = v.; if v != null goto label; label: v = new org.apache.zookeeper.KeeperException$NoNodeException; specialinvoke v.(java.lang.String)>(v); throw v; label: return v; catch java.lang.Throwable from label to label with label; catch java.lang.Throwable from label to label with label; } private org.apache.zookeeper.server.ZooKeeperServer$ChangeRecord getOutstandingChange(java.lang.String) { java.lang.Throwable v; java.util.Deque v; org.apache.zookeeper.server.PrepRequestProcessor v; org.apache.zookeeper.server.ZooKeeperServer v, v; java.util.Map v; java.lang.Object v; java.lang.String v; v := @this: org.apache.zookeeper.server.PrepRequestProcessor; v := @parameter: java.lang.String; v = v.; v = v.; entermonitor v; label: v = v.; v = v.; v = interfaceinvoke v.(v); exitmonitor v; label: return v; label: v := @caughtexception; exitmonitor v; throw v; catch java.lang.Throwable from label to label with label; } protected void addChangeRecord(org.apache.zookeeper.server.ZooKeeperServer$ChangeRecord) { java.lang.Throwable v; org.apache.zookeeper.metrics.Counter v; org.apache.zookeeper.server.ZooKeeperServer$ChangeRecord v; java.util.Deque v, v; org.apache.zookeeper.server.PrepRequestProcessor v; org.apache.zookeeper.server.ZooKeeperServer v, v, v; org.apache.zookeeper.server.ServerMetrics v; java.util.Map v; java.lang.String v; v := @this: org.apache.zookeeper.server.PrepRequestProcessor; v := @parameter: org.apache.zookeeper.server.ZooKeeperServer$ChangeRecord; v = v.; v = v.; entermonitor v; label: v = v.; v = v.; interfaceinvoke v.(v); v = v.; v = v.; v = v.; interfaceinvoke v.(v, v); v = staticinvoke (); v = v.; interfaceinvoke v.(1L); exitmonitor v; label: goto label; label: v := @caughtexception; exitmonitor v; throw v; label: return; catch java.lang.Throwable from label to label with label; } private java.util.Map getPendingChanges(org.apache.zookeeper.MultiOperationRecord) { java.util.Iterator v; java.util.HashMap v; org.apache.zookeeper.server.ZooKeeperServer$ChangeRecord v, v; org.apache.zookeeper.server.PrepRequestProcessor v; org.apache.zookeeper.MultiOperationRecord v; int v, v, v, v; java.lang.Object v; java.lang.String v, v; boolean v; v := @this: org.apache.zookeeper.server.PrepRequestProcessor; v := @parameter: org.apache.zookeeper.MultiOperationRecord; v = new java.util.HashMap; specialinvoke v.()>(); v = virtualinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = virtualinvoke v.(); v = specialinvoke v.(v); if v == null goto label; interfaceinvoke v.(v, v); label: v = virtualinvoke v.(47); v = (int) -1; if v == v goto label; v = virtualinvoke v.(0); v = (int) -1; if v != v goto label; v = virtualinvoke v.(0, v); v = specialinvoke v.(v); if v == null goto label; interfaceinvoke v.(v, v); goto label; label: return v; } void rollbackPendingChanges(long, java.util.Map) { byte v, v; java.util.Map v, v, v; boolean v, v, v; java.util.Collection v; org.apache.zookeeper.server.PrepRequestProcessor v; java.lang.Throwable v; long v, v, v, v; java.util.Deque v, v, v, v; java.lang.String v, v; java.util.Iterator v, v; org.apache.zookeeper.server.ZooKeeperServer v, v, v, v, v, v; java.lang.Object v, v, v; v := @this: org.apache.zookeeper.server.PrepRequestProcessor; v := @parameter: long; v := @parameter: java.util.Map; v = v.; v = v.; entermonitor v; label: v = v.; v = v.; v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = v.; v = v cmp v; if v != 0 goto label; interfaceinvoke v.(); v = v.; v = v.; v = v.; interfaceinvoke v.(v); goto label; label: v = v.; v = v.; v = interfaceinvoke v.(); if v == 0 goto label; exitmonitor v; label: return; label: v = v.; v = v.; v = interfaceinvoke v.(); v = v.; v = interfaceinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = v.; v = v cmp v; if v < 0 goto label; v = v.; v = v.; v = v.; interfaceinvoke v.(v, v); goto label; 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; } private java.lang.String validatePathForCreate(java.lang.String, long) throws org.apache.zookeeper.KeeperException$BadArgumentsException { org.slf4j.Logger v; long v; org.apache.zookeeper.server.PrepRequestProcessor v; org.apache.zookeeper.KeeperException$BadArgumentsException v; int v, v, v, v; java.lang.String v, v, v; boolean v; v := @this: org.apache.zookeeper.server.PrepRequestProcessor; v := @parameter: java.lang.String; v := @parameter: long; v = virtualinvoke v.(47); v = (int) -1; if v == v goto label; v = virtualinvoke v.(0); v = (int) -1; if v != v goto label; v = ; if v == 0 goto label; label: v = ; v = staticinvoke (v); interfaceinvoke v.("Invalid path {} with session 0x{}", v, v); v = new org.apache.zookeeper.KeeperException$BadArgumentsException; specialinvoke v.(java.lang.String)>(v); throw v; label: v = virtualinvoke v.(0, v); return v; } protected void pRequest2Txn(int, long, org.apache.zookeeper.server.Request, org.apache.jute.Record) throws org.apache.zookeeper.KeeperException, java.io.IOException, org.apache.zookeeper.server.RequestProcessor$RequestProcessorException { java.lang.Integer v; org.apache.zookeeper.server.PrepRequestProcessor$DigestOpCode v, v, v, v, v, v, v, v, v; org.apache.jute.Record v, v; java.util.function.Supplier v; java.io.StringReader v; org.apache.zookeeper.KeeperException$BadVersionException v, v; org.apache.zookeeper.server.ServerCnxn v, v, v, v, 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; org.apache.zookeeper.server.quorum.QuorumPeerConfig$ConfigException v; org.apache.zookeeper.server.quorum.Leader v; org.apache.zookeeper.server.SessionTracker v, v, v, v, v, v, v; java.lang.Exception v; org.apache.zookeeper.server.PrepRequestProcessor v; org.apache.zookeeper.server.quorum.QuorumPeer$QuorumServer v; java.util.ArrayList v; org.apache.zookeeper.server.ZooKeeperServer$PrecalculatedDigest v, v, v, v, v, v, v, v, v, v, v, v, v, v; org.apache.zookeeper.data.StatPersisted 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.String v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; java.util.Properties v; org.apache.zookeeper.txn.TxnHeader v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; org.apache.zookeeper.KeeperException$ReconfigDisabledException v; org.apache.zookeeper.metrics.Summary v; boolean v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; java.net.InetSocketAddress v; org.apache.zookeeper.server.Request v; java.util.List v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; org.apache.zookeeper.KeeperException$ReconfigInProgress v; org.apache.zookeeper.txn.SetACLTxn v; org.apache.zookeeper.server.ZooKeeperServer$ChangeRecord v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; org.apache.zookeeper.txn.TxnDigest v; java.util.Deque v, v; org.apache.zookeeper.KeeperException$NotEmptyException v, v; org.apache.zookeeper.server.quorum.flexible.QuorumMaj v; byte[] v, v, v, v, v, v, v, v, v, v, v, v; org.apache.zookeeper.txn.CreateSessionTxn v; byte v, v, v, v, v; java.lang.Long v, v, v, v; java.util.Map v, v, v; org.apache.zookeeper.txn.DeleteTxn v, v; java.lang.Object[] v; org.apache.zookeeper.server.quorum.flexible.QuorumVerifier v, v, v, v, v, v, v, v, v, v, 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, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; org.apache.zookeeper.server.EphemeralType v, v; org.apache.zookeeper.server.ZooKeeperServer v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; org.apache.zookeeper.server.quorum.MultipleAddresses v, v; org.apache.zookeeper.KeeperException$NewConfigNoQuorum v; org.apache.zookeeper.txn.SetDataTxn v, v; java.util.Collection v; org.apache.zookeeper.txn.CheckVersionTxn v; org.slf4j.Logger v, v, v, v, v, v, v, v, v; org.apache.zookeeper.server.quorum.flexible.QuorumOracleMaj v; org.apache.zookeeper.txn.CloseSessionTxn v; java.lang.Object v, v, v, v, v, v, v, v, v, v, v; org.apache.zookeeper.server.quorum.QuorumPeer v, v, v, v, v; java.util.Set v; java.lang.Throwable v; org.apache.zookeeper.server.ZKDatabase v; org.apache.zookeeper.server.ServerMetrics v; org.apache.zookeeper.KeeperException$BadArgumentsException v, v, v, v, v, v, v; java.lang.String[] v; java.util.HashMap v; java.util.Iterator v, v, v, v, v; v := @this: org.apache.zookeeper.server.PrepRequestProcessor; v := @parameter: int; v := @parameter: long; v := @parameter: org.apache.zookeeper.server.Request; v := @parameter: org.apache.jute.Record; v = virtualinvoke v.(); if v != null goto label; v = new org.apache.zookeeper.txn.TxnHeader; v = v.; v = v.; v = staticinvoke (); specialinvoke v.(long,int,long,long,int)>(v, v, v, v, v); virtualinvoke v.(v); label: tableswitch(v) { case -11: goto label; case -10: goto label; case -9: goto label; case -8: goto label; case -7: goto label; case -6: goto label; case -5: goto label; case -4: goto label; case -3: goto label; case -2: goto label; case -1: goto label; case 0: goto label; 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; case 20: goto label; case 21: goto label; default: goto label; }; label: specialinvoke v.(v, v, v); goto label; label: v = virtualinvoke v.(); v = specialinvoke v.(v); v = specialinvoke v.(v); v = v.; if v <= 0 goto label; v = new org.apache.zookeeper.KeeperException$NotEmptyException; specialinvoke v.(java.lang.String)>(v); throw v; label: v = v.; v = virtualinvoke v.(); v = staticinvoke (v); v = ; if v != v goto label; v = new org.apache.zookeeper.KeeperException$BadVersionException; specialinvoke v.(java.lang.String)>(v); throw v; label: v = specialinvoke v.(v); v = new org.apache.zookeeper.txn.DeleteTxn; specialinvoke v.(java.lang.String)>(v); virtualinvoke v.(v); v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(v); v = v.; v = v - 1; v. = v; v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.(v); v = ; v = v.; v = v.; v = specialinvoke v.(v, v, v, v); v. = v; virtualinvoke v.(v); v = new org.apache.zookeeper.server.ZooKeeperServer$ChangeRecord; v = virtualinvoke v.(); v = virtualinvoke v.(); v = (int) -1; specialinvoke v.(long,java.lang.String,org.apache.zookeeper.data.StatPersisted,int,java.util.List)>(v, v, null, v, null); v = ; v = specialinvoke v.(v, v); v. = v; v = v.; specialinvoke v.(v, v); virtualinvoke v.(v); goto label; label: v = v.; v = v.; v = v.; v = virtualinvoke v.(); interfaceinvoke v.(v, v); v = virtualinvoke v.(); v = specialinvoke v.(v); v = specialinvoke v.(v); v = v.; v = v.; v = v.; v = v.; virtualinvoke v.(v, v, 8, v, v, null); v = specialinvoke v.(v); v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); staticinvoke (v, v, v); v = v.; if v <= 0 goto label; v = new org.apache.zookeeper.KeeperException$NotEmptyException; specialinvoke v.(java.lang.String)>(v); throw v; label: v = new org.apache.zookeeper.txn.DeleteTxn; specialinvoke v.(java.lang.String)>(v); virtualinvoke v.(v); v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(v); v = v.; v = v - 1; v. = v; v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.(v); v = ; v = v.; v = v.; v = specialinvoke v.(v, v, v, v); v. = v; virtualinvoke v.(v); v = new org.apache.zookeeper.server.ZooKeeperServer$ChangeRecord; v = virtualinvoke v.(); v = virtualinvoke v.(); v = (int) -1; specialinvoke v.(long,java.lang.String,org.apache.zookeeper.data.StatPersisted,int,java.util.List)>(v, v, null, v, null); v = ; v = specialinvoke v.(v, v); v. = v; v = v.; specialinvoke v.(v, v); virtualinvoke v.(v); goto label; label: v = v.; v = v.; v = v.; v = virtualinvoke v.(); interfaceinvoke v.(v, v); v = virtualinvoke v.(); v = v.; specialinvoke v.(v, v); v = specialinvoke v.(v); v = v.; v = v.; v = v.; v = v.; virtualinvoke v.(v, v, 2, v, v, null); v = v.; v = v.; v = virtualinvoke v.(); virtualinvoke v.(v, v, v, 5); v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); v = staticinvoke (v, v, v); v = new org.apache.zookeeper.txn.SetDataTxn; v = virtualinvoke v.(); specialinvoke v.(java.lang.String,byte[],int)>(v, v, v); virtualinvoke v.(v); v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(v); v = v.; virtualinvoke v.(v); v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; virtualinvoke v.(v); v = virtualinvoke v.(); v. = v; v = ; v = v.; v = v.; v = specialinvoke v.(v, v, v, v); v. = v; v = v.; specialinvoke v.(v, v); virtualinvoke v.(v); goto label; label: v = v.; v = virtualinvoke v.(); if v != 0 goto label; v = ; interfaceinvoke v.("Reconfig operation requested but reconfig feature is disabled."); v = new org.apache.zookeeper.KeeperException$ReconfigDisabledException; specialinvoke v.()>(); throw v; label: v = ; if v == 0 goto label; v = ; interfaceinvoke v.("skipACL is set, reconfig operation will skip ACL checks!"); label: v = v.; v = v.; v = v.; v = virtualinvoke v.(); interfaceinvoke v.(v, v); v = v.; v = v.; v = virtualinvoke v.(); v = interfaceinvoke v.(); v = v.; v = virtualinvoke v.(); v = interfaceinvoke v.(); v = v cmp v; if v == 0 goto label; v = new org.apache.zookeeper.KeeperException$ReconfigInProgress; specialinvoke v.()>(); throw v; label: v = virtualinvoke v.(); v = v cmp -1L; if v == 0 goto label; v = v.; v = virtualinvoke v.(); v = interfaceinvoke v.(); v = v cmp v; if v == 0 goto label; v = v.; v = virtualinvoke v.(); v = interfaceinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v, v) ("Reconfiguration from version \u failed -- last seen version is \u0001"); v = new org.apache.zookeeper.KeeperException$BadVersionException; specialinvoke v.(java.lang.String)>(v); throw v; label: v = virtualinvoke v.(); if v == null goto label; v = ; interfaceinvoke v.("Non-incremental reconfig"); v = virtualinvoke v.(",", "\n"); label: v = new java.util.Properties; specialinvoke v.()>(); v = new java.io.StringReader; specialinvoke v.(java.lang.String)>(v); virtualinvoke v.(v); v = v.; v = virtualinvoke v.(); v = interfaceinvoke v.(); v = staticinvoke (v, v, 1, 0, v); v. = v; v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); interfaceinvoke v.(v); label: goto label; label: v := @caughtexception; v = new org.apache.zookeeper.KeeperException$BadArgumentsException; v = virtualinvoke v.(); specialinvoke v.(java.lang.String)>(v); throw v; label: v = ; interfaceinvoke v.("Incremental reconfig"); v = null; v = virtualinvoke v.(); if v == null goto label; v = staticinvoke (v, ","); label: v = null; v = virtualinvoke v.(); if v == null goto label; v = staticinvoke (v, ","); label: v = v instanceof org.apache.zookeeper.server.quorum.flexible.QuorumMaj; if v != 0 goto label; v = v instanceof org.apache.zookeeper.server.quorum.flexible.QuorumOracleMaj; if v != 0 goto label; v = ; interfaceinvoke v.("Incremental reconfiguration requested but last configuration seen has a non-majority quorum system"); v = new org.apache.zookeeper.KeeperException$BadArgumentsException; specialinvoke v.(java.lang.String)>("Incremental reconfiguration requested but last configuration seen has a non-majority quorum system"); throw v; label: v = new java.util.HashMap; v = interfaceinvoke v.(); specialinvoke v.(java.util.Map)>(v); label: if v == null goto label; v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = staticinvoke (v); v = staticinvoke (v); interfaceinvoke v.(v); goto label; label: if v == null goto label; v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = staticinvoke (v, "="); v = newarray (java.lang.String)[0]; v = interfaceinvoke v.(v); v = lengthof v; if v == 2 goto label; v = new org.apache.zookeeper.KeeperException$BadArgumentsException; specialinvoke v.(java.lang.String)>("Wrong format of server string"); throw v; label: v = v[0]; v = v[0]; v = virtualinvoke v.(46); v = v + 1; v = virtualinvoke v.(v); v = staticinvoke (v); v = staticinvoke (v); v = new org.apache.zookeeper.server.quorum.QuorumPeer$QuorumServer; v = virtualinvoke v.(); v = v[1]; specialinvoke v.(long,java.lang.String)>(v, v); v = v.; if v == null goto label; v = v.; if v == null goto label; v = v.; if v != null goto label; label: v = new org.apache.zookeeper.KeeperException$BadArgumentsException; specialinvoke v.(java.lang.String)>("Wrong format of server string - each server should have 3 ports specified"); throw v; label: v = interfaceinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = v.; v = v.; v = v cmp v; if v == 0 goto label; virtualinvoke v.(v); goto label; label: v = v.; v = staticinvoke (v); interfaceinvoke v.(v); v = v.; v = staticinvoke (v); interfaceinvoke v.(v, v); goto label; label: v := @caughtexception; v = new org.apache.zookeeper.KeeperException$BadArgumentsException; specialinvoke v.(java.lang.String)>("Reconfiguration failed"); throw v; label: v = v instanceof org.apache.zookeeper.server.quorum.flexible.QuorumMaj; if v == 0 goto label; v = new org.apache.zookeeper.server.quorum.flexible.QuorumMaj; specialinvoke v.(java.util.Map)>(v); v. = v; goto label; label: v = new org.apache.zookeeper.server.quorum.flexible.QuorumOracleMaj; v = interfaceinvoke v.(); specialinvoke v.(java.util.Map,java.lang.String)>(v, v); v. = v; label: v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); interfaceinvoke v.(v); label: v = staticinvoke (); if v == 0 goto label; v = v.; v = interfaceinvoke v.(); v = interfaceinvoke v.(); if v >= 2 goto label; v = ; interfaceinvoke v.("Reconfig failed - new configuration must include at least 2 followers"); v = new org.apache.zookeeper.KeeperException$BadArgumentsException; specialinvoke v.(java.lang.String)>("Reconfig failed - new configuration must include at least 2 followers"); throw v; label: v = v.; v = interfaceinvoke v.(); v = interfaceinvoke v.(); if v >= 1 goto label; v = ; interfaceinvoke v.("Reconfig failed - new configuration must include at least 1 follower"); v = new org.apache.zookeeper.KeeperException$BadArgumentsException; specialinvoke v.(java.lang.String)>("Reconfig failed - new configuration must include at least 1 follower"); throw v; label: v = virtualinvoke v.(); v = v.; v = virtualinvoke v.(v); if v != 0 goto label; v = ; interfaceinvoke v.("Reconfig failed - there must be a connected and synced quorum in new configuration"); v = new org.apache.zookeeper.KeeperException$NewConfigNoQuorum; specialinvoke v.()>(); throw v; label: v = specialinvoke v.("/zookeeper/config"); v = v.; v = v.; v = v.; v = v.; virtualinvoke v.(v, v, 2, v, null, null); v = new org.apache.zookeeper.txn.SetDataTxn; v = v.; v = interfaceinvoke v.(); v = virtualinvoke v.(); v = (int) -1; specialinvoke v.(java.lang.String,byte[],int)>("/zookeeper/config", v, v); virtualinvoke v.(v); v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(v); v = v.; v = (int) -1; virtualinvoke v.(v); v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; virtualinvoke v.(v); v = virtualinvoke v.(); v. = v; v = ; v = v.; v = v.; v = specialinvoke v.(v, "/zookeeper/config", v, v); v. = v; v = v.; specialinvoke v.(v, v); virtualinvoke v.(v); goto label; label: v = v.; v = v.; v = v.; v = virtualinvoke v.(); interfaceinvoke v.(v, v); v = virtualinvoke v.(); v = v.; specialinvoke v.(v, v); v = v.; v = virtualinvoke v.(); v = staticinvoke (v, v, v); v = specialinvoke v.(v); v = v.; v = v.; v = v.; v = v.; virtualinvoke v.(v, v, 16, v, v, v); v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); v = staticinvoke (v, v, v); v = new org.apache.zookeeper.txn.SetACLTxn; specialinvoke v.(java.lang.String,java.util.List,int)>(v, v, v); virtualinvoke v.(v); v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(v); v = v.; virtualinvoke v.(v); v = ; v = v.; v = v.; v = specialinvoke v.(v, v, v, v); v. = v; v = v.; specialinvoke v.(v, v); virtualinvoke v.(v); goto label; label: v = staticinvoke (); v = virtualinvoke v.(v); virtualinvoke v.(v); v = v.; v = v.; v = v.; v = virtualinvoke v.(); interfaceinvoke v.(v, v); v = v.; v = v.; v = virtualinvoke v.(); virtualinvoke v.(v, v); goto label; label: v = staticinvoke (); v = v.; v = v.; entermonitor v; label: v = v.; v = virtualinvoke v.(); v = v.; v = virtualinvoke v.(v); v = v.; v = v.; v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = v.; if v != null goto label; v = v.; interfaceinvoke v.(v); goto label; label: v = v.; v = virtualinvoke v.(); v = v.; v = v cmp v; if v != 0 goto label; v = v.; interfaceinvoke v.(v); goto label; label: v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = v.; if v == 0 goto label; v = specialinvoke v.(v); v = specialinvoke v.(v); v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(v); v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.(v); v = ; v = v.; v = v.; v = specialinvoke v.(v, v, v, v); v. = v; virtualinvoke v.(v); label: v = new org.apache.zookeeper.server.ZooKeeperServer$ChangeRecord; v = virtualinvoke v.(); v = virtualinvoke v.(); specialinvoke v.(long,java.lang.String,org.apache.zookeeper.data.StatPersisted,int,java.util.List)>(v, v, null, 0, null); v = ; v = specialinvoke v.(v, v); v. = v; virtualinvoke v.(v); goto label; label: v = staticinvoke (); if v == 0 goto label; v = new org.apache.zookeeper.txn.CloseSessionTxn; v = new java.util.ArrayList; specialinvoke v.(java.util.Collection)>(v); specialinvoke v.(java.util.List)>(v); virtualinvoke v.(v); label: v = v.; v = v.; v = v.; interfaceinvoke v.(v); exitmonitor v; label: goto label; label: v := @caughtexception; exitmonitor v; throw v; label: v = staticinvoke (); v = v.; v = staticinvoke (); v = v - v; interfaceinvoke v.(v); goto label; label: v = v.; v = v.; v = v.; v = virtualinvoke v.(); interfaceinvoke v.(v, v); v = virtualinvoke v.(); v = v.; specialinvoke v.(v, v); v = specialinvoke v.(v); v = v.; v = v.; v = v.; v = v.; virtualinvoke v.(v, v, 1, v, v, null); v = new org.apache.zookeeper.txn.CheckVersionTxn; v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); v = staticinvoke (v, v, v); specialinvoke v.(java.lang.String,int)>(v, v); virtualinvoke v.(v); goto label; label: v = ; v = staticinvoke (v); interfaceinvoke v.("unknown type {}", v); label: v = virtualinvoke v.(); if v != null goto label; v = v.; if v == 0 goto label; specialinvoke v.(v); label: return; catch java.io.IOException from label to label with label; catch org.apache.zookeeper.server.quorum.QuorumPeerConfig$ConfigException from label to label with label; catch org.apache.zookeeper.server.quorum.QuorumPeerConfig$ConfigException from label to label with label; catch java.lang.Throwable from label to label with label; } private void pRequest2TxnCreate(int, org.apache.zookeeper.server.Request, org.apache.jute.Record) throws java.io.IOException, org.apache.zookeeper.KeeperException { org.apache.zookeeper.CreateMode v; byte[] v, v, v; java.lang.Integer v; org.apache.zookeeper.txn.CreateTxn v; org.apache.zookeeper.server.PrepRequestProcessor$DigestOpCode v, v; org.apache.zookeeper.txn.CreateTTLTxn v; org.apache.jute.Record v; org.apache.zookeeper.server.PrepRequestProcessor v; java.lang.Object[] v; long v, v, v, v, v, v, v, v, v, v; org.apache.zookeeper.server.ZooKeeperServer$PrecalculatedDigest v, v, v; org.apache.zookeeper.data.StatPersisted v, v, v, v, v, v, v; java.lang.String v, v, v; org.apache.zookeeper.server.EphemeralType v, v, v; org.apache.zookeeper.txn.TxnHeader v, v, v, v; org.apache.zookeeper.server.ZooKeeperServer v, v; org.apache.zookeeper.KeeperException$NoChildrenForEphemeralsException v; org.apache.zookeeper.KeeperException$NoNodeException v; java.util.Locale v; org.apache.zookeeper.server.ServerCnxn v; boolean v, v, v, v, v, v; org.apache.zookeeper.server.Request v; java.util.List v, v, v, v, v; org.apache.zookeeper.txn.CreateContainerTxn v; org.apache.zookeeper.server.ZooKeeperServer$ChangeRecord v, v, v, v; int v, v, v, v, v, v, v; org.apache.zookeeper.KeeperException$NodeExistsException v; v := @this: org.apache.zookeeper.server.PrepRequestProcessor; v := @parameter: int; v := @parameter: org.apache.zookeeper.server.Request; v := @parameter: org.apache.jute.Record; if v != 21 goto label; v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); goto label; label: v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = -1L; label: v = staticinvoke (v); specialinvoke v.(v, v, v, v); v = v.; v = specialinvoke v.(v, v); v = v.; v = staticinvoke (v, v, v); v = specialinvoke v.(v); v = v.; v = v.; v = v.; v = v.; virtualinvoke v.(v, v, 4, v, v, v); v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); if v == 0 goto label; v = ; v = newarray (java.lang.Object)[1]; v = staticinvoke (v); v[0] = v; v = staticinvoke (v, "%010d", v); v = dynamicinvoke "makeConcatWithConstants" (v, v) ("\u0001\u0001"); label: v = v.; specialinvoke v.(v, v); label: v = specialinvoke v.(v); if v == null goto label; v = new org.apache.zookeeper.KeeperException$NodeExistsException; specialinvoke v.(java.lang.String)>(v); throw v; label: v := @caughtexception; label: v = v.; v = virtualinvoke v.(); v = staticinvoke (v); v = ; if v != v goto label; v = 1; goto label; label: v = 0; label: if v == 0 goto label; v = new org.apache.zookeeper.KeeperException$NoChildrenForEphemeralsException; specialinvoke v.(java.lang.String)>(v); throw v; label: v = v.; v = virtualinvoke v.(); v = v + 1; v = v.; virtualinvoke v.(v, null, v, 1); if v != 19 goto label; v = new org.apache.zookeeper.txn.CreateContainerTxn; specialinvoke v.(java.lang.String,byte[],java.util.List,int)>(v, v, v, v); virtualinvoke v.(v); goto label; label: if v != 21 goto label; v = new org.apache.zookeeper.txn.CreateTTLTxn; specialinvoke v.(java.lang.String,byte[],java.util.List,int,long)>(v, v, v, v, v); virtualinvoke v.(v); goto label; label: v = new org.apache.zookeeper.txn.CreateTxn; v = virtualinvoke v.(); specialinvoke v.(java.lang.String,byte[],java.util.List,boolean,int)>(v, v, v, v, v); virtualinvoke v.(v); label: v = virtualinvoke v.(); v = 0L; v = virtualinvoke v.(); if v == 0 goto label; v = -9223372036854775808L; goto label; label: v = virtualinvoke v.(); if v == 0 goto label; v = ; v = virtualinvoke v.(v); goto label; label: v = virtualinvoke v.(); if v == 0 goto label; v = v.; label: v = virtualinvoke v.(); v = virtualinvoke v.(); v = staticinvoke (v, v, v); v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(v); v = v.; v = v + 1; v. = v; v = v.; virtualinvoke v.(v); v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.(v); v = ; v = v.; v = v.; v = specialinvoke v.(v, v, v, v); v. = v; virtualinvoke v.(v); v = new org.apache.zookeeper.server.ZooKeeperServer$ChangeRecord; v = virtualinvoke v.(); v = virtualinvoke v.(); specialinvoke v.(long,java.lang.String,org.apache.zookeeper.data.StatPersisted,int,java.util.List)>(v, v, v, 0, v); v. = v; v = ; v = v.; v = specialinvoke v.(v, v, v, v); v. = v; v = v.; specialinvoke v.(v, v); virtualinvoke v.(v); return; catch org.apache.zookeeper.KeeperException$NoNodeException from label to label with label; } private void validatePath(java.lang.String, long) throws org.apache.zookeeper.KeeperException$BadArgumentsException { java.lang.Object[] v; org.slf4j.Logger v; long v; java.lang.IllegalArgumentException v; org.apache.zookeeper.server.PrepRequestProcessor v; org.apache.zookeeper.KeeperException$BadArgumentsException v; java.lang.String v, v, v; v := @this: org.apache.zookeeper.server.PrepRequestProcessor; v := @parameter: java.lang.String; v := @parameter: long; label: staticinvoke (v); label: goto label; label: v := @caughtexception; v = ; v = newarray (java.lang.Object)[3]; v[0] = v; v = staticinvoke (v); v[1] = v; v = virtualinvoke v.(); v[2] = v; interfaceinvoke v.("Invalid path {} with session 0x{}, reason: {}", v); v = new org.apache.zookeeper.KeeperException$BadArgumentsException; specialinvoke v.(java.lang.String)>(v); throw v; label: return; catch java.lang.IllegalArgumentException from label to label with label; } private java.lang.String getParentPathAndValidate(java.lang.String) throws org.apache.zookeeper.KeeperException$BadArgumentsException { org.apache.zookeeper.server.ZKDatabase v; org.apache.zookeeper.server.PrepRequestProcessor v; org.apache.zookeeper.server.ZooKeeperServer v; org.apache.zookeeper.KeeperException$BadArgumentsException v; int v, v, v, v; java.lang.String v, v; boolean v; v := @this: org.apache.zookeeper.server.PrepRequestProcessor; v := @parameter: java.lang.String; v = virtualinvoke v.(47); v = (int) -1; if v == v goto label; v = virtualinvoke v.(0); v = (int) -1; if v != v goto label; v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(v); if v == 0 goto label; label: v = new org.apache.zookeeper.KeeperException$BadArgumentsException; specialinvoke v.(java.lang.String)>(v); throw v; label: v = virtualinvoke v.(0, v); return v; } private static int checkAndIncVersion(int, int, java.lang.String) throws org.apache.zookeeper.KeeperException$BadVersionException { int v, v, v, v; java.lang.String v; org.apache.zookeeper.KeeperException$BadVersionException v; v := @parameter: int; v := @parameter: int; v := @parameter: java.lang.String; v = (int) -1; if v == v goto label; if v == v goto label; v = new org.apache.zookeeper.KeeperException$BadVersionException; specialinvoke v.(java.lang.String)>(v); throw v; label: v = v + 1; return v; } protected void pRequest(org.apache.zookeeper.server.Request) throws org.apache.zookeeper.server.RequestProcessor$RequestProcessorException { long v, v, v, v, v, v; org.apache.zookeeper.metrics.Summary v, v; org.apache.zookeeper.server.PrepRequestProcessor v; org.apache.zookeeper.server.Request v; org.apache.zookeeper.server.ZooKeeperServer v; org.apache.zookeeper.server.ServerMetrics v, v; org.apache.zookeeper.server.RequestProcessor v; boolean v; v := @this: org.apache.zookeeper.server.PrepRequestProcessor; v := @parameter: org.apache.zookeeper.server.Request; virtualinvoke v.(null); virtualinvoke v.(null); v = virtualinvoke v.(); if v != 0 goto label; specialinvoke v.(v); label: v = v.; v = virtualinvoke v.(); v. = v; v = staticinvoke (); v = staticinvoke (); v = v.; v = v.; v = v - v; interfaceinvoke v.(v); v = v.; interfaceinvoke v.(v); v = staticinvoke (); v = v.; v = staticinvoke (); v = v - v; interfaceinvoke v.(v); return; } private void pRequestHelper(org.apache.zookeeper.server.Request) { byte[] v, v; java.lang.Integer v; java.util.Map v; org.apache.jute.Record v, v, v; java.lang.Object[] v, v; java.io.ByteArrayOutputStream v; long v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; java.util.function.Supplier v, v, v, v, v, v, v, v, v; org.apache.zookeeper.proto.SetACLRequest v; org.apache.zookeeper.txn.Txn v; java.io.IOException v; org.apache.zookeeper.server.ZooKeeperServer v, v, v, v, v, v, v, v, v, v, v, v, v; org.apache.jute.BinaryOutputArchive v; org.apache.zookeeper.proto.DeleteRequest 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; org.slf4j.Logger v, v, v, v, v; org.apache.zookeeper.KeeperException v, v, v; org.apache.zookeeper.proto.SetDataRequest v; java.lang.Object v, v, v; org.apache.zookeeper.proto.CreateTTLRequest v; org.apache.zookeeper.server.SessionTracker v; java.lang.Exception v; org.apache.zookeeper.server.PrepRequestProcessor v; java.lang.Throwable v; org.apache.zookeeper.proto.CreateRequest v; java.util.ArrayList v; java.lang.String v, v, v, v, v, v, v, v; org.apache.zookeeper.txn.MultiTxn v; org.apache.zookeeper.txn.TxnHeader v, v, v, v, v, v, v; org.apache.zookeeper.proto.CheckVersionRequest v; org.apache.zookeeper.txn.ErrorTxn v, v, v, v; java.nio.ByteBuffer v; boolean v, v, v; org.apache.zookeeper.server.Request v; org.apache.zookeeper.KeeperException$Code v, v, v, v, v, v, v, v; java.util.Iterator v; org.apache.zookeeper.proto.ReconfigRequest v; v := @this: org.apache.zookeeper.server.PrepRequestProcessor; v := @parameter: org.apache.zookeeper.server.Request; label: v = v.; tableswitch(v) { case -11: goto label; case -10: goto label; case -9: goto label; case -8: goto label; case -7: goto label; case -6: goto label; case -5: goto label; case -4: goto label; case -3: goto label; case -2: goto label; case -1: goto label; case 0: goto label; 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; case 20: goto label; case 21: goto label; case 22: goto label; case 23: goto label; case 24: goto label; case 25: goto label; case 26: goto label; case 27: goto label; case 28: goto label; case 29: goto label; case 30: goto label; case 31: goto label; case 32: goto label; case 33: goto label; case 34: goto label; case 35: goto label; case 36: goto label; case 37: goto label; case 38: goto label; case 39: goto label; case 40: goto label; case 41: goto label; case 42: goto label; case 43: goto label; case 44: goto label; case 45: goto label; case 46: goto label; case 47: goto label; case 48: goto label; case 49: goto label; case 50: goto label; case 51: goto label; case 52: goto label; case 53: goto label; case 54: goto label; case 55: goto label; case 56: goto label; case 57: goto label; case 58: goto label; case 59: goto label; case 60: goto label; case 61: goto label; case 62: goto label; case 63: goto label; case 64: goto label; case 65: goto label; case 66: goto label; case 67: goto label; case 68: goto label; case 69: goto label; case 70: goto label; case 71: goto label; case 72: goto label; case 73: goto label; case 74: goto label; case 75: goto label; case 76: goto label; case 77: goto label; case 78: goto label; case 79: goto label; case 80: goto label; case 81: goto label; case 82: goto label; case 83: goto label; case 84: goto label; case 85: goto label; case 86: goto label; case 87: goto label; case 88: goto label; case 89: goto label; case 90: goto label; case 91: goto label; case 92: goto label; case 93: goto label; case 94: goto label; case 95: goto label; case 96: goto label; case 97: goto label; case 98: goto label; case 99: goto label; case 100: goto label; case 101: goto label; case 102: goto label; case 103: goto label; case 104: goto label; case 105: goto label; case 106: goto label; case 107: goto label; default: goto label; }; label: v = staticinvoke (); virtualinvoke v.(v); v = v.; v = v.; v = virtualinvoke v.(); virtualinvoke v.(v, v, v, v); goto label; label: v = staticinvoke (); virtualinvoke v.(v); v = v.; v = v.; v = virtualinvoke v.(); virtualinvoke v.(v, v, v, v); goto label; label: v = staticinvoke (); v = virtualinvoke v.(v); v = v.; v = v.; v = virtualinvoke v.(); virtualinvoke v.(v, v, v, v); goto label; label: v = staticinvoke (); virtualinvoke v.(v); v = v.; v = v.; v = virtualinvoke v.(); virtualinvoke v.(v, v, v, v); goto label; label: v = staticinvoke (); virtualinvoke v.(v); v = v.; v = v.; v = virtualinvoke v.(); virtualinvoke v.(v, v, v, v); goto label; label: v = staticinvoke (); virtualinvoke v.(v); v = v.; v = v.; v = virtualinvoke v.(); virtualinvoke v.(v, v, v, v); goto label; label: v = staticinvoke (); virtualinvoke v.(v); v = v.; v = v.; v = virtualinvoke v.(); virtualinvoke v.(v, v, v, v); goto label; label: v = staticinvoke (); virtualinvoke v.(v); v = v.; v = v.; v = virtualinvoke v.(); virtualinvoke v.(v, v, v, v); goto label; label: v = staticinvoke (); v = virtualinvoke v.(v); label: goto label; label: v := @caughtexception; v = new org.apache.zookeeper.txn.TxnHeader; v = v.; v = v.; v = v.; v = virtualinvoke v.(); v = staticinvoke (); specialinvoke v.(long,int,long,long,int)>(v, v, v, v, 14); virtualinvoke v.(v); throw v; label: v = new java.util.ArrayList; specialinvoke v.()>(); v = v.; v = virtualinvoke v.(); v = null; v = specialinvoke v.(v); v = new org.apache.zookeeper.txn.TxnHeader; v = v.; v = v.; v = staticinvoke (); v = v.; specialinvoke v.(long,int,long,long,int)>(v, v, v, v, v); virtualinvoke v.(v); v = virtualinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = virtualinvoke v.(); if v == null goto label; v = (int) -1; v = v; v = new org.apache.zookeeper.txn.ErrorTxn; v = ; v = virtualinvoke v.(); specialinvoke v.(int)>(v); v = v; goto label; label: v = virtualinvoke v.(); virtualinvoke v.(v, v, v, v); v = virtualinvoke v.(); v = virtualinvoke v.(); label: goto label; label: v := @caughtexception; v = v; v = (int) -1; v = v; v = new org.apache.zookeeper.txn.ErrorTxn; v = virtualinvoke v.(); v = virtualinvoke v.(); specialinvoke v.(int)>(v); v = v; v = virtualinvoke v.(); v = virtualinvoke v.(); v = ; v = virtualinvoke v.(); if v <= v goto label; v = ; v = newarray (java.lang.Object)[3]; v = virtualinvoke v.(); v[0] = v; v = virtualinvoke v.(); v[1] = v; v = virtualinvoke v.(); v[2] = v; interfaceinvoke v.("Got user-level KeeperException when processing {} aborting remaining multi ops. Error Path:{} Error:{}", v); label: virtualinvoke v.(v); virtualinvoke v.(v, v); label: v = new java.io.ByteArrayOutputStream; specialinvoke v.()>(); label: v = staticinvoke (v); interfaceinvoke v.(v, "request"); v = virtualinvoke v.(); v = staticinvoke (v); v = new org.apache.zookeeper.txn.Txn; v = virtualinvoke v.(); specialinvoke v.(int,byte[])>(v, v); interfaceinvoke v.(v); label: virtualinvoke v.(); goto label; label: v := @caughtexception; throw v; label: v = new org.apache.zookeeper.txn.MultiTxn; specialinvoke v.(java.util.List)>(v); virtualinvoke v.(v); v = v.; if v == 0 goto label; specialinvoke v.(v); goto label; label: v = virtualinvoke v.(); if v != 0 goto label; v = v.; v = v.; v = virtualinvoke v.(); virtualinvoke v.(v, v, v, null); goto label; label: v = v.; v = v.; v = v.; v = virtualinvoke v.(); interfaceinvoke v.(v, v); goto label; label: v = ; v = v.; v = staticinvoke (v); interfaceinvoke v.("unknown type {}", v); label: goto label; label: v := @caughtexception; v = virtualinvoke v.(); if v == null goto label; v = virtualinvoke v.(); v = (int) -1; virtualinvoke v.(v); v = new org.apache.zookeeper.txn.ErrorTxn; v = virtualinvoke v.(); v = virtualinvoke v.(); specialinvoke v.(int)>(v); virtualinvoke v.(v); label: v = virtualinvoke v.(); v = virtualinvoke v.(); v = ; v = virtualinvoke v.(); if v <= v goto label; v = ; v = newarray (java.lang.Object)[3]; v = virtualinvoke v.(); v[0] = v; v = virtualinvoke v.(); v[1] = v; v = virtualinvoke v.(); v[2] = v; interfaceinvoke v.("Got user-level KeeperException when processing {} Error Path:{} Error:{}", v); label: virtualinvoke v.(v); goto label; label: v := @caughtexception; v = ; interfaceinvoke v.("Failed to process {}", v, v); v = virtualinvoke v.(); v = ; v = v.; v = staticinvoke (v); interfaceinvoke v.("Dumping request buffer for request type {}: 0x{}", v, v); v = virtualinvoke v.(); if v != null goto label; v = new org.apache.zookeeper.txn.TxnHeader; v = v.; v = v.; v = v.; v = virtualinvoke v.(); v = staticinvoke (); v = v.; specialinvoke v.(long,int,long,long,int)>(v, v, v, v, v); virtualinvoke v.(v); label: v = virtualinvoke v.(); v = (int) -1; virtualinvoke v.(v); v = new org.apache.zookeeper.txn.ErrorTxn; v = ; v = virtualinvoke v.(); specialinvoke v.(int)>(v); virtualinvoke v.(v); label: return; catch java.io.IOException from label to label with label; catch org.apache.zookeeper.KeeperException from label to label with label; catch java.lang.Throwable from label to label with label; catch org.apache.zookeeper.KeeperException from label to label with label; catch java.lang.Exception from label to label with label; } private static java.util.List removeDuplicates(java.util.List) { java.util.Iterator v; java.util.ArrayList v; java.util.List v, v; int v; java.lang.Object v; boolean v, v, v; v := @parameter: java.util.List; if v == null goto label; v = interfaceinvoke v.(); if v == 0 goto label; label: v = staticinvoke (); return v; label: v = new java.util.ArrayList; v = interfaceinvoke v.(); specialinvoke v.(int)>(v); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = virtualinvoke v.(v); if v != 0 goto label; virtualinvoke v.(v); goto label; label: return v; } private void validateCreateRequest(java.lang.String, org.apache.zookeeper.CreateMode, org.apache.zookeeper.server.Request, long) throws org.apache.zookeeper.KeeperException { org.apache.zookeeper.CreateMode v; long v, v, v; org.apache.zookeeper.KeeperException$BadArgumentsException v; org.apache.zookeeper.server.SessionTracker v, v; java.lang.String v; boolean v, v, v; org.apache.zookeeper.KeeperException$UnimplementedException v; org.apache.zookeeper.KeeperException v, v; java.lang.IllegalArgumentException v; org.apache.zookeeper.server.PrepRequestProcessor v; org.apache.zookeeper.server.Request v; org.apache.zookeeper.server.ZooKeeperServer v, v; java.lang.Object v, v; v := @this: org.apache.zookeeper.server.PrepRequestProcessor; v := @parameter: java.lang.String; v := @parameter: org.apache.zookeeper.CreateMode; v := @parameter: org.apache.zookeeper.server.Request; v := @parameter: long; v = virtualinvoke v.(); if v == 0 goto label; v = staticinvoke (); if v != 0 goto label; v = new org.apache.zookeeper.KeeperException$UnimplementedException; specialinvoke v.()>(); throw v; label: staticinvoke (v, v); label: goto label; label: v := @caughtexception; v = new org.apache.zookeeper.KeeperException$BadArgumentsException; specialinvoke v.(java.lang.String)>(v); throw v; label: v = virtualinvoke v.(); if v == 0 goto label; v = virtualinvoke v.(); if v == null goto label; v = virtualinvoke v.(); throw v; label: v = v.; v = v.; v = v.; v = virtualinvoke v.(); interfaceinvoke v.(v, v); goto label; label: v = v.; v = v.; v = v.; v = virtualinvoke v.(); interfaceinvoke v.(v, v); label: return; catch java.lang.IllegalArgumentException from label to label with label; } public static java.util.List fixupACL(java.lang.String, java.util.List, java.util.List) throws org.apache.zookeeper.KeeperException$InvalidACLException { boolean v, v, v, v, v, v, v, v; java.util.List v, v, v; org.apache.zookeeper.KeeperException$InvalidACLException v, v, v, v, v; org.apache.zookeeper.data.ACL v; java.util.ArrayList v; int v, v; java.lang.String v, v, v, v, v, v, v, v, v; org.slf4j.Logger v, v; java.util.Iterator v, v; org.apache.zookeeper.server.auth.ServerAuthenticationProvider v, v; org.apache.zookeeper.data.Id v; java.lang.Object v, v; v := @parameter: java.lang.String; v := @parameter: java.util.List; v := @parameter: java.util.List; v = staticinvoke (v); if v == null goto label; v = interfaceinvoke v.(); if v != 0 goto label; label: v = new org.apache.zookeeper.KeeperException$InvalidACLException; specialinvoke v.(java.lang.String)>(v); throw v; label: v = new java.util.ArrayList; specialinvoke v.()>(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = ; interfaceinvoke v.("Processing ACL: {}", v); if v != null goto label; v = new org.apache.zookeeper.KeeperException$InvalidACLException; specialinvoke v.(java.lang.String)>(v); throw v; label: v = virtualinvoke v.(); if v == null goto label; v = virtualinvoke v.(); if v != null goto label; label: v = new org.apache.zookeeper.KeeperException$InvalidACLException; specialinvoke v.(java.lang.String)>(v); throw v; label: v = virtualinvoke v.(); v = virtualinvoke v.("world"); if v == 0 goto label; v = virtualinvoke v.(); v = virtualinvoke v.("anyone"); if v == 0 goto label; interfaceinvoke v.(v); goto label; label: v = virtualinvoke v.(); v = virtualinvoke v.("auth"); if v == 0 goto label; v = 0; v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = virtualinvoke v.(); v = staticinvoke (v); if v != null goto label; v = ; v = virtualinvoke v.(); interfaceinvoke v.("Missing AuthenticationProvider for {}", v); goto label; label: v = virtualinvoke v.(); if v == 0 goto label; v = 1; v = new org.apache.zookeeper.data.ACL; v = virtualinvoke v.(); specialinvoke v.(int,org.apache.zookeeper.data.Id)>(v, v); interfaceinvoke v.(v); goto label; label: if v != 0 goto label; v = new org.apache.zookeeper.KeeperException$InvalidACLException; specialinvoke v.(java.lang.String)>(v); throw v; label: v = virtualinvoke v.(); v = staticinvoke (v); if v == null goto label; v = virtualinvoke v.(); v = virtualinvoke v.(v); if v != 0 goto label; label: v = new org.apache.zookeeper.KeeperException$InvalidACLException; specialinvoke v.(java.lang.String)>(v); throw v; label: interfaceinvoke v.(v); goto label; label: return v; } public void processRequest(org.apache.zookeeper.server.Request) { org.apache.zookeeper.server.PrepRequestProcessor v; org.apache.zookeeper.server.Request v; org.apache.zookeeper.metrics.Counter v; org.apache.zookeeper.server.ServerMetrics v; long v; java.util.concurrent.LinkedBlockingQueue v; v := @this: org.apache.zookeeper.server.PrepRequestProcessor; v := @parameter: org.apache.zookeeper.server.Request; v = staticinvoke (); v. = v; v = v.; virtualinvoke v.(v); v = staticinvoke (); v = v.; interfaceinvoke v.(1L); return; } public void shutdown() { org.apache.zookeeper.server.PrepRequestProcessor v; org.apache.zookeeper.server.Request v; org.slf4j.Logger v; org.apache.zookeeper.server.RequestProcessor v; java.util.concurrent.LinkedBlockingQueue v, v; v := @this: org.apache.zookeeper.server.PrepRequestProcessor; v = ; interfaceinvoke v.("Shutting down"); v = v.; virtualinvoke v.(); v = v.; v = ; virtualinvoke v.(v); v = v.; interfaceinvoke v.(); return; } private org.apache.zookeeper.server.ZooKeeperServer$PrecalculatedDigest precalculateDigest(org.apache.zookeeper.server.PrepRequestProcessor$DigestOpCode, java.lang.String, byte[], org.apache.zookeeper.data.StatPersisted) throws org.apache.zookeeper.KeeperException$NoNodeException { byte[] v; org.apache.zookeeper.server.DigestCalculator v, v; long v, v, v, v, v; org.apache.zookeeper.server.ZooKeeperServer$ChangeRecord v, v; org.apache.zookeeper.server.ZooKeeperServer$PrecalculatedDigest v, v, v; int[] v; int v, v; org.apache.zookeeper.data.StatPersisted v; java.lang.String v; boolean v; org.apache.zookeeper.server.PrepRequestProcessor$DigestOpCode v; org.apache.zookeeper.server.PrepRequestProcessor v; v := @this: org.apache.zookeeper.server.PrepRequestProcessor; v := @parameter: org.apache.zookeeper.server.PrepRequestProcessor$DigestOpCode; v := @parameter: java.lang.String; v := @parameter: byte[]; v := @parameter: org.apache.zookeeper.data.StatPersisted; v = v.; if v != 0 goto label; return null; label: v = ; v = virtualinvoke v.(); v = v[v]; tableswitch(v) { case 1: goto label; case 2: goto label; case 3: goto label; case 4: goto label; default: goto label; }; label: v = 0L; v = v.; v = virtualinvoke v.(v, v, v); goto label; label: v = specialinvoke v.(v); v = v.; v = v.; v = 0L; goto label; label: v = specialinvoke v.(v); v = v.; v = v.; v = v.; v = virtualinvoke v.(v, v, v); goto label; label: v = 0L; v = 0L; goto label; label: return null; label: v = specialinvoke v.(); v = v - v; v = v + v; v = new org.apache.zookeeper.server.ZooKeeperServer$PrecalculatedDigest; specialinvoke v.(long,long)>(v, v); return v; } private org.apache.zookeeper.server.ZooKeeperServer$PrecalculatedDigest precalculateDigest(org.apache.zookeeper.server.PrepRequestProcessor$DigestOpCode, java.lang.String) throws org.apache.zookeeper.KeeperException$NoNodeException { org.apache.zookeeper.server.PrepRequestProcessor v; org.apache.zookeeper.server.ZooKeeperServer$PrecalculatedDigest v; java.lang.String v; org.apache.zookeeper.server.PrepRequestProcessor$DigestOpCode v; v := @this: org.apache.zookeeper.server.PrepRequestProcessor; v := @parameter: org.apache.zookeeper.server.PrepRequestProcessor$DigestOpCode; v := @parameter: java.lang.String; v = specialinvoke v.(v, v, null, null); return v; } private long getCurrentTreeDigest() { java.lang.Throwable v; org.apache.zookeeper.server.ZKDatabase v; long v; java.util.Deque v, v, v; org.apache.zookeeper.server.ZooKeeperServer$PrecalculatedDigest v; java.lang.Long v, v; boolean v; org.slf4j.Logger v, v; org.apache.zookeeper.server.PrepRequestProcessor v; org.apache.zookeeper.server.ZooKeeperServer v, v, v, v; org.apache.zookeeper.server.DataTree v; java.lang.Object v; v := @this: org.apache.zookeeper.server.PrepRequestProcessor; v = v.; v = v.; entermonitor v; label: v = v.; v = v.; v = interfaceinvoke v.(); if v == 0 goto label; v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = ; v = staticinvoke (v); interfaceinvoke v.("Digest got from data tree is: {}", v); goto label; label: v = v.; v = v.; v = interfaceinvoke v.(); v = v.; v = v.; v = ; v = staticinvoke (v); interfaceinvoke v.("Digest got from outstandingChanges is: {}", v); label: exitmonitor v; label: goto label; label: v := @caughtexception; exitmonitor v; throw v; label: return v; catch java.lang.Throwable from label to label with label; } private void setTxnDigest(org.apache.zookeeper.server.Request) { org.apache.zookeeper.server.PrepRequestProcessor v; org.apache.zookeeper.server.Request v; org.apache.zookeeper.server.DigestCalculator v; int v; long v; org.apache.zookeeper.txn.TxnDigest v; v := @this: org.apache.zookeeper.server.PrepRequestProcessor; v := @parameter: org.apache.zookeeper.server.Request; v = new org.apache.zookeeper.txn.TxnDigest; v = v.; v = virtualinvoke v.(); v = specialinvoke v.(); specialinvoke v.(int,long)>(v, v); virtualinvoke v.(v); return; } private void setTxnDigest(org.apache.zookeeper.server.Request, org.apache.zookeeper.server.ZooKeeperServer$PrecalculatedDigest) { org.apache.zookeeper.server.PrepRequestProcessor v; org.apache.zookeeper.server.Request v; org.apache.zookeeper.server.ZooKeeperServer$PrecalculatedDigest v; org.apache.zookeeper.server.DigestCalculator v; int v; long v; org.apache.zookeeper.txn.TxnDigest v; v := @this: org.apache.zookeeper.server.PrepRequestProcessor; v := @parameter: org.apache.zookeeper.server.Request; v := @parameter: org.apache.zookeeper.server.ZooKeeperServer$PrecalculatedDigest; if v != null goto label; return; label: v = new org.apache.zookeeper.txn.TxnDigest; v = v.; v = virtualinvoke v.(); v = v.; specialinvoke v.(int,long)>(v, v); virtualinvoke v.(v); return; } static void () { org.slf4j.Logger v; v = staticinvoke (class "Lorg/apache/zookeeper/server/PrepRequestProcessor;"); = v; = 0; return; } }