public class org.apache.dubbo.configcenter.support.zookeeper.ZookeeperDynamicConfiguration extends org.apache.dubbo.common.config.configcenter.TreePathDynamicConfiguration
{
private java.util.concurrent.Executor executor;
private java.lang.String rootPath;
private final org.apache.dubbo.remoting.zookeeper.ZookeeperClient zkClient;
private java.util.concurrent.CountDownLatch initializedLatch;
private org.apache.dubbo.configcenter.support.zookeeper.CacheListener cacheListener;
private org.apache.dubbo.common.URL url;
void <init>(org.apache.dubbo.common.URL, org.apache.dubbo.remoting.zookeeper.ZookeeperTransporter)
{
java.lang.IllegalStateException v;
org.apache.dubbo.remoting.zookeeper.ZookeeperTransporter v;
org.apache.dubbo.common.utils.NamedThreadFactory v;
org.apache.dubbo.common.URL v;
org.apache.dubbo.configcenter.support.zookeeper.CacheListener v, v;
int v;
org.apache.dubbo.remoting.zookeeper.ZookeeperClient v, v;
java.lang.String v, v, v, v, v, v;
java.util.concurrent.ExecutorService v;
boolean v;
java.util.concurrent.Executor v;
org.apache.dubbo.common.logger.Logger v;
java.util.concurrent.TimeUnit v;
java.util.concurrent.CountDownLatch v, v, v;
java.lang.InterruptedException v;
java.lang.Class v;
org.apache.dubbo.configcenter.support.zookeeper.ZookeeperDynamicConfiguration v;
v := @this: org.apache.dubbo.configcenter.support.zookeeper.ZookeeperDynamicConfiguration;
v := @parameter: org.apache.dubbo.common.URL;
v := @parameter: org.apache.dubbo.remoting.zookeeper.ZookeeperTransporter;
specialinvoke v.<org.apache.dubbo.common.config.configcenter.TreePathDynamicConfiguration: void <init>(org.apache.dubbo.common.URL)>(v);
v.<org.apache.dubbo.configcenter.support.zookeeper.ZookeeperDynamicConfiguration: org.apache.dubbo.common.URL url> = v;
v = virtualinvoke v.<org.apache.dubbo.configcenter.support.zookeeper.ZookeeperDynamicConfiguration: java.lang.String getRootPath(org.apache.dubbo.common.URL)>(v);
v.<org.apache.dubbo.configcenter.support.zookeeper.ZookeeperDynamicConfiguration: java.lang.String rootPath> = v;
v = new java.util.concurrent.CountDownLatch;
specialinvoke v.<java.util.concurrent.CountDownLatch: void <init>(int)>(1);
v.<org.apache.dubbo.configcenter.support.zookeeper.ZookeeperDynamicConfiguration: java.util.concurrent.CountDownLatch initializedLatch> = v;
v = new org.apache.dubbo.configcenter.support.zookeeper.CacheListener;
v = v.<org.apache.dubbo.configcenter.support.zookeeper.ZookeeperDynamicConfiguration: java.lang.String rootPath>;
v = v.<org.apache.dubbo.configcenter.support.zookeeper.ZookeeperDynamicConfiguration: java.util.concurrent.CountDownLatch initializedLatch>;
specialinvoke v.<org.apache.dubbo.configcenter.support.zookeeper.CacheListener: void <init>(java.lang.String,java.util.concurrent.CountDownLatch)>(v, v);
v.<org.apache.dubbo.configcenter.support.zookeeper.ZookeeperDynamicConfiguration: org.apache.dubbo.configcenter.support.zookeeper.CacheListener cacheListener> = v;
v = new org.apache.dubbo.common.utils.NamedThreadFactory;
v = virtualinvoke v.<java.lang.Object: java.lang.Class getClass()>();
v = virtualinvoke v.<java.lang.Class: java.lang.String getSimpleName()>();
specialinvoke v.<org.apache.dubbo.common.utils.NamedThreadFactory: void <init>(java.lang.String,boolean)>(v, 1);
v = staticinvoke <java.util.concurrent.Executors: java.util.concurrent.ExecutorService newFixedThreadPool(int,java.util.concurrent.ThreadFactory)>(1, v);
v.<org.apache.dubbo.configcenter.support.zookeeper.ZookeeperDynamicConfiguration: java.util.concurrent.Executor executor> = v;
v = interfaceinvoke v.<org.apache.dubbo.remoting.zookeeper.ZookeeperTransporter: org.apache.dubbo.remoting.zookeeper.ZookeeperClient connect(org.apache.dubbo.common.URL)>(v);
v.<org.apache.dubbo.configcenter.support.zookeeper.ZookeeperDynamicConfiguration: org.apache.dubbo.remoting.zookeeper.ZookeeperClient zkClient> = v;
v = v.<org.apache.dubbo.configcenter.support.zookeeper.ZookeeperDynamicConfiguration: org.apache.dubbo.remoting.zookeeper.ZookeeperClient zkClient>;
v = v.<org.apache.dubbo.configcenter.support.zookeeper.ZookeeperDynamicConfiguration: java.lang.String rootPath>;
v = v.<org.apache.dubbo.configcenter.support.zookeeper.ZookeeperDynamicConfiguration: org.apache.dubbo.configcenter.support.zookeeper.CacheListener cacheListener>;
v = v.<org.apache.dubbo.configcenter.support.zookeeper.ZookeeperDynamicConfiguration: java.util.concurrent.Executor executor>;
interfaceinvoke v.<org.apache.dubbo.remoting.zookeeper.ZookeeperClient: void addDataListener(java.lang.String,org.apache.dubbo.remoting.zookeeper.DataListener,java.util.concurrent.Executor)>(v, v, v);
label:
v = virtualinvoke v.<org.apache.dubbo.common.URL: int getParameter(java.lang.String,int)>("init.timeout", 5000);
v = v.<org.apache.dubbo.configcenter.support.zookeeper.ZookeeperDynamicConfiguration: java.util.concurrent.CountDownLatch initializedLatch>;
v = <java.util.concurrent.TimeUnit: java.util.concurrent.TimeUnit MILLISECONDS>;
v = virtualinvoke v.<java.util.concurrent.CountDownLatch: boolean await(long,java.util.concurrent.TimeUnit)>(v, v);
if v != 0 goto label;
v = new java.lang.IllegalStateException;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (org.apache.dubbo.common.URL)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Failed to receive INITIALIZED event from zookeeper, pls. check if url \u is correct");
specialinvoke v.<java.lang.IllegalStateException: void <init>(java.lang.String)>(v);
throw v;
label:
v := @caughtexception;
v = v.<org.apache.dubbo.configcenter.support.zookeeper.ZookeeperDynamicConfiguration: org.apache.dubbo.common.logger.Logger logger>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (org.apache.dubbo.common.URL)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Failed to build local cache for config center (zookeeper).\u0001");
interfaceinvoke v.<org.apache.dubbo.common.logger.Logger: void warn(java.lang.String)>(v);
label:
return;
catch java.lang.InterruptedException from label to label with label;
}
public java.lang.String getInternalProperty(java.lang.String)
{
org.apache.dubbo.remoting.zookeeper.ZookeeperClient v;
java.lang.String v, v, v;
org.apache.dubbo.configcenter.support.zookeeper.ZookeeperDynamicConfiguration v;
v := @this: org.apache.dubbo.configcenter.support.zookeeper.ZookeeperDynamicConfiguration;
v := @parameter: java.lang.String;
v = v.<org.apache.dubbo.configcenter.support.zookeeper.ZookeeperDynamicConfiguration: org.apache.dubbo.remoting.zookeeper.ZookeeperClient zkClient>;
v = virtualinvoke v.<org.apache.dubbo.configcenter.support.zookeeper.ZookeeperDynamicConfiguration: java.lang.String buildPathKey(java.lang.String,java.lang.String)>("", v);
v = interfaceinvoke v.<org.apache.dubbo.remoting.zookeeper.ZookeeperClient: java.lang.String getContent(java.lang.String)>(v);
return v;
}
protected void doClose() throws java.lang.Exception
{
org.apache.dubbo.remoting.zookeeper.ZookeeperClient v;
org.apache.dubbo.configcenter.support.zookeeper.ZookeeperDynamicConfiguration v;
v := @this: org.apache.dubbo.configcenter.support.zookeeper.ZookeeperDynamicConfiguration;
v = v.<org.apache.dubbo.configcenter.support.zookeeper.ZookeeperDynamicConfiguration: org.apache.dubbo.remoting.zookeeper.ZookeeperClient zkClient>;
interfaceinvoke v.<org.apache.dubbo.remoting.zookeeper.ZookeeperClient: void close()>();
return;
}
protected boolean doPublishConfig(java.lang.String, java.lang.String) throws java.lang.Exception
{
org.apache.dubbo.remoting.zookeeper.ZookeeperClient v;
java.lang.String v, v;
org.apache.dubbo.configcenter.support.zookeeper.ZookeeperDynamicConfiguration v;
v := @this: org.apache.dubbo.configcenter.support.zookeeper.ZookeeperDynamicConfiguration;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v = v.<org.apache.dubbo.configcenter.support.zookeeper.ZookeeperDynamicConfiguration: org.apache.dubbo.remoting.zookeeper.ZookeeperClient zkClient>;
interfaceinvoke v.<org.apache.dubbo.remoting.zookeeper.ZookeeperClient: void create(java.lang.String,java.lang.String,boolean)>(v, v, 0);
return 1;
}
protected java.lang.String doGetConfig(java.lang.String) throws java.lang.Exception
{
org.apache.dubbo.remoting.zookeeper.ZookeeperClient v;
java.lang.String v, v;
org.apache.dubbo.configcenter.support.zookeeper.ZookeeperDynamicConfiguration v;
v := @this: org.apache.dubbo.configcenter.support.zookeeper.ZookeeperDynamicConfiguration;
v := @parameter: java.lang.String;
v = v.<org.apache.dubbo.configcenter.support.zookeeper.ZookeeperDynamicConfiguration: org.apache.dubbo.remoting.zookeeper.ZookeeperClient zkClient>;
v = interfaceinvoke v.<org.apache.dubbo.remoting.zookeeper.ZookeeperClient: java.lang.String getContent(java.lang.String)>(v);
return v;
}
protected boolean doRemoveConfig(java.lang.String) throws java.lang.Exception
{
org.apache.dubbo.remoting.zookeeper.ZookeeperClient v;
java.lang.String v;
org.apache.dubbo.configcenter.support.zookeeper.ZookeeperDynamicConfiguration v;
v := @this: org.apache.dubbo.configcenter.support.zookeeper.ZookeeperDynamicConfiguration;
v := @parameter: java.lang.String;
v = v.<org.apache.dubbo.configcenter.support.zookeeper.ZookeeperDynamicConfiguration: org.apache.dubbo.remoting.zookeeper.ZookeeperClient zkClient>;
interfaceinvoke v.<org.apache.dubbo.remoting.zookeeper.ZookeeperClient: void delete(java.lang.String)>(v);
return 1;
}
protected java.util.Collection doGetConfigKeys(java.lang.String)
{
java.util.List v;
org.apache.dubbo.remoting.zookeeper.ZookeeperClient v;
java.lang.String v;
org.apache.dubbo.configcenter.support.zookeeper.ZookeeperDynamicConfiguration v;
v := @this: org.apache.dubbo.configcenter.support.zookeeper.ZookeeperDynamicConfiguration;
v := @parameter: java.lang.String;
v = v.<org.apache.dubbo.configcenter.support.zookeeper.ZookeeperDynamicConfiguration: org.apache.dubbo.remoting.zookeeper.ZookeeperClient zkClient>;
v = interfaceinvoke v.<org.apache.dubbo.remoting.zookeeper.ZookeeperClient: java.util.List getChildren(java.lang.String)>(v);
return v;
}
protected void doAddListener(java.lang.String, org.apache.dubbo.common.config.configcenter.ConfigurationListener)
{
org.apache.dubbo.common.config.configcenter.ConfigurationListener v;
org.apache.dubbo.configcenter.support.zookeeper.CacheListener v;
java.lang.String v;
org.apache.dubbo.configcenter.support.zookeeper.ZookeeperDynamicConfiguration v;
v := @this: org.apache.dubbo.configcenter.support.zookeeper.ZookeeperDynamicConfiguration;
v := @parameter: java.lang.String;
v := @parameter: org.apache.dubbo.common.config.configcenter.ConfigurationListener;
v = v.<org.apache.dubbo.configcenter.support.zookeeper.ZookeeperDynamicConfiguration: org.apache.dubbo.configcenter.support.zookeeper.CacheListener cacheListener>;
virtualinvoke v.<org.apache.dubbo.configcenter.support.zookeeper.CacheListener: void addListener(java.lang.String,org.apache.dubbo.common.config.configcenter.ConfigurationListener)>(v, v);
return;
}
protected void doRemoveListener(java.lang.String, org.apache.dubbo.common.config.configcenter.ConfigurationListener)
{
org.apache.dubbo.common.config.configcenter.ConfigurationListener v;
org.apache.dubbo.configcenter.support.zookeeper.CacheListener v;
java.lang.String v;
org.apache.dubbo.configcenter.support.zookeeper.ZookeeperDynamicConfiguration v;
v := @this: org.apache.dubbo.configcenter.support.zookeeper.ZookeeperDynamicConfiguration;
v := @parameter: java.lang.String;
v := @parameter: org.apache.dubbo.common.config.configcenter.ConfigurationListener;
v = v.<org.apache.dubbo.configcenter.support.zookeeper.ZookeeperDynamicConfiguration: org.apache.dubbo.configcenter.support.zookeeper.CacheListener cacheListener>;
virtualinvoke v.<org.apache.dubbo.configcenter.support.zookeeper.CacheListener: void removeListener(java.lang.String,org.apache.dubbo.common.config.configcenter.ConfigurationListener)>(v, v);
return;
}
}