public class oadd.org.apache.zookeeper.server.DataTree extends java.lang.Object
{
private static final org.slf4j.Logger LOG;
private final java.util.concurrent.ConcurrentHashMap nodes;
private final oadd.org.apache.zookeeper.server.WatchManager dataWatches;
private final oadd.org.apache.zookeeper.server.WatchManager childWatches;
private static final java.lang.String rootZookeeper;
private static final java.lang.String procZookeeper;
private static final java.lang.String procChildZookeeper;
private static final java.lang.String quotaZookeeper;
private static final java.lang.String quotaChildZookeeper;
private static final java.lang.String configZookeeper;
private static final java.lang.String configChildZookeeper;
private final oadd.org.apache.zookeeper.common.PathTrie pTrie;
private final java.util.Map ephemerals;
private final java.util.Set containers;
private final java.util.Set ttls;
private final oadd.org.apache.zookeeper.server.ReferenceCountedACLCache aclCache;
private oadd.org.apache.zookeeper.server.DataNode root;
private final oadd.org.apache.zookeeper.server.DataNode procDataNode;
private final oadd.org.apache.zookeeper.server.DataNode quotaDataNode;
public volatile long lastProcessedZxid;
static final boolean $assertionsDisabled;
public java.util.Set getEphemerals(long)
{
java.lang.Throwable v;
long v;
oadd.org.apache.zookeeper.server.DataTree v;
java.util.HashSet v;
java.lang.Long v;
java.util.Map v;
java.lang.Object v, v;
v := @this: oadd.org.apache.zookeeper.server.DataTree;
v := @parameter: long;
v = v.<oadd.org.apache.zookeeper.server.DataTree: java.util.Map ephemerals>;
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
if v != null goto label;
v = new java.util.HashSet;
specialinvoke v.<java.util.HashSet: void <init>()>();
return v;
label:
entermonitor v;
label:
v = virtualinvoke v.<java.util.HashSet: java.lang.Object clone()>();
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;
}
public java.util.Set getContainers()
{
java.util.HashSet v;
java.util.Set v;
oadd.org.apache.zookeeper.server.DataTree v;
v := @this: oadd.org.apache.zookeeper.server.DataTree;
v = new java.util.HashSet;
v = v.<oadd.org.apache.zookeeper.server.DataTree: java.util.Set containers>;
specialinvoke v.<java.util.HashSet: void <init>(java.util.Collection)>(v);
return v;
}
public java.util.Set getTtls()
{
java.util.HashSet v;
java.util.Set v;
oadd.org.apache.zookeeper.server.DataTree v;
v := @this: oadd.org.apache.zookeeper.server.DataTree;
v = new java.util.HashSet;
v = v.<oadd.org.apache.zookeeper.server.DataTree: java.util.Set ttls>;
specialinvoke v.<java.util.HashSet: void <init>(java.util.Collection)>(v);
return v;
}
public java.util.Collection getSessions()
{
java.util.Set v;
oadd.org.apache.zookeeper.server.DataTree v;
java.util.Map v;
v := @this: oadd.org.apache.zookeeper.server.DataTree;
v = v.<oadd.org.apache.zookeeper.server.DataTree: java.util.Map ephemerals>;
v = interfaceinvoke v.<java.util.Map: java.util.Set keySet()>();
return v;
}
public oadd.org.apache.zookeeper.server.DataNode getNode(java.lang.String)
{
java.util.concurrent.ConcurrentHashMap v;
java.lang.Object v;
java.lang.String v;
oadd.org.apache.zookeeper.server.DataTree v;
v := @this: oadd.org.apache.zookeeper.server.DataTree;
v := @parameter: java.lang.String;
v = v.<oadd.org.apache.zookeeper.server.DataTree: java.util.concurrent.ConcurrentHashMap nodes>;
v = virtualinvoke v.<java.util.concurrent.ConcurrentHashMap: java.lang.Object get(java.lang.Object)>(v);
return v;
}
public int getNodeCount()
{
int v;
java.util.concurrent.ConcurrentHashMap v;
oadd.org.apache.zookeeper.server.DataTree v;
v := @this: oadd.org.apache.zookeeper.server.DataTree;
v = v.<oadd.org.apache.zookeeper.server.DataTree: java.util.concurrent.ConcurrentHashMap nodes>;
v = virtualinvoke v.<java.util.concurrent.ConcurrentHashMap: int size()>();
return v;
}
public int getWatchCount()
{
oadd.org.apache.zookeeper.server.WatchManager v, v;
int v, v, v;
oadd.org.apache.zookeeper.server.DataTree v;
v := @this: oadd.org.apache.zookeeper.server.DataTree;
v = v.<oadd.org.apache.zookeeper.server.DataTree: oadd.org.apache.zookeeper.server.WatchManager dataWatches>;
v = virtualinvoke v.<oadd.org.apache.zookeeper.server.WatchManager: int size()>();
v = v.<oadd.org.apache.zookeeper.server.DataTree: oadd.org.apache.zookeeper.server.WatchManager childWatches>;
v = virtualinvoke v.<oadd.org.apache.zookeeper.server.WatchManager: int size()>();
v = v + v;
return v;
}
public int getEphemeralsCount()
{
java.util.Iterator v;
java.util.Collection v;
oadd.org.apache.zookeeper.server.DataTree v;
java.util.Map v;
int v, v;
java.lang.Object v;
boolean v;
v := @this: oadd.org.apache.zookeeper.server.DataTree;
v = 0;
v = v.<oadd.org.apache.zookeeper.server.DataTree: java.util.Map ephemerals>;
v = interfaceinvoke v.<java.util.Map: java.util.Collection values()>();
v = interfaceinvoke v.<java.util.Collection: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = virtualinvoke v.<java.util.HashSet: int size()>();
v = v + v;
goto label;
label:
return v;
}
public long approximateDataSize()
{
java.lang.Throwable v;
java.util.Iterator v;
java.util.concurrent.ConcurrentHashMap v;
java.util.Set v;
long v, v, v;
oadd.org.apache.zookeeper.server.DataTree v;
int v;
java.lang.Object v, v, v;
boolean v;
v := @this: oadd.org.apache.zookeeper.server.DataTree;
v = 0L;
v = v.<oadd.org.apache.zookeeper.server.DataTree: java.util.concurrent.ConcurrentHashMap nodes>;
v = virtualinvoke v.<java.util.concurrent.ConcurrentHashMap: java.util.Set entrySet()>();
v = interfaceinvoke v.<java.util.Set: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getValue()>();
entermonitor v;
label:
v = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getKey()>();
v = virtualinvoke v.<java.lang.String: int length()>();
v = v + v;
v = virtualinvoke v.<oadd.org.apache.zookeeper.server.DataNode: long getApproximateDataSize()>();
v = v + v;
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;
}
public void <init>()
{
byte[] v, v, v;
java.lang.Long v, v, v;
oadd.org.apache.zookeeper.server.WatchManager v, v;
java.util.concurrent.ConcurrentHashMap v, v, v, v, v, v, v, v;
java.util.Set v, v;
oadd.org.apache.zookeeper.server.DataTree v;
oadd.org.apache.zookeeper.server.ReferenceCountedACLCache v;
java.lang.String v, v;
oadd.org.apache.zookeeper.common.PathTrie v;
oadd.org.apache.zookeeper.server.DataNode v, v, v, v, v, v, v, v, v;
oadd.org.apache.zookeeper.data.StatPersisted v, v, v;
v := @this: oadd.org.apache.zookeeper.server.DataTree;
specialinvoke v.<java.lang.Object: void <init>()>();
v = new java.util.concurrent.ConcurrentHashMap;
specialinvoke v.<java.util.concurrent.ConcurrentHashMap: void <init>()>();
v.<oadd.org.apache.zookeeper.server.DataTree: java.util.concurrent.ConcurrentHashMap nodes> = v;
v = new oadd.org.apache.zookeeper.server.WatchManager;
specialinvoke v.<oadd.org.apache.zookeeper.server.WatchManager: void <init>()>();
v.<oadd.org.apache.zookeeper.server.DataTree: oadd.org.apache.zookeeper.server.WatchManager dataWatches> = v;
v = new oadd.org.apache.zookeeper.server.WatchManager;
specialinvoke v.<oadd.org.apache.zookeeper.server.WatchManager: void <init>()>();
v.<oadd.org.apache.zookeeper.server.DataTree: oadd.org.apache.zookeeper.server.WatchManager childWatches> = v;
v = new oadd.org.apache.zookeeper.common.PathTrie;
specialinvoke v.<oadd.org.apache.zookeeper.common.PathTrie: void <init>()>();
v.<oadd.org.apache.zookeeper.server.DataTree: oadd.org.apache.zookeeper.common.PathTrie pTrie> = v;
v = new java.util.concurrent.ConcurrentHashMap;
specialinvoke v.<java.util.concurrent.ConcurrentHashMap: void <init>()>();
v.<oadd.org.apache.zookeeper.server.DataTree: java.util.Map ephemerals> = v;
v = new java.util.concurrent.ConcurrentHashMap;
specialinvoke v.<java.util.concurrent.ConcurrentHashMap: void <init>()>();
v = staticinvoke <java.util.Collections: java.util.Set newSetFromMap(java.util.Map)>(v);
v.<oadd.org.apache.zookeeper.server.DataTree: java.util.Set containers> = v;
v = new java.util.concurrent.ConcurrentHashMap;
specialinvoke v.<java.util.concurrent.ConcurrentHashMap: void <init>()>();
v = staticinvoke <java.util.Collections: java.util.Set newSetFromMap(java.util.Map)>(v);
v.<oadd.org.apache.zookeeper.server.DataTree: java.util.Set ttls> = v;
v = new oadd.org.apache.zookeeper.server.ReferenceCountedACLCache;
specialinvoke v.<oadd.org.apache.zookeeper.server.ReferenceCountedACLCache: void <init>()>();
v.<oadd.org.apache.zookeeper.server.DataTree: oadd.org.apache.zookeeper.server.ReferenceCountedACLCache aclCache> = v;
v = new oadd.org.apache.zookeeper.server.DataNode;
v = newarray (byte)[0];
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(-1L);
v = new oadd.org.apache.zookeeper.data.StatPersisted;
specialinvoke v.<oadd.org.apache.zookeeper.data.StatPersisted: void <init>()>();
specialinvoke v.<oadd.org.apache.zookeeper.server.DataNode: void <init>(byte[],java.lang.Long,oadd.org.apache.zookeeper.data.StatPersisted)>(v, v, v);
v.<oadd.org.apache.zookeeper.server.DataTree: oadd.org.apache.zookeeper.server.DataNode root> = v;
v = new oadd.org.apache.zookeeper.server.DataNode;
v = newarray (byte)[0];
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(-1L);
v = new oadd.org.apache.zookeeper.data.StatPersisted;
specialinvoke v.<oadd.org.apache.zookeeper.data.StatPersisted: void <init>()>();
specialinvoke v.<oadd.org.apache.zookeeper.server.DataNode: void <init>(byte[],java.lang.Long,oadd.org.apache.zookeeper.data.StatPersisted)>(v, v, v);
v.<oadd.org.apache.zookeeper.server.DataTree: oadd.org.apache.zookeeper.server.DataNode procDataNode> = v;
v = new oadd.org.apache.zookeeper.server.DataNode;
v = newarray (byte)[0];
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(-1L);
v = new oadd.org.apache.zookeeper.data.StatPersisted;
specialinvoke v.<oadd.org.apache.zookeeper.data.StatPersisted: void <init>()>();
specialinvoke v.<oadd.org.apache.zookeeper.server.DataNode: void <init>(byte[],java.lang.Long,oadd.org.apache.zookeeper.data.StatPersisted)>(v, v, v);
v.<oadd.org.apache.zookeeper.server.DataTree: oadd.org.apache.zookeeper.server.DataNode quotaDataNode> = v;
v.<oadd.org.apache.zookeeper.server.DataTree: long lastProcessedZxid> = 0L;
v = v.<oadd.org.apache.zookeeper.server.DataTree: java.util.concurrent.ConcurrentHashMap nodes>;
v = v.<oadd.org.apache.zookeeper.server.DataTree: oadd.org.apache.zookeeper.server.DataNode root>;
virtualinvoke v.<java.util.concurrent.ConcurrentHashMap: java.lang.Object put(java.lang.Object,java.lang.Object)>("", v);
v = v.<oadd.org.apache.zookeeper.server.DataTree: java.util.concurrent.ConcurrentHashMap nodes>;
v = v.<oadd.org.apache.zookeeper.server.DataTree: oadd.org.apache.zookeeper.server.DataNode root>;
virtualinvoke v.<java.util.concurrent.ConcurrentHashMap: java.lang.Object put(java.lang.Object,java.lang.Object)>("/", v);
v = v.<oadd.org.apache.zookeeper.server.DataTree: oadd.org.apache.zookeeper.server.DataNode root>;
v = <oadd.org.apache.zookeeper.server.DataTree: java.lang.String procChildZookeeper>;
virtualinvoke v.<oadd.org.apache.zookeeper.server.DataNode: boolean addChild(java.lang.String)>(v);
v = v.<oadd.org.apache.zookeeper.server.DataTree: java.util.concurrent.ConcurrentHashMap nodes>;
v = v.<oadd.org.apache.zookeeper.server.DataTree: oadd.org.apache.zookeeper.server.DataNode procDataNode>;
virtualinvoke v.<java.util.concurrent.ConcurrentHashMap: java.lang.Object put(java.lang.Object,java.lang.Object)>("/zookeeper", v);
v = v.<oadd.org.apache.zookeeper.server.DataTree: oadd.org.apache.zookeeper.server.DataNode procDataNode>;
v = <oadd.org.apache.zookeeper.server.DataTree: java.lang.String quotaChildZookeeper>;
virtualinvoke v.<oadd.org.apache.zookeeper.server.DataNode: boolean addChild(java.lang.String)>(v);
v = v.<oadd.org.apache.zookeeper.server.DataTree: java.util.concurrent.ConcurrentHashMap nodes>;
v = v.<oadd.org.apache.zookeeper.server.DataTree: oadd.org.apache.zookeeper.server.DataNode quotaDataNode>;
virtualinvoke v.<java.util.concurrent.ConcurrentHashMap: java.lang.Object put(java.lang.Object,java.lang.Object)>("/zookeeper/quota", v);
virtualinvoke v.<oadd.org.apache.zookeeper.server.DataTree: void addConfigNode()>();
return;
}
public void addConfigNode()
{
byte[] v;
java.lang.AssertionError v, v;
oadd.org.apache.zookeeper.server.DataTree v;
java.util.ArrayList v;
java.lang.Long v;
int v;
java.lang.String v;
boolean v, v;
oadd.org.apache.zookeeper.server.DataNode v;
oadd.org.apache.zookeeper.data.StatPersisted v;
java.util.concurrent.ConcurrentHashMap v, v;
oadd.org.apache.zookeeper.KeeperException$NoNodeException v;
java.lang.Object v;
v := @this: oadd.org.apache.zookeeper.server.DataTree;
v = v.<oadd.org.apache.zookeeper.server.DataTree: java.util.concurrent.ConcurrentHashMap nodes>;
v = virtualinvoke v.<java.util.concurrent.ConcurrentHashMap: java.lang.Object get(java.lang.Object)>("/zookeeper");
if v == null goto label;
v = <oadd.org.apache.zookeeper.server.DataTree: java.lang.String configChildZookeeper>;
virtualinvoke v.<oadd.org.apache.zookeeper.server.DataNode: boolean addChild(java.lang.String)>(v);
goto label;
label:
v = <oadd.org.apache.zookeeper.server.DataTree: boolean $assertionsDisabled>;
if v != 0 goto label;
v = new java.lang.AssertionError;
specialinvoke v.<java.lang.AssertionError: void <init>(java.lang.Object)>("There\'s no /zookeeper znode - this should never happen.");
throw v;
label:
v = v.<oadd.org.apache.zookeeper.server.DataTree: java.util.concurrent.ConcurrentHashMap nodes>;
v = new oadd.org.apache.zookeeper.server.DataNode;
v = newarray (byte)[0];
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(-1L);
v = new oadd.org.apache.zookeeper.data.StatPersisted;
specialinvoke v.<oadd.org.apache.zookeeper.data.StatPersisted: void <init>()>();
specialinvoke v.<oadd.org.apache.zookeeper.server.DataNode: void <init>(byte[],java.lang.Long,oadd.org.apache.zookeeper.data.StatPersisted)>(v, v, v);
virtualinvoke v.<java.util.concurrent.ConcurrentHashMap: java.lang.Object put(java.lang.Object,java.lang.Object)>("/zookeeper/config", v);
label:
v = <oadd.org.apache.zookeeper.ZooDefs$Ids: java.util.ArrayList READ_ACL_UNSAFE>;
v = (int) -1;
virtualinvoke v.<oadd.org.apache.zookeeper.server.DataTree: oadd.org.apache.zookeeper.data.Stat setACL(java.lang.String,java.util.List,int)>("/zookeeper/config", v, v);
label:
goto label;
label:
v := @caughtexception;
v = <oadd.org.apache.zookeeper.server.DataTree: boolean $assertionsDisabled>;
if v != 0 goto label;
v = new java.lang.AssertionError;
specialinvoke v.<java.lang.AssertionError: void <init>(java.lang.Object)>("There\'s no /zookeeper/config znode - this should never happen.");
throw v;
label:
return;
catch oadd.org.apache.zookeeper.KeeperException$NoNodeException from label to label with label;
}
boolean isSpecialPath(java.lang.String)
{
oadd.org.apache.zookeeper.server.DataTree v;
java.lang.String v, v, v, v, v;
boolean v, v, v, v;
v := @this: oadd.org.apache.zookeeper.server.DataTree;
v := @parameter: java.lang.String;
v = "/";
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>(v);
if v != 0 goto label;
v = "/zookeeper";
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>(v);
if v != 0 goto label;
v = "/zookeeper/quota";
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>(v);
if v != 0 goto label;
v = "/zookeeper/config";
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>(v);
if v == 0 goto label;
label:
return 1;
label:
return 0;
}
public static void copyStatPersisted(oadd.org.apache.zookeeper.data.StatPersisted, oadd.org.apache.zookeeper.data.StatPersisted)
{
oadd.org.apache.zookeeper.data.StatPersisted v, v;
long v, v, v, v, v, v;
int v, v, v;
v := @parameter: oadd.org.apache.zookeeper.data.StatPersisted;
v := @parameter: oadd.org.apache.zookeeper.data.StatPersisted;
v = virtualinvoke v.<oadd.org.apache.zookeeper.data.StatPersisted: int getAversion()>();
virtualinvoke v.<oadd.org.apache.zookeeper.data.StatPersisted: void setAversion(int)>(v);
v = virtualinvoke v.<oadd.org.apache.zookeeper.data.StatPersisted: long getCtime()>();
virtualinvoke v.<oadd.org.apache.zookeeper.data.StatPersisted: void setCtime(long)>(v);
v = virtualinvoke v.<oadd.org.apache.zookeeper.data.StatPersisted: int getCversion()>();
virtualinvoke v.<oadd.org.apache.zookeeper.data.StatPersisted: void setCversion(int)>(v);
v = virtualinvoke v.<oadd.org.apache.zookeeper.data.StatPersisted: long getCzxid()>();
virtualinvoke v.<oadd.org.apache.zookeeper.data.StatPersisted: void setCzxid(long)>(v);
v = virtualinvoke v.<oadd.org.apache.zookeeper.data.StatPersisted: long getMtime()>();
virtualinvoke v.<oadd.org.apache.zookeeper.data.StatPersisted: void setMtime(long)>(v);
v = virtualinvoke v.<oadd.org.apache.zookeeper.data.StatPersisted: long getMzxid()>();
virtualinvoke v.<oadd.org.apache.zookeeper.data.StatPersisted: void setMzxid(long)>(v);
v = virtualinvoke v.<oadd.org.apache.zookeeper.data.StatPersisted: long getPzxid()>();
virtualinvoke v.<oadd.org.apache.zookeeper.data.StatPersisted: void setPzxid(long)>(v);
v = virtualinvoke v.<oadd.org.apache.zookeeper.data.StatPersisted: int getVersion()>();
virtualinvoke v.<oadd.org.apache.zookeeper.data.StatPersisted: void setVersion(int)>(v);
v = virtualinvoke v.<oadd.org.apache.zookeeper.data.StatPersisted: long getEphemeralOwner()>();
virtualinvoke v.<oadd.org.apache.zookeeper.data.StatPersisted: void setEphemeralOwner(long)>(v);
return;
}
public static void copyStat(oadd.org.apache.zookeeper.data.Stat, oadd.org.apache.zookeeper.data.Stat)
{
long v, v, v, v, v, v;
int v, v, v, v, v;
oadd.org.apache.zookeeper.data.Stat v, v;
v := @parameter: oadd.org.apache.zookeeper.data.Stat;
v := @parameter: oadd.org.apache.zookeeper.data.Stat;
v = virtualinvoke v.<oadd.org.apache.zookeeper.data.Stat: int getAversion()>();
virtualinvoke v.<oadd.org.apache.zookeeper.data.Stat: void setAversion(int)>(v);
v = virtualinvoke v.<oadd.org.apache.zookeeper.data.Stat: long getCtime()>();
virtualinvoke v.<oadd.org.apache.zookeeper.data.Stat: void setCtime(long)>(v);
v = virtualinvoke v.<oadd.org.apache.zookeeper.data.Stat: int getCversion()>();
virtualinvoke v.<oadd.org.apache.zookeeper.data.Stat: void setCversion(int)>(v);
v = virtualinvoke v.<oadd.org.apache.zookeeper.data.Stat: long getCzxid()>();
virtualinvoke v.<oadd.org.apache.zookeeper.data.Stat: void setCzxid(long)>(v);
v = virtualinvoke v.<oadd.org.apache.zookeeper.data.Stat: long getMtime()>();
virtualinvoke v.<oadd.org.apache.zookeeper.data.Stat: void setMtime(long)>(v);
v = virtualinvoke v.<oadd.org.apache.zookeeper.data.Stat: long getMzxid()>();
virtualinvoke v.<oadd.org.apache.zookeeper.data.Stat: void setMzxid(long)>(v);
v = virtualinvoke v.<oadd.org.apache.zookeeper.data.Stat: long getPzxid()>();
virtualinvoke v.<oadd.org.apache.zookeeper.data.Stat: void setPzxid(long)>(v);
v = virtualinvoke v.<oadd.org.apache.zookeeper.data.Stat: int getVersion()>();
virtualinvoke v.<oadd.org.apache.zookeeper.data.Stat: void setVersion(int)>(v);
v = virtualinvoke v.<oadd.org.apache.zookeeper.data.Stat: long getEphemeralOwner()>();
virtualinvoke v.<oadd.org.apache.zookeeper.data.Stat: void setEphemeralOwner(long)>(v);
v = virtualinvoke v.<oadd.org.apache.zookeeper.data.Stat: int getDataLength()>();
virtualinvoke v.<oadd.org.apache.zookeeper.data.Stat: void setDataLength(int)>(v);
v = virtualinvoke v.<oadd.org.apache.zookeeper.data.Stat: int getNumChildren()>();
virtualinvoke v.<oadd.org.apache.zookeeper.data.Stat: void setNumChildren(int)>(v);
return;
}
public void updateCount(java.lang.String, int)
{
byte[] v, v, v;
java.util.concurrent.ConcurrentHashMap v, v;
oadd.org.apache.zookeeper.StatsTrack v, v;
java.lang.Throwable v, v;
oadd.org.apache.zookeeper.server.DataTree v;
int v, v, v, v, v, v, v, v, v;
java.lang.String v, v, v, v, v, v, v, v, v;
org.slf4j.Logger v, v, v;
java.lang.Object v, v;
v := @this: oadd.org.apache.zookeeper.server.DataTree;
v := @parameter: java.lang.String;
v := @parameter: int;
v = staticinvoke <oadd.org.apache.zookeeper.Quotas: java.lang.String statPath(java.lang.String)>(v);
v = v.<oadd.org.apache.zookeeper.server.DataTree: java.util.concurrent.ConcurrentHashMap nodes>;
v = virtualinvoke v.<java.util.concurrent.ConcurrentHashMap: java.lang.Object get(java.lang.Object)>(v);
if v != null goto label;
v = <oadd.org.apache.zookeeper.server.DataTree: org.slf4j.Logger LOG>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Missing count node for stat \u0001");
interfaceinvoke v.<org.slf4j.Logger: void error(java.lang.String)>(v);
return;
label:
entermonitor v;
label:
v = new oadd.org.apache.zookeeper.StatsTrack;
v = new java.lang.String;
v = v.<oadd.org.apache.zookeeper.server.DataNode: byte[] data>;
specialinvoke v.<java.lang.String: void <init>(byte[])>(v);
specialinvoke v.<oadd.org.apache.zookeeper.StatsTrack: void <init>(java.lang.String)>(v);
v = virtualinvoke v.<oadd.org.apache.zookeeper.StatsTrack: int getCount()>();
v = v + v;
virtualinvoke v.<oadd.org.apache.zookeeper.StatsTrack: void setCount(int)>(v);
v = virtualinvoke v.<oadd.org.apache.zookeeper.StatsTrack: java.lang.String toString()>();
v = virtualinvoke v.<java.lang.String: byte[] getBytes()>();
v.<oadd.org.apache.zookeeper.server.DataNode: byte[] data> = v;
exitmonitor v;
label:
goto label;
label:
v := @caughtexception;
exitmonitor v;
throw v;
label:
v = staticinvoke <oadd.org.apache.zookeeper.Quotas: java.lang.String quotaPath(java.lang.String)>(v);
v = v.<oadd.org.apache.zookeeper.server.DataTree: java.util.concurrent.ConcurrentHashMap nodes>;
v = virtualinvoke v.<java.util.concurrent.ConcurrentHashMap: java.lang.Object get(java.lang.Object)>(v);
if v != null goto label;
v = <oadd.org.apache.zookeeper.server.DataTree: org.slf4j.Logger LOG>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Missing count node for quota \u0001");
interfaceinvoke v.<org.slf4j.Logger: void error(java.lang.String)>(v);
return;
label:
entermonitor v;
label:
v = new oadd.org.apache.zookeeper.StatsTrack;
v = new java.lang.String;
v = v.<oadd.org.apache.zookeeper.server.DataNode: byte[] data>;
specialinvoke v.<java.lang.String: void <init>(byte[])>(v);
specialinvoke v.<oadd.org.apache.zookeeper.StatsTrack: void <init>(java.lang.String)>(v);
exitmonitor v;
label:
goto label;
label:
v := @caughtexception;
exitmonitor v;
throw v;
label:
v = virtualinvoke v.<oadd.org.apache.zookeeper.StatsTrack: int getCount()>();
v = (int) -1;
if v <= v goto label;
v = virtualinvoke v.<oadd.org.apache.zookeeper.StatsTrack: int getCount()>();
v = virtualinvoke v.<oadd.org.apache.zookeeper.StatsTrack: int getCount()>();
if v >= v goto label;
v = <oadd.org.apache.zookeeper.server.DataTree: org.slf4j.Logger LOG>;
v = virtualinvoke v.<oadd.org.apache.zookeeper.StatsTrack: int getCount()>();
v = virtualinvoke v.<oadd.org.apache.zookeeper.StatsTrack: int getCount()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,int,int)>(v, v, v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Quota exceeded: \u count=\u limit=\u0001");
interfaceinvoke v.<org.slf4j.Logger: void warn(java.lang.String)>(v);
label:
return;
catch java.lang.Throwable from label to label with label;
catch java.lang.Throwable from label to label with label;
}
public void updateBytes(java.lang.String, long)
{
byte[] v, v, v;
byte v, v;
java.util.concurrent.ConcurrentHashMap v, v;
oadd.org.apache.zookeeper.StatsTrack v, v;
java.lang.Throwable v, v;
long v, v, v, v, v, v, v, v;
oadd.org.apache.zookeeper.server.DataTree v;
java.lang.String v, v, v, v, v, v, v, v, v;
org.slf4j.Logger v, v, v;
java.lang.Object v, v;
v := @this: oadd.org.apache.zookeeper.server.DataTree;
v := @parameter: java.lang.String;
v := @parameter: long;
v = staticinvoke <oadd.org.apache.zookeeper.Quotas: java.lang.String statPath(java.lang.String)>(v);
v = v.<oadd.org.apache.zookeeper.server.DataTree: java.util.concurrent.ConcurrentHashMap nodes>;
v = virtualinvoke v.<java.util.concurrent.ConcurrentHashMap: java.lang.Object get(java.lang.Object)>(v);
if v != null goto label;
v = <oadd.org.apache.zookeeper.server.DataTree: org.slf4j.Logger LOG>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Missing stat node for bytes \u0001");
interfaceinvoke v.<org.slf4j.Logger: void error(java.lang.String)>(v);
return;
label:
entermonitor v;
label:
v = new oadd.org.apache.zookeeper.StatsTrack;
v = new java.lang.String;
v = v.<oadd.org.apache.zookeeper.server.DataNode: byte[] data>;
specialinvoke v.<java.lang.String: void <init>(byte[])>(v);
specialinvoke v.<oadd.org.apache.zookeeper.StatsTrack: void <init>(java.lang.String)>(v);
v = virtualinvoke v.<oadd.org.apache.zookeeper.StatsTrack: long getBytes()>();
v = v + v;
virtualinvoke v.<oadd.org.apache.zookeeper.StatsTrack: void setBytes(long)>(v);
v = virtualinvoke v.<oadd.org.apache.zookeeper.StatsTrack: java.lang.String toString()>();
v = virtualinvoke v.<java.lang.String: byte[] getBytes()>();
v.<oadd.org.apache.zookeeper.server.DataNode: byte[] data> = v;
exitmonitor v;
label:
goto label;
label:
v := @caughtexception;
exitmonitor v;
throw v;
label:
v = staticinvoke <oadd.org.apache.zookeeper.Quotas: java.lang.String quotaPath(java.lang.String)>(v);
v = v.<oadd.org.apache.zookeeper.server.DataTree: java.util.concurrent.ConcurrentHashMap nodes>;
v = virtualinvoke v.<java.util.concurrent.ConcurrentHashMap: java.lang.Object get(java.lang.Object)>(v);
if v != null goto label;
v = <oadd.org.apache.zookeeper.server.DataTree: org.slf4j.Logger LOG>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Missing quota node for bytes \u0001");
interfaceinvoke v.<org.slf4j.Logger: void error(java.lang.String)>(v);
return;
label:
entermonitor v;
label:
v = new oadd.org.apache.zookeeper.StatsTrack;
v = new java.lang.String;
v = v.<oadd.org.apache.zookeeper.server.DataNode: byte[] data>;
specialinvoke v.<java.lang.String: void <init>(byte[])>(v);
specialinvoke v.<oadd.org.apache.zookeeper.StatsTrack: void <init>(java.lang.String)>(v);
exitmonitor v;
label:
goto label;
label:
v := @caughtexception;
exitmonitor v;
throw v;
label:
v = virtualinvoke v.<oadd.org.apache.zookeeper.StatsTrack: long getBytes()>();
v = v cmp -1L;
if v <= 0 goto label;
v = virtualinvoke v.<oadd.org.apache.zookeeper.StatsTrack: long getBytes()>();
v = virtualinvoke v.<oadd.org.apache.zookeeper.StatsTrack: long getBytes()>();
v = v cmp v;
if v >= 0 goto label;
v = <oadd.org.apache.zookeeper.server.DataTree: org.slf4j.Logger LOG>;
v = virtualinvoke v.<oadd.org.apache.zookeeper.StatsTrack: long getBytes()>();
v = virtualinvoke v.<oadd.org.apache.zookeeper.StatsTrack: long getBytes()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,long,long)>(v, v, v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Quota exceeded: \u bytes=\u limit=\u0001");
interfaceinvoke v.<org.slf4j.Logger: void warn(java.lang.String)>(v);
label:
return;
catch java.lang.Throwable from label to label with label;
catch java.lang.Throwable from label to label with label;
}
public void createNode(java.lang.String, byte[], java.util.List, long, int, long, long) throws oadd.org.apache.zookeeper.KeeperException$NoNodeException, oadd.org.apache.zookeeper.KeeperException$NodeExistsException
{
byte[] v;
long v, v, v;
oadd.org.apache.zookeeper.server.DataTree v;
java.util.List v;
int v;
java.lang.String v;
v := @this: oadd.org.apache.zookeeper.server.DataTree;
v := @parameter: java.lang.String;
v := @parameter: byte[];
v := @parameter: java.util.List;
v := @parameter: long;
v := @parameter: int;
v := @parameter: long;
v := @parameter: long;
virtualinvoke v.<oadd.org.apache.zookeeper.server.DataTree: void createNode(java.lang.String,byte[],java.util.List,long,int,long,long,oadd.org.apache.zookeeper.data.Stat)>(v, v, v, v, v, v, v, null);
return;
}
public void createNode(java.lang.String, byte[], java.util.List, long, int, long, long, oadd.org.apache.zookeeper.data.Stat) throws oadd.org.apache.zookeeper.KeeperException$NoNodeException, oadd.org.apache.zookeeper.KeeperException$NodeExistsException
{
byte[] v;
byte v;
java.lang.Long v, v, v;
java.util.Map v, v;
oadd.org.apache.zookeeper.data.Stat v;
oadd.org.apache.zookeeper.server.WatchManager v, v;
oadd.org.apache.zookeeper.KeeperException$NodeExistsException v;
java.util.Set v, v, v;
oadd.org.apache.zookeeper.KeeperException$NoNodeException v;
java.lang.Throwable v, v;
long v, v, v;
oadd.org.apache.zookeeper.server.DataTree v;
java.lang.String v, v, v, v, v, v, v, v, v, v, v;
oadd.org.apache.zookeeper.common.PathTrie v;
boolean v, v, v, v, v;
java.util.concurrent.ConcurrentHashMap v, v;
oadd.org.apache.zookeeper.server.EphemeralType v, v, v;
java.util.List v;
java.util.HashSet v, v;
int v, v, v, v, v, v, v, v;
oadd.org.apache.zookeeper.server.ReferenceCountedACLCache v;
oadd.org.apache.zookeeper.Watcher$Event$EventType v, v;
oadd.org.apache.zookeeper.server.DataNode v;
oadd.org.apache.zookeeper.data.StatPersisted v, v, v, v;
java.lang.Object v, v;
v := @this: oadd.org.apache.zookeeper.server.DataTree;
v := @parameter: java.lang.String;
v := @parameter: byte[];
v := @parameter: java.util.List;
v := @parameter: long;
v := @parameter: int;
v := @parameter: long;
v := @parameter: long;
v := @parameter: oadd.org.apache.zookeeper.data.Stat;
v = virtualinvoke v.<java.lang.String: int lastIndexOf(int)>(47);
v = virtualinvoke v.<java.lang.String: java.lang.String substring(int,int)>(0, v);
v = v + 1;
v = virtualinvoke v.<java.lang.String: java.lang.String substring(int)>(v);
v = new oadd.org.apache.zookeeper.data.StatPersisted;
specialinvoke v.<oadd.org.apache.zookeeper.data.StatPersisted: void <init>()>();
virtualinvoke v.<oadd.org.apache.zookeeper.data.StatPersisted: void setCtime(long)>(v);
virtualinvoke v.<oadd.org.apache.zookeeper.data.StatPersisted: void setMtime(long)>(v);
virtualinvoke v.<oadd.org.apache.zookeeper.data.StatPersisted: void setCzxid(long)>(v);
virtualinvoke v.<oadd.org.apache.zookeeper.data.StatPersisted: void setMzxid(long)>(v);
virtualinvoke v.<oadd.org.apache.zookeeper.data.StatPersisted: void setPzxid(long)>(v);
virtualinvoke v.<oadd.org.apache.zookeeper.data.StatPersisted: void setVersion(int)>(0);
virtualinvoke v.<oadd.org.apache.zookeeper.data.StatPersisted: void setAversion(int)>(0);
virtualinvoke v.<oadd.org.apache.zookeeper.data.StatPersisted: void setEphemeralOwner(long)>(v);
v = v.<oadd.org.apache.zookeeper.server.DataTree: java.util.concurrent.ConcurrentHashMap nodes>;
v = virtualinvoke v.<java.util.concurrent.ConcurrentHashMap: java.lang.Object get(java.lang.Object)>(v);
if v != null goto label;
v = new oadd.org.apache.zookeeper.KeeperException$NoNodeException;
specialinvoke v.<oadd.org.apache.zookeeper.KeeperException$NoNodeException: void <init>()>();
throw v;
label:
entermonitor v;
label:
v = virtualinvoke v.<oadd.org.apache.zookeeper.server.DataNode: java.util.Set getChildren()>();
v = interfaceinvoke v.<java.util.Set: boolean contains(java.lang.Object)>(v);
if v == 0 goto label;
v = new oadd.org.apache.zookeeper.KeeperException$NodeExistsException;
specialinvoke v.<oadd.org.apache.zookeeper.KeeperException$NodeExistsException: void <init>()>();
throw v;
label:
v = (int) -1;
if v != v goto label;
v = v.<oadd.org.apache.zookeeper.server.DataNode: oadd.org.apache.zookeeper.data.StatPersisted stat>;
v = virtualinvoke v.<oadd.org.apache.zookeeper.data.StatPersisted: int getCversion()>();
v = v + 1;
label:
v = v.<oadd.org.apache.zookeeper.server.DataNode: oadd.org.apache.zookeeper.data.StatPersisted stat>;
virtualinvoke v.<oadd.org.apache.zookeeper.data.StatPersisted: void setCversion(int)>(v);
v = v.<oadd.org.apache.zookeeper.server.DataNode: oadd.org.apache.zookeeper.data.StatPersisted stat>;
virtualinvoke v.<oadd.org.apache.zookeeper.data.StatPersisted: void setPzxid(long)>(v);
v = v.<oadd.org.apache.zookeeper.server.DataTree: oadd.org.apache.zookeeper.server.ReferenceCountedACLCache aclCache>;
v = virtualinvoke v.<oadd.org.apache.zookeeper.server.ReferenceCountedACLCache: java.lang.Long convertAcls(java.util.List)>(v);
v = new oadd.org.apache.zookeeper.server.DataNode;
specialinvoke v.<oadd.org.apache.zookeeper.server.DataNode: void <init>(byte[],java.lang.Long,oadd.org.apache.zookeeper.data.StatPersisted)>(v, v, v);
virtualinvoke v.<oadd.org.apache.zookeeper.server.DataNode: boolean addChild(java.lang.String)>(v);
v = v.<oadd.org.apache.zookeeper.server.DataTree: java.util.concurrent.ConcurrentHashMap nodes>;
virtualinvoke v.<java.util.concurrent.ConcurrentHashMap: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
v = staticinvoke <oadd.org.apache.zookeeper.server.EphemeralType: oadd.org.apache.zookeeper.server.EphemeralType get(long)>(v);
v = <oadd.org.apache.zookeeper.server.EphemeralType: oadd.org.apache.zookeeper.server.EphemeralType CONTAINER>;
if v != v goto label;
v = v.<oadd.org.apache.zookeeper.server.DataTree: java.util.Set containers>;
interfaceinvoke v.<java.util.Set: boolean add(java.lang.Object)>(v);
goto label;
label:
v = <oadd.org.apache.zookeeper.server.EphemeralType: oadd.org.apache.zookeeper.server.EphemeralType TTL>;
if v != v goto label;
v = v.<oadd.org.apache.zookeeper.server.DataTree: java.util.Set ttls>;
interfaceinvoke v.<java.util.Set: boolean add(java.lang.Object)>(v);
goto label;
label:
v = v cmp 0L;
if v == 0 goto label;
v = v.<oadd.org.apache.zookeeper.server.DataTree: java.util.Map ephemerals>;
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
if v != null goto label;
v = new java.util.HashSet;
specialinvoke v.<java.util.HashSet: void <init>()>();
v = v;
v = v.<oadd.org.apache.zookeeper.server.DataTree: java.util.Map ephemerals>;
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
label:
v = v;
entermonitor v;
label:
virtualinvoke v.<java.util.HashSet: boolean add(java.lang.Object)>(v);
exitmonitor v;
label:
goto label;
label:
v := @caughtexception;
exitmonitor v;
throw v;
label:
if v == null goto label;
virtualinvoke v.<oadd.org.apache.zookeeper.server.DataNode: void copyStat(oadd.org.apache.zookeeper.data.Stat)>(v);
label:
exitmonitor v;
label:
goto label;
label:
v := @caughtexception;
exitmonitor v;
throw v;
label:
v = virtualinvoke v.<java.lang.String: boolean startsWith(java.lang.String)>("/zookeeper/quota");
if v == 0 goto label;
v = "zookeeper_limits";
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>(v);
if v == 0 goto label;
v = v.<oadd.org.apache.zookeeper.server.DataTree: oadd.org.apache.zookeeper.common.PathTrie pTrie>;
v = "/zookeeper/quota";
v = virtualinvoke v.<java.lang.String: int length()>();
v = virtualinvoke v.<java.lang.String: java.lang.String substring(int)>(v);
virtualinvoke v.<oadd.org.apache.zookeeper.common.PathTrie: void addPath(java.lang.String)>(v);
label:
v = "zookeeper_stats";
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>(v);
if v == 0 goto label;
v = "/zookeeper/quota";
v = virtualinvoke v.<java.lang.String: int length()>();
v = virtualinvoke v.<java.lang.String: java.lang.String substring(int)>(v);
specialinvoke v.<oadd.org.apache.zookeeper.server.DataTree: void updateQuotaForPath(java.lang.String)>(v);
label:
v = virtualinvoke v.<oadd.org.apache.zookeeper.server.DataTree: java.lang.String getMaxPrefixWithQuota(java.lang.String)>(v);
if v == null goto label;
virtualinvoke v.<oadd.org.apache.zookeeper.server.DataTree: void updateCount(java.lang.String,int)>(v, 1);
if v == null goto label;
v = lengthof v;
label:
virtualinvoke v.<oadd.org.apache.zookeeper.server.DataTree: void updateBytes(java.lang.String,long)>(v, v);
label:
v = v.<oadd.org.apache.zookeeper.server.DataTree: oadd.org.apache.zookeeper.server.WatchManager dataWatches>;
v = <oadd.org.apache.zookeeper.Watcher$Event$EventType: oadd.org.apache.zookeeper.Watcher$Event$EventType NodeCreated>;
virtualinvoke v.<oadd.org.apache.zookeeper.server.WatchManager: java.util.Set triggerWatch(java.lang.String,oadd.org.apache.zookeeper.Watcher$Event$EventType)>(v, v);
v = v.<oadd.org.apache.zookeeper.server.DataTree: oadd.org.apache.zookeeper.server.WatchManager childWatches>;
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>("");
if v == 0 goto label;
v = "/";
goto label;
label:
v = v;
label:
v = <oadd.org.apache.zookeeper.Watcher$Event$EventType: oadd.org.apache.zookeeper.Watcher$Event$EventType NodeChildrenChanged>;
virtualinvoke v.<oadd.org.apache.zookeeper.server.WatchManager: java.util.Set triggerWatch(java.lang.String,oadd.org.apache.zookeeper.Watcher$Event$EventType)>(v, v);
return;
catch java.lang.Throwable from label to label with label;
catch java.lang.Throwable from label to label with label;
}
public void deleteNode(java.lang.String, long) throws oadd.org.apache.zookeeper.KeeperException$NoNodeException
{
byte[] v, v;
byte v, v;
java.lang.Long v, v;
java.util.Map v;
oadd.org.apache.zookeeper.server.WatchManager v, v, v;
java.util.Set v, v, v;
oadd.org.apache.zookeeper.KeeperException$NoNodeException v, v;
java.lang.Throwable v, v, v, v, v;
long v, v, v;
oadd.org.apache.zookeeper.server.DataTree v;
java.lang.String v, v, v, v, v, v, v, v, v, v, v;
oadd.org.apache.zookeeper.common.PathTrie v;
boolean v, v, v, v;
java.util.concurrent.ConcurrentHashMap v, v, v;
oadd.org.apache.zookeeper.server.EphemeralType v, v, v;
int v, v, v, v, v, v;
oadd.org.apache.zookeeper.server.ReferenceCountedACLCache v;
oadd.org.apache.zookeeper.Watcher$Event$EventType v, v, v;
org.slf4j.Logger v, v, v;
oadd.org.apache.zookeeper.data.StatPersisted v, v, v;
java.lang.Object v, v, v;
v := @this: oadd.org.apache.zookeeper.server.DataTree;
v := @parameter: java.lang.String;
v := @parameter: long;
v = virtualinvoke v.<java.lang.String: int lastIndexOf(int)>(47);
v = virtualinvoke v.<java.lang.String: java.lang.String substring(int,int)>(0, v);
v = v + 1;
v = virtualinvoke v.<java.lang.String: java.lang.String substring(int)>(v);
v = v.<oadd.org.apache.zookeeper.server.DataTree: java.util.concurrent.ConcurrentHashMap nodes>;
v = virtualinvoke v.<java.util.concurrent.ConcurrentHashMap: java.lang.Object get(java.lang.Object)>(v);
if v != null goto label;
v = new oadd.org.apache.zookeeper.KeeperException$NoNodeException;
specialinvoke v.<oadd.org.apache.zookeeper.KeeperException$NoNodeException: void <init>()>();
throw v;
label:
entermonitor v;
label:
virtualinvoke v.<oadd.org.apache.zookeeper.server.DataNode: boolean removeChild(java.lang.String)>(v);
v = v.<oadd.org.apache.zookeeper.server.DataNode: oadd.org.apache.zookeeper.data.StatPersisted stat>;
v = virtualinvoke v.<oadd.org.apache.zookeeper.data.StatPersisted: long getPzxid()>();
v = v cmp v;
if v <= 0 goto label;
v = v.<oadd.org.apache.zookeeper.server.DataNode: oadd.org.apache.zookeeper.data.StatPersisted stat>;
virtualinvoke v.<oadd.org.apache.zookeeper.data.StatPersisted: void setPzxid(long)>(v);
label:
exitmonitor v;
label:
goto label;
label:
v := @caughtexception;
exitmonitor v;
throw v;
label:
v = v.<oadd.org.apache.zookeeper.server.DataTree: java.util.concurrent.ConcurrentHashMap nodes>;
v = virtualinvoke v.<java.util.concurrent.ConcurrentHashMap: java.lang.Object get(java.lang.Object)>(v);
if v != null goto label;
v = new oadd.org.apache.zookeeper.KeeperException$NoNodeException;
specialinvoke v.<oadd.org.apache.zookeeper.KeeperException$NoNodeException: void <init>()>();
throw v;
label:
v = v.<oadd.org.apache.zookeeper.server.DataTree: java.util.concurrent.ConcurrentHashMap nodes>;
virtualinvoke v.<java.util.concurrent.ConcurrentHashMap: java.lang.Object remove(java.lang.Object)>(v);
entermonitor v;
label:
v = v.<oadd.org.apache.zookeeper.server.DataTree: oadd.org.apache.zookeeper.server.ReferenceCountedACLCache aclCache>;
v = v.<oadd.org.apache.zookeeper.server.DataNode: java.lang.Long acl>;
virtualinvoke v.<oadd.org.apache.zookeeper.server.ReferenceCountedACLCache: void removeUsage(java.lang.Long)>(v);
exitmonitor v;
label:
goto label;
label:
v := @caughtexception;
exitmonitor v;
throw v;
label:
entermonitor v;
label:
v = v.<oadd.org.apache.zookeeper.server.DataNode: oadd.org.apache.zookeeper.data.StatPersisted stat>;
v = virtualinvoke v.<oadd.org.apache.zookeeper.data.StatPersisted: long getEphemeralOwner()>();
v = staticinvoke <oadd.org.apache.zookeeper.server.EphemeralType: oadd.org.apache.zookeeper.server.EphemeralType get(long)>(v);
v = <oadd.org.apache.zookeeper.server.EphemeralType: oadd.org.apache.zookeeper.server.EphemeralType CONTAINER>;
if v != v goto label;
v = v.<oadd.org.apache.zookeeper.server.DataTree: java.util.Set containers>;
interfaceinvoke v.<java.util.Set: boolean remove(java.lang.Object)>(v);
goto label;
label:
v = <oadd.org.apache.zookeeper.server.EphemeralType: oadd.org.apache.zookeeper.server.EphemeralType TTL>;
if v != v goto label;
v = v.<oadd.org.apache.zookeeper.server.DataTree: java.util.Set ttls>;
interfaceinvoke v.<java.util.Set: boolean remove(java.lang.Object)>(v);
goto label;
label:
v = v cmp 0L;
if v == 0 goto label;
v = v.<oadd.org.apache.zookeeper.server.DataTree: java.util.Map ephemerals>;
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
if v == null goto label;
entermonitor v;
label:
virtualinvoke v.<java.util.HashSet: boolean remove(java.lang.Object)>(v);
exitmonitor v;
label:
goto label;
label:
v := @caughtexception;
exitmonitor v;
throw v;
label:
exitmonitor v;
label:
goto label;
label:
v := @caughtexception;
exitmonitor v;
throw v;
label:
v = virtualinvoke v.<java.lang.String: boolean startsWith(java.lang.String)>("/zookeeper");
if v == 0 goto label;
v = "zookeeper_limits";
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>(v);
if v == 0 goto label;
v = v.<oadd.org.apache.zookeeper.server.DataTree: oadd.org.apache.zookeeper.common.PathTrie pTrie>;
v = "/zookeeper/quota";
v = virtualinvoke v.<java.lang.String: int length()>();
v = virtualinvoke v.<java.lang.String: java.lang.String substring(int)>(v);
virtualinvoke v.<oadd.org.apache.zookeeper.common.PathTrie: void deletePath(java.lang.String)>(v);
label:
v = virtualinvoke v.<oadd.org.apache.zookeeper.server.DataTree: java.lang.String getMaxPrefixWithQuota(java.lang.String)>(v);
if v == null goto label;
v = (int) -1;
virtualinvoke v.<oadd.org.apache.zookeeper.server.DataTree: void updateCount(java.lang.String,int)>(v, v);
entermonitor v;
label:
v = v.<oadd.org.apache.zookeeper.server.DataNode: byte[] data>;
if v != null goto label;
v = 0;
goto label;
label:
v = v.<oadd.org.apache.zookeeper.server.DataNode: byte[] data>;
v = lengthof v;
v = neg v;
label:
exitmonitor v;
label:
goto label;
label:
v := @caughtexception;
exitmonitor v;
throw v;
label:
virtualinvoke v.<oadd.org.apache.zookeeper.server.DataTree: void updateBytes(java.lang.String,long)>(v, v);
label:
v = <oadd.org.apache.zookeeper.server.DataTree: org.slf4j.Logger LOG>;
v = interfaceinvoke v.<org.slf4j.Logger: boolean isTraceEnabled()>();
if v == 0 goto label;
v = <oadd.org.apache.zookeeper.server.DataTree: org.slf4j.Logger LOG>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("dataWatches.triggerWatch \u0001");
staticinvoke <oadd.org.apache.zookeeper.server.ZooTrace: void logTraceMessage(org.slf4j.Logger,long,java.lang.String)>(v, 64L, v);
v = <oadd.org.apache.zookeeper.server.DataTree: org.slf4j.Logger LOG>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("childWatches.triggerWatch \u0001");
staticinvoke <oadd.org.apache.zookeeper.server.ZooTrace: void logTraceMessage(org.slf4j.Logger,long,java.lang.String)>(v, 64L, v);
label:
v = v.<oadd.org.apache.zookeeper.server.DataTree: oadd.org.apache.zookeeper.server.WatchManager dataWatches>;
v = <oadd.org.apache.zookeeper.Watcher$Event$EventType: oadd.org.apache.zookeeper.Watcher$Event$EventType NodeDeleted>;
v = virtualinvoke v.<oadd.org.apache.zookeeper.server.WatchManager: java.util.Set triggerWatch(java.lang.String,oadd.org.apache.zookeeper.Watcher$Event$EventType)>(v, v);
v = v.<oadd.org.apache.zookeeper.server.DataTree: oadd.org.apache.zookeeper.server.WatchManager childWatches>;
v = <oadd.org.apache.zookeeper.Watcher$Event$EventType: oadd.org.apache.zookeeper.Watcher$Event$EventType NodeDeleted>;
virtualinvoke v.<oadd.org.apache.zookeeper.server.WatchManager: java.util.Set triggerWatch(java.lang.String,oadd.org.apache.zookeeper.Watcher$Event$EventType,java.util.Set)>(v, v, v);
v = v.<oadd.org.apache.zookeeper.server.DataTree: oadd.org.apache.zookeeper.server.WatchManager childWatches>;
v = "";
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>(v);
if v == 0 goto label;
v = "/";
goto label;
label:
v = v;
label:
v = <oadd.org.apache.zookeeper.Watcher$Event$EventType: oadd.org.apache.zookeeper.Watcher$Event$EventType NodeChildrenChanged>;
virtualinvoke v.<oadd.org.apache.zookeeper.server.WatchManager: java.util.Set triggerWatch(java.lang.String,oadd.org.apache.zookeeper.Watcher$Event$EventType)>(v, v);
return;
catch java.lang.Throwable from label to label with label;
catch java.lang.Throwable from label to label with label;
catch java.lang.Throwable from label to label with label;
catch java.lang.Throwable from label to label with label;
catch java.lang.Throwable from label to label with label;
}
public oadd.org.apache.zookeeper.data.Stat setData(java.lang.String, byte[], int, long, long) throws oadd.org.apache.zookeeper.KeeperException$NoNodeException
{
java.lang.Throwable v;
byte[] v, v;
long v, v;
oadd.org.apache.zookeeper.server.DataTree v;
int v, v, v, v;
java.lang.String v, v;
oadd.org.apache.zookeeper.Watcher$Event$EventType v;
oadd.org.apache.zookeeper.data.Stat v;
oadd.org.apache.zookeeper.server.WatchManager v;
oadd.org.apache.zookeeper.data.StatPersisted v, v, v;
java.util.concurrent.ConcurrentHashMap v;
oadd.org.apache.zookeeper.KeeperException$NoNodeException v;
java.lang.Object v;
v := @this: oadd.org.apache.zookeeper.server.DataTree;
v := @parameter: java.lang.String;
v := @parameter: byte[];
v := @parameter: int;
v := @parameter: long;
v := @parameter: long;
v = new oadd.org.apache.zookeeper.data.Stat;
specialinvoke v.<oadd.org.apache.zookeeper.data.Stat: void <init>()>();
v = v.<oadd.org.apache.zookeeper.server.DataTree: java.util.concurrent.ConcurrentHashMap nodes>;
v = virtualinvoke v.<java.util.concurrent.ConcurrentHashMap: java.lang.Object get(java.lang.Object)>(v);
if v != null goto label;
v = new oadd.org.apache.zookeeper.KeeperException$NoNodeException;
specialinvoke v.<oadd.org.apache.zookeeper.KeeperException$NoNodeException: void <init>()>();
throw v;
label:
entermonitor v;
label:
v = v.<oadd.org.apache.zookeeper.server.DataNode: byte[] data>;
v.<oadd.org.apache.zookeeper.server.DataNode: byte[] data> = v;
v = v.<oadd.org.apache.zookeeper.server.DataNode: oadd.org.apache.zookeeper.data.StatPersisted stat>;
virtualinvoke v.<oadd.org.apache.zookeeper.data.StatPersisted: void setMtime(long)>(v);
v = v.<oadd.org.apache.zookeeper.server.DataNode: oadd.org.apache.zookeeper.data.StatPersisted stat>;
virtualinvoke v.<oadd.org.apache.zookeeper.data.StatPersisted: void setMzxid(long)>(v);
v = v.<oadd.org.apache.zookeeper.server.DataNode: oadd.org.apache.zookeeper.data.StatPersisted stat>;
virtualinvoke v.<oadd.org.apache.zookeeper.data.StatPersisted: void setVersion(int)>(v);
virtualinvoke v.<oadd.org.apache.zookeeper.server.DataNode: void copyStat(oadd.org.apache.zookeeper.data.Stat)>(v);
exitmonitor v;
label:
goto label;
label:
v := @caughtexception;
exitmonitor v;
throw v;
label:
v = virtualinvoke v.<oadd.org.apache.zookeeper.server.DataTree: java.lang.String getMaxPrefixWithQuota(java.lang.String)>(v);
if v == null goto label;
if v != null goto label;
v = 0;
goto label;
label:
v = lengthof v;
label:
if v != null goto label;
v = 0;
goto label;
label:
v = lengthof v;
label:
v = v - v;
virtualinvoke v.<oadd.org.apache.zookeeper.server.DataTree: void updateBytes(java.lang.String,long)>(v, v);
label:
v = v.<oadd.org.apache.zookeeper.server.DataTree: oadd.org.apache.zookeeper.server.WatchManager dataWatches>;
v = <oadd.org.apache.zookeeper.Watcher$Event$EventType: oadd.org.apache.zookeeper.Watcher$Event$EventType NodeDataChanged>;
virtualinvoke v.<oadd.org.apache.zookeeper.server.WatchManager: java.util.Set triggerWatch(java.lang.String,oadd.org.apache.zookeeper.Watcher$Event$EventType)>(v, v);
return v;
catch java.lang.Throwable from label to label with label;
}
public java.lang.String getMaxPrefixWithQuota(java.lang.String)
{
oadd.org.apache.zookeeper.server.DataTree v;
java.lang.String v, v, v, v;
oadd.org.apache.zookeeper.common.PathTrie v;
boolean v, v;
v := @this: oadd.org.apache.zookeeper.server.DataTree;
v := @parameter: java.lang.String;
v = v.<oadd.org.apache.zookeeper.server.DataTree: oadd.org.apache.zookeeper.common.PathTrie pTrie>;
v = virtualinvoke v.<oadd.org.apache.zookeeper.common.PathTrie: java.lang.String findMaxPrefix(java.lang.String)>(v);
v = "/";
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>(v);
if v != 0 goto label;
v = "";
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>(v);
if v == 0 goto label;
label:
return null;
label:
return v;
}
public byte[] getData(java.lang.String, oadd.org.apache.zookeeper.data.Stat, oadd.org.apache.zookeeper.Watcher) throws oadd.org.apache.zookeeper.KeeperException$NoNodeException
{
java.lang.Throwable v;
byte[] v;
oadd.org.apache.zookeeper.server.WatchManager v;
java.util.concurrent.ConcurrentHashMap v;
oadd.org.apache.zookeeper.KeeperException$NoNodeException v;
oadd.org.apache.zookeeper.server.DataTree v;
oadd.org.apache.zookeeper.Watcher v;
java.lang.Object v;
java.lang.String v;
oadd.org.apache.zookeeper.data.Stat v;
v := @this: oadd.org.apache.zookeeper.server.DataTree;
v := @parameter: java.lang.String;
v := @parameter: oadd.org.apache.zookeeper.data.Stat;
v := @parameter: oadd.org.apache.zookeeper.Watcher;
v = v.<oadd.org.apache.zookeeper.server.DataTree: java.util.concurrent.ConcurrentHashMap nodes>;
v = virtualinvoke v.<java.util.concurrent.ConcurrentHashMap: java.lang.Object get(java.lang.Object)>(v);
if v != null goto label;
v = new oadd.org.apache.zookeeper.KeeperException$NoNodeException;
specialinvoke v.<oadd.org.apache.zookeeper.KeeperException$NoNodeException: void <init>()>();
throw v;
label:
entermonitor v;
label:
virtualinvoke v.<oadd.org.apache.zookeeper.server.DataNode: void copyStat(oadd.org.apache.zookeeper.data.Stat)>(v);
if v == null goto label;
v = v.<oadd.org.apache.zookeeper.server.DataTree: oadd.org.apache.zookeeper.server.WatchManager dataWatches>;
virtualinvoke v.<oadd.org.apache.zookeeper.server.WatchManager: void addWatch(java.lang.String,oadd.org.apache.zookeeper.Watcher)>(v, v);
label:
v = v.<oadd.org.apache.zookeeper.server.DataNode: byte[] data>;
exitmonitor v;
label:
return v;
label:
v := @caughtexception;
exitmonitor v;
throw v;
catch java.lang.Throwable from label to label with label;
}
public oadd.org.apache.zookeeper.data.Stat statNode(java.lang.String, oadd.org.apache.zookeeper.Watcher) throws oadd.org.apache.zookeeper.KeeperException$NoNodeException
{
java.lang.Throwable v;
oadd.org.apache.zookeeper.server.WatchManager v;
java.util.concurrent.ConcurrentHashMap v;
oadd.org.apache.zookeeper.KeeperException$NoNodeException v;
oadd.org.apache.zookeeper.server.DataTree v;
oadd.org.apache.zookeeper.Watcher v;
java.lang.Object v;
java.lang.String v;
oadd.org.apache.zookeeper.data.Stat v;
v := @this: oadd.org.apache.zookeeper.server.DataTree;
v := @parameter: java.lang.String;
v := @parameter: oadd.org.apache.zookeeper.Watcher;
v = new oadd.org.apache.zookeeper.data.Stat;
specialinvoke v.<oadd.org.apache.zookeeper.data.Stat: void <init>()>();
v = v.<oadd.org.apache.zookeeper.server.DataTree: java.util.concurrent.ConcurrentHashMap nodes>;
v = virtualinvoke v.<java.util.concurrent.ConcurrentHashMap: java.lang.Object get(java.lang.Object)>(v);
if v == null goto label;
v = v.<oadd.org.apache.zookeeper.server.DataTree: oadd.org.apache.zookeeper.server.WatchManager dataWatches>;
virtualinvoke v.<oadd.org.apache.zookeeper.server.WatchManager: void addWatch(java.lang.String,oadd.org.apache.zookeeper.Watcher)>(v, v);
label:
if v != null goto label;
v = new oadd.org.apache.zookeeper.KeeperException$NoNodeException;
specialinvoke v.<oadd.org.apache.zookeeper.KeeperException$NoNodeException: void <init>()>();
throw v;
label:
entermonitor v;
label:
virtualinvoke v.<oadd.org.apache.zookeeper.server.DataNode: void copyStat(oadd.org.apache.zookeeper.data.Stat)>(v);
exitmonitor v;
label:
return v;
label:
v := @caughtexception;
exitmonitor v;
throw v;
catch java.lang.Throwable from label to label with label;
}
public java.util.List getChildren(java.lang.String, oadd.org.apache.zookeeper.data.Stat, oadd.org.apache.zookeeper.Watcher) throws oadd.org.apache.zookeeper.KeeperException$NoNodeException
{
java.lang.Throwable v;
oadd.org.apache.zookeeper.server.WatchManager v;
java.util.concurrent.ConcurrentHashMap v;
java.util.Set v;
oadd.org.apache.zookeeper.KeeperException$NoNodeException v;
oadd.org.apache.zookeeper.server.DataTree v;
java.util.ArrayList v;
oadd.org.apache.zookeeper.Watcher v;
java.lang.Object v;
java.lang.String v;
oadd.org.apache.zookeeper.data.Stat v;
v := @this: oadd.org.apache.zookeeper.server.DataTree;
v := @parameter: java.lang.String;
v := @parameter: oadd.org.apache.zookeeper.data.Stat;
v := @parameter: oadd.org.apache.zookeeper.Watcher;
v = v.<oadd.org.apache.zookeeper.server.DataTree: java.util.concurrent.ConcurrentHashMap nodes>;
v = virtualinvoke v.<java.util.concurrent.ConcurrentHashMap: java.lang.Object get(java.lang.Object)>(v);
if v != null goto label;
v = new oadd.org.apache.zookeeper.KeeperException$NoNodeException;
specialinvoke v.<oadd.org.apache.zookeeper.KeeperException$NoNodeException: void <init>()>();
throw v;
label:
entermonitor v;
label:
if v == null goto label;
virtualinvoke v.<oadd.org.apache.zookeeper.server.DataNode: void copyStat(oadd.org.apache.zookeeper.data.Stat)>(v);
label:
v = new java.util.ArrayList;
v = virtualinvoke v.<oadd.org.apache.zookeeper.server.DataNode: java.util.Set getChildren()>();
specialinvoke v.<java.util.ArrayList: void <init>(java.util.Collection)>(v);
if v == null goto label;
v = v.<oadd.org.apache.zookeeper.server.DataTree: oadd.org.apache.zookeeper.server.WatchManager childWatches>;
virtualinvoke v.<oadd.org.apache.zookeeper.server.WatchManager: void addWatch(java.lang.String,oadd.org.apache.zookeeper.Watcher)>(v, v);
label:
exitmonitor v;
label:
return v;
label:
v := @caughtexception;
exitmonitor v;
throw v;
catch java.lang.Throwable from label to label with label;
}
public oadd.org.apache.zookeeper.data.Stat setACL(java.lang.String, java.util.List, int) throws oadd.org.apache.zookeeper.KeeperException$NoNodeException
{
java.lang.Throwable v;
oadd.org.apache.zookeeper.data.StatPersisted v;
java.util.concurrent.ConcurrentHashMap v;
oadd.org.apache.zookeeper.KeeperException$NoNodeException v;
oadd.org.apache.zookeeper.server.DataTree v;
java.util.List v;
java.lang.Long v, v;
int v;
java.lang.Object v;
oadd.org.apache.zookeeper.server.ReferenceCountedACLCache v, v;
java.lang.String v;
oadd.org.apache.zookeeper.data.Stat v;
v := @this: oadd.org.apache.zookeeper.server.DataTree;
v := @parameter: java.lang.String;
v := @parameter: java.util.List;
v := @parameter: int;
v = new oadd.org.apache.zookeeper.data.Stat;
specialinvoke v.<oadd.org.apache.zookeeper.data.Stat: void <init>()>();
v = v.<oadd.org.apache.zookeeper.server.DataTree: java.util.concurrent.ConcurrentHashMap nodes>;
v = virtualinvoke v.<java.util.concurrent.ConcurrentHashMap: java.lang.Object get(java.lang.Object)>(v);
if v != null goto label;
v = new oadd.org.apache.zookeeper.KeeperException$NoNodeException;
specialinvoke v.<oadd.org.apache.zookeeper.KeeperException$NoNodeException: void <init>()>();
throw v;
label:
entermonitor v;
label:
v = v.<oadd.org.apache.zookeeper.server.DataTree: oadd.org.apache.zookeeper.server.ReferenceCountedACLCache aclCache>;
v = v.<oadd.org.apache.zookeeper.server.DataNode: java.lang.Long acl>;
virtualinvoke v.<oadd.org.apache.zookeeper.server.ReferenceCountedACLCache: void removeUsage(java.lang.Long)>(v);
v = v.<oadd.org.apache.zookeeper.server.DataNode: oadd.org.apache.zookeeper.data.StatPersisted stat>;
virtualinvoke v.<oadd.org.apache.zookeeper.data.StatPersisted: void setAversion(int)>(v);
v = v.<oadd.org.apache.zookeeper.server.DataTree: oadd.org.apache.zookeeper.server.ReferenceCountedACLCache aclCache>;
v = virtualinvoke v.<oadd.org.apache.zookeeper.server.ReferenceCountedACLCache: java.lang.Long convertAcls(java.util.List)>(v);
v.<oadd.org.apache.zookeeper.server.DataNode: java.lang.Long acl> = v;
virtualinvoke v.<oadd.org.apache.zookeeper.server.DataNode: void copyStat(oadd.org.apache.zookeeper.data.Stat)>(v);
exitmonitor v;
label:
return v;
label:
v := @caughtexception;
exitmonitor v;
throw v;
catch java.lang.Throwable from label to label with label;
}
public java.util.List getACL(java.lang.String, oadd.org.apache.zookeeper.data.Stat) throws oadd.org.apache.zookeeper.KeeperException$NoNodeException
{
java.lang.Throwable v;
java.util.concurrent.ConcurrentHashMap v;
oadd.org.apache.zookeeper.KeeperException$NoNodeException v;
oadd.org.apache.zookeeper.server.DataTree v;
java.util.ArrayList v;
java.util.List v;
java.lang.Long v;
java.lang.Object v;
oadd.org.apache.zookeeper.server.ReferenceCountedACLCache v;
java.lang.String v;
oadd.org.apache.zookeeper.data.Stat v;
v := @this: oadd.org.apache.zookeeper.server.DataTree;
v := @parameter: java.lang.String;
v := @parameter: oadd.org.apache.zookeeper.data.Stat;
v = v.<oadd.org.apache.zookeeper.server.DataTree: java.util.concurrent.ConcurrentHashMap nodes>;
v = virtualinvoke v.<java.util.concurrent.ConcurrentHashMap: java.lang.Object get(java.lang.Object)>(v);
if v != null goto label;
v = new oadd.org.apache.zookeeper.KeeperException$NoNodeException;
specialinvoke v.<oadd.org.apache.zookeeper.KeeperException$NoNodeException: void <init>()>();
throw v;
label:
entermonitor v;
label:
virtualinvoke v.<oadd.org.apache.zookeeper.server.DataNode: void copyStat(oadd.org.apache.zookeeper.data.Stat)>(v);
v = new java.util.ArrayList;
v = v.<oadd.org.apache.zookeeper.server.DataTree: oadd.org.apache.zookeeper.server.ReferenceCountedACLCache aclCache>;
v = v.<oadd.org.apache.zookeeper.server.DataNode: java.lang.Long acl>;
v = virtualinvoke v.<oadd.org.apache.zookeeper.server.ReferenceCountedACLCache: java.util.List convertLong(java.lang.Long)>(v);
specialinvoke v.<java.util.ArrayList: void <init>(java.util.Collection)>(v);
exitmonitor v;
label:
return v;
label:
v := @caughtexception;
exitmonitor v;
throw v;
catch java.lang.Throwable from label to label with label;
}
public java.util.List getACL(oadd.org.apache.zookeeper.server.DataNode)
{
java.lang.Throwable v;
java.util.List v;
oadd.org.apache.zookeeper.server.DataNode v;
java.lang.Long v;
oadd.org.apache.zookeeper.server.ReferenceCountedACLCache v;
oadd.org.apache.zookeeper.server.DataTree v;
v := @this: oadd.org.apache.zookeeper.server.DataTree;
v := @parameter: oadd.org.apache.zookeeper.server.DataNode;
entermonitor v;
label:
v = v.<oadd.org.apache.zookeeper.server.DataTree: oadd.org.apache.zookeeper.server.ReferenceCountedACLCache aclCache>;
v = v.<oadd.org.apache.zookeeper.server.DataNode: java.lang.Long acl>;
v = virtualinvoke v.<oadd.org.apache.zookeeper.server.ReferenceCountedACLCache: java.util.List convertLong(java.lang.Long)>(v);
exitmonitor v;
label:
return v;
label:
v := @caughtexception;
exitmonitor v;
throw v;
catch java.lang.Throwable from label to label with label;
}
public int aclCacheSize()
{
int v;
oadd.org.apache.zookeeper.server.ReferenceCountedACLCache v;
oadd.org.apache.zookeeper.server.DataTree v;
v := @this: oadd.org.apache.zookeeper.server.DataTree;
v = v.<oadd.org.apache.zookeeper.server.DataTree: oadd.org.apache.zookeeper.server.ReferenceCountedACLCache aclCache>;
v = virtualinvoke v.<oadd.org.apache.zookeeper.server.ReferenceCountedACLCache: int size()>();
return v;
}
public oadd.org.apache.zookeeper.server.DataTree$ProcessTxnResult processTxn(oadd.org.apache.zookeeper.txn.TxnHeader, oadd.org.apache.jute.Record)
{
oadd.org.apache.jute.Record v;
oadd.org.apache.zookeeper.server.DataTree$ProcessTxnResult v;
oadd.org.apache.zookeeper.txn.TxnHeader v;
oadd.org.apache.zookeeper.server.DataTree v;
v := @this: oadd.org.apache.zookeeper.server.DataTree;
v := @parameter: oadd.org.apache.zookeeper.txn.TxnHeader;
v := @parameter: oadd.org.apache.jute.Record;
v = virtualinvoke v.<oadd.org.apache.zookeeper.server.DataTree: oadd.org.apache.zookeeper.server.DataTree$ProcessTxnResult processTxn(oadd.org.apache.zookeeper.txn.TxnHeader,oadd.org.apache.jute.Record,boolean)>(v, v, 0);
return v;
}
public oadd.org.apache.zookeeper.server.DataTree$ProcessTxnResult processTxn(oadd.org.apache.zookeeper.txn.TxnHeader, oadd.org.apache.jute.Record, boolean)
{
byte[] v, v, v, v, v, v;
byte v;
oadd.org.apache.zookeeper.data.Stat 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;
oadd.org.apache.zookeeper.server.DataTree v;
java.io.IOException v, v;
oadd.org.apache.zookeeper.server.EphemeralType v;
oadd.org.apache.zookeeper.txn.CheckVersionTxn v;
oadd.org.apache.zookeeper.KeeperException$Code 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, v, v, v, v, v, v, v, v, v, v, v;
org.slf4j.Logger v, v, v, v, v, v, v;
java.lang.Object v, v;
oadd.org.apache.zookeeper.KeeperException v;
oadd.org.apache.zookeeper.txn.SetDataTxn v;
oadd.org.apache.zookeeper.KeeperException$NoNodeException v;
java.lang.AssertionError v;
java.util.ArrayList v;
oadd.org.apache.zookeeper.txn.CreateTTLTxn 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, v, v;
oadd.org.apache.zookeeper.server.DataTree$ProcessTxnResult v, v;
oadd.org.apache.zookeeper.txn.CreateContainerTxn v;
java.nio.ByteBuffer v;
boolean v, v, v, v, v, v, v, v, v, v, v;
oadd.org.apache.jute.Record v, v;
java.util.List v, v, v, v, v, v, v;
oadd.org.apache.zookeeper.txn.DeleteTxn v;
oadd.org.apache.zookeeper.txn.CreateTxn v;
java.util.Iterator v, v;
oadd.org.apache.zookeeper.txn.ErrorTxn v, v;
oadd.org.apache.zookeeper.txn.TxnHeader v, v;
v := @this: oadd.org.apache.zookeeper.server.DataTree;
v := @parameter: oadd.org.apache.zookeeper.txn.TxnHeader;
v := @parameter: oadd.org.apache.jute.Record;
v := @parameter: boolean;
v = new oadd.org.apache.zookeeper.server.DataTree$ProcessTxnResult;
specialinvoke v.<oadd.org.apache.zookeeper.server.DataTree$ProcessTxnResult: void <init>()>();
label:
v = virtualinvoke v.<oadd.org.apache.zookeeper.txn.TxnHeader: long getClientId()>();
v.<oadd.org.apache.zookeeper.server.DataTree$ProcessTxnResult: long clientId> = v;
v = virtualinvoke v.<oadd.org.apache.zookeeper.txn.TxnHeader: int getCxid()>();
v.<oadd.org.apache.zookeeper.server.DataTree$ProcessTxnResult: int cxid> = v;
v = virtualinvoke v.<oadd.org.apache.zookeeper.txn.TxnHeader: long getZxid()>();
v.<oadd.org.apache.zookeeper.server.DataTree$ProcessTxnResult: long zxid> = v;
v = virtualinvoke v.<oadd.org.apache.zookeeper.txn.TxnHeader: int getType()>();
v.<oadd.org.apache.zookeeper.server.DataTree$ProcessTxnResult: int type> = v;
v.<oadd.org.apache.zookeeper.server.DataTree$ProcessTxnResult: int err> = 0;
v.<oadd.org.apache.zookeeper.server.DataTree$ProcessTxnResult: java.util.List multiResult> = null;
v = virtualinvoke v.<oadd.org.apache.zookeeper.txn.TxnHeader: int getType()>();
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:
v = virtualinvoke v.<oadd.org.apache.zookeeper.txn.CreateTxn: java.lang.String getPath()>();
v.<oadd.org.apache.zookeeper.server.DataTree$ProcessTxnResult: java.lang.String path> = v;
v = virtualinvoke v.<oadd.org.apache.zookeeper.txn.CreateTxn: java.lang.String getPath()>();
v = virtualinvoke v.<oadd.org.apache.zookeeper.txn.CreateTxn: byte[] getData()>();
v = virtualinvoke v.<oadd.org.apache.zookeeper.txn.CreateTxn: java.util.List getAcl()>();
v = virtualinvoke v.<oadd.org.apache.zookeeper.txn.CreateTxn: boolean getEphemeral()>();
if v == 0 goto label;
v = virtualinvoke v.<oadd.org.apache.zookeeper.txn.TxnHeader: long getClientId()>();
goto label;
label:
v = 0L;
label:
v = virtualinvoke v.<oadd.org.apache.zookeeper.txn.CreateTxn: int getParentCVersion()>();
v = virtualinvoke v.<oadd.org.apache.zookeeper.txn.TxnHeader: long getZxid()>();
v = virtualinvoke v.<oadd.org.apache.zookeeper.txn.TxnHeader: long getTime()>();
virtualinvoke v.<oadd.org.apache.zookeeper.server.DataTree: void createNode(java.lang.String,byte[],java.util.List,long,int,long,long,oadd.org.apache.zookeeper.data.Stat)>(v, v, v, v, v, v, v, null);
goto label;
label:
v = virtualinvoke v.<oadd.org.apache.zookeeper.txn.CreateTxn: java.lang.String getPath()>();
v.<oadd.org.apache.zookeeper.server.DataTree$ProcessTxnResult: java.lang.String path> = v;
v = new oadd.org.apache.zookeeper.data.Stat;
specialinvoke v.<oadd.org.apache.zookeeper.data.Stat: void <init>()>();
v = virtualinvoke v.<oadd.org.apache.zookeeper.txn.CreateTxn: java.lang.String getPath()>();
v = virtualinvoke v.<oadd.org.apache.zookeeper.txn.CreateTxn: byte[] getData()>();
v = virtualinvoke v.<oadd.org.apache.zookeeper.txn.CreateTxn: java.util.List getAcl()>();
v = virtualinvoke v.<oadd.org.apache.zookeeper.txn.CreateTxn: boolean getEphemeral()>();
if v == 0 goto label;
v = virtualinvoke v.<oadd.org.apache.zookeeper.txn.TxnHeader: long getClientId()>();
goto label;
label:
v = 0L;
label:
v = virtualinvoke v.<oadd.org.apache.zookeeper.txn.CreateTxn: int getParentCVersion()>();
v = virtualinvoke v.<oadd.org.apache.zookeeper.txn.TxnHeader: long getZxid()>();
v = virtualinvoke v.<oadd.org.apache.zookeeper.txn.TxnHeader: long getTime()>();
virtualinvoke v.<oadd.org.apache.zookeeper.server.DataTree: void createNode(java.lang.String,byte[],java.util.List,long,int,long,long,oadd.org.apache.zookeeper.data.Stat)>(v, v, v, v, v, v, v, v);
v.<oadd.org.apache.zookeeper.server.DataTree$ProcessTxnResult: oadd.org.apache.zookeeper.data.Stat stat> = v;
goto label;
label:
v = virtualinvoke v.<oadd.org.apache.zookeeper.txn.CreateTTLTxn: java.lang.String getPath()>();
v.<oadd.org.apache.zookeeper.server.DataTree$ProcessTxnResult: java.lang.String path> = v;
v = new oadd.org.apache.zookeeper.data.Stat;
specialinvoke v.<oadd.org.apache.zookeeper.data.Stat: void <init>()>();
v = virtualinvoke v.<oadd.org.apache.zookeeper.txn.CreateTTLTxn: java.lang.String getPath()>();
v = virtualinvoke v.<oadd.org.apache.zookeeper.txn.CreateTTLTxn: byte[] getData()>();
v = virtualinvoke v.<oadd.org.apache.zookeeper.txn.CreateTTLTxn: java.util.List getAcl()>();
v = <oadd.org.apache.zookeeper.server.EphemeralType: oadd.org.apache.zookeeper.server.EphemeralType TTL>;
v = virtualinvoke v.<oadd.org.apache.zookeeper.txn.CreateTTLTxn: long getTtl()>();
v = virtualinvoke v.<oadd.org.apache.zookeeper.server.EphemeralType: long toEphemeralOwner(long)>(v);
v = virtualinvoke v.<oadd.org.apache.zookeeper.txn.CreateTTLTxn: int getParentCVersion()>();
v = virtualinvoke v.<oadd.org.apache.zookeeper.txn.TxnHeader: long getZxid()>();
v = virtualinvoke v.<oadd.org.apache.zookeeper.txn.TxnHeader: long getTime()>();
virtualinvoke v.<oadd.org.apache.zookeeper.server.DataTree: void createNode(java.lang.String,byte[],java.util.List,long,int,long,long,oadd.org.apache.zookeeper.data.Stat)>(v, v, v, v, v, v, v, v);
v.<oadd.org.apache.zookeeper.server.DataTree$ProcessTxnResult: oadd.org.apache.zookeeper.data.Stat stat> = v;
goto label;
label:
v = virtualinvoke v.<oadd.org.apache.zookeeper.txn.CreateContainerTxn: java.lang.String getPath()>();
v.<oadd.org.apache.zookeeper.server.DataTree$ProcessTxnResult: java.lang.String path> = v;
v = new oadd.org.apache.zookeeper.data.Stat;
specialinvoke v.<oadd.org.apache.zookeeper.data.Stat: void <init>()>();
v = virtualinvoke v.<oadd.org.apache.zookeeper.txn.CreateContainerTxn: java.lang.String getPath()>();
v = virtualinvoke v.<oadd.org.apache.zookeeper.txn.CreateContainerTxn: byte[] getData()>();
v = virtualinvoke v.<oadd.org.apache.zookeeper.txn.CreateContainerTxn: java.util.List getAcl()>();
v = virtualinvoke v.<oadd.org.apache.zookeeper.txn.CreateContainerTxn: int getParentCVersion()>();
v = virtualinvoke v.<oadd.org.apache.zookeeper.txn.TxnHeader: long getZxid()>();
v = virtualinvoke v.<oadd.org.apache.zookeeper.txn.TxnHeader: long getTime()>();
virtualinvoke v.<oadd.org.apache.zookeeper.server.DataTree: void createNode(java.lang.String,byte[],java.util.List,long,int,long,long,oadd.org.apache.zookeeper.data.Stat)>(v, v, v, -9223372036854775808L, v, v, v, v);
v.<oadd.org.apache.zookeeper.server.DataTree$ProcessTxnResult: oadd.org.apache.zookeeper.data.Stat stat> = v;
goto label;
label:
v = virtualinvoke v.<oadd.org.apache.zookeeper.txn.DeleteTxn: java.lang.String getPath()>();
v.<oadd.org.apache.zookeeper.server.DataTree$ProcessTxnResult: java.lang.String path> = v;
v = virtualinvoke v.<oadd.org.apache.zookeeper.txn.DeleteTxn: java.lang.String getPath()>();
v = virtualinvoke v.<oadd.org.apache.zookeeper.txn.TxnHeader: long getZxid()>();
virtualinvoke v.<oadd.org.apache.zookeeper.server.DataTree: void deleteNode(java.lang.String,long)>(v, v);
goto label;
label:
v = virtualinvoke v.<oadd.org.apache.zookeeper.txn.SetDataTxn: java.lang.String getPath()>();
v.<oadd.org.apache.zookeeper.server.DataTree$ProcessTxnResult: java.lang.String path> = v;
v = virtualinvoke v.<oadd.org.apache.zookeeper.txn.SetDataTxn: java.lang.String getPath()>();
v = virtualinvoke v.<oadd.org.apache.zookeeper.txn.SetDataTxn: byte[] getData()>();
v = virtualinvoke v.<oadd.org.apache.zookeeper.txn.SetDataTxn: int getVersion()>();
v = virtualinvoke v.<oadd.org.apache.zookeeper.txn.TxnHeader: long getZxid()>();
v = virtualinvoke v.<oadd.org.apache.zookeeper.txn.TxnHeader: long getTime()>();
v = virtualinvoke v.<oadd.org.apache.zookeeper.server.DataTree: oadd.org.apache.zookeeper.data.Stat setData(java.lang.String,byte[],int,long,long)>(v, v, v, v, v);
v.<oadd.org.apache.zookeeper.server.DataTree$ProcessTxnResult: oadd.org.apache.zookeeper.data.Stat stat> = v;
goto label;
label:
v = virtualinvoke v.<oadd.org.apache.zookeeper.txn.SetACLTxn: java.lang.String getPath()>();
v.<oadd.org.apache.zookeeper.server.DataTree$ProcessTxnResult: java.lang.String path> = v;
v = virtualinvoke v.<oadd.org.apache.zookeeper.txn.SetACLTxn: java.lang.String getPath()>();
v = virtualinvoke v.<oadd.org.apache.zookeeper.txn.SetACLTxn: java.util.List getAcl()>();
v = virtualinvoke v.<oadd.org.apache.zookeeper.txn.SetACLTxn: int getVersion()>();
v = virtualinvoke v.<oadd.org.apache.zookeeper.server.DataTree: oadd.org.apache.zookeeper.data.Stat setACL(java.lang.String,java.util.List,int)>(v, v, v);
v.<oadd.org.apache.zookeeper.server.DataTree$ProcessTxnResult: oadd.org.apache.zookeeper.data.Stat stat> = v;
goto label;
label:
v = virtualinvoke v.<oadd.org.apache.zookeeper.txn.TxnHeader: long getClientId()>();
v = virtualinvoke v.<oadd.org.apache.zookeeper.txn.TxnHeader: long getZxid()>();
virtualinvoke v.<oadd.org.apache.zookeeper.server.DataTree: void killSession(long,long)>(v, v);
goto label;
label:
v = virtualinvoke v.<oadd.org.apache.zookeeper.txn.ErrorTxn: int getErr()>();
v.<oadd.org.apache.zookeeper.server.DataTree$ProcessTxnResult: int err> = v;
goto label;
label:
v = virtualinvoke v.<oadd.org.apache.zookeeper.txn.CheckVersionTxn: java.lang.String getPath()>();
v.<oadd.org.apache.zookeeper.server.DataTree$ProcessTxnResult: java.lang.String path> = v;
goto label;
label:
v = virtualinvoke v.<oadd.org.apache.zookeeper.txn.MultiTxn: java.util.List getTxns()>();
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v.<oadd.org.apache.zookeeper.server.DataTree$ProcessTxnResult: java.util.List multiResult> = v;
v = 0;
v = interfaceinvoke v.<java.util.List: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = virtualinvoke v.<oadd.org.apache.zookeeper.txn.Txn: int getType()>();
v = (int) -1;
if v != v goto label;
v = 1;
label:
v = 0;
v = interfaceinvoke v.<java.util.List: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = virtualinvoke v.<oadd.org.apache.zookeeper.txn.Txn: byte[] getData()>();
v = staticinvoke <java.nio.ByteBuffer: java.nio.ByteBuffer wrap(byte[])>(v);
v = virtualinvoke v.<oadd.org.apache.zookeeper.txn.Txn: int getType()>();
tableswitch(v)
{
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:
v = new oadd.org.apache.zookeeper.txn.CreateTxn;
specialinvoke v.<oadd.org.apache.zookeeper.txn.CreateTxn: void <init>()>();
v = v;
goto label;
label:
v = new oadd.org.apache.zookeeper.txn.CreateTTLTxn;
specialinvoke v.<oadd.org.apache.zookeeper.txn.CreateTTLTxn: void <init>()>();
v = v;
goto label;
label:
v = new oadd.org.apache.zookeeper.txn.CreateContainerTxn;
specialinvoke v.<oadd.org.apache.zookeeper.txn.CreateContainerTxn: void <init>()>();
v = v;
goto label;
label:
v = new oadd.org.apache.zookeeper.txn.DeleteTxn;
specialinvoke v.<oadd.org.apache.zookeeper.txn.DeleteTxn: void <init>()>();
v = v;
goto label;
label:
v = new oadd.org.apache.zookeeper.txn.SetDataTxn;
specialinvoke v.<oadd.org.apache.zookeeper.txn.SetDataTxn: void <init>()>();
v = v;
goto label;
label:
v = new oadd.org.apache.zookeeper.txn.ErrorTxn;
specialinvoke v.<oadd.org.apache.zookeeper.txn.ErrorTxn: void <init>()>();
v = v;
v = 1;
goto label;
label:
v = new oadd.org.apache.zookeeper.txn.CheckVersionTxn;
specialinvoke v.<oadd.org.apache.zookeeper.txn.CheckVersionTxn: void <init>()>();
v = v;
goto label;
label:
v = new java.io.IOException;
v = virtualinvoke v.<oadd.org.apache.zookeeper.txn.Txn: int getType()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (int)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Invalid type of op: \u0001");
specialinvoke v.<java.io.IOException: void <init>(java.lang.String)>(v);
throw v;
label:
v = <oadd.org.apache.zookeeper.server.DataTree: boolean $assertionsDisabled>;
staticinvoke <oadd.org.apache.zookeeper.server.ByteBufferInputStream: void byteBuffer2Record(java.nio.ByteBuffer,oadd.org.apache.jute.Record)>(v, v);
if v == 0 goto label;
v = virtualinvoke v.<oadd.org.apache.zookeeper.txn.Txn: int getType()>();
v = (int) -1;
if v == v goto label;
if v == 0 goto label;
v = <oadd.org.apache.zookeeper.KeeperException$Code: oadd.org.apache.zookeeper.KeeperException$Code RUNTIMEINCONSISTENCY>;
v = virtualinvoke v.<oadd.org.apache.zookeeper.KeeperException$Code: int intValue()>();
goto label;
label:
v = <oadd.org.apache.zookeeper.KeeperException$Code: oadd.org.apache.zookeeper.KeeperException$Code OK>;
v = virtualinvoke v.<oadd.org.apache.zookeeper.KeeperException$Code: int intValue()>();
label:
v = (int) -1;
virtualinvoke v.<oadd.org.apache.zookeeper.txn.Txn: void setType(int)>(v);
v = new oadd.org.apache.zookeeper.txn.ErrorTxn;
specialinvoke v.<oadd.org.apache.zookeeper.txn.ErrorTxn: void <init>(int)>(v);
v = v;
label:
if v == 0 goto label;
v = <oadd.org.apache.zookeeper.server.DataTree: boolean $assertionsDisabled>;
if v != 0 goto label;
v = virtualinvoke v.<oadd.org.apache.zookeeper.txn.Txn: int getType()>();
v = (int) -1;
if v == v goto label;
v = new java.lang.AssertionError;
specialinvoke v.<java.lang.AssertionError: void <init>()>();
throw v;
label:
v = new oadd.org.apache.zookeeper.txn.TxnHeader;
v = virtualinvoke v.<oadd.org.apache.zookeeper.txn.TxnHeader: long getClientId()>();
v = virtualinvoke v.<oadd.org.apache.zookeeper.txn.TxnHeader: int getCxid()>();
v = virtualinvoke v.<oadd.org.apache.zookeeper.txn.TxnHeader: long getZxid()>();
v = virtualinvoke v.<oadd.org.apache.zookeeper.txn.TxnHeader: long getTime()>();
v = virtualinvoke v.<oadd.org.apache.zookeeper.txn.Txn: int getType()>();
specialinvoke v.<oadd.org.apache.zookeeper.txn.TxnHeader: void <init>(long,int,long,long,int)>(v, v, v, v, v);
v = virtualinvoke v.<oadd.org.apache.zookeeper.server.DataTree: oadd.org.apache.zookeeper.server.DataTree$ProcessTxnResult processTxn(oadd.org.apache.zookeeper.txn.TxnHeader,oadd.org.apache.jute.Record,boolean)>(v, v, 1);
v = v.<oadd.org.apache.zookeeper.server.DataTree$ProcessTxnResult: java.util.List multiResult>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = v.<oadd.org.apache.zookeeper.server.DataTree$ProcessTxnResult: int err>;
if v == 0 goto label;
v = v.<oadd.org.apache.zookeeper.server.DataTree$ProcessTxnResult: int err>;
if v != 0 goto label;
v = v.<oadd.org.apache.zookeeper.server.DataTree$ProcessTxnResult: int err>;
v.<oadd.org.apache.zookeeper.server.DataTree$ProcessTxnResult: int err> = v;
goto label;
label:
v := @caughtexception;
v = <oadd.org.apache.zookeeper.server.DataTree: org.slf4j.Logger LOG>;
v = interfaceinvoke v.<org.slf4j.Logger: boolean isDebugEnabled()>();
if v == 0 goto label;
v = <oadd.org.apache.zookeeper.server.DataTree: org.slf4j.Logger LOG>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (oadd.org.apache.zookeeper.txn.TxnHeader,oadd.org.apache.jute.Record)>(v, v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Failed: \u0001:\u0001");
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String,java.lang.Throwable)>(v, v);
label:
v = virtualinvoke v.<oadd.org.apache.zookeeper.KeeperException: oadd.org.apache.zookeeper.KeeperException$Code code()>();
v = virtualinvoke v.<oadd.org.apache.zookeeper.KeeperException$Code: int intValue()>();
v.<oadd.org.apache.zookeeper.server.DataTree$ProcessTxnResult: int err> = v;
goto label;
label:
v := @caughtexception;
v = <oadd.org.apache.zookeeper.server.DataTree: org.slf4j.Logger LOG>;
v = interfaceinvoke v.<org.slf4j.Logger: boolean isDebugEnabled()>();
if v == 0 goto label;
v = <oadd.org.apache.zookeeper.server.DataTree: org.slf4j.Logger LOG>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (oadd.org.apache.zookeeper.txn.TxnHeader,oadd.org.apache.jute.Record)>(v, v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Failed: \u0001:\u0001");
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String,java.lang.Throwable)>(v, v);
label:
if v != 0 goto label;
v = v.<oadd.org.apache.zookeeper.server.DataTree$ProcessTxnResult: long zxid>;
v = v.<oadd.org.apache.zookeeper.server.DataTree: long lastProcessedZxid>;
v = v cmp v;
if v <= 0 goto label;
v = v.<oadd.org.apache.zookeeper.server.DataTree$ProcessTxnResult: long zxid>;
v.<oadd.org.apache.zookeeper.server.DataTree: long lastProcessedZxid> = v;
label:
v = virtualinvoke v.<oadd.org.apache.zookeeper.txn.TxnHeader: int getType()>();
if v != 1 goto label;
v = v.<oadd.org.apache.zookeeper.server.DataTree$ProcessTxnResult: int err>;
v = <oadd.org.apache.zookeeper.KeeperException$Code: oadd.org.apache.zookeeper.KeeperException$Code NODEEXISTS>;
v = virtualinvoke v.<oadd.org.apache.zookeeper.KeeperException$Code: int intValue()>();
if v != v goto label;
v = <oadd.org.apache.zookeeper.server.DataTree: org.slf4j.Logger LOG>;
v = virtualinvoke v.<oadd.org.apache.zookeeper.txn.TxnHeader: int getType()>();
v = v.<oadd.org.apache.zookeeper.server.DataTree$ProcessTxnResult: java.lang.String path>;
v = v.<oadd.org.apache.zookeeper.server.DataTree$ProcessTxnResult: int err>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (int,java.lang.String,int)>(v, v, v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Adjusting parent cversion for Txn: \u path:\u err: \u0001");
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String)>(v);
v = v.<oadd.org.apache.zookeeper.server.DataTree$ProcessTxnResult: java.lang.String path>;
v = virtualinvoke v.<java.lang.String: int lastIndexOf(int)>(47);
v = v.<oadd.org.apache.zookeeper.server.DataTree$ProcessTxnResult: java.lang.String path>;
v = virtualinvoke v.<java.lang.String: java.lang.String substring(int,int)>(0, v);
label:
v = virtualinvoke v.<oadd.org.apache.zookeeper.txn.CreateTxn: int getParentCVersion()>();
v = virtualinvoke v.<oadd.org.apache.zookeeper.txn.TxnHeader: long getZxid()>();
virtualinvoke v.<oadd.org.apache.zookeeper.server.DataTree: void setCversionPzxid(java.lang.String,int,long)>(v, v, v);
label:
goto label;
label:
v := @caughtexception;
v = <oadd.org.apache.zookeeper.server.DataTree: org.slf4j.Logger LOG>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Failed to set parent cversion for: \u0001");
interfaceinvoke v.<org.slf4j.Logger: void error(java.lang.String,java.lang.Throwable)>(v, v);
v = virtualinvoke v.<oadd.org.apache.zookeeper.KeeperException$NoNodeException: oadd.org.apache.zookeeper.KeeperException$Code code()>();
v = virtualinvoke v.<oadd.org.apache.zookeeper.KeeperException$Code: int intValue()>();
v.<oadd.org.apache.zookeeper.server.DataTree$ProcessTxnResult: int err> = v;
goto label;
label:
v = v.<oadd.org.apache.zookeeper.server.DataTree$ProcessTxnResult: int err>;
v = <oadd.org.apache.zookeeper.KeeperException$Code: oadd.org.apache.zookeeper.KeeperException$Code OK>;
v = virtualinvoke v.<oadd.org.apache.zookeeper.KeeperException$Code: int intValue()>();
if v == v goto label;
v = <oadd.org.apache.zookeeper.server.DataTree: org.slf4j.Logger LOG>;
v = virtualinvoke v.<oadd.org.apache.zookeeper.txn.TxnHeader: int getType()>();
v = v.<oadd.org.apache.zookeeper.server.DataTree$ProcessTxnResult: int err>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (int,int)>(v, v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Ignoring processTxn failure hdr: \u : error: \u0001");
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String)>(v);
label:
return v;
catch oadd.org.apache.zookeeper.KeeperException from label to label with label;
catch java.io.IOException from label to label with label;
catch oadd.org.apache.zookeeper.KeeperException$NoNodeException from label to label with label;
}
void killSession(long, long)
{
long v, v;
oadd.org.apache.zookeeper.server.DataTree v;
java.lang.Long v;
java.util.Map v;
java.lang.String v, v, v, v;
boolean v, v;
org.slf4j.Logger v, v, v;
java.util.Iterator v;
oadd.org.apache.zookeeper.KeeperException$NoNodeException v;
java.lang.Object v, v;
v := @this: oadd.org.apache.zookeeper.server.DataTree;
v := @parameter: long;
v := @parameter: long;
v = v.<oadd.org.apache.zookeeper.server.DataTree: java.util.Map ephemerals>;
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
v = interfaceinvoke v.<java.util.Map: java.lang.Object remove(java.lang.Object)>(v);
if v == null goto label;
v = virtualinvoke v.<java.util.HashSet: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
label:
virtualinvoke v.<oadd.org.apache.zookeeper.server.DataTree: void deleteNode(java.lang.String,long)>(v, v);
v = <oadd.org.apache.zookeeper.server.DataTree: org.slf4j.Logger LOG>;
v = interfaceinvoke v.<org.slf4j.Logger: boolean isDebugEnabled()>();
if v == 0 goto label;
v = <oadd.org.apache.zookeeper.server.DataTree: org.slf4j.Logger LOG>;
v = staticinvoke <java.lang.Long: java.lang.String toHexString(long)>(v);
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,java.lang.String)>(v, v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Deleting ephemeral node \u for session 0x\u0001");
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String)>(v);
label:
goto label;
label:
v := @caughtexception;
v = <oadd.org.apache.zookeeper.server.DataTree: org.slf4j.Logger LOG>;
v = staticinvoke <java.lang.Long: java.lang.String toHexString(long)>(v);
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,java.lang.String)>(v, v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Ignoring NoNodeException for path \u while removing ephemeral for dead session 0x\u0001");
interfaceinvoke v.<org.slf4j.Logger: void warn(java.lang.String)>(v);
goto label;
label:
return;
catch oadd.org.apache.zookeeper.KeeperException$NoNodeException from label to label with label;
}
private void getCounts(java.lang.String, oadd.org.apache.zookeeper.server.DataTree$Counts)
{
java.lang.Throwable v;
byte[] v, v;
java.lang.Object[] v;
oadd.org.apache.zookeeper.server.DataTree$Counts v;
java.lang.String[] v;
long v, v;
oadd.org.apache.zookeeper.server.DataTree v;
int v, v, v, v, v, v;
java.lang.String v, v, v;
oadd.org.apache.zookeeper.server.DataNode v;
java.util.Set v;
v := @this: oadd.org.apache.zookeeper.server.DataTree;
v := @parameter: java.lang.String;
v := @parameter: oadd.org.apache.zookeeper.server.DataTree$Counts;
v = virtualinvoke v.<oadd.org.apache.zookeeper.server.DataTree: oadd.org.apache.zookeeper.server.DataNode getNode(java.lang.String)>(v);
if v != null goto label;
return;
label:
entermonitor v;
label:
v = virtualinvoke v.<oadd.org.apache.zookeeper.server.DataNode: java.util.Set getChildren()>();
v = interfaceinvoke v.<java.util.Set: int size()>();
v = newarray (java.lang.String)[v];
v = interfaceinvoke v.<java.util.Set: java.lang.Object[] toArray(java.lang.Object[])>(v);
v = v.<oadd.org.apache.zookeeper.server.DataNode: byte[] data>;
if v != null goto label;
v = 0;
goto label;
label:
v = v.<oadd.org.apache.zookeeper.server.DataNode: byte[] data>;
v = lengthof v;
label:
exitmonitor v;
label:
goto label;
label:
v := @caughtexception;
exitmonitor v;
throw v;
label:
v = v.<oadd.org.apache.zookeeper.server.DataTree$Counts: int count>;
v = v + 1;
v.<oadd.org.apache.zookeeper.server.DataTree$Counts: int count> = v;
v = v.<oadd.org.apache.zookeeper.server.DataTree$Counts: long bytes>;
v = v + v;
v.<oadd.org.apache.zookeeper.server.DataTree$Counts: long bytes> = v;
v = lengthof v;
v = 0;
label:
if v >= v goto label;
v = v[v];
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,java.lang.String)>(v, v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("\u0001/\u0001");
specialinvoke v.<oadd.org.apache.zookeeper.server.DataTree: void getCounts(java.lang.String,oadd.org.apache.zookeeper.server.DataTree$Counts)>(v, v);
v = v + 1;
goto label;
label:
return;
catch java.lang.Throwable from label to label with label;
}
private void updateQuotaForPath(java.lang.String)
{
java.lang.Throwable v;
byte[] v;
oadd.org.apache.zookeeper.server.DataNode v;
org.slf4j.Logger v;
oadd.org.apache.zookeeper.server.DataTree$Counts v;
long v;
oadd.org.apache.zookeeper.server.DataTree v;
oadd.org.apache.zookeeper.StatsTrack v;
int v;
java.lang.String v, v, v, v;
v := @this: oadd.org.apache.zookeeper.server.DataTree;
v := @parameter: java.lang.String;
v = new oadd.org.apache.zookeeper.server.DataTree$Counts;
specialinvoke v.<oadd.org.apache.zookeeper.server.DataTree$Counts: void <init>()>();
specialinvoke v.<oadd.org.apache.zookeeper.server.DataTree: void getCounts(java.lang.String,oadd.org.apache.zookeeper.server.DataTree$Counts)>(v, v);
v = new oadd.org.apache.zookeeper.StatsTrack;
specialinvoke v.<oadd.org.apache.zookeeper.StatsTrack: void <init>()>();
v = v.<oadd.org.apache.zookeeper.server.DataTree$Counts: long bytes>;
virtualinvoke v.<oadd.org.apache.zookeeper.StatsTrack: void setBytes(long)>(v);
v = v.<oadd.org.apache.zookeeper.server.DataTree$Counts: int count>;
virtualinvoke v.<oadd.org.apache.zookeeper.StatsTrack: void setCount(int)>(v);
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("/zookeeper/quota\u0001/zookeeper_stats");
v = virtualinvoke v.<oadd.org.apache.zookeeper.server.DataTree: oadd.org.apache.zookeeper.server.DataNode getNode(java.lang.String)>(v);
if v != null goto label;
v = <oadd.org.apache.zookeeper.server.DataTree: org.slf4j.Logger LOG>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Missing quota stat node \u0001");
interfaceinvoke v.<org.slf4j.Logger: void warn(java.lang.String)>(v);
return;
label:
entermonitor v;
label:
v = virtualinvoke v.<oadd.org.apache.zookeeper.StatsTrack: java.lang.String toString()>();
v = virtualinvoke v.<java.lang.String: byte[] getBytes()>();
v.<oadd.org.apache.zookeeper.server.DataNode: byte[] data> = 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 void traverseNode(java.lang.String)
{
java.lang.Throwable v;
java.lang.Object[] v;
java.lang.String[] v;
oadd.org.apache.zookeeper.server.DataTree v;
int v, v, v, v, v, v;
java.lang.String v, v, v, v, v;
oadd.org.apache.zookeeper.common.PathTrie v;
boolean v;
oadd.org.apache.zookeeper.server.DataNode v;
java.util.Set v;
v := @this: oadd.org.apache.zookeeper.server.DataTree;
v := @parameter: java.lang.String;
v = virtualinvoke v.<oadd.org.apache.zookeeper.server.DataTree: oadd.org.apache.zookeeper.server.DataNode getNode(java.lang.String)>(v);
entermonitor v;
label:
v = virtualinvoke v.<oadd.org.apache.zookeeper.server.DataNode: java.util.Set getChildren()>();
v = interfaceinvoke v.<java.util.Set: int size()>();
v = newarray (java.lang.String)[v];
v = interfaceinvoke v.<java.util.Set: java.lang.Object[] toArray(java.lang.Object[])>(v);
exitmonitor v;
label:
goto label;
label:
v := @caughtexception;
exitmonitor v;
throw v;
label:
v = lengthof v;
if v != 0 goto label;
v = virtualinvoke v.<java.lang.String: boolean endsWith(java.lang.String)>("/zookeeper_limits");
if v == 0 goto label;
v = "/zookeeper/quota";
v = virtualinvoke v.<java.lang.String: int length()>();
v = virtualinvoke v.<java.lang.String: int indexOf(java.lang.String)>("/zookeeper_limits");
v = virtualinvoke v.<java.lang.String: java.lang.String substring(int,int)>(v, v);
specialinvoke v.<oadd.org.apache.zookeeper.server.DataTree: void updateQuotaForPath(java.lang.String)>(v);
v = v.<oadd.org.apache.zookeeper.server.DataTree: oadd.org.apache.zookeeper.common.PathTrie pTrie>;
virtualinvoke v.<oadd.org.apache.zookeeper.common.PathTrie: void addPath(java.lang.String)>(v);
label:
return;
label:
v = lengthof v;
v = 0;
label:
if v >= v goto label;
v = v[v];
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,java.lang.String)>(v, v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("\u0001/\u0001");
specialinvoke v.<oadd.org.apache.zookeeper.server.DataTree: void traverseNode(java.lang.String)>(v);
v = v + 1;
goto label;
label:
return;
catch java.lang.Throwable from label to label with label;
}
private void setupQuota()
{
oadd.org.apache.zookeeper.server.DataNode v;
oadd.org.apache.zookeeper.server.DataTree v;
v := @this: oadd.org.apache.zookeeper.server.DataTree;
v = virtualinvoke v.<oadd.org.apache.zookeeper.server.DataTree: oadd.org.apache.zookeeper.server.DataNode getNode(java.lang.String)>("/zookeeper/quota");
if v != null goto label;
return;
label:
specialinvoke v.<oadd.org.apache.zookeeper.server.DataTree: void traverseNode(java.lang.String)>("/zookeeper/quota");
return;
}
void serializeNode(oadd.org.apache.jute.OutputArchive, java.lang.StringBuilder) throws java.io.IOException
{
java.lang.Throwable v;
byte[] v;
java.lang.Object[] v;
oadd.org.apache.jute.OutputArchive v;
java.lang.String[] v;
oadd.org.apache.zookeeper.server.DataTree v;
java.lang.Long v;
int v, v, v, v;
java.lang.String v, v;
oadd.org.apache.zookeeper.server.DataNode v, v;
oadd.org.apache.zookeeper.data.StatPersisted v, v;
java.util.Set v;
java.lang.StringBuilder v;
v := @this: oadd.org.apache.zookeeper.server.DataTree;
v := @parameter: oadd.org.apache.jute.OutputArchive;
v := @parameter: java.lang.StringBuilder;
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.String toString()>();
v = virtualinvoke v.<oadd.org.apache.zookeeper.server.DataTree: oadd.org.apache.zookeeper.server.DataNode getNode(java.lang.String)>(v);
if v != null goto label;
return;
label:
entermonitor v;
label:
v = new oadd.org.apache.zookeeper.data.StatPersisted;
specialinvoke v.<oadd.org.apache.zookeeper.data.StatPersisted: void <init>()>();
v = v.<oadd.org.apache.zookeeper.server.DataNode: oadd.org.apache.zookeeper.data.StatPersisted stat>;
staticinvoke <oadd.org.apache.zookeeper.server.DataTree: void copyStatPersisted(oadd.org.apache.zookeeper.data.StatPersisted,oadd.org.apache.zookeeper.data.StatPersisted)>(v, v);
v = new oadd.org.apache.zookeeper.server.DataNode;
v = v.<oadd.org.apache.zookeeper.server.DataNode: byte[] data>;
v = v.<oadd.org.apache.zookeeper.server.DataNode: java.lang.Long acl>;
specialinvoke v.<oadd.org.apache.zookeeper.server.DataNode: void <init>(byte[],java.lang.Long,oadd.org.apache.zookeeper.data.StatPersisted)>(v, v, v);
v = virtualinvoke v.<oadd.org.apache.zookeeper.server.DataNode: java.util.Set getChildren()>();
v = interfaceinvoke v.<java.util.Set: int size()>();
v = newarray (java.lang.String)[v];
v = interfaceinvoke v.<java.util.Set: java.lang.Object[] toArray(java.lang.Object[])>(v);
exitmonitor v;
label:
goto label;
label:
v := @caughtexception;
exitmonitor v;
throw v;
label:
virtualinvoke v.<oadd.org.apache.zookeeper.server.DataTree: void serializeNodeData(oadd.org.apache.jute.OutputArchive,java.lang.String,oadd.org.apache.zookeeper.server.DataNode)>(v, v, v);
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(char)>(47);
v = virtualinvoke v.<java.lang.StringBuilder: int length()>();
v = lengthof v;
v = 0;
label:
if v >= v goto label;
v = v[v];
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder delete(int,int)>(v, 2147483647);
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>(v);
virtualinvoke v.<oadd.org.apache.zookeeper.server.DataTree: void serializeNode(oadd.org.apache.jute.OutputArchive,java.lang.StringBuilder)>(v, v);
v = v + 1;
goto label;
label:
return;
catch java.lang.Throwable from label to label with label;
}
public void serializeNodeData(oadd.org.apache.jute.OutputArchive, java.lang.String, oadd.org.apache.zookeeper.server.DataNode) throws java.io.IOException
{
oadd.org.apache.zookeeper.server.DataNode v;
oadd.org.apache.jute.OutputArchive v;
java.lang.String v;
oadd.org.apache.zookeeper.server.DataTree v;
v := @this: oadd.org.apache.zookeeper.server.DataTree;
v := @parameter: oadd.org.apache.jute.OutputArchive;
v := @parameter: java.lang.String;
v := @parameter: oadd.org.apache.zookeeper.server.DataNode;
interfaceinvoke v.<oadd.org.apache.jute.OutputArchive: void writeString(java.lang.String,java.lang.String)>(v, "path");
interfaceinvoke v.<oadd.org.apache.jute.OutputArchive: void writeRecord(oadd.org.apache.jute.Record,java.lang.String)>(v, "node");
return;
}
public void serialize(oadd.org.apache.jute.OutputArchive, java.lang.String) throws java.io.IOException
{
oadd.org.apache.zookeeper.server.DataNode v;
oadd.org.apache.jute.OutputArchive v;
java.lang.StringBuilder v;
oadd.org.apache.zookeeper.server.ReferenceCountedACLCache v;
java.lang.String v;
oadd.org.apache.zookeeper.server.DataTree v;
v := @this: oadd.org.apache.zookeeper.server.DataTree;
v := @parameter: oadd.org.apache.jute.OutputArchive;
v := @parameter: java.lang.String;
v = v.<oadd.org.apache.zookeeper.server.DataTree: oadd.org.apache.zookeeper.server.ReferenceCountedACLCache aclCache>;
virtualinvoke v.<oadd.org.apache.zookeeper.server.ReferenceCountedACLCache: void serialize(oadd.org.apache.jute.OutputArchive)>(v);
v = new java.lang.StringBuilder;
specialinvoke v.<java.lang.StringBuilder: void <init>(java.lang.String)>("");
virtualinvoke v.<oadd.org.apache.zookeeper.server.DataTree: void serializeNode(oadd.org.apache.jute.OutputArchive,java.lang.StringBuilder)>(v, v);
v = v.<oadd.org.apache.zookeeper.server.DataTree: oadd.org.apache.zookeeper.server.DataNode root>;
if v == null goto label;
interfaceinvoke v.<oadd.org.apache.jute.OutputArchive: void writeString(java.lang.String,java.lang.String)>("/", "path");
label:
return;
}
public void deserialize(oadd.org.apache.jute.InputArchive, java.lang.String) throws java.io.IOException
{
byte v;
java.lang.Long v, v, v;
java.util.Map v, v;
oadd.org.apache.jute.InputArchive v;
boolean v;
java.util.concurrent.ConcurrentHashMap v, v, v, v;
java.util.Set v, v;
oadd.org.apache.zookeeper.server.EphemeralType v, v, v;
java.lang.Throwable v;
long v;
oadd.org.apache.zookeeper.server.DataTree v;
java.util.HashSet v;
int v, v, v;
oadd.org.apache.zookeeper.server.ReferenceCountedACLCache v, v, v;
java.lang.String v, v, v, v, v, v;
oadd.org.apache.zookeeper.common.PathTrie v;
oadd.org.apache.zookeeper.server.DataNode v, v;
oadd.org.apache.zookeeper.data.StatPersisted v;
java.io.IOException v;
java.lang.Object v, v;
v := @this: oadd.org.apache.zookeeper.server.DataTree;
v := @parameter: oadd.org.apache.jute.InputArchive;
v := @parameter: java.lang.String;
v = v.<oadd.org.apache.zookeeper.server.DataTree: oadd.org.apache.zookeeper.server.ReferenceCountedACLCache aclCache>;
virtualinvoke v.<oadd.org.apache.zookeeper.server.ReferenceCountedACLCache: void deserialize(oadd.org.apache.jute.InputArchive)>(v);
v = v.<oadd.org.apache.zookeeper.server.DataTree: java.util.concurrent.ConcurrentHashMap nodes>;
virtualinvoke v.<java.util.concurrent.ConcurrentHashMap: void clear()>();
v = v.<oadd.org.apache.zookeeper.server.DataTree: oadd.org.apache.zookeeper.common.PathTrie pTrie>;
virtualinvoke v.<oadd.org.apache.zookeeper.common.PathTrie: void clear()>();
v = interfaceinvoke v.<oadd.org.apache.jute.InputArchive: java.lang.String readString(java.lang.String)>("path");
label:
v = "/";
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>(v);
if v != 0 goto label;
v = new oadd.org.apache.zookeeper.server.DataNode;
specialinvoke v.<oadd.org.apache.zookeeper.server.DataNode: void <init>()>();
interfaceinvoke v.<oadd.org.apache.jute.InputArchive: void readRecord(oadd.org.apache.jute.Record,java.lang.String)>(v, "node");
v = v.<oadd.org.apache.zookeeper.server.DataTree: java.util.concurrent.ConcurrentHashMap nodes>;
virtualinvoke v.<java.util.concurrent.ConcurrentHashMap: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
entermonitor v;
label:
v = v.<oadd.org.apache.zookeeper.server.DataTree: oadd.org.apache.zookeeper.server.ReferenceCountedACLCache aclCache>;
v = v.<oadd.org.apache.zookeeper.server.DataNode: java.lang.Long acl>;
virtualinvoke v.<oadd.org.apache.zookeeper.server.ReferenceCountedACLCache: void addUsage(java.lang.Long)>(v);
exitmonitor v;
label:
goto label;
label:
v := @caughtexception;
exitmonitor v;
throw v;
label:
v = virtualinvoke v.<java.lang.String: int lastIndexOf(int)>(47);
v = (int) -1;
if v != v goto label;
v.<oadd.org.apache.zookeeper.server.DataTree: oadd.org.apache.zookeeper.server.DataNode root> = v;
goto label;
label:
v = virtualinvoke v.<java.lang.String: java.lang.String substring(int,int)>(0, v);
v = v.<oadd.org.apache.zookeeper.server.DataTree: java.util.concurrent.ConcurrentHashMap nodes>;
v = virtualinvoke v.<java.util.concurrent.ConcurrentHashMap: java.lang.Object get(java.lang.Object)>(v);
if v != null goto label;
v = new java.io.IOException;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,java.lang.String)>(v, v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Invalid Datatree, unable to find parent \u of path \u0001");
specialinvoke v.<java.io.IOException: void <init>(java.lang.String)>(v);
throw v;
label:
v = v + 1;
v = virtualinvoke v.<java.lang.String: java.lang.String substring(int)>(v);
virtualinvoke v.<oadd.org.apache.zookeeper.server.DataNode: boolean addChild(java.lang.String)>(v);
v = v.<oadd.org.apache.zookeeper.server.DataNode: oadd.org.apache.zookeeper.data.StatPersisted stat>;
v = virtualinvoke v.<oadd.org.apache.zookeeper.data.StatPersisted: long getEphemeralOwner()>();
v = staticinvoke <oadd.org.apache.zookeeper.server.EphemeralType: oadd.org.apache.zookeeper.server.EphemeralType get(long)>(v);
v = <oadd.org.apache.zookeeper.server.EphemeralType: oadd.org.apache.zookeeper.server.EphemeralType CONTAINER>;
if v != v goto label;
v = v.<oadd.org.apache.zookeeper.server.DataTree: java.util.Set containers>;
interfaceinvoke v.<java.util.Set: boolean add(java.lang.Object)>(v);
goto label;
label:
v = <oadd.org.apache.zookeeper.server.EphemeralType: oadd.org.apache.zookeeper.server.EphemeralType TTL>;
if v != v goto label;
v = v.<oadd.org.apache.zookeeper.server.DataTree: java.util.Set ttls>;
interfaceinvoke v.<java.util.Set: boolean add(java.lang.Object)>(v);
goto label;
label:
v = v cmp 0L;
if v == 0 goto label;
v = v.<oadd.org.apache.zookeeper.server.DataTree: java.util.Map ephemerals>;
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
if v != null goto label;
v = new java.util.HashSet;
specialinvoke v.<java.util.HashSet: void <init>()>();
v = v;
v = v.<oadd.org.apache.zookeeper.server.DataTree: java.util.Map ephemerals>;
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
label:
virtualinvoke v.<java.util.HashSet: boolean add(java.lang.Object)>(v);
label:
v = interfaceinvoke v.<oadd.org.apache.jute.InputArchive: java.lang.String readString(java.lang.String)>("path");
goto label;
label:
v = v.<oadd.org.apache.zookeeper.server.DataTree: java.util.concurrent.ConcurrentHashMap nodes>;
v = v.<oadd.org.apache.zookeeper.server.DataTree: oadd.org.apache.zookeeper.server.DataNode root>;
virtualinvoke v.<java.util.concurrent.ConcurrentHashMap: java.lang.Object put(java.lang.Object,java.lang.Object)>("/", v);
specialinvoke v.<oadd.org.apache.zookeeper.server.DataTree: void setupQuota()>();
v = v.<oadd.org.apache.zookeeper.server.DataTree: oadd.org.apache.zookeeper.server.ReferenceCountedACLCache aclCache>;
virtualinvoke v.<oadd.org.apache.zookeeper.server.ReferenceCountedACLCache: void purgeUnused()>();
return;
catch java.lang.Throwable from label to label with label;
}
public synchronized void dumpWatchesSummary(java.io.PrintWriter)
{
java.io.PrintWriter v;
oadd.org.apache.zookeeper.server.WatchManager v;
java.lang.String v;
oadd.org.apache.zookeeper.server.DataTree v;
v := @this: oadd.org.apache.zookeeper.server.DataTree;
v := @parameter: java.io.PrintWriter;
v = v.<oadd.org.apache.zookeeper.server.DataTree: oadd.org.apache.zookeeper.server.WatchManager dataWatches>;
v = virtualinvoke v.<oadd.org.apache.zookeeper.server.WatchManager: java.lang.String toString()>();
virtualinvoke v.<java.io.PrintWriter: void print(java.lang.String)>(v);
return;
}
public synchronized void dumpWatches(java.io.PrintWriter, boolean)
{
java.io.PrintWriter v;
oadd.org.apache.zookeeper.server.WatchManager v;
oadd.org.apache.zookeeper.server.DataTree v;
boolean v;
v := @this: oadd.org.apache.zookeeper.server.DataTree;
v := @parameter: java.io.PrintWriter;
v := @parameter: boolean;
v = v.<oadd.org.apache.zookeeper.server.DataTree: oadd.org.apache.zookeeper.server.WatchManager dataWatches>;
virtualinvoke v.<oadd.org.apache.zookeeper.server.WatchManager: void dumpWatches(java.io.PrintWriter,boolean)>(v, v);
return;
}
public synchronized oadd.org.apache.zookeeper.server.WatchesReport getWatches()
{
oadd.org.apache.zookeeper.server.WatchManager v;
oadd.org.apache.zookeeper.server.WatchesReport v;
oadd.org.apache.zookeeper.server.DataTree v;
v := @this: oadd.org.apache.zookeeper.server.DataTree;
v = v.<oadd.org.apache.zookeeper.server.DataTree: oadd.org.apache.zookeeper.server.WatchManager dataWatches>;
v = virtualinvoke v.<oadd.org.apache.zookeeper.server.WatchManager: oadd.org.apache.zookeeper.server.WatchesReport getWatches()>();
return v;
}
public synchronized oadd.org.apache.zookeeper.server.WatchesPathReport getWatchesByPath()
{
oadd.org.apache.zookeeper.server.WatchesPathReport v;
oadd.org.apache.zookeeper.server.WatchManager v;
oadd.org.apache.zookeeper.server.DataTree v;
v := @this: oadd.org.apache.zookeeper.server.DataTree;
v = v.<oadd.org.apache.zookeeper.server.DataTree: oadd.org.apache.zookeeper.server.WatchManager dataWatches>;
v = virtualinvoke v.<oadd.org.apache.zookeeper.server.WatchManager: oadd.org.apache.zookeeper.server.WatchesPathReport getWatchesByPath()>();
return v;
}
public synchronized oadd.org.apache.zookeeper.server.WatchesSummary getWatchesSummary()
{
oadd.org.apache.zookeeper.server.WatchManager v;
oadd.org.apache.zookeeper.server.DataTree v;
oadd.org.apache.zookeeper.server.WatchesSummary v;
v := @this: oadd.org.apache.zookeeper.server.DataTree;
v = v.<oadd.org.apache.zookeeper.server.DataTree: oadd.org.apache.zookeeper.server.WatchManager dataWatches>;
v = virtualinvoke v.<oadd.org.apache.zookeeper.server.WatchManager: oadd.org.apache.zookeeper.server.WatchesSummary getWatchesSummary()>();
return v;
}
public void dumpEphemerals(java.io.PrintWriter)
{
java.lang.Throwable v;
long v;
oadd.org.apache.zookeeper.server.DataTree v;
java.util.Map v, v;
int v;
java.lang.String v, v, v, v;
boolean v, v;
java.io.PrintWriter v;
java.util.Iterator v, v;
java.util.Set v, v;
java.lang.Object v, v, v, v;
v := @this: oadd.org.apache.zookeeper.server.DataTree;
v := @parameter: java.io.PrintWriter;
v = v.<oadd.org.apache.zookeeper.server.DataTree: java.util.Map ephemerals>;
v = interfaceinvoke v.<java.util.Map: java.util.Set keySet()>();
v = interfaceinvoke v.<java.util.Set: int size()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (int)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Sessions with Ephemerals (\u):");
virtualinvoke v.<java.io.PrintWriter: void println(java.lang.String)>(v);
v = v.<oadd.org.apache.zookeeper.server.DataTree: java.util.Map ephemerals>;
v = interfaceinvoke v.<java.util.Map: java.util.Set entrySet()>();
v = interfaceinvoke v.<java.util.Set: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getKey()>();
v = virtualinvoke v.<java.lang.Long: long longValue()>();
v = staticinvoke <java.lang.Long: java.lang.String toHexString(long)>(v);
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("0x\u0001");
virtualinvoke v.<java.io.PrintWriter: void print(java.lang.String)>(v);
virtualinvoke v.<java.io.PrintWriter: void println(java.lang.String)>(":");
v = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getValue()>();
if v == null goto label;
entermonitor v;
label:
v = virtualinvoke v.<java.util.HashSet: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.Object)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("\t\u0001");
virtualinvoke v.<java.io.PrintWriter: void println(java.lang.String)>(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;
}
public java.util.Map getEphemerals()
{
java.lang.Throwable v;
java.util.Iterator v;
java.util.Set v;
java.util.HashMap v;
oadd.org.apache.zookeeper.server.DataTree v;
java.util.HashSet v;
java.util.Map v;
java.lang.Object v, v, v, v;
boolean v;
v := @this: oadd.org.apache.zookeeper.server.DataTree;
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
v = v.<oadd.org.apache.zookeeper.server.DataTree: java.util.Map ephemerals>;
v = interfaceinvoke v.<java.util.Map: java.util.Set entrySet()>();
v = interfaceinvoke v.<java.util.Set: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getValue()>();
entermonitor v;
label:
v = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getKey()>();
v = new java.util.HashSet;
v = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getValue()>();
specialinvoke v.<java.util.HashSet: void <init>(java.util.Collection)>(v);
virtualinvoke v.<java.util.HashMap: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
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;
}
public void removeCnxn(oadd.org.apache.zookeeper.Watcher)
{
oadd.org.apache.zookeeper.server.WatchManager v, v;
oadd.org.apache.zookeeper.Watcher v;
oadd.org.apache.zookeeper.server.DataTree v;
v := @this: oadd.org.apache.zookeeper.server.DataTree;
v := @parameter: oadd.org.apache.zookeeper.Watcher;
v = v.<oadd.org.apache.zookeeper.server.DataTree: oadd.org.apache.zookeeper.server.WatchManager dataWatches>;
virtualinvoke v.<oadd.org.apache.zookeeper.server.WatchManager: void removeWatcher(oadd.org.apache.zookeeper.Watcher)>(v);
v = v.<oadd.org.apache.zookeeper.server.DataTree: oadd.org.apache.zookeeper.server.WatchManager childWatches>;
virtualinvoke v.<oadd.org.apache.zookeeper.server.WatchManager: void removeWatcher(oadd.org.apache.zookeeper.Watcher)>(v);
return;
}
public void setWatches(long, java.util.List, java.util.List, java.util.List, oadd.org.apache.zookeeper.Watcher)
{
oadd.org.apache.zookeeper.Watcher v;
byte v, v;
boolean v, v, v;
oadd.org.apache.zookeeper.server.WatchManager v, v, v;
java.util.List v, v, v;
long v, v, v;
oadd.org.apache.zookeeper.WatchedEvent v, v, v, v, v;
oadd.org.apache.zookeeper.server.DataTree v;
oadd.org.apache.zookeeper.Watcher$Event$KeeperState v, v, v, v, v;
oadd.org.apache.zookeeper.Watcher$Event$EventType v, v, v, v, v;
oadd.org.apache.zookeeper.server.DataNode v, v, v;
java.util.Iterator v, v, v;
oadd.org.apache.zookeeper.data.StatPersisted v, v;
java.lang.Object v, v, v;
v := @this: oadd.org.apache.zookeeper.server.DataTree;
v := @parameter: long;
v := @parameter: java.util.List;
v := @parameter: java.util.List;
v := @parameter: java.util.List;
v := @parameter: oadd.org.apache.zookeeper.Watcher;
v = interfaceinvoke v.<java.util.List: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = virtualinvoke v.<oadd.org.apache.zookeeper.server.DataTree: oadd.org.apache.zookeeper.server.DataNode getNode(java.lang.String)>(v);
if v != null goto label;
v = new oadd.org.apache.zookeeper.WatchedEvent;
v = <oadd.org.apache.zookeeper.Watcher$Event$EventType: oadd.org.apache.zookeeper.Watcher$Event$EventType NodeDeleted>;
v = <oadd.org.apache.zookeeper.Watcher$Event$KeeperState: oadd.org.apache.zookeeper.Watcher$Event$KeeperState SyncConnected>;
specialinvoke v.<oadd.org.apache.zookeeper.WatchedEvent: void <init>(oadd.org.apache.zookeeper.Watcher$Event$EventType,oadd.org.apache.zookeeper.Watcher$Event$KeeperState,java.lang.String)>(v, v, v);
interfaceinvoke v.<oadd.org.apache.zookeeper.Watcher: void process(oadd.org.apache.zookeeper.WatchedEvent)>(v);
goto label;
label:
v = v.<oadd.org.apache.zookeeper.server.DataNode: oadd.org.apache.zookeeper.data.StatPersisted stat>;
v = virtualinvoke v.<oadd.org.apache.zookeeper.data.StatPersisted: long getMzxid()>();
v = v cmp v;
if v <= 0 goto label;
v = new oadd.org.apache.zookeeper.WatchedEvent;
v = <oadd.org.apache.zookeeper.Watcher$Event$EventType: oadd.org.apache.zookeeper.Watcher$Event$EventType NodeDataChanged>;
v = <oadd.org.apache.zookeeper.Watcher$Event$KeeperState: oadd.org.apache.zookeeper.Watcher$Event$KeeperState SyncConnected>;
specialinvoke v.<oadd.org.apache.zookeeper.WatchedEvent: void <init>(oadd.org.apache.zookeeper.Watcher$Event$EventType,oadd.org.apache.zookeeper.Watcher$Event$KeeperState,java.lang.String)>(v, v, v);
interfaceinvoke v.<oadd.org.apache.zookeeper.Watcher: void process(oadd.org.apache.zookeeper.WatchedEvent)>(v);
goto label;
label:
v = v.<oadd.org.apache.zookeeper.server.DataTree: oadd.org.apache.zookeeper.server.WatchManager dataWatches>;
virtualinvoke v.<oadd.org.apache.zookeeper.server.WatchManager: void addWatch(java.lang.String,oadd.org.apache.zookeeper.Watcher)>(v, v);
goto label;
label:
v = interfaceinvoke v.<java.util.List: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = virtualinvoke v.<oadd.org.apache.zookeeper.server.DataTree: oadd.org.apache.zookeeper.server.DataNode getNode(java.lang.String)>(v);
if v == null goto label;
v = new oadd.org.apache.zookeeper.WatchedEvent;
v = <oadd.org.apache.zookeeper.Watcher$Event$EventType: oadd.org.apache.zookeeper.Watcher$Event$EventType NodeCreated>;
v = <oadd.org.apache.zookeeper.Watcher$Event$KeeperState: oadd.org.apache.zookeeper.Watcher$Event$KeeperState SyncConnected>;
specialinvoke v.<oadd.org.apache.zookeeper.WatchedEvent: void <init>(oadd.org.apache.zookeeper.Watcher$Event$EventType,oadd.org.apache.zookeeper.Watcher$Event$KeeperState,java.lang.String)>(v, v, v);
interfaceinvoke v.<oadd.org.apache.zookeeper.Watcher: void process(oadd.org.apache.zookeeper.WatchedEvent)>(v);
goto label;
label:
v = v.<oadd.org.apache.zookeeper.server.DataTree: oadd.org.apache.zookeeper.server.WatchManager dataWatches>;
virtualinvoke v.<oadd.org.apache.zookeeper.server.WatchManager: void addWatch(java.lang.String,oadd.org.apache.zookeeper.Watcher)>(v, v);
goto label;
label:
v = interfaceinvoke v.<java.util.List: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = virtualinvoke v.<oadd.org.apache.zookeeper.server.DataTree: oadd.org.apache.zookeeper.server.DataNode getNode(java.lang.String)>(v);
if v != null goto label;
v = new oadd.org.apache.zookeeper.WatchedEvent;
v = <oadd.org.apache.zookeeper.Watcher$Event$EventType: oadd.org.apache.zookeeper.Watcher$Event$EventType NodeDeleted>;
v = <oadd.org.apache.zookeeper.Watcher$Event$KeeperState: oadd.org.apache.zookeeper.Watcher$Event$KeeperState SyncConnected>;
specialinvoke v.<oadd.org.apache.zookeeper.WatchedEvent: void <init>(oadd.org.apache.zookeeper.Watcher$Event$EventType,oadd.org.apache.zookeeper.Watcher$Event$KeeperState,java.lang.String)>(v, v, v);
interfaceinvoke v.<oadd.org.apache.zookeeper.Watcher: void process(oadd.org.apache.zookeeper.WatchedEvent)>(v);
goto label;
label:
v = v.<oadd.org.apache.zookeeper.server.DataNode: oadd.org.apache.zookeeper.data.StatPersisted stat>;
v = virtualinvoke v.<oadd.org.apache.zookeeper.data.StatPersisted: long getPzxid()>();
v = v cmp v;
if v <= 0 goto label;
v = new oadd.org.apache.zookeeper.WatchedEvent;
v = <oadd.org.apache.zookeeper.Watcher$Event$EventType: oadd.org.apache.zookeeper.Watcher$Event$EventType NodeChildrenChanged>;
v = <oadd.org.apache.zookeeper.Watcher$Event$KeeperState: oadd.org.apache.zookeeper.Watcher$Event$KeeperState SyncConnected>;
specialinvoke v.<oadd.org.apache.zookeeper.WatchedEvent: void <init>(oadd.org.apache.zookeeper.Watcher$Event$EventType,oadd.org.apache.zookeeper.Watcher$Event$KeeperState,java.lang.String)>(v, v, v);
interfaceinvoke v.<oadd.org.apache.zookeeper.Watcher: void process(oadd.org.apache.zookeeper.WatchedEvent)>(v);
goto label;
label:
v = v.<oadd.org.apache.zookeeper.server.DataTree: oadd.org.apache.zookeeper.server.WatchManager childWatches>;
virtualinvoke v.<oadd.org.apache.zookeeper.server.WatchManager: void addWatch(java.lang.String,oadd.org.apache.zookeeper.Watcher)>(v, v);
goto label;
label:
return;
}
public void setCversionPzxid(java.lang.String, int, long) throws oadd.org.apache.zookeeper.KeeperException$NoNodeException
{
java.lang.Throwable v;
long v;
oadd.org.apache.zookeeper.server.DataTree v;
int v, v, v, v, v, v;
java.lang.String v;
boolean v;
oadd.org.apache.zookeeper.data.StatPersisted v, v, v, v;
java.util.concurrent.ConcurrentHashMap v;
oadd.org.apache.zookeeper.KeeperException$NoNodeException v;
java.lang.Object v;
v := @this: oadd.org.apache.zookeeper.server.DataTree;
v := @parameter: java.lang.String;
v := @parameter: int;
v := @parameter: long;
v = virtualinvoke v.<java.lang.String: boolean endsWith(java.lang.String)>("/");
if v == 0 goto label;
v = virtualinvoke v.<java.lang.String: int length()>();
v = v - 1;
v = virtualinvoke v.<java.lang.String: java.lang.String substring(int,int)>(0, v);
label:
v = v.<oadd.org.apache.zookeeper.server.DataTree: java.util.concurrent.ConcurrentHashMap nodes>;
v = virtualinvoke v.<java.util.concurrent.ConcurrentHashMap: java.lang.Object get(java.lang.Object)>(v);
if v != null goto label;
v = new oadd.org.apache.zookeeper.KeeperException$NoNodeException;
specialinvoke v.<oadd.org.apache.zookeeper.KeeperException$NoNodeException: void <init>(java.lang.String)>(v);
throw v;
label:
entermonitor v;
label:
v = (int) -1;
if v != v goto label;
v = v.<oadd.org.apache.zookeeper.server.DataNode: oadd.org.apache.zookeeper.data.StatPersisted stat>;
v = virtualinvoke v.<oadd.org.apache.zookeeper.data.StatPersisted: int getCversion()>();
v = v + 1;
label:
v = v.<oadd.org.apache.zookeeper.server.DataNode: oadd.org.apache.zookeeper.data.StatPersisted stat>;
v = virtualinvoke v.<oadd.org.apache.zookeeper.data.StatPersisted: int getCversion()>();
if v <= v goto label;
v = v.<oadd.org.apache.zookeeper.server.DataNode: oadd.org.apache.zookeeper.data.StatPersisted stat>;
virtualinvoke v.<oadd.org.apache.zookeeper.data.StatPersisted: void setCversion(int)>(v);
v = v.<oadd.org.apache.zookeeper.server.DataNode: oadd.org.apache.zookeeper.data.StatPersisted stat>;
virtualinvoke v.<oadd.org.apache.zookeeper.data.StatPersisted: void setPzxid(long)>(v);
label:
exitmonitor v;
label:
goto label;
label:
v := @caughtexception;
exitmonitor v;
throw v;
label:
return;
catch java.lang.Throwable from label to label with label;
}
public boolean containsWatcher(java.lang.String, oadd.org.apache.zookeeper.Watcher$WatcherType, oadd.org.apache.zookeeper.Watcher)
{
oadd.org.apache.zookeeper.server.WatchManager v, v, v, v;
oadd.org.apache.zookeeper.server.DataTree v;
oadd.org.apache.zookeeper.Watcher v;
int[] v;
int v, v;
java.lang.String v;
oadd.org.apache.zookeeper.Watcher$WatcherType v;
boolean v, v, v;
v := @this: oadd.org.apache.zookeeper.server.DataTree;
v := @parameter: java.lang.String;
v := @parameter: oadd.org.apache.zookeeper.Watcher$WatcherType;
v := @parameter: oadd.org.apache.zookeeper.Watcher;
v = 0;
v = <oadd.org.apache.zookeeper.server.DataTree$1: int[] $SwitchMap$org$apache$zookeeper$Watcher$WatcherType>;
v = virtualinvoke v.<oadd.org.apache.zookeeper.Watcher$WatcherType: int ordinal()>();
v = v[v];
tableswitch(v)
{
case 1: goto label;
case 2: goto label;
case 3: goto label;
default: goto label;
};
label:
v = v.<oadd.org.apache.zookeeper.server.DataTree: oadd.org.apache.zookeeper.server.WatchManager childWatches>;
v = virtualinvoke v.<oadd.org.apache.zookeeper.server.WatchManager: boolean containsWatcher(java.lang.String,oadd.org.apache.zookeeper.Watcher)>(v, v);
goto label;
label:
v = v.<oadd.org.apache.zookeeper.server.DataTree: oadd.org.apache.zookeeper.server.WatchManager dataWatches>;
v = virtualinvoke v.<oadd.org.apache.zookeeper.server.WatchManager: boolean containsWatcher(java.lang.String,oadd.org.apache.zookeeper.Watcher)>(v, v);
goto label;
label:
v = v.<oadd.org.apache.zookeeper.server.DataTree: oadd.org.apache.zookeeper.server.WatchManager childWatches>;
v = virtualinvoke v.<oadd.org.apache.zookeeper.server.WatchManager: boolean containsWatcher(java.lang.String,oadd.org.apache.zookeeper.Watcher)>(v, v);
if v == 0 goto label;
v = 1;
label:
v = v.<oadd.org.apache.zookeeper.server.DataTree: oadd.org.apache.zookeeper.server.WatchManager dataWatches>;
v = virtualinvoke v.<oadd.org.apache.zookeeper.server.WatchManager: boolean containsWatcher(java.lang.String,oadd.org.apache.zookeeper.Watcher)>(v, v);
if v == 0 goto label;
v = 1;
label:
return v;
}
public boolean removeWatch(java.lang.String, oadd.org.apache.zookeeper.Watcher$WatcherType, oadd.org.apache.zookeeper.Watcher)
{
oadd.org.apache.zookeeper.server.WatchManager v, v, v, v;
oadd.org.apache.zookeeper.server.DataTree v;
oadd.org.apache.zookeeper.Watcher v;
int[] v;
int v, v;
java.lang.String v;
oadd.org.apache.zookeeper.Watcher$WatcherType v;
boolean v, v, v;
v := @this: oadd.org.apache.zookeeper.server.DataTree;
v := @parameter: java.lang.String;
v := @parameter: oadd.org.apache.zookeeper.Watcher$WatcherType;
v := @parameter: oadd.org.apache.zookeeper.Watcher;
v = 0;
v = <oadd.org.apache.zookeeper.server.DataTree$1: int[] $SwitchMap$org$apache$zookeeper$Watcher$WatcherType>;
v = virtualinvoke v.<oadd.org.apache.zookeeper.Watcher$WatcherType: int ordinal()>();
v = v[v];
tableswitch(v)
{
case 1: goto label;
case 2: goto label;
case 3: goto label;
default: goto label;
};
label:
v = v.<oadd.org.apache.zookeeper.server.DataTree: oadd.org.apache.zookeeper.server.WatchManager childWatches>;
v = virtualinvoke v.<oadd.org.apache.zookeeper.server.WatchManager: boolean removeWatcher(java.lang.String,oadd.org.apache.zookeeper.Watcher)>(v, v);
goto label;
label:
v = v.<oadd.org.apache.zookeeper.server.DataTree: oadd.org.apache.zookeeper.server.WatchManager dataWatches>;
v = virtualinvoke v.<oadd.org.apache.zookeeper.server.WatchManager: boolean removeWatcher(java.lang.String,oadd.org.apache.zookeeper.Watcher)>(v, v);
goto label;
label:
v = v.<oadd.org.apache.zookeeper.server.DataTree: oadd.org.apache.zookeeper.server.WatchManager childWatches>;
v = virtualinvoke v.<oadd.org.apache.zookeeper.server.WatchManager: boolean removeWatcher(java.lang.String,oadd.org.apache.zookeeper.Watcher)>(v, v);
if v == 0 goto label;
v = 1;
label:
v = v.<oadd.org.apache.zookeeper.server.DataTree: oadd.org.apache.zookeeper.server.WatchManager dataWatches>;
v = virtualinvoke v.<oadd.org.apache.zookeeper.server.WatchManager: boolean removeWatcher(java.lang.String,oadd.org.apache.zookeeper.Watcher)>(v, v);
if v == 0 goto label;
v = 1;
label:
return v;
}
public oadd.org.apache.zookeeper.server.ReferenceCountedACLCache getReferenceCountedAclCache()
{
oadd.org.apache.zookeeper.server.ReferenceCountedACLCache v;
oadd.org.apache.zookeeper.server.DataTree v;
v := @this: oadd.org.apache.zookeeper.server.DataTree;
v = v.<oadd.org.apache.zookeeper.server.DataTree: oadd.org.apache.zookeeper.server.ReferenceCountedACLCache aclCache>;
return v;
}
static void <clinit>()
{
int v, v, v, v;
java.lang.String v, v, v, v, v, v, v, v;
boolean v, v;
org.slf4j.Logger v;
java.lang.Class v;
v = class "Loadd/org/apache/zookeeper/server/DataTree;";
v = virtualinvoke v.<java.lang.Class: boolean desiredAssertionStatus()>();
if v != 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
<oadd.org.apache.zookeeper.server.DataTree: boolean $assertionsDisabled> = v;
v = staticinvoke <org.slf4j.LoggerFactory: org.slf4j.Logger getLogger(java.lang.Class)>(class "Loadd/org/apache/zookeeper/server/DataTree;");
<oadd.org.apache.zookeeper.server.DataTree: org.slf4j.Logger LOG> = v;
v = "/zookeeper";
v = virtualinvoke v.<java.lang.String: java.lang.String substring(int)>(1);
<oadd.org.apache.zookeeper.server.DataTree: java.lang.String procChildZookeeper> = v;
v = "/zookeeper/quota";
v = "/zookeeper";
v = virtualinvoke v.<java.lang.String: int length()>();
v = v + 1;
v = virtualinvoke v.<java.lang.String: java.lang.String substring(int)>(v);
<oadd.org.apache.zookeeper.server.DataTree: java.lang.String quotaChildZookeeper> = v;
v = "/zookeeper/config";
v = "/zookeeper";
v = virtualinvoke v.<java.lang.String: int length()>();
v = v + 1;
v = virtualinvoke v.<java.lang.String: java.lang.String substring(int)>(v);
<oadd.org.apache.zookeeper.server.DataTree: java.lang.String configChildZookeeper> = v;
return;
}
}