final class org.apache.dubbo.registry.client.EventPublishingServiceDiscovery extends java.lang.Object implements org.apache.dubbo.registry.client.ServiceDiscovery
{
protected static final java.lang.String REGISTER_ACTION;
protected static final java.lang.String UPDATE_ACTION;
protected static final java.lang.String UNREGISTER_ACTION;
protected static final java.lang.String INITIALIZE_ACTION;
protected static final java.lang.String DESTROY_ACTION;
protected final org.apache.dubbo.event.EventDispatcher eventDispatcher;
protected final java.util.concurrent.atomic.AtomicBoolean initialized;
protected final java.util.concurrent.atomic.AtomicBoolean destroyed;
protected final org.apache.dubbo.common.logger.Logger logger;
private final org.apache.dubbo.registry.client.ServiceDiscovery serviceDiscovery;
protected void <init>(org.apache.dubbo.registry.client.ServiceDiscovery)
{
org.apache.dubbo.common.logger.Logger v;
java.util.concurrent.atomic.AtomicBoolean v, v;
java.lang.NullPointerException v;
org.apache.dubbo.registry.client.ServiceDiscovery v;
java.lang.Class v;
org.apache.dubbo.registry.client.EventPublishingServiceDiscovery v;
org.apache.dubbo.event.EventDispatcher v;
v := @this: org.apache.dubbo.registry.client.EventPublishingServiceDiscovery;
v := @parameter: org.apache.dubbo.registry.client.ServiceDiscovery;
specialinvoke v.<java.lang.Object: void <init>()>();
v = staticinvoke <org.apache.dubbo.event.EventDispatcher: org.apache.dubbo.event.EventDispatcher getDefaultExtension()>();
v.<org.apache.dubbo.registry.client.EventPublishingServiceDiscovery: org.apache.dubbo.event.EventDispatcher eventDispatcher> = v;
v = new java.util.concurrent.atomic.AtomicBoolean;
specialinvoke v.<java.util.concurrent.atomic.AtomicBoolean: void <init>(boolean)>(0);
v.<org.apache.dubbo.registry.client.EventPublishingServiceDiscovery: java.util.concurrent.atomic.AtomicBoolean initialized> = v;
v = new java.util.concurrent.atomic.AtomicBoolean;
specialinvoke v.<java.util.concurrent.atomic.AtomicBoolean: void <init>(boolean)>(0);
v.<org.apache.dubbo.registry.client.EventPublishingServiceDiscovery: java.util.concurrent.atomic.AtomicBoolean destroyed> = v;
v = virtualinvoke v.<java.lang.Object: java.lang.Class getClass()>();
v = staticinvoke <org.apache.dubbo.common.logger.LoggerFactory: org.apache.dubbo.common.logger.Logger getLogger(java.lang.Class)>(v);
v.<org.apache.dubbo.registry.client.EventPublishingServiceDiscovery: org.apache.dubbo.common.logger.Logger logger> = v;
if v != null goto label;
v = new java.lang.NullPointerException;
specialinvoke v.<java.lang.NullPointerException: void <init>(java.lang.String)>("The ServiceDiscovery argument must not be null!");
throw v;
label:
v.<org.apache.dubbo.registry.client.EventPublishingServiceDiscovery: org.apache.dubbo.registry.client.ServiceDiscovery serviceDiscovery> = v;
return;
}
public final void register(org.apache.dubbo.registry.client.ServiceInstance) throws java.lang.RuntimeException
{
org.apache.dubbo.registry.client.ServiceInstance v;
org.apache.dubbo.registry.client.event.ServiceInstanceRegisteredEvent v;
org.apache.dubbo.common.function.ThrowableAction v;
org.apache.dubbo.registry.client.event.ServiceInstancePreRegisteredEvent v;
org.apache.dubbo.registry.client.ServiceDiscovery v, v;
java.util.Optional v, v;
org.apache.dubbo.registry.client.EventPublishingServiceDiscovery v;
v := @this: org.apache.dubbo.registry.client.EventPublishingServiceDiscovery;
v := @parameter: org.apache.dubbo.registry.client.ServiceInstance;
virtualinvoke v.<org.apache.dubbo.registry.client.EventPublishingServiceDiscovery: void assertDestroyed(java.lang.String)>("register");
virtualinvoke v.<org.apache.dubbo.registry.client.EventPublishingServiceDiscovery: void assertInitialized(java.lang.String)>("register");
v = new org.apache.dubbo.registry.client.event.ServiceInstancePreRegisteredEvent;
v = v.<org.apache.dubbo.registry.client.EventPublishingServiceDiscovery: org.apache.dubbo.registry.client.ServiceDiscovery serviceDiscovery>;
specialinvoke v.<org.apache.dubbo.registry.client.event.ServiceInstancePreRegisteredEvent: void <init>(java.lang.Object,org.apache.dubbo.registry.client.ServiceInstance)>(v, v);
v = staticinvoke <java.util.Optional: java.util.Optional of(java.lang.Object)>(v);
v = staticinvoke <org.apache.dubbo.registry.client.EventPublishingServiceDiscovery$lambda_register_0__2: org.apache.dubbo.common.function.ThrowableAction bootstrap$(org.apache.dubbo.registry.client.EventPublishingServiceDiscovery,org.apache.dubbo.registry.client.ServiceInstance)>(v, v);
v = new org.apache.dubbo.registry.client.event.ServiceInstanceRegisteredEvent;
v = v.<org.apache.dubbo.registry.client.EventPublishingServiceDiscovery: org.apache.dubbo.registry.client.ServiceDiscovery serviceDiscovery>;
specialinvoke v.<org.apache.dubbo.registry.client.event.ServiceInstanceRegisteredEvent: void <init>(java.lang.Object,org.apache.dubbo.registry.client.ServiceInstance)>(v, v);
v = staticinvoke <java.util.Optional: java.util.Optional of(java.lang.Object)>(v);
virtualinvoke v.<org.apache.dubbo.registry.client.EventPublishingServiceDiscovery: void executeWithEvents(java.util.Optional,org.apache.dubbo.common.function.ThrowableAction,java.util.Optional)>(v, v, v);
return;
}
public final void update(org.apache.dubbo.registry.client.ServiceInstance) throws java.lang.RuntimeException
{
java.util.Optional v, v;
org.apache.dubbo.registry.client.ServiceInstance v;
org.apache.dubbo.registry.client.EventPublishingServiceDiscovery v;
org.apache.dubbo.common.function.ThrowableAction v;
v := @this: org.apache.dubbo.registry.client.EventPublishingServiceDiscovery;
v := @parameter: org.apache.dubbo.registry.client.ServiceInstance;
virtualinvoke v.<org.apache.dubbo.registry.client.EventPublishingServiceDiscovery: void assertDestroyed(java.lang.String)>("update");
virtualinvoke v.<org.apache.dubbo.registry.client.EventPublishingServiceDiscovery: void assertInitialized(java.lang.String)>("update");
v = staticinvoke <java.util.Optional: java.util.Optional empty()>();
v = staticinvoke <org.apache.dubbo.registry.client.EventPublishingServiceDiscovery$lambda_update_1__3: org.apache.dubbo.common.function.ThrowableAction bootstrap$(org.apache.dubbo.registry.client.EventPublishingServiceDiscovery,org.apache.dubbo.registry.client.ServiceInstance)>(v, v);
v = staticinvoke <java.util.Optional: java.util.Optional empty()>();
virtualinvoke v.<org.apache.dubbo.registry.client.EventPublishingServiceDiscovery: void executeWithEvents(java.util.Optional,org.apache.dubbo.common.function.ThrowableAction,java.util.Optional)>(v, v, v);
return;
}
public final void unregister(org.apache.dubbo.registry.client.ServiceInstance) throws java.lang.RuntimeException
{
org.apache.dubbo.registry.client.event.ServiceInstancePreUnregisteredEvent v;
java.util.Optional v, v;
org.apache.dubbo.registry.client.ServiceInstance v;
org.apache.dubbo.registry.client.EventPublishingServiceDiscovery v;
org.apache.dubbo.registry.client.event.ServiceInstanceUnregisteredEvent v;
org.apache.dubbo.common.function.ThrowableAction v;
v := @this: org.apache.dubbo.registry.client.EventPublishingServiceDiscovery;
v := @parameter: org.apache.dubbo.registry.client.ServiceInstance;
virtualinvoke v.<org.apache.dubbo.registry.client.EventPublishingServiceDiscovery: void assertDestroyed(java.lang.String)>("unregister");
virtualinvoke v.<org.apache.dubbo.registry.client.EventPublishingServiceDiscovery: void assertInitialized(java.lang.String)>("unregister");
v = new org.apache.dubbo.registry.client.event.ServiceInstancePreUnregisteredEvent;
specialinvoke v.<org.apache.dubbo.registry.client.event.ServiceInstancePreUnregisteredEvent: void <init>(java.lang.Object,org.apache.dubbo.registry.client.ServiceInstance)>(v, v);
v = staticinvoke <java.util.Optional: java.util.Optional of(java.lang.Object)>(v);
v = staticinvoke <org.apache.dubbo.registry.client.EventPublishingServiceDiscovery$lambda_unregister_2__4: org.apache.dubbo.common.function.ThrowableAction bootstrap$(org.apache.dubbo.registry.client.EventPublishingServiceDiscovery,org.apache.dubbo.registry.client.ServiceInstance)>(v, v);
v = new org.apache.dubbo.registry.client.event.ServiceInstanceUnregisteredEvent;
specialinvoke v.<org.apache.dubbo.registry.client.event.ServiceInstanceUnregisteredEvent: void <init>(java.lang.Object,org.apache.dubbo.registry.client.ServiceInstance)>(v, v);
v = staticinvoke <java.util.Optional: java.util.Optional of(java.lang.Object)>(v);
virtualinvoke v.<org.apache.dubbo.registry.client.EventPublishingServiceDiscovery: void executeWithEvents(java.util.Optional,org.apache.dubbo.common.function.ThrowableAction,java.util.Optional)>(v, v, v);
return;
}
public java.util.Set getServices()
{
org.apache.dubbo.registry.client.ServiceDiscovery v;
java.util.Set v;
org.apache.dubbo.registry.client.EventPublishingServiceDiscovery v;
v := @this: org.apache.dubbo.registry.client.EventPublishingServiceDiscovery;
v = v.<org.apache.dubbo.registry.client.EventPublishingServiceDiscovery: org.apache.dubbo.registry.client.ServiceDiscovery serviceDiscovery>;
v = interfaceinvoke v.<org.apache.dubbo.registry.client.ServiceDiscovery: java.util.Set getServices()>();
return v;
}
public java.util.List getInstances(java.lang.String) throws java.lang.NullPointerException
{
java.util.List v;
org.apache.dubbo.registry.client.ServiceDiscovery v;
java.lang.String v;
org.apache.dubbo.registry.client.EventPublishingServiceDiscovery v;
v := @this: org.apache.dubbo.registry.client.EventPublishingServiceDiscovery;
v := @parameter: java.lang.String;
v = v.<org.apache.dubbo.registry.client.EventPublishingServiceDiscovery: org.apache.dubbo.registry.client.ServiceDiscovery serviceDiscovery>;
v = interfaceinvoke v.<org.apache.dubbo.registry.client.ServiceDiscovery: java.util.List getInstances(java.lang.String)>(v);
return v;
}
public org.apache.dubbo.common.utils.Page getInstances(java.lang.String, int, int) throws java.lang.NullPointerException, java.lang.IllegalArgumentException
{
org.apache.dubbo.common.utils.Page v;
int v, v;
org.apache.dubbo.registry.client.ServiceDiscovery v;
java.lang.String v;
org.apache.dubbo.registry.client.EventPublishingServiceDiscovery v;
v := @this: org.apache.dubbo.registry.client.EventPublishingServiceDiscovery;
v := @parameter: java.lang.String;
v := @parameter: int;
v := @parameter: int;
v = v.<org.apache.dubbo.registry.client.EventPublishingServiceDiscovery: org.apache.dubbo.registry.client.ServiceDiscovery serviceDiscovery>;
v = interfaceinvoke v.<org.apache.dubbo.registry.client.ServiceDiscovery: org.apache.dubbo.common.utils.Page getInstances(java.lang.String,int,int)>(v, v, v);
return v;
}
public org.apache.dubbo.common.utils.Page getInstances(java.lang.String, int, int, boolean) throws java.lang.NullPointerException, java.lang.IllegalArgumentException
{
org.apache.dubbo.common.utils.Page v;
int v, v;
org.apache.dubbo.registry.client.ServiceDiscovery v;
java.lang.String v;
org.apache.dubbo.registry.client.EventPublishingServiceDiscovery v;
boolean v;
v := @this: org.apache.dubbo.registry.client.EventPublishingServiceDiscovery;
v := @parameter: java.lang.String;
v := @parameter: int;
v := @parameter: int;
v := @parameter: boolean;
v = v.<org.apache.dubbo.registry.client.EventPublishingServiceDiscovery: org.apache.dubbo.registry.client.ServiceDiscovery serviceDiscovery>;
v = interfaceinvoke v.<org.apache.dubbo.registry.client.ServiceDiscovery: org.apache.dubbo.common.utils.Page getInstances(java.lang.String,int,int,boolean)>(v, v, v, v);
return v;
}
public java.util.Map getInstances(java.lang.Iterable, int, int) throws java.lang.NullPointerException, java.lang.IllegalArgumentException
{
java.util.Map v;
int v, v;
org.apache.dubbo.registry.client.ServiceDiscovery v;
org.apache.dubbo.registry.client.EventPublishingServiceDiscovery v;
java.lang.Iterable v;
v := @this: org.apache.dubbo.registry.client.EventPublishingServiceDiscovery;
v := @parameter: java.lang.Iterable;
v := @parameter: int;
v := @parameter: int;
v = v.<org.apache.dubbo.registry.client.EventPublishingServiceDiscovery: org.apache.dubbo.registry.client.ServiceDiscovery serviceDiscovery>;
v = interfaceinvoke v.<org.apache.dubbo.registry.client.ServiceDiscovery: java.util.Map getInstances(java.lang.Iterable,int,int)>(v, v, v);
return v;
}
public java.lang.String toString()
{
org.apache.dubbo.registry.client.ServiceDiscovery v;
java.lang.String v;
org.apache.dubbo.registry.client.EventPublishingServiceDiscovery v;
v := @this: org.apache.dubbo.registry.client.EventPublishingServiceDiscovery;
v = v.<org.apache.dubbo.registry.client.EventPublishingServiceDiscovery: org.apache.dubbo.registry.client.ServiceDiscovery serviceDiscovery>;
v = interfaceinvoke v.<org.apache.dubbo.registry.client.ServiceDiscovery: java.lang.String toString()>();
return v;
}
public void addServiceInstancesChangedListener(org.apache.dubbo.registry.client.event.listener.ServiceInstancesChangedListener) throws java.lang.NullPointerException, java.lang.IllegalArgumentException
{
org.apache.dubbo.registry.client.ServiceDiscovery v;
org.apache.dubbo.registry.client.event.listener.ServiceInstancesChangedListener v;
org.apache.dubbo.registry.client.EventPublishingServiceDiscovery v;
org.apache.dubbo.event.EventDispatcher v;
v := @this: org.apache.dubbo.registry.client.EventPublishingServiceDiscovery;
v := @parameter: org.apache.dubbo.registry.client.event.listener.ServiceInstancesChangedListener;
v = v.<org.apache.dubbo.registry.client.EventPublishingServiceDiscovery: org.apache.dubbo.registry.client.ServiceDiscovery serviceDiscovery>;
interfaceinvoke v.<org.apache.dubbo.registry.client.ServiceDiscovery: void addServiceInstancesChangedListener(org.apache.dubbo.registry.client.event.listener.ServiceInstancesChangedListener)>(v);
v = v.<org.apache.dubbo.registry.client.EventPublishingServiceDiscovery: org.apache.dubbo.event.EventDispatcher eventDispatcher>;
interfaceinvoke v.<org.apache.dubbo.event.EventDispatcher: void addEventListener(org.apache.dubbo.event.EventListener)>(v);
return;
}
public org.apache.dubbo.common.URL getUrl()
{
org.apache.dubbo.registry.client.ServiceDiscovery v;
org.apache.dubbo.common.URL v;
org.apache.dubbo.registry.client.EventPublishingServiceDiscovery v;
v := @this: org.apache.dubbo.registry.client.EventPublishingServiceDiscovery;
v = v.<org.apache.dubbo.registry.client.EventPublishingServiceDiscovery: org.apache.dubbo.registry.client.ServiceDiscovery serviceDiscovery>;
v = interfaceinvoke v.<org.apache.dubbo.registry.client.ServiceDiscovery: org.apache.dubbo.common.URL getUrl()>();
return v;
}
public org.apache.dubbo.registry.client.ServiceInstance getLocalInstance()
{
org.apache.dubbo.registry.client.ServiceDiscovery v;
org.apache.dubbo.registry.client.ServiceInstance v;
org.apache.dubbo.registry.client.EventPublishingServiceDiscovery v;
v := @this: org.apache.dubbo.registry.client.EventPublishingServiceDiscovery;
v = v.<org.apache.dubbo.registry.client.EventPublishingServiceDiscovery: org.apache.dubbo.registry.client.ServiceDiscovery serviceDiscovery>;
v = interfaceinvoke v.<org.apache.dubbo.registry.client.ServiceDiscovery: org.apache.dubbo.registry.client.ServiceInstance getLocalInstance()>();
return v;
}
public void initialize(org.apache.dubbo.common.URL)
{
org.apache.dubbo.common.logger.Logger v, v;
org.apache.dubbo.registry.client.event.ServiceDiscoveryInitializedEvent v;
org.apache.dubbo.registry.client.event.ServiceDiscoveryInitializingEvent v;
java.util.concurrent.atomic.AtomicBoolean v;
org.apache.dubbo.common.function.ThrowableAction v;
org.apache.dubbo.common.URL v;
org.apache.dubbo.registry.client.ServiceDiscovery v, v;
java.util.Optional v, v;
org.apache.dubbo.registry.client.EventPublishingServiceDiscovery v;
boolean v, v;
v := @this: org.apache.dubbo.registry.client.EventPublishingServiceDiscovery;
v := @parameter: org.apache.dubbo.common.URL;
virtualinvoke v.<org.apache.dubbo.registry.client.EventPublishingServiceDiscovery: void assertInitialized(java.lang.String)>("initialize");
v = virtualinvoke v.<org.apache.dubbo.registry.client.EventPublishingServiceDiscovery: boolean isInitialized()>();
if v == 0 goto label;
v = v.<org.apache.dubbo.registry.client.EventPublishingServiceDiscovery: org.apache.dubbo.common.logger.Logger logger>;
v = interfaceinvoke v.<org.apache.dubbo.common.logger.Logger: boolean isWarnEnabled()>();
if v == 0 goto label;
v = v.<org.apache.dubbo.registry.client.EventPublishingServiceDiscovery: org.apache.dubbo.common.logger.Logger logger>;
interfaceinvoke v.<org.apache.dubbo.common.logger.Logger: void warn(java.lang.String)>("It\'s ignored to start current ServiceDiscovery, because it has been started.");
label:
return;
label:
v = new org.apache.dubbo.registry.client.event.ServiceDiscoveryInitializingEvent;
v = v.<org.apache.dubbo.registry.client.EventPublishingServiceDiscovery: org.apache.dubbo.registry.client.ServiceDiscovery serviceDiscovery>;
specialinvoke v.<org.apache.dubbo.registry.client.event.ServiceDiscoveryInitializingEvent: void <init>(org.apache.dubbo.registry.client.ServiceDiscovery,org.apache.dubbo.registry.client.ServiceDiscovery)>(v, v);
v = staticinvoke <java.util.Optional: java.util.Optional of(java.lang.Object)>(v);
v = staticinvoke <org.apache.dubbo.registry.client.EventPublishingServiceDiscovery$lambda_initialize_3__5: org.apache.dubbo.common.function.ThrowableAction bootstrap$(org.apache.dubbo.registry.client.EventPublishingServiceDiscovery,org.apache.dubbo.common.URL)>(v, v);
v = new org.apache.dubbo.registry.client.event.ServiceDiscoveryInitializedEvent;
v = v.<org.apache.dubbo.registry.client.EventPublishingServiceDiscovery: org.apache.dubbo.registry.client.ServiceDiscovery serviceDiscovery>;
specialinvoke v.<org.apache.dubbo.registry.client.event.ServiceDiscoveryInitializedEvent: void <init>(org.apache.dubbo.registry.client.ServiceDiscovery,org.apache.dubbo.registry.client.ServiceDiscovery)>(v, v);
v = staticinvoke <java.util.Optional: java.util.Optional of(java.lang.Object)>(v);
virtualinvoke v.<org.apache.dubbo.registry.client.EventPublishingServiceDiscovery: void executeWithEvents(java.util.Optional,org.apache.dubbo.common.function.ThrowableAction,java.util.Optional)>(v, v, v);
v = v.<org.apache.dubbo.registry.client.EventPublishingServiceDiscovery: java.util.concurrent.atomic.AtomicBoolean initialized>;
virtualinvoke v.<java.util.concurrent.atomic.AtomicBoolean: boolean compareAndSet(boolean,boolean)>(0, 1);
return;
}
public void destroy()
{
org.apache.dubbo.registry.client.event.ServiceDiscoveryDestroyingEvent v;
org.apache.dubbo.common.logger.Logger v, v;
java.util.concurrent.atomic.AtomicBoolean v;
org.apache.dubbo.registry.client.event.ServiceDiscoveryDestroyedEvent v;
org.apache.dubbo.common.function.ThrowableAction v;
org.apache.dubbo.registry.client.ServiceDiscovery v, v, v;
java.util.Optional v, v;
org.apache.dubbo.registry.client.EventPublishingServiceDiscovery v;
boolean v, v;
v := @this: org.apache.dubbo.registry.client.EventPublishingServiceDiscovery;
virtualinvoke v.<org.apache.dubbo.registry.client.EventPublishingServiceDiscovery: void assertDestroyed(java.lang.String)>("destroy");
v = virtualinvoke v.<org.apache.dubbo.registry.client.EventPublishingServiceDiscovery: boolean isDestroyed()>();
if v == 0 goto label;
v = v.<org.apache.dubbo.registry.client.EventPublishingServiceDiscovery: org.apache.dubbo.common.logger.Logger logger>;
v = interfaceinvoke v.<org.apache.dubbo.common.logger.Logger: boolean isWarnEnabled()>();
if v == 0 goto label;
v = v.<org.apache.dubbo.registry.client.EventPublishingServiceDiscovery: org.apache.dubbo.common.logger.Logger logger>;
interfaceinvoke v.<org.apache.dubbo.common.logger.Logger: void warn(java.lang.String)>("It\'s ignored to stop current ServiceDiscovery, because it has been stopped.");
label:
return;
label:
v = new org.apache.dubbo.registry.client.event.ServiceDiscoveryDestroyingEvent;
v = v.<org.apache.dubbo.registry.client.EventPublishingServiceDiscovery: org.apache.dubbo.registry.client.ServiceDiscovery serviceDiscovery>;
specialinvoke v.<org.apache.dubbo.registry.client.event.ServiceDiscoveryDestroyingEvent: void <init>(org.apache.dubbo.registry.client.ServiceDiscovery,org.apache.dubbo.registry.client.ServiceDiscovery)>(v, v);
v = staticinvoke <java.util.Optional: java.util.Optional of(java.lang.Object)>(v);
v = v.<org.apache.dubbo.registry.client.EventPublishingServiceDiscovery: org.apache.dubbo.registry.client.ServiceDiscovery serviceDiscovery>;
virtualinvoke v.<java.lang.Object: java.lang.Class getClass()>();
v = staticinvoke <org.apache.dubbo.registry.client.EventPublishingServiceDiscovery$destroy__6: org.apache.dubbo.common.function.ThrowableAction bootstrap$(org.apache.dubbo.registry.client.ServiceDiscovery)>(v);
v = new org.apache.dubbo.registry.client.event.ServiceDiscoveryDestroyedEvent;
v = v.<org.apache.dubbo.registry.client.EventPublishingServiceDiscovery: org.apache.dubbo.registry.client.ServiceDiscovery serviceDiscovery>;
specialinvoke v.<org.apache.dubbo.registry.client.event.ServiceDiscoveryDestroyedEvent: void <init>(org.apache.dubbo.registry.client.ServiceDiscovery,org.apache.dubbo.registry.client.ServiceDiscovery)>(v, v);
v = staticinvoke <java.util.Optional: java.util.Optional of(java.lang.Object)>(v);
virtualinvoke v.<org.apache.dubbo.registry.client.EventPublishingServiceDiscovery: void executeWithEvents(java.util.Optional,org.apache.dubbo.common.function.ThrowableAction,java.util.Optional)>(v, v, v);
v = v.<org.apache.dubbo.registry.client.EventPublishingServiceDiscovery: java.util.concurrent.atomic.AtomicBoolean destroyed>;
virtualinvoke v.<java.util.concurrent.atomic.AtomicBoolean: boolean compareAndSet(boolean,boolean)>(0, 1);
return;
}
protected final void executeWithEvents(java.util.Optional, org.apache.dubbo.common.function.ThrowableAction, java.util.Optional)
{
java.lang.Throwable v;
org.apache.dubbo.registry.client.event.ServiceDiscoveryExceptionEvent v;
org.apache.dubbo.common.function.ThrowableAction v;
java.util.function.Consumer v, v;
org.apache.dubbo.registry.client.ServiceDiscovery v;
java.util.Optional v, v;
org.apache.dubbo.registry.client.EventPublishingServiceDiscovery v;
v := @this: org.apache.dubbo.registry.client.EventPublishingServiceDiscovery;
v := @parameter: java.util.Optional;
v := @parameter: org.apache.dubbo.common.function.ThrowableAction;
v := @parameter: java.util.Optional;
v = staticinvoke <org.apache.dubbo.registry.client.EventPublishingServiceDiscovery$dispatchEvent__7: java.util.function.Consumer bootstrap$(org.apache.dubbo.registry.client.EventPublishingServiceDiscovery)>(v);
virtualinvoke v.<java.util.Optional: void ifPresent(java.util.function.Consumer)>(v);
label:
interfaceinvoke v.<org.apache.dubbo.common.function.ThrowableAction: void execute()>();
label:
goto label;
label:
v := @caughtexception;
v = new org.apache.dubbo.registry.client.event.ServiceDiscoveryExceptionEvent;
v = v.<org.apache.dubbo.registry.client.EventPublishingServiceDiscovery: org.apache.dubbo.registry.client.ServiceDiscovery serviceDiscovery>;
specialinvoke v.<org.apache.dubbo.registry.client.event.ServiceDiscoveryExceptionEvent: void <init>(org.apache.dubbo.registry.client.ServiceDiscovery,org.apache.dubbo.registry.client.ServiceDiscovery,java.lang.Throwable)>(v, v, v);
specialinvoke v.<org.apache.dubbo.registry.client.EventPublishingServiceDiscovery: void dispatchEvent(org.apache.dubbo.event.Event)>(v);
label:
v = staticinvoke <org.apache.dubbo.registry.client.EventPublishingServiceDiscovery$dispatchEvent__8: java.util.function.Consumer bootstrap$(org.apache.dubbo.registry.client.EventPublishingServiceDiscovery)>(v);
virtualinvoke v.<java.util.Optional: void ifPresent(java.util.function.Consumer)>(v);
return;
catch java.lang.Throwable from label to label with label;
}
public void dispatchEvent(org.apache.dubbo.event.Event)
{
org.apache.dubbo.registry.client.EventPublishingServiceDiscovery v;
org.apache.dubbo.event.EventDispatcher v;
org.apache.dubbo.event.Event v;
v := @this: org.apache.dubbo.registry.client.EventPublishingServiceDiscovery;
v := @parameter: org.apache.dubbo.event.Event;
v = v.<org.apache.dubbo.registry.client.EventPublishingServiceDiscovery: org.apache.dubbo.event.EventDispatcher eventDispatcher>;
interfaceinvoke v.<org.apache.dubbo.event.EventDispatcher: void dispatch(org.apache.dubbo.event.Event)>(v);
return;
}
public final boolean isInitialized()
{
java.util.concurrent.atomic.AtomicBoolean v;
org.apache.dubbo.registry.client.EventPublishingServiceDiscovery v;
boolean v;
v := @this: org.apache.dubbo.registry.client.EventPublishingServiceDiscovery;
v = v.<org.apache.dubbo.registry.client.EventPublishingServiceDiscovery: java.util.concurrent.atomic.AtomicBoolean initialized>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicBoolean: boolean get()>();
return v;
}
public final boolean isDestroyed()
{
java.util.concurrent.atomic.AtomicBoolean v;
org.apache.dubbo.registry.client.EventPublishingServiceDiscovery v;
boolean v;
v := @this: org.apache.dubbo.registry.client.EventPublishingServiceDiscovery;
v = v.<org.apache.dubbo.registry.client.EventPublishingServiceDiscovery: java.util.concurrent.atomic.AtomicBoolean destroyed>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicBoolean: boolean get()>();
return v;
}
protected void assertDestroyed(java.lang.String) throws java.lang.IllegalStateException
{
java.lang.IllegalStateException v;
java.lang.String v, v;
org.apache.dubbo.registry.client.EventPublishingServiceDiscovery v;
boolean v;
v := @this: org.apache.dubbo.registry.client.EventPublishingServiceDiscovery;
v := @parameter: java.lang.String;
v = virtualinvoke v.<org.apache.dubbo.registry.client.EventPublishingServiceDiscovery: boolean isInitialized()>();
if v != 0 goto label;
v = new java.lang.IllegalStateException;
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[])>("The action[\u] is rejected, because the ServiceDiscovery is not initialized yet.");
specialinvoke v.<java.lang.IllegalStateException: void <init>(java.lang.String)>(v);
throw v;
label:
return;
}
protected void assertInitialized(java.lang.String) throws java.lang.IllegalStateException
{
java.lang.IllegalStateException v;
java.lang.String v, v;
org.apache.dubbo.registry.client.EventPublishingServiceDiscovery v;
boolean v;
v := @this: org.apache.dubbo.registry.client.EventPublishingServiceDiscovery;
v := @parameter: java.lang.String;
v = virtualinvoke v.<org.apache.dubbo.registry.client.EventPublishingServiceDiscovery: boolean isDestroyed()>();
if v == 0 goto label;
v = new java.lang.IllegalStateException;
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[])>("The action[\u] is rejected, because the ServiceDiscovery is destroyed already.");
specialinvoke v.<java.lang.IllegalStateException: void <init>(java.lang.String)>(v);
throw v;
label:
return;
}
}