public class oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl extends java.lang.Object implements oadd.org.apache.curator.x.discovery.ServiceDiscovery
{
private final org.slf4j.Logger log;
private final oadd.org.apache.curator.framework.CuratorFramework client;
private final java.lang.String basePath;
private final oadd.org.apache.curator.x.discovery.details.InstanceSerializer serializer;
private final java.util.concurrent.ConcurrentMap services;
private final java.util.Collection caches;
private final java.util.Collection providers;
private final boolean watchInstances;
private final oadd.org.apache.curator.framework.state.ConnectionStateListener connectionStateListener;
public void <init>(oadd.org.apache.curator.framework.CuratorFramework, java.lang.String, oadd.org.apache.curator.x.discovery.details.InstanceSerializer, oadd.org.apache.curator.x.discovery.ServiceInstance, boolean)
{
oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl v;
oadd.org.apache.curator.framework.recipes.cache.CuratorCacheBridge v;
java.util.concurrent.ConcurrentMap v, v, v, v;
oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl$Entry v;
java.lang.String v, v;
oadd.org.apache.curator.x.discovery.details.InstanceSerializer v;
boolean v;
org.slf4j.Logger v;
oadd.org.apache.curator.x.discovery.ServiceInstance v;
java.util.Set v, v;
oadd.org.apache.curator.framework.CuratorFramework v;
oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl$1 v;
java.lang.Class v;
java.lang.Object v, v, v;
v := @this: oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl;
v := @parameter: oadd.org.apache.curator.framework.CuratorFramework;
v := @parameter: java.lang.String;
v := @parameter: oadd.org.apache.curator.x.discovery.details.InstanceSerializer;
v := @parameter: oadd.org.apache.curator.x.discovery.ServiceInstance;
v := @parameter: boolean;
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.x.discovery.details.ServiceDiscoveryImpl: org.slf4j.Logger log> = 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.ServiceDiscoveryImpl: java.util.concurrent.ConcurrentMap services> = v;
v = staticinvoke <oadd.org.apache.curator.shaded.com.google.common.collect.Maps: java.util.concurrent.ConcurrentMap newConcurrentMap()>();
v = staticinvoke <oadd.org.apache.curator.shaded.com.google.common.collect.Sets: java.util.Set newSetFromMap(java.util.Map)>(v);
v.<oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl: java.util.Collection caches> = v;
v = staticinvoke <oadd.org.apache.curator.shaded.com.google.common.collect.Maps: java.util.concurrent.ConcurrentMap newConcurrentMap()>();
v = staticinvoke <oadd.org.apache.curator.shaded.com.google.common.collect.Sets: java.util.Set newSetFromMap(java.util.Map)>(v);
v.<oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl: java.util.Collection providers> = v;
v = new oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl$1;
specialinvoke v.<oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl$1: void <init>(oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl)>(v);
v.<oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl: oadd.org.apache.curator.framework.state.ConnectionStateListener connectionStateListener> = v;
v.<oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl: boolean watchInstances> = v;
v = staticinvoke <oadd.org.apache.curator.shaded.com.google.common.base.Preconditions: java.lang.Object checkNotNull(java.lang.Object,java.lang.Object)>(v, "client cannot be null");
v.<oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl: oadd.org.apache.curator.framework.CuratorFramework client> = v;
v = staticinvoke <oadd.org.apache.curator.shaded.com.google.common.base.Preconditions: java.lang.Object checkNotNull(java.lang.Object,java.lang.Object)>(v, "basePath cannot be null");
v.<oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl: java.lang.String basePath> = v;
v = staticinvoke <oadd.org.apache.curator.shaded.com.google.common.base.Preconditions: java.lang.Object checkNotNull(java.lang.Object,java.lang.Object)>(v, "serializer cannot be null");
v.<oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl: oadd.org.apache.curator.x.discovery.details.InstanceSerializer serializer> = v;
if v == null goto label;
v = new oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl$Entry;
specialinvoke v.<oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl$Entry: void <init>(oadd.org.apache.curator.x.discovery.ServiceInstance)>(v);
v = specialinvoke v.<oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl: oadd.org.apache.curator.framework.recipes.cache.CuratorCacheBridge makeNodeCache(oadd.org.apache.curator.x.discovery.ServiceInstance)>(v);
v.<oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl$Entry: oadd.org.apache.curator.framework.recipes.cache.CuratorCacheBridge cache> = v;
v = v.<oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl: java.util.concurrent.ConcurrentMap services>;
v = virtualinvoke v.<oadd.org.apache.curator.x.discovery.ServiceInstance: java.lang.String getId()>();
interfaceinvoke v.<java.util.concurrent.ConcurrentMap: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
label:
return;
}
public void start() throws java.lang.Exception
{
oadd.org.apache.curator.framework.listen.Listenable v;
oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl v;
org.slf4j.Logger v;
oadd.org.apache.curator.framework.state.ConnectionStateListener v;
oadd.org.apache.curator.framework.CuratorFramework v;
oadd.org.apache.zookeeper.KeeperException v;
v := @this: oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl;
label:
specialinvoke v.<oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl: void reRegisterServices()>();
label:
goto label;
label:
v := @caughtexception;
v = v.<oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl: org.slf4j.Logger log>;
interfaceinvoke v.<org.slf4j.Logger: void error(java.lang.String,java.lang.Throwable)>("Could not register instances - will try again later", v);
label:
v = v.<oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl: oadd.org.apache.curator.framework.CuratorFramework client>;
v = interfaceinvoke v.<oadd.org.apache.curator.framework.CuratorFramework: oadd.org.apache.curator.framework.listen.Listenable getConnectionStateListenable()>();
v = v.<oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl: oadd.org.apache.curator.framework.state.ConnectionStateListener connectionStateListener>;
interfaceinvoke v.<oadd.org.apache.curator.framework.listen.Listenable: void addListener(java.lang.Object)>(v);
return;
catch oadd.org.apache.zookeeper.KeeperException from label to label with label;
}
public void close() throws java.io.IOException
{
oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl v;
oadd.org.apache.curator.framework.state.ConnectionStateListener v;
java.util.ArrayList v;
java.util.concurrent.ConcurrentMap v;
oadd.org.apache.curator.utils.ExceptionAccumulator v;
java.lang.String v, v;
boolean v, v;
oadd.org.apache.curator.framework.listen.Listenable v;
org.slf4j.Logger v;
java.util.Iterator v, v;
oadd.org.apache.curator.x.discovery.ServiceInstance v;
java.util.Collection v, v;
oadd.org.apache.zookeeper.KeeperException$NoNodeException v;
oadd.org.apache.curator.framework.CuratorFramework v;
java.lang.Exception v;
java.lang.Object v, v;
v := @this: oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl;
v = new oadd.org.apache.curator.utils.ExceptionAccumulator;
specialinvoke v.<oadd.org.apache.curator.utils.ExceptionAccumulator: void <init>()>();
v = v.<oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl: java.util.Collection providers>;
v = staticinvoke <oadd.org.apache.curator.shaded.com.google.common.collect.Lists: java.util.ArrayList newArrayList(java.lang.Iterable)>(v);
v = virtualinvoke v.<java.util.ArrayList: 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()>();
staticinvoke <oadd.org.apache.curator.utils.CloseableUtils: void closeQuietly(java.io.Closeable)>(v);
goto label;
label:
v = v.<oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl: java.util.concurrent.ConcurrentMap services>;
v = interfaceinvoke v.<java.util.concurrent.ConcurrentMap: 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()>();
label:
specialinvoke v.<oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl: void internalUnregisterService(oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl$Entry)>(v);
label:
goto label;
label:
v := @caughtexception;
goto label;
label:
v := @caughtexception;
virtualinvoke v.<oadd.org.apache.curator.utils.ExceptionAccumulator: void add(java.lang.Throwable)>(v);
v = v.<oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl: org.slf4j.Logger log>;
v = v.<oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl$Entry: oadd.org.apache.curator.x.discovery.ServiceInstance service>;
v = virtualinvoke v.<oadd.org.apache.curator.x.discovery.ServiceInstance: java.lang.String getName()>();
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[])>("Could not unregister instance: \u0001");
interfaceinvoke v.<org.slf4j.Logger: void error(java.lang.String,java.lang.Throwable)>(v, v);
goto label;
label:
v = v.<oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl: oadd.org.apache.curator.framework.CuratorFramework client>;
v = interfaceinvoke v.<oadd.org.apache.curator.framework.CuratorFramework: oadd.org.apache.curator.framework.listen.Listenable getConnectionStateListenable()>();
v = v.<oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl: oadd.org.apache.curator.framework.state.ConnectionStateListener connectionStateListener>;
interfaceinvoke v.<oadd.org.apache.curator.framework.listen.Listenable: void removeListener(java.lang.Object)>(v);
virtualinvoke v.<oadd.org.apache.curator.utils.ExceptionAccumulator: void propagate()>();
return;
catch oadd.org.apache.zookeeper.KeeperException$NoNodeException from label to label with label;
catch java.lang.Exception from label to label with label;
}
public void registerService(oadd.org.apache.curator.x.discovery.ServiceInstance) throws java.lang.Exception
{
java.lang.Throwable v;
oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl v;
oadd.org.apache.curator.x.discovery.ServiceInstance v;
oadd.org.apache.curator.framework.recipes.cache.CuratorCacheBridge v;
java.util.concurrent.ConcurrentMap v;
oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl$Entry v, v, v;
java.lang.Object v;
java.lang.String v;
v := @this: oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl;
v := @parameter: oadd.org.apache.curator.x.discovery.ServiceInstance;
v = new oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl$Entry;
specialinvoke v.<oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl$Entry: void <init>(oadd.org.apache.curator.x.discovery.ServiceInstance)>(v);
v = v.<oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl: java.util.concurrent.ConcurrentMap services>;
v = virtualinvoke v.<oadd.org.apache.curator.x.discovery.ServiceInstance: java.lang.String getId()>();
v = interfaceinvoke v.<java.util.concurrent.ConcurrentMap: java.lang.Object putIfAbsent(java.lang.Object,java.lang.Object)>(v, v);
if v == null goto label;
v = v;
goto label;
label:
v = v;
label:
v = v;
entermonitor v;
label:
if v != v goto label;
v = specialinvoke v.<oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl: oadd.org.apache.curator.framework.recipes.cache.CuratorCacheBridge makeNodeCache(oadd.org.apache.curator.x.discovery.ServiceInstance)>(v);
v.<oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl$Entry: oadd.org.apache.curator.framework.recipes.cache.CuratorCacheBridge cache> = v;
label:
virtualinvoke v.<oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl: void internalRegisterService(oadd.org.apache.curator.x.discovery.ServiceInstance)>(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;
}
public void updateService(oadd.org.apache.curator.x.discovery.ServiceInstance) throws java.lang.Exception
{
java.lang.Throwable v;
byte[] v;
oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl v;
oadd.org.apache.curator.x.discovery.ServiceInstance v;
oadd.org.apache.curator.framework.api.SetDataBuilder v;
oadd.org.apache.curator.framework.CuratorFramework v;
java.lang.Exception v;
java.util.concurrent.ConcurrentMap v;
java.lang.Object v;
java.lang.String v, v, v, v, v;
oadd.org.apache.curator.x.discovery.details.InstanceSerializer v;
v := @this: oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl;
v := @parameter: oadd.org.apache.curator.x.discovery.ServiceInstance;
v = v.<oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl: java.util.concurrent.ConcurrentMap services>;
v = virtualinvoke v.<oadd.org.apache.curator.x.discovery.ServiceInstance: java.lang.String getId()>();
v = interfaceinvoke v.<java.util.concurrent.ConcurrentMap: java.lang.Object get(java.lang.Object)>(v);
if v != null goto label;
v = new java.lang.Exception;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (oadd.org.apache.curator.x.discovery.ServiceInstance)>(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[])>("Service not registered: \u0001");
specialinvoke v.<java.lang.Exception: void <init>(java.lang.String)>(v);
throw v;
label:
entermonitor v;
label:
v.<oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl$Entry: oadd.org.apache.curator.x.discovery.ServiceInstance service> = v;
v = v.<oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl: oadd.org.apache.curator.x.discovery.details.InstanceSerializer serializer>;
v = interfaceinvoke v.<oadd.org.apache.curator.x.discovery.details.InstanceSerializer: byte[] serialize(oadd.org.apache.curator.x.discovery.ServiceInstance)>(v);
v = virtualinvoke v.<oadd.org.apache.curator.x.discovery.ServiceInstance: java.lang.String getName()>();
v = virtualinvoke v.<oadd.org.apache.curator.x.discovery.ServiceInstance: java.lang.String getId()>();
v = virtualinvoke v.<oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl: java.lang.String pathForInstance(java.lang.String,java.lang.String)>(v, v);
v = v.<oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl: oadd.org.apache.curator.framework.CuratorFramework client>;
v = interfaceinvoke v.<oadd.org.apache.curator.framework.CuratorFramework: oadd.org.apache.curator.framework.api.SetDataBuilder setData()>();
interfaceinvoke v.<oadd.org.apache.curator.framework.api.SetDataBuilder: java.lang.Object forPath(java.lang.String,byte[])>(v, v);
exitmonitor v;
label:
goto label;
label:
v := @caughtexception;
exitmonitor v;
throw v;
label:
return;
catch java.lang.Throwable from label to label with label;
}
protected void internalRegisterService(oadd.org.apache.curator.x.discovery.ServiceInstance) throws java.lang.Exception
{
byte[] v;
oadd.org.apache.curator.x.discovery.ServiceType v;
oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl v;
oadd.org.apache.zookeeper.CreateMode v;
int[] v;
oadd.org.apache.curator.framework.api.CreateBuilder v;
int v, v, v;
java.lang.String v, v, v;
oadd.org.apache.curator.x.discovery.details.InstanceSerializer v;
boolean v;
oadd.org.apache.zookeeper.KeeperException$NodeExistsException v;
oadd.org.apache.curator.x.discovery.ServiceInstance v;
oadd.org.apache.curator.framework.CuratorFramework v, v;
oadd.org.apache.curator.framework.api.ProtectACLCreateModeStatPathAndBytesable v;
java.lang.Object v;
oadd.org.apache.curator.framework.api.DeleteBuilder v;
v := @this: oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl;
v := @parameter: oadd.org.apache.curator.x.discovery.ServiceInstance;
v = v.<oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl: oadd.org.apache.curator.x.discovery.details.InstanceSerializer serializer>;
v = interfaceinvoke v.<oadd.org.apache.curator.x.discovery.details.InstanceSerializer: byte[] serialize(oadd.org.apache.curator.x.discovery.ServiceInstance)>(v);
v = virtualinvoke v.<oadd.org.apache.curator.x.discovery.ServiceInstance: java.lang.String getName()>();
v = virtualinvoke v.<oadd.org.apache.curator.x.discovery.ServiceInstance: java.lang.String getId()>();
v = virtualinvoke v.<oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl: java.lang.String pathForInstance(java.lang.String,java.lang.String)>(v, v);
v = 0;
v = 0;
label:
if v != 0 goto label;
if v >= 2 goto label;
label:
v = <oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl$2: int[] $SwitchMap$org$apache$curator$x$discovery$ServiceType>;
v = virtualinvoke v.<oadd.org.apache.curator.x.discovery.ServiceInstance: oadd.org.apache.curator.x.discovery.ServiceType getServiceType()>();
v = virtualinvoke v.<oadd.org.apache.curator.x.discovery.ServiceType: int ordinal()>();
v = v[v];
lookupswitch(v)
{
case 1: goto label;
case 2: goto label;
default: goto label;
};
label:
v = <oadd.org.apache.zookeeper.CreateMode: oadd.org.apache.zookeeper.CreateMode EPHEMERAL>;
goto label;
label:
v = <oadd.org.apache.zookeeper.CreateMode: oadd.org.apache.zookeeper.CreateMode EPHEMERAL_SEQUENTIAL>;
goto label;
label:
v = <oadd.org.apache.zookeeper.CreateMode: oadd.org.apache.zookeeper.CreateMode PERSISTENT>;
label:
v = v.<oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl: oadd.org.apache.curator.framework.CuratorFramework client>;
v = interfaceinvoke v.<oadd.org.apache.curator.framework.CuratorFramework: oadd.org.apache.curator.framework.api.CreateBuilder create()>();
v = interfaceinvoke v.<oadd.org.apache.curator.framework.api.CreateBuilder: oadd.org.apache.curator.framework.api.ProtectACLCreateModeStatPathAndBytesable creatingParentContainersIfNeeded()>();
v = interfaceinvoke v.<oadd.org.apache.curator.framework.api.ProtectACLCreateModeStatPathAndBytesable: java.lang.Object withMode(oadd.org.apache.zookeeper.CreateMode)>(v);
interfaceinvoke v.<oadd.org.apache.curator.framework.api.ACLBackgroundPathAndBytesable: java.lang.Object forPath(java.lang.String,byte[])>(v, v);
v = 1;
label:
goto label;
label:
v := @caughtexception;
v = v.<oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl: oadd.org.apache.curator.framework.CuratorFramework client>;
v = interfaceinvoke v.<oadd.org.apache.curator.framework.CuratorFramework: oadd.org.apache.curator.framework.api.DeleteBuilder delete()>();
interfaceinvoke v.<oadd.org.apache.curator.framework.api.DeleteBuilder: java.lang.Object forPath(java.lang.String)>(v);
label:
v = v + 1;
goto label;
label:
return;
catch oadd.org.apache.zookeeper.KeeperException$NodeExistsException from label to label with label;
}
public void unregisterService(oadd.org.apache.curator.x.discovery.ServiceInstance) throws java.lang.Exception
{
oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl v;
oadd.org.apache.curator.x.discovery.ServiceInstance v;
java.lang.Object v;
java.lang.String v;
java.util.concurrent.ConcurrentMap v;
v := @this: oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl;
v := @parameter: oadd.org.apache.curator.x.discovery.ServiceInstance;
v = v.<oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl: java.util.concurrent.ConcurrentMap services>;
v = virtualinvoke v.<oadd.org.apache.curator.x.discovery.ServiceInstance: java.lang.String getId()>();
v = interfaceinvoke v.<java.util.concurrent.ConcurrentMap: java.lang.Object remove(java.lang.Object)>(v);
specialinvoke v.<oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl: void internalUnregisterService(oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl$Entry)>(v);
return;
}
public oadd.org.apache.curator.x.discovery.ServiceProviderBuilder serviceProviderBuilder()
{
oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl v;
oadd.org.apache.curator.x.discovery.details.ServiceProviderBuilderImpl v;
java.util.concurrent.ThreadFactory v;
oadd.org.apache.curator.x.discovery.ServiceProviderBuilder v, v;
oadd.org.apache.curator.x.discovery.strategies.RoundRobinStrategy v;
v := @this: oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl;
v = new oadd.org.apache.curator.x.discovery.details.ServiceProviderBuilderImpl;
specialinvoke v.<oadd.org.apache.curator.x.discovery.details.ServiceProviderBuilderImpl: void <init>(oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl)>(v);
v = new oadd.org.apache.curator.x.discovery.strategies.RoundRobinStrategy;
specialinvoke v.<oadd.org.apache.curator.x.discovery.strategies.RoundRobinStrategy: void <init>()>();
v = virtualinvoke v.<oadd.org.apache.curator.x.discovery.details.ServiceProviderBuilderImpl: oadd.org.apache.curator.x.discovery.ServiceProviderBuilder providerStrategy(oadd.org.apache.curator.x.discovery.ProviderStrategy)>(v);
v = staticinvoke <oadd.org.apache.curator.utils.ThreadUtils: java.util.concurrent.ThreadFactory newThreadFactory(java.lang.String)>("ServiceProvider");
v = interfaceinvoke v.<oadd.org.apache.curator.x.discovery.ServiceProviderBuilder: oadd.org.apache.curator.x.discovery.ServiceProviderBuilder threadFactory(java.util.concurrent.ThreadFactory)>(v);
return v;
}
public oadd.org.apache.curator.x.discovery.ServiceCacheBuilder serviceCacheBuilder()
{
oadd.org.apache.curator.x.discovery.details.ServiceCacheBuilderImpl v;
oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl v;
v := @this: oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl;
v = new oadd.org.apache.curator.x.discovery.details.ServiceCacheBuilderImpl;
specialinvoke v.<oadd.org.apache.curator.x.discovery.details.ServiceCacheBuilderImpl: void <init>(oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl)>(v);
return v;
}
public java.util.Collection queryForNames() throws java.lang.Exception
{
oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl v;
java.lang.Object v;
java.lang.String v;
oadd.org.apache.curator.framework.CuratorFramework v;
oadd.org.apache.curator.shaded.com.google.common.collect.ImmutableList v;
oadd.org.apache.curator.framework.api.GetChildrenBuilder v;
v := @this: oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl;
v = v.<oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl: 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 = v.<oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl: java.lang.String basePath>;
v = interfaceinvoke v.<oadd.org.apache.curator.framework.api.GetChildrenBuilder: java.lang.Object forPath(java.lang.String)>(v);
v = staticinvoke <oadd.org.apache.curator.shaded.com.google.common.collect.ImmutableList: oadd.org.apache.curator.shaded.com.google.common.collect.ImmutableList copyOf(java.util.Collection)>(v);
return v;
}
public java.util.Collection queryForInstances(java.lang.String) throws java.lang.Exception
{
oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl v;
java.util.List v;
java.lang.String v;
v := @this: oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl;
v := @parameter: java.lang.String;
v = virtualinvoke v.<oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl: java.util.List queryForInstances(java.lang.String,oadd.org.apache.zookeeper.Watcher)>(v, null);
return v;
}
public oadd.org.apache.curator.x.discovery.ServiceInstance queryForInstance(java.lang.String, java.lang.String) throws java.lang.Exception
{
oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl v;
oadd.org.apache.curator.x.discovery.ServiceInstance v;
oadd.org.apache.curator.framework.api.GetDataBuilder v;
oadd.org.apache.zookeeper.KeeperException$NoNodeException v;
oadd.org.apache.curator.framework.CuratorFramework v;
java.lang.Object v;
java.lang.String v, v, v;
oadd.org.apache.curator.x.discovery.details.InstanceSerializer v;
v := @this: oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v = virtualinvoke v.<oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl: java.lang.String pathForInstance(java.lang.String,java.lang.String)>(v, v);
label:
v = v.<oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl: 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 forPath(java.lang.String)>(v);
v = v.<oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl: oadd.org.apache.curator.x.discovery.details.InstanceSerializer serializer>;
v = interfaceinvoke v.<oadd.org.apache.curator.x.discovery.details.InstanceSerializer: oadd.org.apache.curator.x.discovery.ServiceInstance deserialize(byte[])>(v);
label:
return v;
label:
v := @caughtexception;
return null;
catch oadd.org.apache.zookeeper.KeeperException$NoNodeException from label to label with label;
}
void cacheOpened(oadd.org.apache.curator.x.discovery.ServiceCache)
{
oadd.org.apache.curator.x.discovery.ServiceCache v;
oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl v;
java.util.Collection v;
v := @this: oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl;
v := @parameter: oadd.org.apache.curator.x.discovery.ServiceCache;
v = v.<oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl: java.util.Collection caches>;
interfaceinvoke v.<java.util.Collection: boolean add(java.lang.Object)>(v);
return;
}
void cacheClosed(oadd.org.apache.curator.x.discovery.ServiceCache)
{
oadd.org.apache.curator.x.discovery.ServiceCache v;
oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl v;
java.util.Collection v;
v := @this: oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl;
v := @parameter: oadd.org.apache.curator.x.discovery.ServiceCache;
v = v.<oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl: java.util.Collection caches>;
interfaceinvoke v.<java.util.Collection: boolean remove(java.lang.Object)>(v);
return;
}
void providerOpened(oadd.org.apache.curator.x.discovery.ServiceProvider)
{
oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl v;
oadd.org.apache.curator.x.discovery.ServiceProvider v;
java.util.Collection v;
v := @this: oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl;
v := @parameter: oadd.org.apache.curator.x.discovery.ServiceProvider;
v = v.<oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl: java.util.Collection providers>;
interfaceinvoke v.<java.util.Collection: boolean add(java.lang.Object)>(v);
return;
}
void providerClosed(oadd.org.apache.curator.x.discovery.ServiceProvider)
{
oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl v;
oadd.org.apache.curator.x.discovery.ServiceProvider v;
java.util.Collection v;
v := @this: oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl;
v := @parameter: oadd.org.apache.curator.x.discovery.ServiceProvider;
v = v.<oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl: java.util.Collection providers>;
interfaceinvoke v.<java.util.Collection: boolean remove(java.lang.Object)>(v);
return;
}
oadd.org.apache.curator.framework.CuratorFramework getClient()
{
oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl v;
oadd.org.apache.curator.framework.CuratorFramework v;
v := @this: oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl;
v = v.<oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl: oadd.org.apache.curator.framework.CuratorFramework client>;
return v;
}
java.lang.String pathForName(java.lang.String)
{
oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl v;
java.lang.String v, v, v;
v := @this: oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl;
v := @parameter: java.lang.String;
v = v.<oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl: java.lang.String basePath>;
v = staticinvoke <oadd.org.apache.curator.utils.ZKPaths: java.lang.String makePath(java.lang.String,java.lang.String)>(v, v);
return v;
}
oadd.org.apache.curator.x.discovery.details.InstanceSerializer getSerializer()
{
oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl v;
oadd.org.apache.curator.x.discovery.details.InstanceSerializer v;
v := @this: oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl;
v = v.<oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl: oadd.org.apache.curator.x.discovery.details.InstanceSerializer serializer>;
return v;
}
java.util.List queryForInstances(java.lang.String, oadd.org.apache.zookeeper.Watcher) throws java.lang.Exception
{
oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl v;
java.util.Iterator v;
oadd.org.apache.curator.x.discovery.ServiceInstance v;
oadd.org.apache.zookeeper.KeeperException$NoNodeException v;
oadd.org.apache.curator.framework.CuratorFramework v;
oadd.org.apache.curator.shaded.com.google.common.collect.ImmutableList v;
oadd.org.apache.curator.framework.api.GetChildrenBuilder v;
oadd.org.apache.zookeeper.Watcher v;
oadd.org.apache.curator.shaded.com.google.common.collect.ImmutableList$Builder v;
java.lang.Object v, v;
java.lang.String v, v;
boolean v;
v := @this: oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl;
v := @parameter: java.lang.String;
v := @parameter: oadd.org.apache.zookeeper.Watcher;
v = staticinvoke <oadd.org.apache.curator.shaded.com.google.common.collect.ImmutableList: oadd.org.apache.curator.shaded.com.google.common.collect.ImmutableList$Builder builder()>();
v = virtualinvoke v.<oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl: java.lang.String pathForName(java.lang.String)>(v);
if v == null goto label;
specialinvoke v.<oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl: java.util.List getChildrenWatched(java.lang.String,oadd.org.apache.zookeeper.Watcher,boolean)>(v, v, 1);
goto label;
label:
v = v.<oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl: 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 forPath(java.lang.String)>(v);
label:
goto label;
label:
v := @caughtexception;
v = staticinvoke <oadd.org.apache.curator.shaded.com.google.common.collect.Lists: java.util.ArrayList newArrayList()>();
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.curator.x.discovery.details.ServiceDiscoveryImpl: oadd.org.apache.curator.x.discovery.ServiceInstance queryForInstance(java.lang.String,java.lang.String)>(v, v);
if v == null goto label;
virtualinvoke v.<oadd.org.apache.curator.shaded.com.google.common.collect.ImmutableList$Builder: oadd.org.apache.curator.shaded.com.google.common.collect.ImmutableList$Builder add(java.lang.Object)>(v);
goto label;
label:
v = virtualinvoke v.<oadd.org.apache.curator.shaded.com.google.common.collect.ImmutableList$Builder: oadd.org.apache.curator.shaded.com.google.common.collect.ImmutableList build()>();
return v;
catch oadd.org.apache.zookeeper.KeeperException$NoNodeException from label to label with label;
}
int debugServicesQty()
{
int v;
oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl v;
java.util.concurrent.ConcurrentMap v;
v := @this: oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl;
v = v.<oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl: java.util.concurrent.ConcurrentMap services>;
v = interfaceinvoke v.<java.util.concurrent.ConcurrentMap: int size()>();
return v;
}
private java.util.List getChildrenWatched(java.lang.String, oadd.org.apache.zookeeper.Watcher, boolean) throws java.lang.Exception
{
oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl v;
oadd.org.apache.zookeeper.KeeperException$NodeExistsException v;
oadd.org.apache.zookeeper.KeeperException$NoNodeException v;
oadd.org.apache.curator.framework.CuratorFramework v, v;
oadd.org.apache.curator.framework.api.ProtectACLCreateModeStatPathAndBytesable v;
oadd.org.apache.curator.framework.api.GetChildrenBuilder v;
oadd.org.apache.zookeeper.Watcher v;
oadd.org.apache.curator.framework.api.CreateBuilder v;
java.lang.Object v, v;
java.lang.String v;
boolean v;
v := @this: oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl;
v := @parameter: java.lang.String;
v := @parameter: oadd.org.apache.zookeeper.Watcher;
v := @parameter: boolean;
label:
v = v.<oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl: 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 usingWatcher(oadd.org.apache.zookeeper.Watcher)>(v);
v = interfaceinvoke v.<oadd.org.apache.curator.framework.api.BackgroundPathable: java.lang.Object forPath(java.lang.String)>(v);
label:
goto label;
label:
v := @caughtexception;
if v == 0 goto label;
label:
v = v.<oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl: oadd.org.apache.curator.framework.CuratorFramework client>;
v = interfaceinvoke v.<oadd.org.apache.curator.framework.CuratorFramework: oadd.org.apache.curator.framework.api.CreateBuilder create()>();
v = interfaceinvoke v.<oadd.org.apache.curator.framework.api.CreateBuilder: oadd.org.apache.curator.framework.api.ProtectACLCreateModeStatPathAndBytesable creatingParentContainersIfNeeded()>();
interfaceinvoke v.<oadd.org.apache.curator.framework.api.ProtectACLCreateModeStatPathAndBytesable: java.lang.Object forPath(java.lang.String)>(v);
label:
goto label;
label:
v := @caughtexception;
label:
v = specialinvoke v.<oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl: java.util.List getChildrenWatched(java.lang.String,oadd.org.apache.zookeeper.Watcher,boolean)>(v, v, 0);
goto label;
label:
throw v;
label:
return v;
catch oadd.org.apache.zookeeper.KeeperException$NoNodeException from label to label with label;
catch oadd.org.apache.zookeeper.KeeperException$NodeExistsException from label to label with label;
}
java.lang.String pathForInstance(java.lang.String, java.lang.String)
{
oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl v;
java.lang.String v, v, v, v;
v := @this: oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v = virtualinvoke v.<oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl: java.lang.String pathForName(java.lang.String)>(v);
v = staticinvoke <oadd.org.apache.curator.utils.ZKPaths: java.lang.String makePath(java.lang.String,java.lang.String)>(v, v);
return v;
}
oadd.org.apache.curator.x.discovery.ServiceInstance getRegisteredService(java.lang.String)
{
oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl v;
oadd.org.apache.curator.x.discovery.ServiceInstance v;
java.lang.Object v;
java.lang.String v;
java.util.concurrent.ConcurrentMap v;
v := @this: oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl;
v := @parameter: java.lang.String;
v = v.<oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl: java.util.concurrent.ConcurrentMap services>;
v = interfaceinvoke v.<java.util.concurrent.ConcurrentMap: java.lang.Object get(java.lang.Object)>(v);
if v == null goto label;
v = v.<oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl$Entry: oadd.org.apache.curator.x.discovery.ServiceInstance service>;
goto label;
label:
v = null;
label:
return v;
}
private void reRegisterServices() throws java.lang.Exception
{
java.lang.Throwable v;
oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl v;
java.util.Iterator v;
oadd.org.apache.curator.x.discovery.ServiceInstance v;
java.util.Collection v;
java.util.concurrent.ConcurrentMap v;
java.lang.Object v;
boolean v;
v := @this: oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl;
v = v.<oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl: java.util.concurrent.ConcurrentMap services>;
v = interfaceinvoke v.<java.util.concurrent.ConcurrentMap: 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()>();
entermonitor v;
label:
v = v.<oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl$Entry: oadd.org.apache.curator.x.discovery.ServiceInstance service>;
virtualinvoke v.<oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl: void internalRegisterService(oadd.org.apache.curator.x.discovery.ServiceInstance)>(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 oadd.org.apache.curator.framework.recipes.cache.CuratorCacheBridge makeNodeCache(oadd.org.apache.curator.x.discovery.ServiceInstance)
{
oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl v;
oadd.org.apache.curator.framework.recipes.cache.CuratorCacheBridge v;
oadd.org.apache.curator.framework.recipes.cache.CuratorCache$Options v;
oadd.org.apache.curator.framework.recipes.cache.CuratorCacheListenerBuilder v, v, v;
java.lang.String v, v, v;
boolean v;
oadd.org.apache.curator.framework.listen.Listenable v;
oadd.org.apache.curator.framework.recipes.cache.CuratorCache$Options[] v;
oadd.org.apache.curator.x.discovery.ServiceInstance v;
oadd.org.apache.curator.framework.recipes.cache.CuratorCacheListener v, v;
oadd.org.apache.curator.framework.CuratorFramework v;
oadd.org.apache.curator.framework.recipes.cache.CuratorCacheBridgeBuilder v, v, v;
v := @this: oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl;
v := @parameter: oadd.org.apache.curator.x.discovery.ServiceInstance;
v = v.<oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl: boolean watchInstances>;
if v != 0 goto label;
return null;
label:
v = v.<oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl: oadd.org.apache.curator.framework.CuratorFramework client>;
v = virtualinvoke v.<oadd.org.apache.curator.x.discovery.ServiceInstance: java.lang.String getName()>();
v = virtualinvoke v.<oadd.org.apache.curator.x.discovery.ServiceInstance: java.lang.String getId()>();
v = virtualinvoke v.<oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl: java.lang.String pathForInstance(java.lang.String,java.lang.String)>(v, v);
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 = newarray (oadd.org.apache.curator.framework.recipes.cache.CuratorCache$Options)[1];
v = <oadd.org.apache.curator.framework.recipes.cache.CuratorCache$Options: oadd.org.apache.curator.framework.recipes.cache.CuratorCache$Options SINGLE_NODE_CACHE>;
v[0] = v;
v = interfaceinvoke v.<oadd.org.apache.curator.framework.recipes.cache.CuratorCacheBridgeBuilder: oadd.org.apache.curator.framework.recipes.cache.CuratorCacheBridgeBuilder withOptions(oadd.org.apache.curator.framework.recipes.cache.CuratorCache$Options[])>(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 = staticinvoke <oadd.org.apache.curator.framework.recipes.cache.CuratorCacheListener: oadd.org.apache.curator.framework.recipes.cache.CuratorCacheListenerBuilder builder()>();
v = interfaceinvoke v.<oadd.org.apache.curator.framework.recipes.cache.CuratorCacheListenerBuilder: oadd.org.apache.curator.framework.recipes.cache.CuratorCacheListenerBuilder afterInitialized()>();
v = staticinvoke <oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl$lambda_makeNodeCache_0__1049: oadd.org.apache.curator.framework.recipes.cache.CuratorCacheListener bootstrap$(oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl,oadd.org.apache.curator.x.discovery.ServiceInstance)>(v, v);
v = interfaceinvoke v.<oadd.org.apache.curator.framework.recipes.cache.CuratorCacheListenerBuilder: oadd.org.apache.curator.framework.recipes.cache.CuratorCacheListenerBuilder forAll(oadd.org.apache.curator.framework.recipes.cache.CuratorCacheListener)>(v);
v = interfaceinvoke v.<oadd.org.apache.curator.framework.recipes.cache.CuratorCacheListenerBuilder: oadd.org.apache.curator.framework.recipes.cache.CuratorCacheListener build()>();
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);
interfaceinvoke v.<oadd.org.apache.curator.framework.recipes.cache.CuratorCacheBridge: void start()>();
return v;
}
private void internalUnregisterService(oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl$Entry) throws java.lang.Exception
{
java.lang.Throwable v;
oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl v;
oadd.org.apache.curator.x.discovery.ServiceInstance v, v;
oadd.org.apache.zookeeper.KeeperException$NoNodeException v;
oadd.org.apache.curator.framework.CuratorFramework v;
oadd.org.apache.curator.framework.recipes.cache.CuratorCacheBridge v, v;
oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl$Entry v;
java.lang.Object v;
java.lang.String v, v, v;
oadd.org.apache.curator.framework.api.DeleteBuilder v;
v := @this: oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl;
v := @parameter: oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl$Entry;
if v == null goto label;
entermonitor v;
label:
v = v.<oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl$Entry: oadd.org.apache.curator.framework.recipes.cache.CuratorCacheBridge cache>;
if v == null goto label;
v = v.<oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl$Entry: oadd.org.apache.curator.framework.recipes.cache.CuratorCacheBridge cache>;
staticinvoke <oadd.org.apache.curator.utils.CloseableUtils: void closeQuietly(java.io.Closeable)>(v);
v.<oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl$Entry: oadd.org.apache.curator.framework.recipes.cache.CuratorCacheBridge cache> = null;
label:
v = v.<oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl$Entry: oadd.org.apache.curator.x.discovery.ServiceInstance service>;
v = virtualinvoke v.<oadd.org.apache.curator.x.discovery.ServiceInstance: java.lang.String getName()>();
v = v.<oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl$Entry: oadd.org.apache.curator.x.discovery.ServiceInstance service>;
v = virtualinvoke v.<oadd.org.apache.curator.x.discovery.ServiceInstance: java.lang.String getId()>();
v = virtualinvoke v.<oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl: java.lang.String pathForInstance(java.lang.String,java.lang.String)>(v, v);
label:
v = v.<oadd.org.apache.curator.x.discovery.details.ServiceDiscoveryImpl: oadd.org.apache.curator.framework.CuratorFramework client>;
v = interfaceinvoke v.<oadd.org.apache.curator.framework.CuratorFramework: oadd.org.apache.curator.framework.api.DeleteBuilder delete()>();
v = interfaceinvoke v.<oadd.org.apache.curator.framework.api.DeleteBuilder: java.lang.Object guaranteed()>();
interfaceinvoke v.<oadd.org.apache.curator.framework.api.ChildrenDeletable: java.lang.Object forPath(java.lang.String)>(v);
label:
goto label;
label:
v := @caughtexception;
label:
exitmonitor v;
label:
goto label;
label:
v := @caughtexception;
exitmonitor v;
throw v;
label:
return;
catch oadd.org.apache.zookeeper.KeeperException$NoNodeException from label to label with label;
catch java.lang.Throwable from label to label with label;
}
}