public class oadd.org.apache.curator.x.discovery.details.ServiceCacheImpl extends java.lang.Object implements oadd.org.apache.curator.x.discovery.ServiceCache, oadd.org.apache.curator.framework.recipes.cache.PathChildrenCacheListener
{
private final oadd.org.apache.curator.framework.listen.StandardListenerManager listenerContainer;
private final oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl discovery;
private final java.util.concurrent.atomic.AtomicReference state;
private final oadd.org.apache.curator.framework.recipes.cache.CuratorCacheBridge cache;
private final java.util.concurrent.ConcurrentMap instances;
private final oadd.org.apache.curator.framework.EnsureContainers ensureContainers;
private final java.util.concurrent.CountDownLatch initializedLatch;
volatile java.util.concurrent.CountDownLatch debugStartLatch;
volatile java.util.concurrent.CountDownLatch debugStartWaitLatch;
private static java.util.concurrent.ExecutorService convertThreadFactory(java.util.concurrent.ThreadFactory)
{
java.util.concurrent.ThreadFactory v;
java.util.concurrent.ExecutorService v;
v := @parameter: java.util.concurrent.ThreadFactory;
staticinvoke <oadd.org.apache.curator.shaded.com.google.common.base.Preconditions: java.lang.Object checkNotNull(java.lang.Object,java.lang.Object)>(v, "threadFactory cannot be null");
v = staticinvoke <java.util.concurrent.Executors: java.util.concurrent.ExecutorService newSingleThreadExecutor(java.util.concurrent.ThreadFactory)>(v);
return v;
}
void <init>(oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl, java.lang.String, java.util.concurrent.ThreadFactory)
{
oadd.org.apache.curator.x.discovery.details.ServiceCacheImpl v;
oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl v;
java.lang.String v;
java.util.concurrent.ThreadFactory v;
java.util.concurrent.ExecutorService v;
v := @this: oadd.org.apache.curator.x.discovery.details.ServiceCacheImpl;
v := @parameter: oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl;
v := @parameter: java.lang.String;
v := @parameter: java.util.concurrent.ThreadFactory;
v = staticinvoke <oadd.org.apache.curator.x.discovery.details.ServiceCacheImpl: java.util.concurrent.ExecutorService convertThreadFactory(java.util.concurrent.ThreadFactory)>(v);
specialinvoke v.<oadd.org.apache.curator.x.discovery.details.ServiceCacheImpl: void <init>(oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl,java.lang.String,java.util.concurrent.ExecutorService)>(v, v, v);
return;
}
void <init>(oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl, java.lang.String, java.util.concurrent.ExecutorService)
{
oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl v;
oadd.org.apache.curator.framework.listen.StandardListenerManager v;
oadd.org.apache.curator.framework.recipes.cache.CuratorCacheBridge v, v;
java.lang.Runnable v;
java.util.concurrent.atomic.AtomicReference v;
java.util.concurrent.ConcurrentMap v;
oadd.org.apache.curator.x.discovery.details.ServiceCacheImpl v;
oadd.org.apache.curator.framework.recipes.cache.CuratorCacheListenerBuilder v, v, v;
java.lang.String v, v;
java.util.concurrent.ExecutorService v;
oadd.org.apache.curator.x.discovery.details.ServiceCacheImpl$State v;
oadd.org.apache.curator.framework.EnsureContainers v;
oadd.org.apache.curator.framework.listen.Listenable v;
oadd.org.apache.curator.framework.recipes.cache.CuratorCacheListener v;
oadd.org.apache.curator.framework.CuratorFramework v, v, v;
oadd.org.apache.curator.framework.recipes.cache.CuratorCacheBridgeBuilder v, v, v;
java.util.concurrent.CountDownLatch v;
v := @this: oadd.org.apache.curator.x.discovery.details.ServiceCacheImpl;
v := @parameter: oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl;
v := @parameter: java.lang.String;
v := @parameter: java.util.concurrent.ExecutorService;
specialinvoke v.<java.lang.Object: void <init>()>();
v = staticinvoke <oadd.org.apache.curator.framework.listen.StandardListenerManager: oadd.org.apache.curator.framework.listen.StandardListenerManager standard()>();
v.<oadd.org.apache.curator.x.discovery.details.ServiceCacheImpl: oadd.org.apache.curator.framework.listen.StandardListenerManager listenerContainer> = v;
v = new java.util.concurrent.atomic.AtomicReference;
v = <oadd.org.apache.curator.x.discovery.details.ServiceCacheImpl$State: oadd.org.apache.curator.x.discovery.details.ServiceCacheImpl$State LATENT>;
specialinvoke v.<java.util.concurrent.atomic.AtomicReference: void <init>(java.lang.Object)>(v);
v.<oadd.org.apache.curator.x.discovery.details.ServiceCacheImpl: java.util.concurrent.atomic.AtomicReference state> = v;
v = staticinvoke <oadd.org.apache.curator.shaded.com.google.common.collect.Maps: java.util.concurrent.ConcurrentMap newConcurrentMap()>();
v.<oadd.org.apache.curator.x.discovery.details.ServiceCacheImpl: java.util.concurrent.ConcurrentMap instances> = v;
v = new java.util.concurrent.CountDownLatch;
specialinvoke v.<java.util.concurrent.CountDownLatch: void <init>(int)>(1);
v.<oadd.org.apache.curator.x.discovery.details.ServiceCacheImpl: java.util.concurrent.CountDownLatch initializedLatch> = v;
v.<oadd.org.apache.curator.x.discovery.details.ServiceCacheImpl: java.util.concurrent.CountDownLatch debugStartLatch> = null;
v.<oadd.org.apache.curator.x.discovery.details.ServiceCacheImpl: java.util.concurrent.CountDownLatch debugStartWaitLatch> = null;
staticinvoke <oadd.org.apache.curator.shaded.com.google.common.base.Preconditions: java.lang.Object checkNotNull(java.lang.Object,java.lang.Object)>(v, "discovery cannot be null");
staticinvoke <oadd.org.apache.curator.shaded.com.google.common.base.Preconditions: java.lang.Object checkNotNull(java.lang.Object,java.lang.Object)>(v, "name cannot be null");
v.<oadd.org.apache.curator.x.discovery.details.ServiceCacheImpl: oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl discovery> = v;
v = virtualinvoke v.<oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl: java.lang.String pathForName(java.lang.String)>(v);
v = virtualinvoke v.<oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl: oadd.org.apache.curator.framework.CuratorFramework getClient()>();
v = staticinvoke <oadd.org.apache.curator.framework.recipes.cache.CuratorCache: oadd.org.apache.curator.framework.recipes.cache.CuratorCacheBridgeBuilder bridgeBuilder(oadd.org.apache.curator.framework.CuratorFramework,java.lang.String)>(v, v);
v = interfaceinvoke v.<oadd.org.apache.curator.framework.recipes.cache.CuratorCacheBridgeBuilder: oadd.org.apache.curator.framework.recipes.cache.CuratorCacheBridgeBuilder withExecutorService(java.util.concurrent.ExecutorService)>(v);
v = interfaceinvoke v.<oadd.org.apache.curator.framework.recipes.cache.CuratorCacheBridgeBuilder: oadd.org.apache.curator.framework.recipes.cache.CuratorCacheBridgeBuilder withDataNotCached()>();
v = interfaceinvoke v.<oadd.org.apache.curator.framework.recipes.cache.CuratorCacheBridgeBuilder: oadd.org.apache.curator.framework.recipes.cache.CuratorCacheBridge build()>();
v.<oadd.org.apache.curator.x.discovery.details.ServiceCacheImpl: oadd.org.apache.curator.framework.recipes.cache.CuratorCacheBridge cache> = v;
v = staticinvoke <oadd.org.apache.curator.framework.recipes.cache.CuratorCacheListener: oadd.org.apache.curator.framework.recipes.cache.CuratorCacheListenerBuilder builder()>();
v = virtualinvoke v.<oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl: oadd.org.apache.curator.framework.CuratorFramework getClient()>();
v = interfaceinvoke v.<oadd.org.apache.curator.framework.recipes.cache.CuratorCacheListenerBuilder: oadd.org.apache.curator.framework.recipes.cache.CuratorCacheListenerBuilder forPathChildrenCache(java.lang.String,oadd.org.apache.curator.framework.CuratorFramework,oadd.org.apache.curator.framework.recipes.cache.PathChildrenCacheListener)>(v, v, v);
v = staticinvoke <oadd.org.apache.curator.x.discovery.details.ServiceCacheImpl$initialized__1046: java.lang.Runnable bootstrap$(oadd.org.apache.curator.x.discovery.details.ServiceCacheImpl)>(v);
v = interfaceinvoke v.<oadd.org.apache.curator.framework.recipes.cache.CuratorCacheListenerBuilder: oadd.org.apache.curator.framework.recipes.cache.CuratorCacheListenerBuilder forInitialized(java.lang.Runnable)>(v);
v = interfaceinvoke v.<oadd.org.apache.curator.framework.recipes.cache.CuratorCacheListenerBuilder: oadd.org.apache.curator.framework.recipes.cache.CuratorCacheListener build()>();
v = v.<oadd.org.apache.curator.x.discovery.details.ServiceCacheImpl: oadd.org.apache.curator.framework.recipes.cache.CuratorCacheBridge cache>;
v = interfaceinvoke v.<oadd.org.apache.curator.framework.recipes.cache.CuratorCacheBridge: oadd.org.apache.curator.framework.listen.Listenable listenable()>();
interfaceinvoke v.<oadd.org.apache.curator.framework.listen.Listenable: void addListener(java.lang.Object)>(v);
v = new oadd.org.apache.curator.framework.EnsureContainers;
v = virtualinvoke v.<oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl: oadd.org.apache.curator.framework.CuratorFramework getClient()>();
specialinvoke v.<oadd.org.apache.curator.framework.EnsureContainers: void <init>(oadd.org.apache.curator.framework.CuratorFramework,java.lang.String)>(v, v);
v.<oadd.org.apache.curator.x.discovery.details.ServiceCacheImpl: oadd.org.apache.curator.framework.EnsureContainers ensureContainers> = v;
return;
}
public java.util.List getInstances()
{
oadd.org.apache.curator.x.discovery.details.ServiceCacheImpl v;
java.util.Collection v;
java.util.ArrayList v;
java.util.concurrent.ConcurrentMap v;
v := @this: oadd.org.apache.curator.x.discovery.details.ServiceCacheImpl;
v = v.<oadd.org.apache.curator.x.discovery.details.ServiceCacheImpl: java.util.concurrent.ConcurrentMap instances>;
v = interfaceinvoke v.<java.util.concurrent.ConcurrentMap: java.util.Collection values()>();
v = staticinvoke <oadd.org.apache.curator.shaded.com.google.common.collect.Lists: java.util.ArrayList newArrayList(java.lang.Iterable)>(v);
return v;
}
public void start() throws java.lang.Exception
{
oadd.org.apache.curator.x.discovery.details.ServiceCacheImpl v;
java.util.concurrent.CountDownLatch v;
v := @this: oadd.org.apache.curator.x.discovery.details.ServiceCacheImpl;
v = virtualinvoke v.<oadd.org.apache.curator.x.discovery.details.ServiceCacheImpl: java.util.concurrent.CountDownLatch startImmediate()>();
virtualinvoke v.<java.util.concurrent.CountDownLatch: void await()>();
return;
}
public java.util.concurrent.CountDownLatch startImmediate() throws java.lang.Exception
{
oadd.org.apache.curator.framework.EnsureContainers v;
oadd.org.apache.curator.framework.recipes.cache.CuratorCacheBridge v;
java.util.concurrent.atomic.AtomicReference v;
oadd.org.apache.curator.x.discovery.details.ServiceCacheImpl v;
java.util.concurrent.CountDownLatch v, v, v, v, v, v;
oadd.org.apache.curator.x.discovery.details.ServiceCacheImpl$State v, v;
boolean v;
v := @this: oadd.org.apache.curator.x.discovery.details.ServiceCacheImpl;
v = v.<oadd.org.apache.curator.x.discovery.details.ServiceCacheImpl: java.util.concurrent.atomic.AtomicReference state>;
v = <oadd.org.apache.curator.x.discovery.details.ServiceCacheImpl$State: oadd.org.apache.curator.x.discovery.details.ServiceCacheImpl$State LATENT>;
v = <oadd.org.apache.curator.x.discovery.details.ServiceCacheImpl$State: oadd.org.apache.curator.x.discovery.details.ServiceCacheImpl$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, "Cannot be started more than once");
v = v.<oadd.org.apache.curator.x.discovery.details.ServiceCacheImpl: oadd.org.apache.curator.framework.EnsureContainers ensureContainers>;
virtualinvoke v.<oadd.org.apache.curator.framework.EnsureContainers: void ensure()>();
v = v.<oadd.org.apache.curator.x.discovery.details.ServiceCacheImpl: oadd.org.apache.curator.framework.recipes.cache.CuratorCacheBridge cache>;
interfaceinvoke v.<oadd.org.apache.curator.framework.recipes.cache.CuratorCacheBridge: void start()>();
v = v.<oadd.org.apache.curator.x.discovery.details.ServiceCacheImpl: java.util.concurrent.CountDownLatch debugStartLatch>;
if v == null goto label;
v = v.<oadd.org.apache.curator.x.discovery.details.ServiceCacheImpl: java.util.concurrent.CountDownLatch initializedLatch>;
virtualinvoke v.<java.util.concurrent.CountDownLatch: void await()>();
v = v.<oadd.org.apache.curator.x.discovery.details.ServiceCacheImpl: java.util.concurrent.CountDownLatch debugStartLatch>;
virtualinvoke v.<java.util.concurrent.CountDownLatch: void countDown()>();
v.<oadd.org.apache.curator.x.discovery.details.ServiceCacheImpl: java.util.concurrent.CountDownLatch debugStartLatch> = null;
label:
v = v.<oadd.org.apache.curator.x.discovery.details.ServiceCacheImpl: java.util.concurrent.CountDownLatch debugStartWaitLatch>;
if v == null goto label;
v = v.<oadd.org.apache.curator.x.discovery.details.ServiceCacheImpl: java.util.concurrent.CountDownLatch debugStartWaitLatch>;
virtualinvoke v.<java.util.concurrent.CountDownLatch: void await()>();
v.<oadd.org.apache.curator.x.discovery.details.ServiceCacheImpl: java.util.concurrent.CountDownLatch debugStartWaitLatch> = null;
label:
v = v.<oadd.org.apache.curator.x.discovery.details.ServiceCacheImpl: java.util.concurrent.CountDownLatch initializedLatch>;
return v;
}
public void close()
{
oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl v;
oadd.org.apache.curator.framework.listen.StandardListenerManager v, v;
oadd.org.apache.curator.framework.recipes.cache.CuratorCacheBridge v;
java.util.concurrent.atomic.AtomicReference v;
java.util.function.Consumer v;
oadd.org.apache.curator.x.discovery.details.ServiceCacheImpl v;
oadd.org.apache.curator.x.discovery.details.ServiceCacheImpl$State v, v;
boolean v;
v := @this: oadd.org.apache.curator.x.discovery.details.ServiceCacheImpl;
v = v.<oadd.org.apache.curator.x.discovery.details.ServiceCacheImpl: java.util.concurrent.atomic.AtomicReference state>;
v = <oadd.org.apache.curator.x.discovery.details.ServiceCacheImpl$State: oadd.org.apache.curator.x.discovery.details.ServiceCacheImpl$State STARTED>;
v = <oadd.org.apache.curator.x.discovery.details.ServiceCacheImpl$State: oadd.org.apache.curator.x.discovery.details.ServiceCacheImpl$State STOPPED>;
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 closed or has not been started");
v = v.<oadd.org.apache.curator.x.discovery.details.ServiceCacheImpl: oadd.org.apache.curator.framework.listen.StandardListenerManager listenerContainer>;
v = staticinvoke <oadd.org.apache.curator.x.discovery.details.ServiceCacheImpl$lambda_close_0__1047: java.util.function.Consumer bootstrap$(oadd.org.apache.curator.x.discovery.details.ServiceCacheImpl)>(v);
virtualinvoke v.<oadd.org.apache.curator.framework.listen.StandardListenerManager: void forEach(java.util.function.Consumer)>(v);
v = v.<oadd.org.apache.curator.x.discovery.details.ServiceCacheImpl: oadd.org.apache.curator.framework.listen.StandardListenerManager listenerContainer>;
virtualinvoke v.<oadd.org.apache.curator.framework.listen.StandardListenerManager: void clear()>();
v = v.<oadd.org.apache.curator.x.discovery.details.ServiceCacheImpl: oadd.org.apache.curator.framework.recipes.cache.CuratorCacheBridge cache>;
staticinvoke <oadd.org.apache.curator.utils.CloseableUtils: void closeQuietly(java.io.Closeable)>(v);
v = v.<oadd.org.apache.curator.x.discovery.details.ServiceCacheImpl: oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl discovery>;
virtualinvoke v.<oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl: void cacheClosed(oadd.org.apache.curator.x.discovery.ServiceCache)>(v);
return;
}
public void addListener(oadd.org.apache.curator.x.discovery.details.ServiceCacheListener)
{
oadd.org.apache.curator.framework.listen.Listenable v;
oadd.org.apache.curator.x.discovery.details.ServiceCacheImpl v;
oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl v;
oadd.org.apache.curator.x.discovery.details.ServiceCacheListener v;
oadd.org.apache.curator.framework.listen.StandardListenerManager v;
oadd.org.apache.curator.framework.CuratorFramework v;
v := @this: oadd.org.apache.curator.x.discovery.details.ServiceCacheImpl;
v := @parameter: oadd.org.apache.curator.x.discovery.details.ServiceCacheListener;
v = v.<oadd.org.apache.curator.x.discovery.details.ServiceCacheImpl: oadd.org.apache.curator.framework.listen.StandardListenerManager listenerContainer>;
virtualinvoke v.<oadd.org.apache.curator.framework.listen.StandardListenerManager: void addListener(java.lang.Object)>(v);
v = v.<oadd.org.apache.curator.x.discovery.details.ServiceCacheImpl: oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl discovery>;
v = virtualinvoke v.<oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl: oadd.org.apache.curator.framework.CuratorFramework getClient()>();
v = interfaceinvoke v.<oadd.org.apache.curator.framework.CuratorFramework: oadd.org.apache.curator.framework.listen.Listenable getConnectionStateListenable()>();
interfaceinvoke v.<oadd.org.apache.curator.framework.listen.Listenable: void addListener(java.lang.Object)>(v);
return;
}
public void addListener(oadd.org.apache.curator.x.discovery.details.ServiceCacheListener, java.util.concurrent.Executor)
{
oadd.org.apache.curator.framework.listen.Listenable v;
oadd.org.apache.curator.x.discovery.details.ServiceCacheImpl v;
oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl v;
java.util.concurrent.Executor v;
oadd.org.apache.curator.x.discovery.details.ServiceCacheListener v;
oadd.org.apache.curator.framework.listen.StandardListenerManager v;
oadd.org.apache.curator.framework.CuratorFramework v;
v := @this: oadd.org.apache.curator.x.discovery.details.ServiceCacheImpl;
v := @parameter: oadd.org.apache.curator.x.discovery.details.ServiceCacheListener;
v := @parameter: java.util.concurrent.Executor;
v = v.<oadd.org.apache.curator.x.discovery.details.ServiceCacheImpl: oadd.org.apache.curator.framework.listen.StandardListenerManager listenerContainer>;
virtualinvoke v.<oadd.org.apache.curator.framework.listen.StandardListenerManager: void addListener(java.lang.Object,java.util.concurrent.Executor)>(v, v);
v = v.<oadd.org.apache.curator.x.discovery.details.ServiceCacheImpl: oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl discovery>;
v = virtualinvoke v.<oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl: oadd.org.apache.curator.framework.CuratorFramework getClient()>();
v = interfaceinvoke v.<oadd.org.apache.curator.framework.CuratorFramework: oadd.org.apache.curator.framework.listen.Listenable getConnectionStateListenable()>();
interfaceinvoke v.<oadd.org.apache.curator.framework.listen.Listenable: void addListener(java.lang.Object,java.util.concurrent.Executor)>(v, v);
return;
}
public void removeListener(oadd.org.apache.curator.x.discovery.details.ServiceCacheListener)
{
oadd.org.apache.curator.framework.listen.Listenable v;
oadd.org.apache.curator.x.discovery.details.ServiceCacheImpl v;
oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl v;
oadd.org.apache.curator.x.discovery.details.ServiceCacheListener v;
oadd.org.apache.curator.framework.listen.StandardListenerManager v;
oadd.org.apache.curator.framework.CuratorFramework v;
v := @this: oadd.org.apache.curator.x.discovery.details.ServiceCacheImpl;
v := @parameter: oadd.org.apache.curator.x.discovery.details.ServiceCacheListener;
v = v.<oadd.org.apache.curator.x.discovery.details.ServiceCacheImpl: oadd.org.apache.curator.framework.listen.StandardListenerManager listenerContainer>;
virtualinvoke v.<oadd.org.apache.curator.framework.listen.StandardListenerManager: void removeListener(java.lang.Object)>(v);
v = v.<oadd.org.apache.curator.x.discovery.details.ServiceCacheImpl: oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl discovery>;
v = virtualinvoke v.<oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl: oadd.org.apache.curator.framework.CuratorFramework getClient()>();
v = interfaceinvoke v.<oadd.org.apache.curator.framework.CuratorFramework: oadd.org.apache.curator.framework.listen.Listenable getConnectionStateListenable()>();
interfaceinvoke v.<oadd.org.apache.curator.framework.listen.Listenable: void removeListener(java.lang.Object)>(v);
return;
}
public void childEvent(oadd.org.apache.curator.framework.CuratorFramework, oadd.org.apache.curator.framework.recipes.cache.PathChildrenCacheEvent)
{
long v;
oadd.org.apache.curator.framework.listen.StandardListenerManager v;
oadd.org.apache.curator.framework.recipes.cache.ChildData v, v;
oadd.org.apache.curator.framework.recipes.cache.PathChildrenCacheEvent v;
java.util.concurrent.ConcurrentMap v;
oadd.org.apache.curator.x.discovery.details.ServiceCacheImpl v;
byte v;
int[] v;
int v, v;
java.lang.String v;
boolean v;
oadd.org.apache.curator.framework.recipes.cache.PathChildrenCacheEvent$Type v;
oadd.org.apache.curator.framework.CuratorFramework v;
java.util.function.Consumer v;
java.util.concurrent.CountDownLatch v;
v := @this: oadd.org.apache.curator.x.discovery.details.ServiceCacheImpl;
v := @parameter: oadd.org.apache.curator.framework.CuratorFramework;
v := @parameter: oadd.org.apache.curator.framework.recipes.cache.PathChildrenCacheEvent;
v = 0;
v = <oadd.org.apache.curator.x.discovery.details.ServiceCacheImpl$1: int[] $SwitchMap$org$apache$curator$framework$recipes$cache$PathChildrenCacheEvent$Type>;
v = virtualinvoke v.<oadd.org.apache.curator.framework.recipes.cache.PathChildrenCacheEvent: oadd.org.apache.curator.framework.recipes.cache.PathChildrenCacheEvent$Type getType()>();
v = virtualinvoke v.<oadd.org.apache.curator.framework.recipes.cache.PathChildrenCacheEvent$Type: 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.curator.framework.recipes.cache.PathChildrenCacheEvent: oadd.org.apache.curator.framework.recipes.cache.ChildData getData()>();
specialinvoke v.<oadd.org.apache.curator.x.discovery.details.ServiceCacheImpl: void addInstance(oadd.org.apache.curator.framework.recipes.cache.ChildData)>(v);
v = 1;
goto label;
label:
v = v.<oadd.org.apache.curator.x.discovery.details.ServiceCacheImpl: java.util.concurrent.ConcurrentMap instances>;
v = virtualinvoke v.<oadd.org.apache.curator.framework.recipes.cache.PathChildrenCacheEvent: oadd.org.apache.curator.framework.recipes.cache.ChildData getData()>();
v = specialinvoke v.<oadd.org.apache.curator.x.discovery.details.ServiceCacheImpl: java.lang.String instanceIdFromData(oadd.org.apache.curator.framework.recipes.cache.ChildData)>(v);
interfaceinvoke v.<java.util.concurrent.ConcurrentMap: java.lang.Object remove(java.lang.Object)>(v);
v = 1;
label:
if v == 0 goto label;
v = v.<oadd.org.apache.curator.x.discovery.details.ServiceCacheImpl: java.util.concurrent.CountDownLatch initializedLatch>;
v = virtualinvoke v.<java.util.concurrent.CountDownLatch: long getCount()>();
v = v cmp 0L;
if v != 0 goto label;
v = v.<oadd.org.apache.curator.x.discovery.details.ServiceCacheImpl: oadd.org.apache.curator.framework.listen.StandardListenerManager listenerContainer>;
v = staticinvoke <oadd.org.apache.curator.x.discovery.details.ServiceCacheImpl$cacheChanged__1048: java.util.function.Consumer bootstrap$()>();
virtualinvoke v.<oadd.org.apache.curator.framework.listen.StandardListenerManager: void forEach(java.util.function.Consumer)>(v);
label:
return;
}
private java.lang.String instanceIdFromData(oadd.org.apache.curator.framework.recipes.cache.ChildData)
{
oadd.org.apache.curator.x.discovery.details.ServiceCacheImpl v;
java.lang.String v, v;
oadd.org.apache.curator.framework.recipes.cache.ChildData v;
v := @this: oadd.org.apache.curator.x.discovery.details.ServiceCacheImpl;
v := @parameter: oadd.org.apache.curator.framework.recipes.cache.ChildData;
v = virtualinvoke v.<oadd.org.apache.curator.framework.recipes.cache.ChildData: java.lang.String getPath()>();
v = staticinvoke <oadd.org.apache.curator.utils.ZKPaths: java.lang.String getNodeFromPath(java.lang.String)>(v);
return v;
}
private void addInstance(oadd.org.apache.curator.framework.recipes.cache.ChildData)
{
byte[] v;
oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl v;
oadd.org.apache.curator.x.discovery.ServiceInstance v;
java.lang.RuntimeException v;
oadd.org.apache.curator.framework.recipes.cache.ChildData v;
java.lang.Exception v;
java.util.concurrent.ConcurrentMap v;
oadd.org.apache.curator.x.discovery.details.ServiceCacheImpl v;
java.lang.String v;
oadd.org.apache.curator.x.discovery.details.InstanceSerializer v;
v := @this: oadd.org.apache.curator.x.discovery.details.ServiceCacheImpl;
v := @parameter: oadd.org.apache.curator.framework.recipes.cache.ChildData;
label:
v = specialinvoke v.<oadd.org.apache.curator.x.discovery.details.ServiceCacheImpl: java.lang.String instanceIdFromData(oadd.org.apache.curator.framework.recipes.cache.ChildData)>(v);
v = v.<oadd.org.apache.curator.x.discovery.details.ServiceCacheImpl: oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl discovery>;
v = virtualinvoke v.<oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl: oadd.org.apache.curator.x.discovery.details.InstanceSerializer getSerializer()>();
v = virtualinvoke v.<oadd.org.apache.curator.framework.recipes.cache.ChildData: byte[] getData()>();
v = interfaceinvoke v.<oadd.org.apache.curator.x.discovery.details.InstanceSerializer: oadd.org.apache.curator.x.discovery.ServiceInstance deserialize(byte[])>(v);
v = v.<oadd.org.apache.curator.x.discovery.details.ServiceCacheImpl: java.util.concurrent.ConcurrentMap instances>;
interfaceinvoke v.<java.util.concurrent.ConcurrentMap: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
label:
goto label;
label:
v := @caughtexception;
v = new java.lang.RuntimeException;
specialinvoke v.<java.lang.RuntimeException: void <init>(java.lang.Throwable)>(v);
throw v;
label:
return;
catch java.lang.Exception from label to label with label;
}
public void initialized()
{
oadd.org.apache.curator.x.discovery.details.ServiceCacheImpl v;
java.util.concurrent.CountDownLatch v;
oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl v;
v := @this: oadd.org.apache.curator.x.discovery.details.ServiceCacheImpl;
v = v.<oadd.org.apache.curator.x.discovery.details.ServiceCacheImpl: oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl discovery>;
virtualinvoke v.<oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl: void cacheOpened(oadd.org.apache.curator.x.discovery.ServiceCache)>(v);
v = v.<oadd.org.apache.curator.x.discovery.details.ServiceCacheImpl: java.util.concurrent.CountDownLatch initializedLatch>;
virtualinvoke v.<java.util.concurrent.CountDownLatch: void countDown()>();
return;
}
}