public class oadd.org.apache.zookeeper.server.ZooKeeperServer extends java.lang.Object implements oadd.org.apache.zookeeper.server.SessionTracker$SessionExpirer, oadd.org.apache.zookeeper.server.ServerStats$Provider { protected static final org.slf4j.Logger LOG; protected oadd.org.apache.zookeeper.server.ZooKeeperServerBean jmxServerBean; protected oadd.org.apache.zookeeper.server.DataTreeBean jmxDataTreeBean; public static final int DEFAULT_TICK_TIME; protected int tickTime; protected int minSessionTimeout; protected int maxSessionTimeout; protected oadd.org.apache.zookeeper.server.SessionTracker sessionTracker; private oadd.org.apache.zookeeper.server.persistence.FileTxnSnapLog txnLogFactory; private oadd.org.apache.zookeeper.server.ZKDatabase zkDb; private final java.util.concurrent.atomic.AtomicLong hzxid; public static final java.lang.Exception ok; protected oadd.org.apache.zookeeper.server.RequestProcessor firstProcessor; protected volatile oadd.org.apache.zookeeper.server.ZooKeeperServer$State state; private static final long superSecret; private final java.util.concurrent.atomic.AtomicInteger requestsInProcess; final java.util.Deque outstandingChanges; final java.util.HashMap outstandingChangesForPath; protected oadd.org.apache.zookeeper.server.ServerCnxnFactory serverCnxnFactory; protected oadd.org.apache.zookeeper.server.ServerCnxnFactory secureServerCnxnFactory; private final oadd.org.apache.zookeeper.server.ServerStats serverStats; private final oadd.org.apache.zookeeper.server.ZooKeeperServerListener listener; private oadd.org.apache.zookeeper.server.ZooKeeperServerShutdownHandler zkShutdownHandler; private volatile int createSessionTrackerServerId; void removeCnxn(oadd.org.apache.zookeeper.server.ServerCnxn) { oadd.org.apache.zookeeper.server.ZKDatabase v; oadd.org.apache.zookeeper.server.ZooKeeperServer v; oadd.org.apache.zookeeper.server.ServerCnxn v; v := @this: oadd.org.apache.zookeeper.server.ZooKeeperServer; v := @parameter: oadd.org.apache.zookeeper.server.ServerCnxn; v = v.; virtualinvoke v.(v); return; } public void () { java.util.HashMap v; oadd.org.apache.zookeeper.server.ZooKeeperServer v; java.util.concurrent.atomic.AtomicLong v; java.util.concurrent.atomic.AtomicInteger v; int v, v; oadd.org.apache.zookeeper.server.ZooKeeperServer$State v; oadd.org.apache.zookeeper.server.ZooKeeperServerListenerImpl v; java.util.ArrayDeque v; oadd.org.apache.zookeeper.server.ServerStats v; v := @this: oadd.org.apache.zookeeper.server.ZooKeeperServer; specialinvoke v.()>(); v. = 3000; v = (int) -1; v. = v; v = (int) -1; v. = v; v. = null; v = new java.util.concurrent.atomic.AtomicLong; specialinvoke v.(long)>(0L); v. = v; v = ; v. = v; v = new java.util.concurrent.atomic.AtomicInteger; specialinvoke v.(int)>(0); v. = v; v = new java.util.ArrayDeque; specialinvoke v.()>(); v. = v; v = new java.util.HashMap; specialinvoke v.()>(); v. = v; v. = 1; v = new oadd.org.apache.zookeeper.server.ServerStats; specialinvoke v.(oadd.org.apache.zookeeper.server.ServerStats$Provider)>(v); v. = v; v = new oadd.org.apache.zookeeper.server.ZooKeeperServerListenerImpl; specialinvoke v.(oadd.org.apache.zookeeper.server.ZooKeeperServer)>(v); v. = v; return; } public void (oadd.org.apache.zookeeper.server.persistence.FileTxnSnapLog, int, int, int, oadd.org.apache.zookeeper.server.ZKDatabase) { java.util.HashMap v; oadd.org.apache.zookeeper.server.ZooKeeperServer v; java.util.concurrent.atomic.AtomicInteger v; int v, v, v, v, v, v, v; oadd.org.apache.zookeeper.server.ZooKeeperServer$State v; java.lang.String v; oadd.org.apache.zookeeper.server.persistence.FileTxnSnapLog v, v; oadd.org.apache.zookeeper.server.ServerStats v, v; org.slf4j.Logger v; java.io.File v, v; java.util.concurrent.atomic.AtomicLong v; oadd.org.apache.zookeeper.server.ZKDatabase v; oadd.org.apache.zookeeper.server.ZooKeeperServerListenerImpl v; java.util.ArrayDeque v; v := @this: oadd.org.apache.zookeeper.server.ZooKeeperServer; v := @parameter: oadd.org.apache.zookeeper.server.persistence.FileTxnSnapLog; v := @parameter: int; v := @parameter: int; v := @parameter: int; v := @parameter: oadd.org.apache.zookeeper.server.ZKDatabase; specialinvoke v.()>(); v. = 3000; v = (int) -1; v. = v; v = (int) -1; v. = v; v. = null; v = new java.util.concurrent.atomic.AtomicLong; specialinvoke v.(long)>(0L); v. = v; v = ; v. = v; v = new java.util.concurrent.atomic.AtomicInteger; specialinvoke v.(int)>(0); v. = v; v = new java.util.ArrayDeque; specialinvoke v.()>(); v. = v; v = new java.util.HashMap; specialinvoke v.()>(); v. = v; v. = 1; v = new oadd.org.apache.zookeeper.server.ServerStats; specialinvoke v.(oadd.org.apache.zookeeper.server.ServerStats$Provider)>(v); v. = v; v. = v; v = v.; v = v.; virtualinvoke v.(v); v. = v; v. = v; virtualinvoke v.(v); virtualinvoke v.(v); v = new oadd.org.apache.zookeeper.server.ZooKeeperServerListenerImpl; specialinvoke v.(oadd.org.apache.zookeeper.server.ZooKeeperServer)>(v); v. = v; v = ; v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v, v, v, v, v) ("Created server with tickTime \u minSessionTimeout \u maxSessionTimeout \u datadir \u snapdir \u0001"); interfaceinvoke v.(v); return; } public void (oadd.org.apache.zookeeper.server.persistence.FileTxnSnapLog, int) throws java.io.IOException { int v, v, v; oadd.org.apache.zookeeper.server.ZKDatabase v; oadd.org.apache.zookeeper.server.ZooKeeperServer v; oadd.org.apache.zookeeper.server.persistence.FileTxnSnapLog v; v := @this: oadd.org.apache.zookeeper.server.ZooKeeperServer; v := @parameter: oadd.org.apache.zookeeper.server.persistence.FileTxnSnapLog; v := @parameter: int; v = new oadd.org.apache.zookeeper.server.ZKDatabase; specialinvoke v.(oadd.org.apache.zookeeper.server.persistence.FileTxnSnapLog)>(v); v = (int) -1; v = (int) -1; specialinvoke v.(oadd.org.apache.zookeeper.server.persistence.FileTxnSnapLog,int,int,int,oadd.org.apache.zookeeper.server.ZKDatabase)>(v, v, v, v, v); return; } public oadd.org.apache.zookeeper.server.ServerStats serverStats() { oadd.org.apache.zookeeper.server.ZooKeeperServer v; oadd.org.apache.zookeeper.server.ServerStats v; v := @this: oadd.org.apache.zookeeper.server.ZooKeeperServer; v = v.; return v; } public void dumpConf(java.io.PrintWriter) { long v, v, v; oadd.org.apache.zookeeper.server.ZooKeeperServer v; int v, v, v, v, v, v; java.lang.String v, v; oadd.org.apache.zookeeper.server.persistence.FileTxnSnapLog v, v; java.io.PrintWriter v; java.io.File v, v; oadd.org.apache.zookeeper.server.ZKDatabase v, v; v := @this: oadd.org.apache.zookeeper.server.ZooKeeperServer; v := @parameter: java.io.PrintWriter; virtualinvoke v.("clientPort="); v = virtualinvoke v.(); virtualinvoke v.(v); virtualinvoke v.("secureClientPort="); v = virtualinvoke v.(); virtualinvoke v.(v); virtualinvoke v.("dataDir="); v = v.; v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.(v); virtualinvoke v.("dataDirSize="); v = virtualinvoke v.(); virtualinvoke v.(v); virtualinvoke v.("dataLogDir="); v = v.; v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.(v); virtualinvoke v.("dataLogSize="); v = virtualinvoke v.(); virtualinvoke v.(v); virtualinvoke v.("tickTime="); v = virtualinvoke v.(); virtualinvoke v.(v); virtualinvoke v.("maxClientCnxns="); v = virtualinvoke v.(); virtualinvoke v.(v); virtualinvoke v.("minSessionTimeout="); v = virtualinvoke v.(); virtualinvoke v.(v); virtualinvoke v.("maxSessionTimeout="); v = virtualinvoke v.(); virtualinvoke v.(v); virtualinvoke v.("serverId="); v = virtualinvoke v.(); virtualinvoke v.(v); return; } public oadd.org.apache.zookeeper.server.ZooKeeperServerConf getConf() { long v; oadd.org.apache.zookeeper.server.ZooKeeperServer v; int v, v, v, v, v; java.lang.String v, v; oadd.org.apache.zookeeper.server.persistence.FileTxnSnapLog v, v; oadd.org.apache.zookeeper.server.ZooKeeperServerConf v; java.io.File v, v; oadd.org.apache.zookeeper.server.ZKDatabase v, v; v := @this: oadd.org.apache.zookeeper.server.ZooKeeperServer; v = new oadd.org.apache.zookeeper.server.ZooKeeperServerConf; v = virtualinvoke v.(); v = v.; v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); v = v.; v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); specialinvoke v.(int,java.lang.String,java.lang.String,int,int,int,int,long)>(v, v, v, v, v, v, v, v); return v; } public void (java.io.File, java.io.File, int) throws java.io.IOException { int v; oadd.org.apache.zookeeper.server.ZooKeeperServer v; oadd.org.apache.zookeeper.server.persistence.FileTxnSnapLog v; java.io.File v, v; v := @this: oadd.org.apache.zookeeper.server.ZooKeeperServer; v := @parameter: java.io.File; v := @parameter: java.io.File; v := @parameter: int; v = new oadd.org.apache.zookeeper.server.persistence.FileTxnSnapLog; specialinvoke v.(java.io.File,java.io.File)>(v, v); specialinvoke v.(oadd.org.apache.zookeeper.server.persistence.FileTxnSnapLog,int)>(v, v); return; } public void (oadd.org.apache.zookeeper.server.persistence.FileTxnSnapLog) throws java.io.IOException { int v, v; oadd.org.apache.zookeeper.server.ZKDatabase v; oadd.org.apache.zookeeper.server.ZooKeeperServer v; oadd.org.apache.zookeeper.server.persistence.FileTxnSnapLog v; v := @this: oadd.org.apache.zookeeper.server.ZooKeeperServer; v := @parameter: oadd.org.apache.zookeeper.server.persistence.FileTxnSnapLog; v = new oadd.org.apache.zookeeper.server.ZKDatabase; specialinvoke v.(oadd.org.apache.zookeeper.server.persistence.FileTxnSnapLog)>(v); v = (int) -1; v = (int) -1; specialinvoke v.(oadd.org.apache.zookeeper.server.persistence.FileTxnSnapLog,int,int,int,oadd.org.apache.zookeeper.server.ZKDatabase)>(v, 3000, v, v, v); return; } public oadd.org.apache.zookeeper.server.ZKDatabase getZKDatabase() { oadd.org.apache.zookeeper.server.ZKDatabase v; oadd.org.apache.zookeeper.server.ZooKeeperServer v; v := @this: oadd.org.apache.zookeeper.server.ZooKeeperServer; v = v.; return v; } public void setZKDatabase(oadd.org.apache.zookeeper.server.ZKDatabase) { oadd.org.apache.zookeeper.server.ZKDatabase v; oadd.org.apache.zookeeper.server.ZooKeeperServer v; v := @this: oadd.org.apache.zookeeper.server.ZooKeeperServer; v := @parameter: oadd.org.apache.zookeeper.server.ZKDatabase; v. = v; return; } public void loadData() throws java.io.IOException, java.lang.InterruptedException { long v, v, v, v; oadd.org.apache.zookeeper.server.ZooKeeperServer v; java.util.LinkedList v; boolean v, v, v; java.util.Iterator v, v; java.util.Collection v; java.util.concurrent.ConcurrentHashMap v; oadd.org.apache.zookeeper.server.ZKDatabase v, v, v, v, v, v; java.lang.Object v, v, v; v := @this: oadd.org.apache.zookeeper.server.ZooKeeperServer; v = v.; v = virtualinvoke v.(); if v == 0 goto label; v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); goto label; label: v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); label: v = new java.util.LinkedList; specialinvoke v.()>(); v = v.; v = virtualinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(v); if v != null goto label; virtualinvoke v.(v); goto label; label: v = virtualinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = virtualinvoke v.(); v = v.; v = virtualinvoke v.(); virtualinvoke v.(v, v); goto label; label: virtualinvoke v.(); return; } public void takeSnapshot() { org.slf4j.Logger v; java.util.concurrent.ConcurrentHashMap v; java.io.IOException v; oadd.org.apache.zookeeper.server.ZooKeeperServer v; oadd.org.apache.zookeeper.server.DataTree v; oadd.org.apache.zookeeper.server.ZKDatabase v, v; oadd.org.apache.zookeeper.server.persistence.FileTxnSnapLog v; v := @this: oadd.org.apache.zookeeper.server.ZooKeeperServer; label: v = v.; v = v.; v = virtualinvoke v.(); v = v.; v = virtualinvoke v.(); virtualinvoke v.(v, v); label: goto label; label: v := @caughtexception; v = ; interfaceinvoke v.("Severe unrecoverable error, exiting", v); staticinvoke (10); label: return; catch java.io.IOException from label to label with label; } public long getDataDirSize() { oadd.org.apache.zookeeper.server.ZKDatabase v, v; long v; oadd.org.apache.zookeeper.server.ZooKeeperServer v; oadd.org.apache.zookeeper.server.persistence.FileTxnSnapLog v; java.io.File v; v := @this: oadd.org.apache.zookeeper.server.ZooKeeperServer; v = v.; if v != null goto label; return 0L; label: v = v.; v = v.; v = virtualinvoke v.(); v = specialinvoke v.(v); return v; } public long getLogDirSize() { oadd.org.apache.zookeeper.server.ZKDatabase v, v; long v; oadd.org.apache.zookeeper.server.ZooKeeperServer v; oadd.org.apache.zookeeper.server.persistence.FileTxnSnapLog v; java.io.File v; v := @this: oadd.org.apache.zookeeper.server.ZooKeeperServer; v = v.; if v != null goto label; return 0L; label: v = v.; v = v.; v = virtualinvoke v.(); v = specialinvoke v.(v); return v; } private long getDirSize(java.io.File) { long v, v; oadd.org.apache.zookeeper.server.ZooKeeperServer v; java.io.File v, v; int v, v; java.io.File[] v; boolean v; v := @this: oadd.org.apache.zookeeper.server.ZooKeeperServer; v := @parameter: java.io.File; v = 0L; v = virtualinvoke v.(); if v == 0 goto label; v = virtualinvoke v.(); if v == null goto label; v = lengthof v; v = 0; label: if v >= v goto label; v = v[v]; v = specialinvoke v.(v); v = v + v; v = v + 1; goto label; label: v = virtualinvoke v.(); label: return v; } public long getZxid() { java.util.concurrent.atomic.AtomicLong v; long v; oadd.org.apache.zookeeper.server.ZooKeeperServer v; v := @this: oadd.org.apache.zookeeper.server.ZooKeeperServer; v = v.; v = virtualinvoke v.(); return v; } public oadd.org.apache.zookeeper.server.SessionTracker getSessionTracker() { oadd.org.apache.zookeeper.server.ZooKeeperServer v; oadd.org.apache.zookeeper.server.SessionTracker v; v := @this: oadd.org.apache.zookeeper.server.ZooKeeperServer; v = v.; return v; } long getNextZxid() { java.util.concurrent.atomic.AtomicLong v; long v; oadd.org.apache.zookeeper.server.ZooKeeperServer v; v := @this: oadd.org.apache.zookeeper.server.ZooKeeperServer; v = v.; v = virtualinvoke v.(); return v; } public void setZxid(long) { java.util.concurrent.atomic.AtomicLong v; long v; oadd.org.apache.zookeeper.server.ZooKeeperServer v; v := @this: oadd.org.apache.zookeeper.server.ZooKeeperServer; v := @parameter: long; v = v.; virtualinvoke v.(v); return; } private void close(long) { oadd.org.apache.zookeeper.server.Request v; int v; long v; oadd.org.apache.zookeeper.server.ZooKeeperServer v; v := @this: oadd.org.apache.zookeeper.server.ZooKeeperServer; v := @parameter: long; v = new oadd.org.apache.zookeeper.server.Request; v = (int) -11; specialinvoke v.(oadd.org.apache.zookeeper.server.ServerCnxn,long,int,int,java.nio.ByteBuffer,java.util.List)>(null, v, 0, v, null, null); virtualinvoke v.(v); virtualinvoke v.(v); return; } public void closeSession(long) { org.slf4j.Logger v; long v; java.lang.String v, v; oadd.org.apache.zookeeper.server.ZooKeeperServer v; v := @this: oadd.org.apache.zookeeper.server.ZooKeeperServer; v := @parameter: long; v = ; v = staticinvoke (v); v = dynamicinvoke "makeConcatWithConstants" (v) ("Closing session 0x\u0001"); interfaceinvoke v.(v); specialinvoke v.(v); return; } protected void killSession(long, long) { org.slf4j.Logger v, v; long v, v; oadd.org.apache.zookeeper.server.ZooKeeperServer v; oadd.org.apache.zookeeper.server.ZKDatabase v; java.lang.String v, v; oadd.org.apache.zookeeper.server.SessionTracker v, v; boolean v; v := @this: oadd.org.apache.zookeeper.server.ZooKeeperServer; v := @parameter: long; v := @parameter: long; v = v.; virtualinvoke v.(v, v); v = ; v = interfaceinvoke v.(); if v == 0 goto label; v = ; v = staticinvoke (v); v = dynamicinvoke "makeConcatWithConstants" (v) ("ZooKeeperServer --- killSession: 0x\u0001"); staticinvoke (v, 32L, v); label: v = v.; if v == null goto label; v = v.; interfaceinvoke v.(v); label: return; } public void expire(oadd.org.apache.zookeeper.server.SessionTracker$Session) { org.slf4j.Logger v; oadd.org.apache.zookeeper.server.SessionTracker$Session v; int v; long v; java.lang.String v, v; oadd.org.apache.zookeeper.server.ZooKeeperServer v; v := @this: oadd.org.apache.zookeeper.server.ZooKeeperServer; v := @parameter: oadd.org.apache.zookeeper.server.SessionTracker$Session; v = interfaceinvoke v.(); v = ; v = staticinvoke (v); v = interfaceinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v, v) ("Expiring session 0x\u, timeout of \u0001ms exceeded"); interfaceinvoke v.(v); specialinvoke v.(v); return; } void touch(oadd.org.apache.zookeeper.server.ServerCnxn) throws oadd.org.apache.zookeeper.server.ZooKeeperServer$MissingSessionException { oadd.org.apache.zookeeper.server.ServerCnxn v; long v; oadd.org.apache.zookeeper.server.ZooKeeperServer v; int v; java.lang.String v, v; oadd.org.apache.zookeeper.server.ZooKeeperServer$MissingSessionException v; oadd.org.apache.zookeeper.server.SessionTracker v; boolean v; v := @this: oadd.org.apache.zookeeper.server.ZooKeeperServer; v := @parameter: oadd.org.apache.zookeeper.server.ServerCnxn; if v != null goto label; return; label: v = virtualinvoke v.(); v = virtualinvoke v.(); v = v.; v = interfaceinvoke v.(v, v); if v != 0 goto label; v = new oadd.org.apache.zookeeper.server.ZooKeeperServer$MissingSessionException; v = staticinvoke (v); v = dynamicinvoke "makeConcatWithConstants" (v) ("No session with sessionid 0x\u exists, probably expired and removed"); specialinvoke v.(java.lang.String)>(v); throw v; label: return; } protected void registerJMX() { org.slf4j.Logger v, v; oadd.org.apache.zookeeper.server.ZooKeeperServer v; oadd.org.apache.zookeeper.server.DataTree v; java.lang.Exception v, v; oadd.org.apache.zookeeper.server.DataTreeBean v, v; oadd.org.apache.zookeeper.jmx.MBeanRegistry v, v; oadd.org.apache.zookeeper.server.ZKDatabase v; oadd.org.apache.zookeeper.server.ZooKeeperServerBean v, v, v; v := @this: oadd.org.apache.zookeeper.server.ZooKeeperServer; label: v = new oadd.org.apache.zookeeper.server.ZooKeeperServerBean; specialinvoke v.(oadd.org.apache.zookeeper.server.ZooKeeperServer)>(v); v. = v; v = staticinvoke (); v = v.; virtualinvoke v.(v, null); label: v = new oadd.org.apache.zookeeper.server.DataTreeBean; v = v.; v = virtualinvoke v.(); specialinvoke v.(oadd.org.apache.zookeeper.server.DataTree)>(v); v. = v; v = staticinvoke (); v = v.; v = v.; virtualinvoke v.(v, v); label: goto label; label: v := @caughtexception; v = ; interfaceinvoke v.("Failed to register with JMX", v); v. = null; label: goto label; label: v := @caughtexception; v = ; interfaceinvoke v.("Failed to register with JMX", v); v. = null; label: return; catch java.lang.Exception from label to label with label; catch java.lang.Exception from label to label with label; } public void startdata() throws java.io.IOException, java.lang.InterruptedException { oadd.org.apache.zookeeper.server.ZKDatabase v, v, v; oadd.org.apache.zookeeper.server.ZooKeeperServer v; oadd.org.apache.zookeeper.server.persistence.FileTxnSnapLog v; boolean v; v := @this: oadd.org.apache.zookeeper.server.ZooKeeperServer; v = v.; if v != null goto label; v = new oadd.org.apache.zookeeper.server.ZKDatabase; v = v.; specialinvoke v.(oadd.org.apache.zookeeper.server.persistence.FileTxnSnapLog)>(v); v. = v; label: v = v.; v = virtualinvoke v.(); if v != 0 goto label; virtualinvoke v.(); label: return; } public synchronized void startup() { oadd.org.apache.zookeeper.server.ZooKeeperServer$State v; oadd.org.apache.zookeeper.server.ZooKeeperServer v; oadd.org.apache.zookeeper.server.SessionTracker v; v := @this: oadd.org.apache.zookeeper.server.ZooKeeperServer; v = v.; if v != null goto label; virtualinvoke v.(); label: virtualinvoke v.(); virtualinvoke v.(); virtualinvoke v.(); v = ; virtualinvoke v.(v); virtualinvoke v.(); return; } protected void setupRequestProcessors() { oadd.org.apache.zookeeper.server.SyncRequestProcessor v; oadd.org.apache.zookeeper.server.PrepRequestProcessor v; oadd.org.apache.zookeeper.server.FinalRequestProcessor v; oadd.org.apache.zookeeper.server.RequestProcessor v; oadd.org.apache.zookeeper.server.ZooKeeperServer v; v := @this: oadd.org.apache.zookeeper.server.ZooKeeperServer; v = new oadd.org.apache.zookeeper.server.FinalRequestProcessor; specialinvoke v.(oadd.org.apache.zookeeper.server.ZooKeeperServer)>(v); v = new oadd.org.apache.zookeeper.server.SyncRequestProcessor; specialinvoke v.(oadd.org.apache.zookeeper.server.ZooKeeperServer,oadd.org.apache.zookeeper.server.RequestProcessor)>(v, v); virtualinvoke v.(); v = new oadd.org.apache.zookeeper.server.PrepRequestProcessor; specialinvoke v.(oadd.org.apache.zookeeper.server.ZooKeeperServer,oadd.org.apache.zookeeper.server.RequestProcessor)>(v, v); v. = v; v = v.; virtualinvoke v.(); return; } public oadd.org.apache.zookeeper.server.ZooKeeperServerListener getZooKeeperServerListener() { oadd.org.apache.zookeeper.server.ZooKeeperServer v; oadd.org.apache.zookeeper.server.ZooKeeperServerListener v; v := @this: oadd.org.apache.zookeeper.server.ZooKeeperServer; v = v.; return v; } public void setCreateSessionTrackerServerId(int) { int v; oadd.org.apache.zookeeper.server.ZooKeeperServer v; v := @this: oadd.org.apache.zookeeper.server.ZooKeeperServer; v := @parameter: int; v. = v; return; } protected void createSessionTracker() { oadd.org.apache.zookeeper.server.ZooKeeperServerListener v; int v, v; java.util.concurrent.ConcurrentHashMap v; oadd.org.apache.zookeeper.server.ZKDatabase v; oadd.org.apache.zookeeper.server.ZooKeeperServer v; oadd.org.apache.zookeeper.server.SessionTrackerImpl v; v := @this: oadd.org.apache.zookeeper.server.ZooKeeperServer; v = new oadd.org.apache.zookeeper.server.SessionTrackerImpl; v = v.; v = virtualinvoke v.(); v = v.; v = v.; v = virtualinvoke v.(); specialinvoke v.(oadd.org.apache.zookeeper.server.SessionTracker$SessionExpirer,java.util.concurrent.ConcurrentMap,int,long,oadd.org.apache.zookeeper.server.ZooKeeperServerListener)>(v, v, v, v, v); v. = v; return; } protected void startSessionTracker() { oadd.org.apache.zookeeper.server.ZooKeeperServer v; oadd.org.apache.zookeeper.server.SessionTracker v; v := @this: oadd.org.apache.zookeeper.server.ZooKeeperServer; v = v.; virtualinvoke v.(); return; } protected void setState(oadd.org.apache.zookeeper.server.ZooKeeperServer$State) { org.slf4j.Logger v; oadd.org.apache.zookeeper.server.ZooKeeperServer$State v; oadd.org.apache.zookeeper.server.ZooKeeperServer v; oadd.org.apache.zookeeper.server.ZooKeeperServerShutdownHandler v, v; v := @this: oadd.org.apache.zookeeper.server.ZooKeeperServer; v := @parameter: oadd.org.apache.zookeeper.server.ZooKeeperServer$State; v. = v; v = v.; if v == null goto label; v = v.; virtualinvoke v.(v); goto label; label: v = ; interfaceinvoke v.("ZKShutdownHandler is not registered, so ZooKeeper server won\'t take any action on ERROR or SHUTDOWN server state changes"); label: return; } protected boolean canShutdown() { oadd.org.apache.zookeeper.server.ZooKeeperServer$State v, v, v, v; oadd.org.apache.zookeeper.server.ZooKeeperServer v; boolean v; v := @this: oadd.org.apache.zookeeper.server.ZooKeeperServer; v = v.; v = ; if v == v goto label; v = v.; v = ; if v != v goto label; label: v = 1; goto label; label: v = 0; label: return v; } public boolean isRunning() { oadd.org.apache.zookeeper.server.ZooKeeperServer$State v, v; oadd.org.apache.zookeeper.server.ZooKeeperServer v; boolean v; v := @this: oadd.org.apache.zookeeper.server.ZooKeeperServer; v = v.; v = ; if v != v goto label; v = 1; goto label; label: v = 0; label: return v; } public void shutdown() { oadd.org.apache.zookeeper.server.ZooKeeperServer v; v := @this: oadd.org.apache.zookeeper.server.ZooKeeperServer; virtualinvoke v.(0); return; } public synchronized void shutdown(boolean) { oadd.org.apache.zookeeper.server.ZooKeeperServer v; oadd.org.apache.zookeeper.server.ZooKeeperServer$State v; oadd.org.apache.zookeeper.server.SessionTracker v, v; boolean v, v; org.slf4j.Logger v, v, v; java.io.IOException v; oadd.org.apache.zookeeper.server.ZKDatabase v, v, v, v; oadd.org.apache.zookeeper.server.RequestProcessor v, v; v := @this: oadd.org.apache.zookeeper.server.ZooKeeperServer; v := @parameter: boolean; v = virtualinvoke v.(); if v != 0 goto label; v = ; interfaceinvoke v.("ZooKeeper server is not running, so not proceeding to shutdown!"); return; label: v = ; interfaceinvoke v.("shutting down"); v = ; virtualinvoke v.(v); v = v.; if v == null goto label; v = v.; interfaceinvoke v.(); label: v = v.; if v == null goto label; v = v.; interfaceinvoke v.(); label: v = v.; if v == null goto label; if v == 0 goto label; v = v.; virtualinvoke v.(); goto label; label: v = v.; virtualinvoke v.(); label: goto label; label: v := @caughtexception; v = ; interfaceinvoke v.("Error updating DB", v); v = v.; virtualinvoke v.(); label: virtualinvoke v.(); return; catch java.io.IOException from label to label with label; } protected void unregisterJMX() { org.slf4j.Logger v, v; oadd.org.apache.zookeeper.server.ZooKeeperServer v; java.lang.Exception v, v; oadd.org.apache.zookeeper.server.DataTreeBean v, v; oadd.org.apache.zookeeper.jmx.MBeanRegistry v, v; oadd.org.apache.zookeeper.server.ZooKeeperServerBean v, v; v := @this: oadd.org.apache.zookeeper.server.ZooKeeperServer; label: v = v.; if v == null goto label; v = staticinvoke (); v = v.; virtualinvoke v.(v); label: goto label; label: v := @caughtexception; v = ; interfaceinvoke v.("Failed to unregister with JMX", v); label: v = v.; if v == null goto label; v = staticinvoke (); v = v.; virtualinvoke v.(v); label: goto label; label: v := @caughtexception; v = ; interfaceinvoke v.("Failed to unregister with JMX", v); label: v. = null; v. = null; return; catch java.lang.Exception from label to label with label; catch java.lang.Exception from label to label with label; } public void incInProcess() { oadd.org.apache.zookeeper.server.ZooKeeperServer v; java.util.concurrent.atomic.AtomicInteger v; v := @this: oadd.org.apache.zookeeper.server.ZooKeeperServer; v = v.; virtualinvoke v.(); return; } public void decInProcess() { oadd.org.apache.zookeeper.server.ZooKeeperServer v; java.util.concurrent.atomic.AtomicInteger v; v := @this: oadd.org.apache.zookeeper.server.ZooKeeperServer; v = v.; virtualinvoke v.(); return; } public int getInProcess() { int v; oadd.org.apache.zookeeper.server.ZooKeeperServer v; java.util.concurrent.atomic.AtomicInteger v; v := @this: oadd.org.apache.zookeeper.server.ZooKeeperServer; v = v.; v = virtualinvoke v.(); return v; } byte[] generatePasswd(long) { byte[] v; java.util.Random v; long v, v; oadd.org.apache.zookeeper.server.ZooKeeperServer v; v := @this: oadd.org.apache.zookeeper.server.ZooKeeperServer; v := @parameter: long; v = new java.util.Random; v = v ^ 3007405056L; specialinvoke v.(long)>(v); v = newarray (byte)[16]; virtualinvoke v.(v); return v; } protected boolean checkPasswd(long, byte[]) { byte[] v, v; byte v; long v; oadd.org.apache.zookeeper.server.ZooKeeperServer v; boolean v, v; v := @this: oadd.org.apache.zookeeper.server.ZooKeeperServer; v := @parameter: long; v := @parameter: byte[]; v = v cmp 0L; if v == 0 goto label; v = virtualinvoke v.(v); v = staticinvoke (v, v); if v == 0 goto label; v = 1; goto label; label: v = 0; label: return v; } long createSession(oadd.org.apache.zookeeper.server.ServerCnxn, byte[], int) { byte[] v; oadd.org.apache.zookeeper.server.ServerCnxn v; java.util.Random v; long v, v; oadd.org.apache.zookeeper.server.ZooKeeperServer v; java.nio.ByteBuffer v; oadd.org.apache.zookeeper.server.Request v; int v, v; oadd.org.apache.zookeeper.server.SessionTracker v; v := @this: oadd.org.apache.zookeeper.server.ZooKeeperServer; v := @parameter: oadd.org.apache.zookeeper.server.ServerCnxn; v := @parameter: byte[]; v := @parameter: int; if v != null goto label; v = newarray (byte)[0]; label: v = v.; v = interfaceinvoke v.(v); v = new java.util.Random; v = v ^ 3007405056L; specialinvoke v.(long)>(v); virtualinvoke v.(v); v = staticinvoke (4); virtualinvoke v.(v); virtualinvoke v.(v); v = new oadd.org.apache.zookeeper.server.Request; v = (int) -10; specialinvoke v.(oadd.org.apache.zookeeper.server.ServerCnxn,long,int,int,java.nio.ByteBuffer,java.util.List)>(v, v, 0, v, v, null); virtualinvoke v.(v); virtualinvoke v.(v); return v; } public void setOwner(long, java.lang.Object) throws oadd.org.apache.zookeeper.KeeperException$SessionExpiredException { java.lang.Object v; long v; oadd.org.apache.zookeeper.server.ZooKeeperServer v; oadd.org.apache.zookeeper.server.SessionTracker v; v := @this: oadd.org.apache.zookeeper.server.ZooKeeperServer; v := @parameter: long; v := @parameter: java.lang.Object; v = v.; interfaceinvoke v.(v, v); return; } protected void revalidateSession(oadd.org.apache.zookeeper.server.ServerCnxn, long, int) throws java.io.IOException { org.slf4j.Logger v, v; oadd.org.apache.zookeeper.server.ServerCnxn v; long v; oadd.org.apache.zookeeper.server.ZooKeeperServer v; int v; java.lang.String v, v; oadd.org.apache.zookeeper.server.SessionTracker v; boolean v, v; v := @this: oadd.org.apache.zookeeper.server.ZooKeeperServer; v := @parameter: oadd.org.apache.zookeeper.server.ServerCnxn; v := @parameter: long; v := @parameter: int; v = v.; v = interfaceinvoke v.(v, v); v = ; v = interfaceinvoke v.(); if v == 0 goto label; v = ; v = staticinvoke (v); v = dynamicinvoke "makeConcatWithConstants" (v, v) ("Session 0x\u is valid: \u0001"); staticinvoke (v, 32L, v); label: virtualinvoke v.(v, v); return; } public void reopenSession(oadd.org.apache.zookeeper.server.ServerCnxn, long, byte[], int) throws java.io.IOException { byte[] v; org.slf4j.Logger v; oadd.org.apache.zookeeper.server.ServerCnxn v; long v; oadd.org.apache.zookeeper.server.ZooKeeperServer v; java.net.InetSocketAddress v; int v; java.lang.String v, v; boolean v; v := @this: oadd.org.apache.zookeeper.server.ZooKeeperServer; v := @parameter: oadd.org.apache.zookeeper.server.ServerCnxn; v := @parameter: long; v := @parameter: byte[]; v := @parameter: int; v = virtualinvoke v.(v, v); if v == 0 goto label; virtualinvoke v.(v, v, v); goto label; label: v = ; v = virtualinvoke v.(); v = staticinvoke (v); v = dynamicinvoke "makeConcatWithConstants" (v, v) ("Incorrect password from \u for session 0x\u0001"); interfaceinvoke v.(v); virtualinvoke v.(v, 0); label: return; } public void finishSessionInit(oadd.org.apache.zookeeper.server.ServerCnxn, boolean) { byte[] v, v; oadd.org.apache.zookeeper.server.ServerCnxn v; java.nio.ByteBuffer v, v, v; oadd.org.apache.zookeeper.server.ServerCnxnFactory v, v, v, v, v, v; boolean v, v, v, v, v; java.util.Set v, v; java.net.InetSocketAddress v, v; java.lang.Exception v, v; oadd.org.apache.zookeeper.proto.ConnectResponse v; java.io.ByteArrayOutputStream v; long v, v, v, v; oadd.org.apache.zookeeper.server.ZooKeeperServer v; int v, v, v, v, v; java.lang.String v, v, v, v; org.slf4j.Logger v, v, v, v; oadd.org.apache.jute.BinaryOutputArchive v; v := @this: oadd.org.apache.zookeeper.server.ZooKeeperServer; v := @parameter: oadd.org.apache.zookeeper.server.ServerCnxn; v := @parameter: boolean; label: if v == 0 goto label; v = v.; if v == null goto label; v = v.; v = v.; v = interfaceinvoke v.(v); if v == 0 goto label; v = v.; virtualinvoke v.(v); goto label; label: v = v.; if v == null goto label; v = v.; v = v.; v = interfaceinvoke v.(v); if v == 0 goto label; v = v.; virtualinvoke v.(v); label: goto label; label: v := @caughtexception; v = ; interfaceinvoke v.("Failed to register with JMX", v); label: v = new oadd.org.apache.zookeeper.proto.ConnectResponse; if v == 0 goto label; v = virtualinvoke v.(); goto label; label: v = 0; label: if v == 0 goto label; v = virtualinvoke v.(); goto label; label: v = 0L; label: if v == 0 goto label; v = virtualinvoke v.(); v = virtualinvoke v.(v); goto label; label: v = newarray (byte)[16]; label: specialinvoke v.(int,int,long,byte[])>(0, v, v, v); v = new java.io.ByteArrayOutputStream; specialinvoke v.()>(); v = staticinvoke (v); v = (int) -1; virtualinvoke v.(v, "len"); virtualinvoke v.(v, "connect"); v = v.; if v != 0 goto label; v = v instanceof oadd.org.apache.zookeeper.server.quorum.ReadOnlyZooKeeperServer; virtualinvoke v.(v, "readOnly"); label: virtualinvoke v.(); v = virtualinvoke v.(); v = staticinvoke (v); v = virtualinvoke v.(); v = v - 4; v = virtualinvoke v.(v); virtualinvoke v.(); virtualinvoke v.(v); if v == 0 goto label; v = ; v = virtualinvoke v.(); v = staticinvoke (v); v = virtualinvoke v.(); v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v, v, v)