class oadd.org.apache.curator.framework.recipes.cache.CuratorCacheImpl extends java.lang.Object implements oadd.org.apache.curator.framework.recipes.cache.CuratorCache, oadd.org.apache.curator.framework.recipes.cache.CuratorCacheBridge
{
private final org.slf4j.Logger log;
private final java.util.concurrent.atomic.AtomicReference state;
private final oadd.org.apache.curator.framework.recipes.watch.PersistentWatcher persistentWatcher;
private final oadd.org.apache.curator.framework.CuratorFramework client;
private final oadd.org.apache.curator.framework.recipes.cache.CuratorCacheStorage storage;
private final java.lang.String path;
private final boolean recursive;
private final boolean compressedData;
private final boolean clearOnClose;
private final oadd.org.apache.curator.framework.listen.StandardListenerManager listenerManager;
private final java.util.function.Consumer exceptionHandler;
private final oadd.org.apache.curator.framework.recipes.cache.OutstandingOps outstandingOps;
void <init>(oadd.org.apache.curator.framework.CuratorFramework, oadd.org.apache.curator.framework.recipes.cache.CuratorCacheStorage, java.lang.String, oadd.org.apache.curator.framework.recipes.cache.CuratorCache$Options[], java.util.function.Consumer)
{
oadd.org.apache.curator.framework.recipes.cache.OutstandingOps v;
oadd.org.apache.curator.framework.listen.StandardListenerManager v;
java.lang.Runnable v, v;
oadd.org.apache.zookeeper.Watcher v;
boolean v, v, v, v, v, v;
oadd.org.apache.curator.framework.listen.Listenable v, v;
oadd.org.apache.curator.framework.recipes.cache.CuratorCache$Options[] v;
oadd.org.apache.curator.framework.recipes.cache.CuratorCacheImpl v;
java.util.Set v, v;
oadd.org.apache.curator.framework.CuratorFramework v;
oadd.org.apache.curator.framework.recipes.cache.CuratorCacheImpl$State v;
oadd.org.apache.curator.framework.recipes.watch.PersistentWatcher v, v, v;
oadd.org.apache.curator.framework.recipes.cache.CuratorCacheStorage v, v;
java.util.concurrent.atomic.AtomicReference v;
oadd.org.apache.curator.framework.recipes.cache.CuratorCache$Options v, v, v;
java.lang.String v;
org.slf4j.Logger v;
java.util.function.Consumer v, v;
java.lang.Class v;
v := @this: oadd.org.apache.curator.framework.recipes.cache.CuratorCacheImpl;
v := @parameter: oadd.org.apache.curator.framework.CuratorFramework;
v := @parameter: oadd.org.apache.curator.framework.recipes.cache.CuratorCacheStorage;
v := @parameter: java.lang.String;
v := @parameter: oadd.org.apache.curator.framework.recipes.cache.CuratorCache$Options[];
v := @parameter: java.util.function.Consumer;
specialinvoke v.<java.lang.Object: void <init>()>();
v = virtualinvoke v.<java.lang.Object: java.lang.Class getClass()>();
v = staticinvoke <org.slf4j.LoggerFactory: org.slf4j.Logger getLogger(java.lang.Class)>(v);
v.<oadd.org.apache.curator.framework.recipes.cache.CuratorCacheImpl: org.slf4j.Logger log> = v;
v = new java.util.concurrent.atomic.AtomicReference;
v = <oadd.org.apache.curator.framework.recipes.cache.CuratorCacheImpl$State: oadd.org.apache.curator.framework.recipes.cache.CuratorCacheImpl$State LATENT>;
specialinvoke v.<java.util.concurrent.atomic.AtomicReference: void <init>(java.lang.Object)>(v);
v.<oadd.org.apache.curator.framework.recipes.cache.CuratorCacheImpl: java.util.concurrent.atomic.AtomicReference state> = v;
v = staticinvoke <oadd.org.apache.curator.framework.listen.StandardListenerManager: oadd.org.apache.curator.framework.listen.StandardListenerManager standard()>();
v.<oadd.org.apache.curator.framework.recipes.cache.CuratorCacheImpl: oadd.org.apache.curator.framework.listen.StandardListenerManager listenerManager> = v;
v = new oadd.org.apache.curator.framework.recipes.cache.OutstandingOps;
v = staticinvoke <oadd.org.apache.curator.framework.recipes.cache.CuratorCacheImpl$lambda_new_0__1007: java.lang.Runnable bootstrap$(oadd.org.apache.curator.framework.recipes.cache.CuratorCacheImpl)>(v);
specialinvoke v.<oadd.org.apache.curator.framework.recipes.cache.OutstandingOps: void <init>(java.lang.Runnable)>(v);
v.<oadd.org.apache.curator.framework.recipes.cache.CuratorCacheImpl: oadd.org.apache.curator.framework.recipes.cache.OutstandingOps outstandingOps> = v;
if v == null goto label;
v = staticinvoke <oadd.org.apache.curator.shaded.com.google.common.collect.Sets: java.util.HashSet newHashSet(java.lang.Object[])>(v);
goto label;
label:
v = staticinvoke <java.util.Collections: java.util.Set emptySet()>();
label:
v = v;
v.<oadd.org.apache.curator.framework.recipes.cache.CuratorCacheImpl: oadd.org.apache.curator.framework.CuratorFramework client> = v;
if v == null goto label;
v = v;
goto label;
label:
v = staticinvoke <oadd.org.apache.curator.framework.recipes.cache.CuratorCacheStorage: oadd.org.apache.curator.framework.recipes.cache.CuratorCacheStorage standard()>();
label:
v.<oadd.org.apache.curator.framework.recipes.cache.CuratorCacheImpl: oadd.org.apache.curator.framework.recipes.cache.CuratorCacheStorage storage> = v;
v.<oadd.org.apache.curator.framework.recipes.cache.CuratorCacheImpl: java.lang.String path> = v;
v = <oadd.org.apache.curator.framework.recipes.cache.CuratorCache$Options: oadd.org.apache.curator.framework.recipes.cache.CuratorCache$Options SINGLE_NODE_CACHE>;
v = interfaceinvoke v.<java.util.Set: boolean contains(java.lang.Object)>(v);
if v != 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
v.<oadd.org.apache.curator.framework.recipes.cache.CuratorCacheImpl: boolean recursive> = v;
v = <oadd.org.apache.curator.framework.recipes.cache.CuratorCache$Options: oadd.org.apache.curator.framework.recipes.cache.CuratorCache$Options COMPRESSED_DATA>;
v = interfaceinvoke v.<java.util.Set: boolean contains(java.lang.Object)>(v);
v.<oadd.org.apache.curator.framework.recipes.cache.CuratorCacheImpl: boolean compressedData> = v;
v = <oadd.org.apache.curator.framework.recipes.cache.CuratorCache$Options: oadd.org.apache.curator.framework.recipes.cache.CuratorCache$Options DO_NOT_CLEAR_ON_CLOSE>;
v = interfaceinvoke v.<java.util.Set: boolean contains(java.lang.Object)>(v);
if v != 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
v.<oadd.org.apache.curator.framework.recipes.cache.CuratorCacheImpl: boolean clearOnClose> = v;
v = new oadd.org.apache.curator.framework.recipes.watch.PersistentWatcher;
v = v.<oadd.org.apache.curator.framework.recipes.cache.CuratorCacheImpl: boolean recursive>;
specialinvoke v.<oadd.org.apache.curator.framework.recipes.watch.PersistentWatcher: void <init>(oadd.org.apache.curator.framework.CuratorFramework,java.lang.String,boolean)>(v, v, v);
v.<oadd.org.apache.curator.framework.recipes.cache.CuratorCacheImpl: oadd.org.apache.curator.framework.recipes.watch.PersistentWatcher persistentWatcher> = v;
v = v.<oadd.org.apache.curator.framework.recipes.cache.CuratorCacheImpl: oadd.org.apache.curator.framework.recipes.watch.PersistentWatcher persistentWatcher>;
v = virtualinvoke v.<oadd.org.apache.curator.framework.recipes.watch.PersistentWatcher: oadd.org.apache.curator.framework.listen.Listenable getListenable()>();
v = staticinvoke <oadd.org.apache.curator.framework.recipes.cache.CuratorCacheImpl$processEvent__1008: oadd.org.apache.zookeeper.Watcher bootstrap$(oadd.org.apache.curator.framework.recipes.cache.CuratorCacheImpl)>(v);
interfaceinvoke v.<oadd.org.apache.curator.framework.listen.Listenable: void addListener(java.lang.Object)>(v);
v = v.<oadd.org.apache.curator.framework.recipes.cache.CuratorCacheImpl: oadd.org.apache.curator.framework.recipes.watch.PersistentWatcher persistentWatcher>;
v = virtualinvoke v.<oadd.org.apache.curator.framework.recipes.watch.PersistentWatcher: oadd.org.apache.curator.framework.listen.Listenable getResetListenable()>();
v = staticinvoke <oadd.org.apache.curator.framework.recipes.cache.CuratorCacheImpl$rebuild__1009: java.lang.Runnable bootstrap$(oadd.org.apache.curator.framework.recipes.cache.CuratorCacheImpl)>(v);
interfaceinvoke v.<oadd.org.apache.curator.framework.listen.Listenable: void addListener(java.lang.Object)>(v);
if v == null goto label;
v = v;
goto label;
label:
v = staticinvoke <oadd.org.apache.curator.framework.recipes.cache.CuratorCacheImpl$lambda_new_1__1010: java.util.function.Consumer bootstrap$(oadd.org.apache.curator.framework.recipes.cache.CuratorCacheImpl)>(v);
label:
v.<oadd.org.apache.curator.framework.recipes.cache.CuratorCacheImpl: java.util.function.Consumer exceptionHandler> = v;
return;
}
public void start()
{
oadd.org.apache.curator.framework.recipes.watch.PersistentWatcher v;
oadd.org.apache.curator.framework.recipes.cache.CuratorCacheImpl v;
oadd.org.apache.curator.framework.recipes.cache.CuratorCacheImpl$State v, v;
java.util.concurrent.atomic.AtomicReference v;
boolean v;
v := @this: oadd.org.apache.curator.framework.recipes.cache.CuratorCacheImpl;
v = v.<oadd.org.apache.curator.framework.recipes.cache.CuratorCacheImpl: java.util.concurrent.atomic.AtomicReference state>;
v = <oadd.org.apache.curator.framework.recipes.cache.CuratorCacheImpl$State: oadd.org.apache.curator.framework.recipes.cache.CuratorCacheImpl$State LATENT>;
v = <oadd.org.apache.curator.framework.recipes.cache.CuratorCacheImpl$State: oadd.org.apache.curator.framework.recipes.cache.CuratorCacheImpl$State STARTED>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicReference: boolean compareAndSet(java.lang.Object,java.lang.Object)>(v, v);
staticinvoke <oadd.org.apache.curator.shaded.com.google.common.base.Preconditions: void checkState(boolean,java.lang.Object)>(v, "Already started");
v = v.<oadd.org.apache.curator.framework.recipes.cache.CuratorCacheImpl: oadd.org.apache.curator.framework.recipes.watch.PersistentWatcher persistentWatcher>;
virtualinvoke v.<oadd.org.apache.curator.framework.recipes.watch.PersistentWatcher: void start()>();
return;
}
public void close()
{
oadd.org.apache.curator.framework.recipes.cache.CuratorCacheImpl v;
oadd.org.apache.curator.framework.recipes.cache.CuratorCacheImpl$State v, v;
java.util.concurrent.atomic.AtomicReference v;
oadd.org.apache.curator.framework.recipes.watch.PersistentWatcher v;
oadd.org.apache.curator.framework.recipes.cache.CuratorCacheStorage v;
boolean v, v;
v := @this: oadd.org.apache.curator.framework.recipes.cache.CuratorCacheImpl;
v = v.<oadd.org.apache.curator.framework.recipes.cache.CuratorCacheImpl: java.util.concurrent.atomic.AtomicReference state>;
v = <oadd.org.apache.curator.framework.recipes.cache.CuratorCacheImpl$State: oadd.org.apache.curator.framework.recipes.cache.CuratorCacheImpl$State STARTED>;
v = <oadd.org.apache.curator.framework.recipes.cache.CuratorCacheImpl$State: oadd.org.apache.curator.framework.recipes.cache.CuratorCacheImpl$State CLOSED>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicReference: boolean compareAndSet(java.lang.Object,java.lang.Object)>(v, v);
if v == 0 goto label;
v = v.<oadd.org.apache.curator.framework.recipes.cache.CuratorCacheImpl: oadd.org.apache.curator.framework.recipes.watch.PersistentWatcher persistentWatcher>;
virtualinvoke v.<oadd.org.apache.curator.framework.recipes.watch.PersistentWatcher: void close()>();
v = v.<oadd.org.apache.curator.framework.recipes.cache.CuratorCacheImpl: boolean clearOnClose>;
if v == 0 goto label;
v = v.<oadd.org.apache.curator.framework.recipes.cache.CuratorCacheImpl: oadd.org.apache.curator.framework.recipes.cache.CuratorCacheStorage storage>;
interfaceinvoke v.<oadd.org.apache.curator.framework.recipes.cache.CuratorCacheStorage: void clear()>();
label:
return;
}
public boolean isCuratorCache()
{
oadd.org.apache.curator.framework.recipes.cache.CuratorCacheImpl v;
v := @this: oadd.org.apache.curator.framework.recipes.cache.CuratorCacheImpl;
return 1;
}
public oadd.org.apache.curator.framework.listen.Listenable listenable()
{
oadd.org.apache.curator.framework.listen.StandardListenerManager v;
oadd.org.apache.curator.framework.recipes.cache.CuratorCacheImpl v;
v := @this: oadd.org.apache.curator.framework.recipes.cache.CuratorCacheImpl;
v = v.<oadd.org.apache.curator.framework.recipes.cache.CuratorCacheImpl: oadd.org.apache.curator.framework.listen.StandardListenerManager listenerManager>;
return v;
}
public java.util.Optional get(java.lang.String)
{
oadd.org.apache.curator.framework.recipes.cache.CuratorCacheStorage v;
oadd.org.apache.curator.framework.recipes.cache.CuratorCacheImpl v;
java.util.Optional v;
java.lang.String v;
v := @this: oadd.org.apache.curator.framework.recipes.cache.CuratorCacheImpl;
v := @parameter: java.lang.String;
v = v.<oadd.org.apache.curator.framework.recipes.cache.CuratorCacheImpl: oadd.org.apache.curator.framework.recipes.cache.CuratorCacheStorage storage>;
v = interfaceinvoke v.<oadd.org.apache.curator.framework.recipes.cache.CuratorCacheStorage: java.util.Optional get(java.lang.String)>(v);
return v;
}
public int size()
{
int v;
oadd.org.apache.curator.framework.recipes.cache.CuratorCacheStorage v;
oadd.org.apache.curator.framework.recipes.cache.CuratorCacheImpl v;
v := @this: oadd.org.apache.curator.framework.recipes.cache.CuratorCacheImpl;
v = v.<oadd.org.apache.curator.framework.recipes.cache.CuratorCacheImpl: oadd.org.apache.curator.framework.recipes.cache.CuratorCacheStorage storage>;
v = interfaceinvoke v.<oadd.org.apache.curator.framework.recipes.cache.CuratorCacheStorage: int size()>();
return v;
}
public java.util.stream.Stream stream()
{
java.util.stream.Stream v;
oadd.org.apache.curator.framework.recipes.cache.CuratorCacheStorage v;
oadd.org.apache.curator.framework.recipes.cache.CuratorCacheImpl v;
v := @this: oadd.org.apache.curator.framework.recipes.cache.CuratorCacheImpl;
v = v.<oadd.org.apache.curator.framework.recipes.cache.CuratorCacheImpl: oadd.org.apache.curator.framework.recipes.cache.CuratorCacheStorage storage>;
v = interfaceinvoke v.<oadd.org.apache.curator.framework.recipes.cache.CuratorCacheStorage: java.util.stream.Stream stream()>();
return v;
}
oadd.org.apache.curator.framework.recipes.cache.CuratorCacheStorage storage()
{
oadd.org.apache.curator.framework.recipes.cache.CuratorCacheStorage v;
oadd.org.apache.curator.framework.recipes.cache.CuratorCacheImpl v;
v := @this: oadd.org.apache.curator.framework.recipes.cache.CuratorCacheImpl;
v = v.<oadd.org.apache.curator.framework.recipes.cache.CuratorCacheImpl: oadd.org.apache.curator.framework.recipes.cache.CuratorCacheStorage storage>;
return v;
}
public void rebuild()
{
java.util.function.Predicate v;
oadd.org.apache.curator.framework.recipes.cache.CuratorCacheImpl v;
oadd.org.apache.curator.framework.recipes.cache.CuratorCacheImpl$State v;
java.util.concurrent.atomic.AtomicReference v;
java.util.function.Function v;
java.util.function.Consumer v;
java.util.stream.Stream v, v, v;
oadd.org.apache.curator.framework.recipes.cache.CuratorCacheStorage v;
java.lang.Object v;
java.lang.String v;
v := @this: oadd.org.apache.curator.framework.recipes.cache.CuratorCacheImpl;
v = v.<oadd.org.apache.curator.framework.recipes.cache.CuratorCacheImpl: java.util.concurrent.atomic.AtomicReference state>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicReference: java.lang.Object get()>();
v = <oadd.org.apache.curator.framework.recipes.cache.CuratorCacheImpl$State: oadd.org.apache.curator.framework.recipes.cache.CuratorCacheImpl$State STARTED>;
if v == v goto label;
return;
label:
v = v.<oadd.org.apache.curator.framework.recipes.cache.CuratorCacheImpl: java.lang.String path>;
specialinvoke v.<oadd.org.apache.curator.framework.recipes.cache.CuratorCacheImpl: void nodeChanged(java.lang.String)>(v);
v = v.<oadd.org.apache.curator.framework.recipes.cache.CuratorCacheImpl: oadd.org.apache.curator.framework.recipes.cache.CuratorCacheStorage storage>;
v = interfaceinvoke v.<oadd.org.apache.curator.framework.recipes.cache.CuratorCacheStorage: java.util.stream.Stream stream()>();
v = staticinvoke <oadd.org.apache.curator.framework.recipes.cache.CuratorCacheImpl$getPath__1011: java.util.function.Function bootstrap$()>();
v = interfaceinvoke v.<java.util.stream.Stream: java.util.stream.Stream map(java.util.function.Function)>(v);
v = staticinvoke <oadd.org.apache.curator.framework.recipes.cache.CuratorCacheImpl$lambda_rebuild_2__1012: java.util.function.Predicate bootstrap$(oadd.org.apache.curator.framework.recipes.cache.CuratorCacheImpl)>(v);
v = interfaceinvoke v.<java.util.stream.Stream: java.util.stream.Stream filter(java.util.function.Predicate)>(v);
v = staticinvoke <oadd.org.apache.curator.framework.recipes.cache.CuratorCacheImpl$nodeChanged__1013: java.util.function.Consumer bootstrap$(oadd.org.apache.curator.framework.recipes.cache.CuratorCacheImpl)>(v);
interfaceinvoke v.<java.util.stream.Stream: void forEach(java.util.function.Consumer)>(v);
return;
}
public void processEvent(oadd.org.apache.zookeeper.WatchedEvent)
{
oadd.org.apache.curator.framework.recipes.cache.CuratorCacheImpl v;
oadd.org.apache.zookeeper.WatchedEvent v;
oadd.org.apache.curator.framework.recipes.cache.CuratorCacheImpl$State v;
java.util.concurrent.atomic.AtomicReference v;
int[] v;
int v, v;
java.lang.Object v;
java.lang.String v, v;
oadd.org.apache.zookeeper.Watcher$Event$EventType v;
v := @this: oadd.org.apache.curator.framework.recipes.cache.CuratorCacheImpl;
v := @parameter: oadd.org.apache.zookeeper.WatchedEvent;
v = v.<oadd.org.apache.curator.framework.recipes.cache.CuratorCacheImpl: java.util.concurrent.atomic.AtomicReference state>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicReference: java.lang.Object get()>();
v = <oadd.org.apache.curator.framework.recipes.cache.CuratorCacheImpl$State: oadd.org.apache.curator.framework.recipes.cache.CuratorCacheImpl$State STARTED>;
if v == v goto label;
return;
label:
v = <oadd.org.apache.curator.framework.recipes.cache.CuratorCacheImpl$1: int[] $SwitchMap$org$apache$zookeeper$Watcher$Event$EventType>;
v = virtualinvoke v.<oadd.org.apache.zookeeper.WatchedEvent: oadd.org.apache.zookeeper.Watcher$Event$EventType getType()>();
v = virtualinvoke v.<oadd.org.apache.zookeeper.Watcher$Event$EventType: int ordinal()>();
v = v[v];
tableswitch(v)
{
case 1: goto label;
case 2: goto label;
case 3: goto label;
default: goto label;
};
label:
v = virtualinvoke v.<oadd.org.apache.zookeeper.WatchedEvent: java.lang.String getPath()>();
specialinvoke v.<oadd.org.apache.curator.framework.recipes.cache.CuratorCacheImpl: void nodeChanged(java.lang.String)>(v);
goto label;
label:
v = virtualinvoke v.<oadd.org.apache.zookeeper.WatchedEvent: java.lang.String getPath()>();
specialinvoke v.<oadd.org.apache.curator.framework.recipes.cache.CuratorCacheImpl: void removeStorage(java.lang.String)>(v);
label:
return;
}
private void checkChildrenChanged(java.lang.String, oadd.org.apache.zookeeper.data.Stat, oadd.org.apache.zookeeper.data.Stat)
{
oadd.org.apache.curator.framework.recipes.cache.OutstandingOps v;
java.util.concurrent.atomic.AtomicReference v;
oadd.org.apache.curator.framework.api.GetChildrenBuilder v;
oadd.org.apache.curator.framework.api.BackgroundCallback v;
int v, v;
java.lang.String v;
oadd.org.apache.zookeeper.data.Stat v, v;
boolean v;
oadd.org.apache.curator.framework.recipes.cache.CuratorCacheImpl v;
oadd.org.apache.curator.framework.CuratorFramework v;
oadd.org.apache.curator.framework.recipes.cache.CuratorCacheImpl$State v;
java.lang.Exception v;
java.lang.Object v, v;
v := @this: oadd.org.apache.curator.framework.recipes.cache.CuratorCacheImpl;
v := @parameter: java.lang.String;
v := @parameter: oadd.org.apache.zookeeper.data.Stat;
v := @parameter: oadd.org.apache.zookeeper.data.Stat;
v = v.<oadd.org.apache.curator.framework.recipes.cache.CuratorCacheImpl: java.util.concurrent.atomic.AtomicReference state>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicReference: java.lang.Object get()>();
v = <oadd.org.apache.curator.framework.recipes.cache.CuratorCacheImpl$State: oadd.org.apache.curator.framework.recipes.cache.CuratorCacheImpl$State STARTED>;
if v != v goto label;
v = v.<oadd.org.apache.curator.framework.recipes.cache.CuratorCacheImpl: boolean recursive>;
if v != 0 goto label;
label:
return;
label:
if v == null goto label;
v = virtualinvoke v.<oadd.org.apache.zookeeper.data.Stat: int getCversion()>();
v = virtualinvoke v.<oadd.org.apache.zookeeper.data.Stat: int getCversion()>();
if v != v goto label;
return;
label:
v = staticinvoke <oadd.org.apache.curator.framework.recipes.cache.CuratorCacheImpl$lambda_checkChildrenChanged_4__1014: oadd.org.apache.curator.framework.api.BackgroundCallback bootstrap$(oadd.org.apache.curator.framework.recipes.cache.CuratorCacheImpl,java.lang.String)>(v, v);
v = v.<oadd.org.apache.curator.framework.recipes.cache.CuratorCacheImpl: oadd.org.apache.curator.framework.recipes.cache.OutstandingOps outstandingOps>;
virtualinvoke v.<oadd.org.apache.curator.framework.recipes.cache.OutstandingOps: void increment()>();
v = v.<oadd.org.apache.curator.framework.recipes.cache.CuratorCacheImpl: oadd.org.apache.curator.framework.CuratorFramework client>;
v = interfaceinvoke v.<oadd.org.apache.curator.framework.CuratorFramework: oadd.org.apache.curator.framework.api.GetChildrenBuilder getChildren()>();
v = interfaceinvoke v.<oadd.org.apache.curator.framework.api.GetChildrenBuilder: java.lang.Object inBackground(oadd.org.apache.curator.framework.api.BackgroundCallback)>(v);
interfaceinvoke v.<oadd.org.apache.curator.framework.api.ErrorListenerPathable: java.lang.Object forPath(java.lang.String)>(v);
label:
goto label;
label:
v := @caughtexception;
specialinvoke v.<oadd.org.apache.curator.framework.recipes.cache.CuratorCacheImpl: void handleException(java.lang.Exception)>(v);
label:
return;
catch java.lang.Exception from label to label with label;
}
public void nodeChanged(java.lang.String)
{
oadd.org.apache.curator.framework.recipes.cache.OutstandingOps v;
oadd.org.apache.curator.framework.api.GetDataBuilder v, v;
java.util.concurrent.atomic.AtomicReference v;
oadd.org.apache.curator.framework.api.BackgroundCallback v;
java.lang.String v;
boolean v;
oadd.org.apache.curator.framework.recipes.cache.CuratorCacheImpl v;
oadd.org.apache.curator.framework.CuratorFramework v, v;
oadd.org.apache.curator.framework.recipes.cache.CuratorCacheImpl$State v;
java.lang.Exception v;
java.lang.Object v, v, v, v;
v := @this: oadd.org.apache.curator.framework.recipes.cache.CuratorCacheImpl;
v := @parameter: java.lang.String;
v = v.<oadd.org.apache.curator.framework.recipes.cache.CuratorCacheImpl: java.util.concurrent.atomic.AtomicReference state>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicReference: java.lang.Object get()>();
v = <oadd.org.apache.curator.framework.recipes.cache.CuratorCacheImpl$State: oadd.org.apache.curator.framework.recipes.cache.CuratorCacheImpl$State STARTED>;
if v == v goto label;
return;
label:
v = staticinvoke <oadd.org.apache.curator.framework.recipes.cache.CuratorCacheImpl$lambda_nodeChanged_5__1015: oadd.org.apache.curator.framework.api.BackgroundCallback bootstrap$(oadd.org.apache.curator.framework.recipes.cache.CuratorCacheImpl)>(v);
v = v.<oadd.org.apache.curator.framework.recipes.cache.CuratorCacheImpl: oadd.org.apache.curator.framework.recipes.cache.OutstandingOps outstandingOps>;
virtualinvoke v.<oadd.org.apache.curator.framework.recipes.cache.OutstandingOps: void increment()>();
v = v.<oadd.org.apache.curator.framework.recipes.cache.CuratorCacheImpl: boolean compressedData>;
if v == 0 goto label;
v = v.<oadd.org.apache.curator.framework.recipes.cache.CuratorCacheImpl: oadd.org.apache.curator.framework.CuratorFramework client>;
v = interfaceinvoke v.<oadd.org.apache.curator.framework.CuratorFramework: oadd.org.apache.curator.framework.api.GetDataBuilder getData()>();
v = interfaceinvoke v.<oadd.org.apache.curator.framework.api.GetDataBuilder: java.lang.Object decompressed()>();
v = interfaceinvoke v.<oadd.org.apache.curator.framework.api.GetDataWatchBackgroundStatable: java.lang.Object inBackground(oadd.org.apache.curator.framework.api.BackgroundCallback)>(v);
interfaceinvoke v.<oadd.org.apache.curator.framework.api.ErrorListenerPathable: java.lang.Object forPath(java.lang.String)>(v);
goto label;
label:
v = v.<oadd.org.apache.curator.framework.recipes.cache.CuratorCacheImpl: oadd.org.apache.curator.framework.CuratorFramework client>;
v = interfaceinvoke v.<oadd.org.apache.curator.framework.CuratorFramework: oadd.org.apache.curator.framework.api.GetDataBuilder getData()>();
v = interfaceinvoke v.<oadd.org.apache.curator.framework.api.GetDataBuilder: java.lang.Object inBackground(oadd.org.apache.curator.framework.api.BackgroundCallback)>(v);
interfaceinvoke v.<oadd.org.apache.curator.framework.api.ErrorListenerPathable: java.lang.Object forPath(java.lang.String)>(v);
label:
goto label;
label:
v := @caughtexception;
specialinvoke v.<oadd.org.apache.curator.framework.recipes.cache.CuratorCacheImpl: void handleException(java.lang.Exception)>(v);
label:
return;
catch java.lang.Exception from label to label with label;
}
private java.util.Optional putStorage(oadd.org.apache.curator.framework.recipes.cache.ChildData)
{
oadd.org.apache.curator.framework.recipes.cache.CuratorCacheImpl v;
oadd.org.apache.curator.framework.recipes.cache.ChildData v;
java.util.function.Consumer v, v;
oadd.org.apache.curator.framework.recipes.cache.CuratorCacheStorage v;
int v, v;
java.util.Optional v;
java.lang.Object v;
oadd.org.apache.zookeeper.data.Stat v, v;
boolean v;
v := @this: oadd.org.apache.curator.framework.recipes.cache.CuratorCacheImpl;
v := @parameter: oadd.org.apache.curator.framework.recipes.cache.ChildData;
v = v.<oadd.org.apache.curator.framework.recipes.cache.CuratorCacheImpl: oadd.org.apache.curator.framework.recipes.cache.CuratorCacheStorage storage>;
v = interfaceinvoke v.<oadd.org.apache.curator.framework.recipes.cache.CuratorCacheStorage: java.util.Optional put(oadd.org.apache.curator.framework.recipes.cache.ChildData)>(v);
v = virtualinvoke v.<java.util.Optional: boolean isPresent()>();
if v == 0 goto label;
v = virtualinvoke v.<java.util.Optional: java.lang.Object get()>();
v = virtualinvoke v.<oadd.org.apache.curator.framework.recipes.cache.ChildData: oadd.org.apache.zookeeper.data.Stat getStat()>();
v = virtualinvoke v.<oadd.org.apache.zookeeper.data.Stat: int getVersion()>();
v = virtualinvoke v.<oadd.org.apache.curator.framework.recipes.cache.ChildData: oadd.org.apache.zookeeper.data.Stat getStat()>();
v = virtualinvoke v.<oadd.org.apache.zookeeper.data.Stat: int getVersion()>();
if v == v goto label;
v = staticinvoke <oadd.org.apache.curator.framework.recipes.cache.CuratorCacheImpl$lambda_putStorage_6__1017: java.util.function.Consumer bootstrap$(java.util.Optional,oadd.org.apache.curator.framework.recipes.cache.ChildData)>(v, v);
specialinvoke v.<oadd.org.apache.curator.framework.recipes.cache.CuratorCacheImpl: void callListeners(java.util.function.Consumer)>(v);
goto label;
label:
v = staticinvoke <oadd.org.apache.curator.framework.recipes.cache.CuratorCacheImpl$lambda_putStorage_7__1016: java.util.function.Consumer bootstrap$(oadd.org.apache.curator.framework.recipes.cache.ChildData)>(v);
specialinvoke v.<oadd.org.apache.curator.framework.recipes.cache.CuratorCacheImpl: void callListeners(java.util.function.Consumer)>(v);
label:
return v;
}
private void removeStorage(java.lang.String)
{
java.util.function.Consumer v;
oadd.org.apache.curator.framework.recipes.cache.CuratorCacheStorage v;
oadd.org.apache.curator.framework.recipes.cache.CuratorCacheImpl v;
java.util.Optional v;
java.lang.String v;
v := @this: oadd.org.apache.curator.framework.recipes.cache.CuratorCacheImpl;
v := @parameter: java.lang.String;
v = v.<oadd.org.apache.curator.framework.recipes.cache.CuratorCacheImpl: oadd.org.apache.curator.framework.recipes.cache.CuratorCacheStorage storage>;
v = interfaceinvoke v.<oadd.org.apache.curator.framework.recipes.cache.CuratorCacheStorage: java.util.Optional remove(java.lang.String)>(v);
v = staticinvoke <oadd.org.apache.curator.framework.recipes.cache.CuratorCacheImpl$lambda_removeStorage_9__1018: java.util.function.Consumer bootstrap$(oadd.org.apache.curator.framework.recipes.cache.CuratorCacheImpl)>(v);
virtualinvoke v.<java.util.Optional: void ifPresent(java.util.function.Consumer)>(v);
return;
}
private void callListeners(java.util.function.Consumer)
{
java.util.function.Consumer v;
oadd.org.apache.curator.framework.recipes.cache.CuratorCacheImpl v;
java.lang.Object v;
oadd.org.apache.curator.framework.CuratorFramework v;
oadd.org.apache.curator.framework.recipes.cache.CuratorCacheImpl$State v;
java.lang.Runnable v;
java.util.concurrent.atomic.AtomicReference v;
v := @this: oadd.org.apache.curator.framework.recipes.cache.CuratorCacheImpl;
v := @parameter: java.util.function.Consumer;
v = v.<oadd.org.apache.curator.framework.recipes.cache.CuratorCacheImpl: java.util.concurrent.atomic.AtomicReference state>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicReference: java.lang.Object get()>();
v = <oadd.org.apache.curator.framework.recipes.cache.CuratorCacheImpl$State: oadd.org.apache.curator.framework.recipes.cache.CuratorCacheImpl$State STARTED>;
if v != v goto label;
v = v.<oadd.org.apache.curator.framework.recipes.cache.CuratorCacheImpl: oadd.org.apache.curator.framework.CuratorFramework client>;
v = staticinvoke <oadd.org.apache.curator.framework.recipes.cache.CuratorCacheImpl$lambda_callListeners_10__1019: java.lang.Runnable bootstrap$(oadd.org.apache.curator.framework.recipes.cache.CuratorCacheImpl,java.util.function.Consumer)>(v, v);
interfaceinvoke v.<oadd.org.apache.curator.framework.CuratorFramework: java.util.concurrent.CompletableFuture runSafe(java.lang.Runnable)>(v);
label:
return;
}
private void handleException(oadd.org.apache.curator.framework.api.CuratorEvent)
{
oadd.org.apache.curator.framework.api.CuratorEvent v;
oadd.org.apache.zookeeper.KeeperException$Code v;
oadd.org.apache.curator.framework.recipes.cache.CuratorCacheImpl v;
int v;
oadd.org.apache.zookeeper.KeeperException v;
v := @this: oadd.org.apache.curator.framework.recipes.cache.CuratorCacheImpl;
v := @parameter: oadd.org.apache.curator.framework.api.CuratorEvent;
v = interfaceinvoke v.<oadd.org.apache.curator.framework.api.CuratorEvent: int getResultCode()>();
v = staticinvoke <oadd.org.apache.zookeeper.KeeperException$Code: oadd.org.apache.zookeeper.KeeperException$Code get(int)>(v);
v = staticinvoke <oadd.org.apache.zookeeper.KeeperException: oadd.org.apache.zookeeper.KeeperException create(oadd.org.apache.zookeeper.KeeperException$Code)>(v);
specialinvoke v.<oadd.org.apache.curator.framework.recipes.cache.CuratorCacheImpl: void handleException(java.lang.Exception)>(v);
return;
}
private void handleException(java.lang.Exception)
{
java.util.function.Consumer v;
java.lang.Exception v;
oadd.org.apache.curator.framework.recipes.cache.CuratorCacheImpl v;
v := @this: oadd.org.apache.curator.framework.recipes.cache.CuratorCacheImpl;
v := @parameter: java.lang.Exception;
staticinvoke <oadd.org.apache.curator.utils.ThreadUtils: boolean checkInterrupted(java.lang.Throwable)>(v);
v = v.<oadd.org.apache.curator.framework.recipes.cache.CuratorCacheImpl: java.util.function.Consumer exceptionHandler>;
interfaceinvoke v.<java.util.function.Consumer: void accept(java.lang.Object)>(v);
return;
}
}