public class oadd.org.apache.zookeeper.server.PrepRequestProcessor extends oadd.org.apache.zookeeper.server.ZooKeeperCriticalThread implements oadd.org.apache.zookeeper.server.RequestProcessor { private static final org.slf4j.Logger LOG; static boolean skipACL; private static boolean failCreate; java.util.concurrent.LinkedBlockingQueue submittedRequests; private final oadd.org.apache.zookeeper.server.RequestProcessor nextProcessor; oadd.org.apache.zookeeper.server.ZooKeeperServer zks; public void (oadd.org.apache.zookeeper.server.ZooKeeperServer, oadd.org.apache.zookeeper.server.RequestProcessor) { long v; oadd.org.apache.zookeeper.server.ZooKeeperServer v; java.util.concurrent.LinkedBlockingQueue v; oadd.org.apache.zookeeper.server.PrepRequestProcessor v; oadd.org.apache.zookeeper.server.ZooKeeperServerListener v; int v; oadd.org.apache.zookeeper.server.RequestProcessor v; java.lang.String v; v := @this: oadd.org.apache.zookeeper.server.PrepRequestProcessor; v := @parameter: oadd.org.apache.zookeeper.server.ZooKeeperServer; v := @parameter: oadd.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,oadd.org.apache.zookeeper.server.ZooKeeperServerListener)>(v, v); v = new java.util.concurrent.LinkedBlockingQueue; specialinvoke v.()>(); v. = v; v. = v; v. = v; return; } public static void setFailCreate(boolean) { boolean v; v := @parameter: boolean; = v; return; } public void run() { java.lang.Throwable v, v; long v; oadd.org.apache.zookeeper.server.PrepRequestProcessor v; int v; java.lang.String v, v, v; boolean v, v; org.slf4j.Logger v, v, v, v; java.util.concurrent.LinkedBlockingQueue v; java.lang.Exception v; oadd.org.apache.zookeeper.server.Request v; java.lang.Object v; oadd.org.apache.zookeeper.server.RequestProcessor$RequestProcessorException v; v := @this: oadd.org.apache.zookeeper.server.PrepRequestProcessor; label: v = v.; v = virtualinvoke v.(); v = 2L; v = v.; if v != 11 goto label; v = 8L; label: v = ; v = interfaceinvoke v.(); if v == 0 goto label; v = ; staticinvoke (v, v, 80, v, ""); label: v = ; if v == v goto label; virtualinvoke v.(v); goto label; label: v := @caughtexception; v = virtualinvoke v.(); v = v instanceof oadd.org.apache.zookeeper.server.quorum.Leader$XidRolloverException; if v == 0 goto label; v = ; v = virtualinvoke v.(); v = virtualinvoke v.(); interfaceinvoke v.(v); label: v = virtualinvoke v.(); virtualinvoke v.(v, v); goto label; label: v := @caughtexception; v = virtualinvoke v.(); virtualinvoke v.(v, v); label: v = ; interfaceinvoke v.("PrepRequestProcessor exited loop!"); return; catch oadd.org.apache.zookeeper.server.RequestProcessor$RequestProcessorException from label to label with label; catch java.lang.Exception from label to label with label; } private oadd.org.apache.zookeeper.server.ZooKeeperServer$ChangeRecord getRecordForPath(java.lang.String) throws oadd.org.apache.zookeeper.KeeperException$NoNodeException { java.lang.Throwable v, v; oadd.org.apache.zookeeper.server.ZooKeeperServer$ChangeRecord v; java.util.HashMap v; oadd.org.apache.zookeeper.server.ZooKeeperServer v, v, v, v; java.util.Deque v; oadd.org.apache.zookeeper.server.PrepRequestProcessor v; int v; java.lang.String v; oadd.org.apache.zookeeper.server.DataNode v; oadd.org.apache.zookeeper.data.StatPersisted v, v; java.util.Set v; oadd.org.apache.zookeeper.KeeperException$NoNodeException v; java.util.List v; oadd.org.apache.zookeeper.server.ZKDatabase v, v; java.lang.Object v; v := @this: oadd.org.apache.zookeeper.server.PrepRequestProcessor; v := @parameter: java.lang.String; v = v.; v = v.; entermonitor v; label: v = v.; v = v.; v = virtualinvoke 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 oadd.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,oadd.org.apache.zookeeper.data.StatPersisted,int,java.util.List)>(-1L, v, v, v, 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 oadd.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 oadd.org.apache.zookeeper.server.ZooKeeperServer$ChangeRecord getOutstandingChange(java.lang.String) { java.lang.Throwable v; java.util.HashMap v; oadd.org.apache.zookeeper.server.ZooKeeperServer v, v; java.util.Deque v; oadd.org.apache.zookeeper.server.PrepRequestProcessor v; java.lang.Object v; java.lang.String v; v := @this: oadd.org.apache.zookeeper.server.PrepRequestProcessor; v := @parameter: java.lang.String; v = v.; v = v.; entermonitor v; label: v = v.; v = v.; v = virtualinvoke v.(v); exitmonitor v; label: return v; label: v := @caughtexception; exitmonitor v; throw v; catch java.lang.Throwable from label to label with label; } private void addChangeRecord(oadd.org.apache.zookeeper.server.ZooKeeperServer$ChangeRecord) { java.lang.Throwable v; oadd.org.apache.zookeeper.server.ZooKeeperServer$ChangeRecord v; java.util.HashMap v; oadd.org.apache.zookeeper.server.ZooKeeperServer v, v, v; java.util.Deque v, v; oadd.org.apache.zookeeper.server.PrepRequestProcessor v; java.lang.String v; v := @this: oadd.org.apache.zookeeper.server.PrepRequestProcessor; v := @parameter: oadd.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.; virtualinvoke v.(v, v); 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(oadd.org.apache.zookeeper.MultiTransactionRecord) { java.util.Iterator v; oadd.org.apache.zookeeper.server.ZooKeeperServer$ChangeRecord v, v; java.util.HashMap v; oadd.org.apache.zookeeper.server.PrepRequestProcessor v; int v, v, v, v; java.lang.Object v; java.lang.String v, v; oadd.org.apache.zookeeper.MultiTransactionRecord v; boolean v; v := @this: oadd.org.apache.zookeeper.server.PrepRequestProcessor; v := @parameter: oadd.org.apache.zookeeper.MultiTransactionRecord; 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; virtualinvoke 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; virtualinvoke v.(v, v); goto label; label: return v; } void rollbackPendingChanges(long, java.util.Map) { oadd.org.apache.zookeeper.server.PrepRequestProcessor v; byte v, v; java.util.Map v; boolean v, v, v; java.util.Collection v; java.lang.Throwable v; java.util.HashMap v, v; long v, v, v, v; oadd.org.apache.zookeeper.server.ZooKeeperServer v, v, v, v, v, v; java.util.Deque v, v, v, v; java.lang.String v, v; java.util.Iterator v, v; java.lang.Object v, v, v; v := @this: oadd.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.; virtualinvoke 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.; virtualinvoke 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; } static void checkACL(oadd.org.apache.zookeeper.server.ZooKeeperServer, java.util.List, int, java.util.List) throws oadd.org.apache.zookeeper.KeeperException$NoAuthException { java.lang.Integer v; boolean v, v, v, v, v, v, v, v, v, v; oadd.org.apache.zookeeper.data.Id v; java.util.List v, v; oadd.org.apache.zookeeper.server.ZooKeeperServer v; int v, v, v, v; java.lang.String v, v, v, v, v, v, v, v; org.slf4j.Logger v, v, v, v; java.util.Iterator v, v, v; oadd.org.apache.zookeeper.KeeperException$NoAuthException v; java.lang.Object v, v, v; oadd.org.apache.zookeeper.server.auth.AuthenticationProvider v; v := @parameter: oadd.org.apache.zookeeper.server.ZooKeeperServer; v := @parameter: java.util.List; v := @parameter: int; v := @parameter: java.util.List; v = ; if v == 0 goto label; return; label: v = ; v = interfaceinvoke v.(); if v == 0 goto label; v = ; v = staticinvoke (v); interfaceinvoke v.("Permission requested: {} ", v); v = ; interfaceinvoke v.("ACLs for node: {}", v); v = ; interfaceinvoke v.("Client credentials: {}", v); label: if v == null goto label; v = interfaceinvoke v.(); if v != 0 goto label; label: return; label: v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.("super"); if v == 0 goto label; return; label: v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = v & v; if v == 0 goto 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; return; label: v = virtualinvoke v.(); v = staticinvoke (v); if v == null goto label; v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(v); if v == 0 goto label; v = virtualinvoke v.(); v = virtualinvoke v.(); v = interfaceinvoke v.(v, v); if v == 0 goto label; return; label: v = new oadd.org.apache.zookeeper.KeeperException$NoAuthException; specialinvoke v.()>(); throw v; } private java.lang.String validatePathForCreate(java.lang.String, long) throws oadd.org.apache.zookeeper.KeeperException$BadArgumentsException { org.slf4j.Logger v; long v; oadd.org.apache.zookeeper.server.PrepRequestProcessor v; oadd.org.apache.zookeeper.KeeperException$BadArgumentsException v; int v, v, v, v; java.lang.String v, v, v; boolean v; v := @this: oadd.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 %s with session 0x%s", v, v); v = new oadd.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, oadd.org.apache.zookeeper.server.Request, oadd.org.apache.jute.Record, boolean) throws oadd.org.apache.zookeeper.KeeperException, java.io.IOException, oadd.org.apache.zookeeper.server.RequestProcessor$RequestProcessorException { oadd.org.apache.zookeeper.KeeperException$BadArgumentsException v, v, v, v, v, v, v; oadd.org.apache.zookeeper.server.quorum.QuorumPeer$QuorumServer v; java.io.StringReader v; oadd.org.apache.zookeeper.KeeperException$ReconfigInProgress v; oadd.org.apache.zookeeper.txn.SetACLTxn v; oadd.org.apache.zookeeper.KeeperException$NewConfigNoQuorum v; oadd.org.apache.zookeeper.KeeperException$ReconfigDisabledException 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; oadd.org.apache.zookeeper.txn.SetDataTxn v, v; oadd.org.apache.zookeeper.server.quorum.flexible.QuorumVerifier v, v, v, v, v, v, v, v, v, v, v; oadd.org.apache.zookeeper.KeeperException$NotEmptyException 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, v, v, v; java.util.Properties v; oadd.org.apache.zookeeper.server.PrepRequestProcessor v; boolean v, v, v, v, v, v, v, v, v, v, v, v; oadd.org.apache.jute.Record v; oadd.org.apache.zookeeper.server.quorum.Leader v; java.net.InetSocketAddress v, v, v; java.util.List v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; oadd.org.apache.zookeeper.txn.DeleteTxn v, v; oadd.org.apache.zookeeper.server.quorum.flexible.QuorumMaj v; java.util.Deque v, v; oadd.org.apache.zookeeper.data.StatPersisted v, v, v, v, v, v, v, v, v, v; byte[] v, v, v; byte v, v, v, v, v; java.lang.Long v, v, v, v; java.util.Map v, v, v; oadd.org.apache.zookeeper.server.Request 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, v, v, v, v, v, v, v, v; oadd.org.apache.zookeeper.server.ZooKeeperServer v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; oadd.org.apache.zookeeper.server.SessionTracker v, v, v, v, v, v, v, v; java.util.Collection v; oadd.org.apache.zookeeper.server.EphemeralType v, v; oadd.org.apache.zookeeper.server.ZKDatabase v; oadd.org.apache.zookeeper.txn.CheckVersionTxn v; org.slf4j.Logger v, v, v, v, v, v, v, v, v; java.lang.Object v, v, v, v, v, v, v, v, v, v, v; oadd.org.apache.zookeeper.txn.CreateSessionTxn v; java.util.Set v; java.lang.Throwable v; oadd.org.apache.zookeeper.server.ZooKeeperServer$ChangeRecord v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; java.nio.ByteBuffer v, v, v, v, v, v, v, v; oadd.org.apache.zookeeper.KeeperException$BadVersionException v, v; java.lang.String[] v; java.util.HashMap v; java.util.Iterator v, v, v, v, v; oadd.org.apache.zookeeper.server.quorum.QuorumPeer v, v, v, v, v; oadd.org.apache.zookeeper.txn.TxnHeader v, v, v, v, v, v, v, v, v, v, v; oadd.org.apache.zookeeper.server.quorum.QuorumPeerConfig$ConfigException v; v := @this: oadd.org.apache.zookeeper.server.PrepRequestProcessor; v := @parameter: int; v := @parameter: long; v := @parameter: oadd.org.apache.zookeeper.server.Request; v := @parameter: oadd.org.apache.jute.Record; v := @parameter: boolean; v = new oadd.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); 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, v); goto label; label: v = new java.lang.String; v = v.; v = virtualinvoke v.(); specialinvoke v.(byte[])>(v); v = specialinvoke v.(v); v = specialinvoke v.(v); v = specialinvoke v.(v); v = v.; if v <= 0 goto label; v = new oadd.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 oadd.org.apache.zookeeper.KeeperException$BadVersionException; specialinvoke v.(java.lang.String)>(v); throw v; label: v = new oadd.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; specialinvoke v.(v); v = new oadd.org.apache.zookeeper.server.ZooKeeperServer$ChangeRecord; v = virtualinvoke v.(); v = virtualinvoke v.(); v = (int) -1; specialinvoke v.(long,java.lang.String,oadd.org.apache.zookeeper.data.StatPersisted,int,java.util.List)>(v, v, null, v, null); specialinvoke v.(v); goto label; label: v = v.; v = v.; v = v.; v = virtualinvoke v.(); interfaceinvoke v.(v, v); if v == 0 goto label; v = v.; staticinvoke (v, v); label: v = virtualinvoke v.(); v = specialinvoke v.(v); v = specialinvoke v.(v); v = specialinvoke v.(v); v = v.; v = v.; v = v.; staticinvoke (v, v, 8, v); v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); staticinvoke (v, v, v); v = v.; if v <= 0 goto label; v = new oadd.org.apache.zookeeper.KeeperException$NotEmptyException; specialinvoke v.(java.lang.String)>(v); throw v; label: v = new oadd.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; specialinvoke v.(v); v = new oadd.org.apache.zookeeper.server.ZooKeeperServer$ChangeRecord; v = virtualinvoke v.(); v = virtualinvoke v.(); v = (int) -1; specialinvoke v.(long,java.lang.String,oadd.org.apache.zookeeper.data.StatPersisted,int,java.util.List)>(v, v, null, v, null); specialinvoke v.(v); goto label; label: v = v.; v = v.; v = v.; v = virtualinvoke v.(); interfaceinvoke v.(v, v); if v == 0 goto label; v = v.; staticinvoke (v, v); label: v = virtualinvoke v.(); v = v.; specialinvoke v.(v, v); v = specialinvoke v.(v); v = v.; v = v.; v = v.; staticinvoke (v, v, 2, v); v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); v = staticinvoke (v, v, v); v = new oadd.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); specialinvoke v.(v); goto label; label: v = staticinvoke (); if v != 0 goto label; v = ; interfaceinvoke v.("Reconfig operation requested but reconfig feature is disabled."); v = new oadd.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 oadd.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 oadd.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 = staticinvoke (v, v, 1, 0); v. = v; v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); interfaceinvoke v.(v); label: goto label; label: v := @caughtexception; v = new oadd.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 oadd.org.apache.zookeeper.server.quorum.flexible.QuorumMaj; if v != 0 goto label; v = ; interfaceinvoke v.("Incremental reconfiguration requested but last configuration seen has a non-majority quorum system"); v = new oadd.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 oadd.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 oadd.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 oadd.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 oadd.org.apache.zookeeper.KeeperException$BadArgumentsException; specialinvoke v.(java.lang.String)>("Reconfiguration failed"); throw v; label: v = new oadd.org.apache.zookeeper.server.quorum.flexible.QuorumMaj; specialinvoke v.(java.util.Map)>(v); v. = v; 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 oadd.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 oadd.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 oadd.org.apache.zookeeper.KeeperException$NewConfigNoQuorum; specialinvoke v.()>(); throw v; label: v = specialinvoke v.("/zookeeper/config"); v = v.; v = v.; v = v.; staticinvoke (v, v, 2, v); v = new oadd.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); specialinvoke v.(v); goto label; label: v = v.; v = v.; v = v.; v = virtualinvoke v.(); interfaceinvoke v.(v, v); if v == 0 goto label; v = v.; staticinvoke (v, v); label: v = virtualinvoke v.(); v = v.; specialinvoke v.(v, v); v = v.; v = virtualinvoke v.(); v = specialinvoke v.(v, v, v); v = specialinvoke v.(v); v = v.; v = v.; v = v.; staticinvoke (v, v, 16, v); v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); v = staticinvoke (v, v, v); v = new oadd.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); specialinvoke v.(v); goto label; label: v = v.; virtualinvoke v.(); v = v.; v = virtualinvoke v.(); v = new oadd.org.apache.zookeeper.txn.CreateSessionTxn; specialinvoke v.(int)>(v); virtualinvoke v.(v); v = v.; virtualinvoke v.(); v = virtualinvoke v.(); if v == 0 goto label; v = v.; v = v.; v = v.; interfaceinvoke v.(v, v); goto label; label: v = v.; v = v.; v = v.; interfaceinvoke v.(v, v); label: v = v.; v = v.; v = virtualinvoke v.(); virtualinvoke v.(v, v); goto label; label: v = v.; v = virtualinvoke v.(); v = v.; v = virtualinvoke v.(v); 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.; 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 = new oadd.org.apache.zookeeper.server.ZooKeeperServer$ChangeRecord; v = virtualinvoke v.(); v = virtualinvoke v.(); specialinvoke v.(long,java.lang.String,oadd.org.apache.zookeeper.data.StatPersisted,int,java.util.List)>(v, v, null, 0, null); specialinvoke v.(v); goto label; label: v = v.; v = v.; v = v.; interfaceinvoke v.(v); exitmonitor v; label: goto label; label: v := @caughtexception; exitmonitor v; throw v; label: v = v.; v = v.; v = v.; v = virtualinvoke v.(); interfaceinvoke v.(v, v); if v == 0 goto label; v = v.; staticinvoke (v, v); label: v = virtualinvoke v.(); v = v.; specialinvoke v.(v, v); v = specialinvoke v.(v); v = v.; v = v.; v = v.; staticinvoke (v, v, 1, v); v = new oadd.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 = dynamicinvoke "makeConcatWithConstants" (v) ("unknown type \u0001"); interfaceinvoke v.(v); label: return; catch java.io.IOException from label to label with label; catch oadd.org.apache.zookeeper.server.quorum.QuorumPeerConfig$ConfigException from label to label with label; catch oadd.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, oadd.org.apache.zookeeper.server.Request, oadd.org.apache.jute.Record, boolean) throws java.io.IOException, oadd.org.apache.zookeeper.KeeperException { byte[] v; oadd.org.apache.zookeeper.CreateMode v; oadd.org.apache.zookeeper.txn.CreateContainerTxn v; java.lang.Integer v; java.nio.ByteBuffer v; oadd.org.apache.zookeeper.server.PrepRequestProcessor v; java.util.Locale v; boolean v, v, v, v, v; oadd.org.apache.jute.Record v; oadd.org.apache.zookeeper.KeeperException$NodeExistsException v; oadd.org.apache.zookeeper.KeeperException$NoNodeException v; oadd.org.apache.zookeeper.server.EphemeralType v, v; java.util.List v, v, v, v, v; oadd.org.apache.zookeeper.server.Request v; java.lang.Object[] v; oadd.org.apache.zookeeper.server.ZooKeeperServer$ChangeRecord v, v, v, v; long v, v, v, v, v, v, v; oadd.org.apache.zookeeper.server.ZooKeeperServer v; oadd.org.apache.zookeeper.txn.CreateTTLTxn v; int v, v, v, v, v, v, v; java.lang.String v, v, v; oadd.org.apache.zookeeper.txn.CreateTxn v; oadd.org.apache.zookeeper.data.StatPersisted v, v, v, v, v; oadd.org.apache.zookeeper.txn.TxnHeader v, v; oadd.org.apache.zookeeper.KeeperException$NoChildrenForEphemeralsException v; v := @this: oadd.org.apache.zookeeper.server.PrepRequestProcessor; v := @parameter: int; v := @parameter: oadd.org.apache.zookeeper.server.Request; v := @parameter: oadd.org.apache.jute.Record; v := @parameter: boolean; if v == 0 goto label; v = v.; staticinvoke (v, v); label: 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 = specialinvoke v.(v, v, v); v = specialinvoke v.(v); v = v.; v = v.; v = v.; staticinvoke (v, v, 4, 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 oadd.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 oadd.org.apache.zookeeper.KeeperException$NoChildrenForEphemeralsException; specialinvoke v.(java.lang.String)>(v); throw v; label: v = v.; v = virtualinvoke v.(); v = v + 1; if v != 19 goto label; v = new oadd.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 oadd.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 oadd.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 = new oadd.org.apache.zookeeper.data.StatPersisted; specialinvoke v.()>(); v = virtualinvoke v.(); if v == 0 goto label; v = v.; virtualinvoke v.(v); label: v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(v); v = v.; v = v + 1; v. = v; v = v.; virtualinvoke v.(v); specialinvoke v.(v); v = new oadd.org.apache.zookeeper.server.ZooKeeperServer$ChangeRecord; v = virtualinvoke v.(); v = virtualinvoke v.(); specialinvoke v.(long,java.lang.String,oadd.org.apache.zookeeper.data.StatPersisted,int,java.util.List)>(v, v, v, 0, v); specialinvoke v.(v); return; catch oadd.org.apache.zookeeper.KeeperException$NoNodeException from label to label with label; } private void validatePath(java.lang.String, long) throws oadd.org.apache.zookeeper.KeeperException$BadArgumentsException { java.lang.Object[] v; org.slf4j.Logger v; long v; java.lang.IllegalArgumentException v; oadd.org.apache.zookeeper.server.PrepRequestProcessor v; oadd.org.apache.zookeeper.KeeperException$BadArgumentsException v; java.lang.String v, v, v; v := @this: oadd.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 oadd.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 oadd.org.apache.zookeeper.KeeperException$BadArgumentsException { oadd.org.apache.zookeeper.server.ZooKeeperServer v; oadd.org.apache.zookeeper.server.PrepRequestProcessor v; oadd.org.apache.zookeeper.KeeperException$BadArgumentsException v; int v, v, v, v; oadd.org.apache.zookeeper.server.ZKDatabase v; java.lang.String v, v; boolean v; v := @this: oadd.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 oadd.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 oadd.org.apache.zookeeper.KeeperException$BadVersionException { oadd.org.apache.zookeeper.KeeperException$BadVersionException v; int v, v, v, v; java.lang.String 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 oadd.org.apache.zookeeper.KeeperException$BadVersionException; specialinvoke v.(java.lang.String)>(v); throw v; label: v = v + 1; return v; } protected void pRequest(oadd.org.apache.zookeeper.server.Request) throws oadd.org.apache.zookeeper.server.RequestProcessor$RequestProcessorException { byte[] v, v; byte v; java.util.Map v; oadd.org.apache.zookeeper.server.Request v; java.lang.StringBuilder v; oadd.org.apache.zookeeper.server.RequestProcessor 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; oadd.org.apache.zookeeper.server.ZooKeeperServer v, v, v, v, v, v, v, v, v, v, v, v; short v; java.io.IOException v; oadd.org.apache.zookeeper.MultiTransactionRecord v; oadd.org.apache.zookeeper.server.SessionTracker v; oadd.org.apache.zookeeper.proto.ReconfigRequest v; oadd.org.apache.zookeeper.proto.CreateTTLRequest v; oadd.org.apache.zookeeper.KeeperException$Code v, v, v, 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; org.slf4j.Logger v, v, v, v, v; oadd.org.apache.jute.BinaryOutputArchive v; java.lang.Object v, v; oadd.org.apache.zookeeper.txn.MultiTxn v; oadd.org.apache.zookeeper.KeeperException v, v, v; java.lang.Exception v; oadd.org.apache.zookeeper.proto.SetACLRequest v; oadd.org.apache.zookeeper.proto.DeleteRequest v; java.util.ArrayList v; oadd.org.apache.zookeeper.txn.Txn v; java.lang.String v, v, v, v, v, v, v, v, v, v, v; oadd.org.apache.zookeeper.proto.CheckVersionRequest v; java.nio.ByteBuffer v, v, v, v; oadd.org.apache.zookeeper.server.PrepRequestProcessor v; boolean v, v, v; oadd.org.apache.jute.Record v, v; oadd.org.apache.zookeeper.proto.SetDataRequest v; oadd.org.apache.zookeeper.proto.CreateRequest v; java.util.Iterator v; oadd.org.apache.zookeeper.txn.ErrorTxn v, v, v, v; oadd.org.apache.zookeeper.txn.TxnHeader v, v, v, v, v, v, v; v := @this: oadd.org.apache.zookeeper.server.PrepRequestProcessor; v := @parameter: oadd.org.apache.zookeeper.server.Request; virtualinvoke v.(null); virtualinvoke v.(null); label: v = v.; lookupswitch(v) { case -11: goto label; case -10: 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 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 101: goto label; default: goto label; }; label: v = new oadd.org.apache.zookeeper.proto.CreateRequest; specialinvoke v.()>(); v = v.; v = v.; v = virtualinvoke v.(); virtualinvoke v.(v, v, v, v, 1); goto label; label: v = new oadd.org.apache.zookeeper.proto.CreateTTLRequest; specialinvoke v.()>(); v = v.; v = v.; v = virtualinvoke v.(); virtualinvoke v.(v, v, v, v, 1); goto label; label: v = new oadd.org.apache.zookeeper.proto.DeleteRequest; specialinvoke v.()>(); v = v.; v = v.; v = virtualinvoke v.(); virtualinvoke v.(v, v, v, v, 1); goto label; label: v = new oadd.org.apache.zookeeper.proto.SetDataRequest; specialinvoke v.()>(); v = v.; v = v.; v = virtualinvoke v.(); virtualinvoke v.(v, v, v, v, 1); goto label; label: v = new oadd.org.apache.zookeeper.proto.ReconfigRequest; specialinvoke v.()>(); v = v.; staticinvoke (v, v); v = v.; v = v.; v = virtualinvoke v.(); virtualinvoke v.(v, v, v, v, 1); goto label; label: v = new oadd.org.apache.zookeeper.proto.SetACLRequest; specialinvoke v.()>(); v = v.; v = v.; v = virtualinvoke v.(); virtualinvoke v.(v, v, v, v, 1); goto label; label: v = new oadd.org.apache.zookeeper.proto.CheckVersionRequest; specialinvoke v.()>(); v = v.; v = v.; v = virtualinvoke v.(); virtualinvoke v.(v, v, v, v, 1); goto label; label: v = new oadd.org.apache.zookeeper.MultiTransactionRecord; specialinvoke v.()>(); label: v = v.; staticinvoke (v, v); label: goto label; label: v := @caughtexception; v = new oadd.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 = 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 oadd.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, 0); v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); label: goto label; label: v := @caughtexception; v = v; v = (int) -1; v = v; v = new oadd.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.()>(); v = staticinvoke (v); interfaceinvoke v.(v, "request"); v = virtualinvoke v.(); v = staticinvoke (v); v = new oadd.org.apache.zookeeper.txn.Txn; v = virtualinvoke v.(); specialinvoke v.(int,byte[])>(v, v); interfaceinvoke v.(v); goto label; label: v = new oadd.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 = new oadd.org.apache.zookeeper.txn.MultiTxn; specialinvoke v.(java.util.List)>(v); virtualinvoke 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, 1); goto label; label: v = v.; v = v.; v = v.; v = virtualinvoke v.(); interfaceinvoke v.(v, v); goto label; label: v = ; v = v.; v = dynamicinvoke "makeConcatWithConstants" (v) ("unknown type \u0001"); interfaceinvoke v.(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 oadd.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 = ; v = dynamicinvoke "makeConcatWithConstants" (v) ("Failed to process \u0001"); interfaceinvoke v.(v, v); v = new java.lang.StringBuilder; specialinvoke v.()>(); v = v.; if v == null goto label; virtualinvoke v.(); label: v = virtualinvoke v.(); if v == 0 goto label; v = virtualinvoke v.(); v = v & 255; v = staticinvoke (v); virtualinvoke v.(v); goto label; label: virtualinvoke v.("request buffer is null"); label: v = ; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("Dumping request buffer: 0x\u0001"); interfaceinvoke v.(v); v = virtualinvoke v.(); if v == null goto label; v = virtualinvoke v.(); v = (int) -1; virtualinvoke v.(v); v = new oadd.org.apache.zookeeper.txn.ErrorTxn; v = ; v = virtualinvoke v.(); specialinvoke v.(int)>(v); virtualinvoke v.(v); label: v = v.; v = virtualinvoke v.(); v. = v; v = v.; interfaceinvoke v.(v); return; catch java.io.IOException from label to label with label; catch oadd.org.apache.zookeeper.KeeperException from label to label with label; catch oadd.org.apache.zookeeper.KeeperException from label to label with label; catch java.lang.Exception from label to label with label; } private java.util.List removeDuplicates(java.util.List) { oadd.org.apache.zookeeper.server.PrepRequestProcessor v; java.util.List v; java.util.Iterator v; java.lang.Object v; java.util.LinkedList v; boolean v, v; v := @this: oadd.org.apache.zookeeper.server.PrepRequestProcessor; v := @parameter: java.util.List; v = new java.util.LinkedList; specialinvoke 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, oadd.org.apache.zookeeper.CreateMode, oadd.org.apache.zookeeper.server.Request, long) throws oadd.org.apache.zookeeper.KeeperException { oadd.org.apache.zookeeper.CreateMode v; long v, v, v; oadd.org.apache.zookeeper.server.ZooKeeperServer v, v; oadd.org.apache.zookeeper.server.PrepRequestProcessor v; java.lang.String v; oadd.org.apache.zookeeper.KeeperException v, v; oadd.org.apache.zookeeper.server.SessionTracker v, v; boolean v, v, v; java.lang.IllegalArgumentException v; oadd.org.apache.zookeeper.KeeperException$BadArgumentsException v; oadd.org.apache.zookeeper.server.Request v; oadd.org.apache.zookeeper.KeeperException$UnimplementedException v; java.lang.Object v, v; v := @this: oadd.org.apache.zookeeper.server.PrepRequestProcessor; v := @parameter: java.lang.String; v := @parameter: oadd.org.apache.zookeeper.CreateMode; v := @parameter: oadd.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 oadd.org.apache.zookeeper.KeeperException$UnimplementedException; specialinvoke v.()>(); throw v; label: staticinvoke (v, v); label: goto label; label: v := @caughtexception; v = new oadd.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; } private java.util.List fixupACL(java.lang.String, java.util.List, java.util.List) throws oadd.org.apache.zookeeper.KeeperException$InvalidACLException { oadd.org.apache.zookeeper.server.PrepRequestProcessor v; boolean v, v, v, v, v, v, v, v; oadd.org.apache.zookeeper.data.Id v; oadd.org.apache.zookeeper.data.ACL v; oadd.org.apache.zookeeper.KeeperException$InvalidACLException v, v, v, v, v; java.util.List v, v, v; int v, v; java.lang.String v, v, v, v, v, v, v, v, v, v; java.util.LinkedList v; org.slf4j.Logger v, v; java.util.Iterator v, v; java.lang.Object v, v; oadd.org.apache.zookeeper.server.auth.AuthenticationProvider v, v; v := @this: oadd.org.apache.zookeeper.server.PrepRequestProcessor; v := @parameter: java.lang.String; v := @parameter: java.util.List; v := @parameter: java.util.List; v = specialinvoke v.(v); v = new java.util.LinkedList; specialinvoke v.()>(); if v == null goto label; v = interfaceinvoke v.(); if v != 0 goto label; label: v = new oadd.org.apache.zookeeper.KeeperException$InvalidACLException; specialinvoke v.(java.lang.String)>(v); throw v; label: 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 oadd.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 oadd.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; virtualinvoke 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.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("Missing AuthenticationProvider for \u0001"); interfaceinvoke v.(v); goto label; label: v = interfaceinvoke v.(); if v == 0 goto label; v = 1; v = new oadd.org.apache.zookeeper.data.ACL; v = virtualinvoke v.(); specialinvoke v.(int,oadd.org.apache.zookeeper.data.Id)>(v, v); virtualinvoke v.(v); goto label; label: if v != 0 goto label; v = new oadd.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 = interfaceinvoke v.(v); if v != 0 goto label; label: v = new oadd.org.apache.zookeeper.KeeperException$InvalidACLException; specialinvoke v.(java.lang.String)>(v); throw v; label: virtualinvoke v.(v); goto label; label: return v; } public void processRequest(oadd.org.apache.zookeeper.server.Request) { oadd.org.apache.zookeeper.server.PrepRequestProcessor v; java.util.concurrent.LinkedBlockingQueue v; oadd.org.apache.zookeeper.server.Request v; v := @this: oadd.org.apache.zookeeper.server.PrepRequestProcessor; v := @parameter: oadd.org.apache.zookeeper.server.Request; v = v.; virtualinvoke v.(v); return; } public void shutdown() { oadd.org.apache.zookeeper.server.PrepRequestProcessor v; org.slf4j.Logger v; oadd.org.apache.zookeeper.server.Request v; oadd.org.apache.zookeeper.server.RequestProcessor v; java.util.concurrent.LinkedBlockingQueue v, v; v := @this: oadd.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; } static void () { org.slf4j.Logger v, v; java.lang.String v; boolean v, v; v = staticinvoke (class "Loadd/org/apache/zookeeper/server/PrepRequestProcessor;"); = v; v = staticinvoke ("zookeeper.skipACL", "no"); v = virtualinvoke v.("yes"); = v; v = ; if v == 0 goto label; v = ; interfaceinvoke v.("zookeeper.skipACL==\"yes\", ACL checks will be skipped"); label: = 0; return; } }