public class org.apache.dubbo.remoting.zookeeper.curator.CuratorZookeeperClient extends org.apache.dubbo.remoting.zookeeper.support.AbstractZookeeperClient
{
protected static final org.apache.dubbo.common.logger.Logger logger;
private static final java.lang.String ZK_SESSION_EXPIRE_KEY;
static final java.nio.charset.Charset CHARSET;
private final org.apache.curator.framework.CuratorFramework client;
private java.util.Map treeCacheMap;
public void <init>(org.apache.dubbo.common.URL)
{
byte[] v;
java.lang.IllegalStateException v, v;
org.apache.dubbo.remoting.zookeeper.curator.CuratorZookeeperClient$CuratorConnectionStateListener v;
org.apache.dubbo.common.URL v;
int v, v, v, v, v;
org.apache.curator.framework.listen.Listenable v;
org.apache.curator.framework.CuratorFrameworkFactory$Builder v, v, v, v, v;
java.lang.String v, v, v;
boolean v;
java.util.concurrent.ConcurrentHashMap v;
java.lang.Exception v;
java.util.concurrent.TimeUnit v;
org.apache.curator.framework.CuratorFramework v, v, v, v;
org.apache.dubbo.remoting.zookeeper.curator.CuratorZookeeperClient v;
org.apache.curator.retry.RetryNTimes v;
v := @this: org.apache.dubbo.remoting.zookeeper.curator.CuratorZookeeperClient;
v := @parameter: org.apache.dubbo.common.URL;
specialinvoke v.<org.apache.dubbo.remoting.zookeeper.support.AbstractZookeeperClient: void <init>(org.apache.dubbo.common.URL)>(v);
v = new java.util.concurrent.ConcurrentHashMap;
specialinvoke v.<java.util.concurrent.ConcurrentHashMap: void <init>()>();
v.<org.apache.dubbo.remoting.zookeeper.curator.CuratorZookeeperClient: java.util.Map treeCacheMap> = v;
label:
v = v.<org.apache.dubbo.remoting.zookeeper.curator.CuratorZookeeperClient: int DEFAULT_CONNECTION_TIMEOUT_MS>;
v = virtualinvoke v.<org.apache.dubbo.common.URL: int getParameter(java.lang.String,int)>("timeout", v);
v = v.<org.apache.dubbo.remoting.zookeeper.curator.CuratorZookeeperClient: int DEFAULT_SESSION_TIMEOUT_MS>;
v = virtualinvoke v.<org.apache.dubbo.common.URL: int getParameter(java.lang.String,int)>("zk.session.expire", v);
v = staticinvoke <org.apache.curator.framework.CuratorFrameworkFactory: org.apache.curator.framework.CuratorFrameworkFactory$Builder builder()>();
v = virtualinvoke v.<org.apache.dubbo.common.URL: java.lang.String getBackupAddress()>();
v = virtualinvoke v.<org.apache.curator.framework.CuratorFrameworkFactory$Builder: org.apache.curator.framework.CuratorFrameworkFactory$Builder connectString(java.lang.String)>(v);
v = new org.apache.curator.retry.RetryNTimes;
specialinvoke v.<org.apache.curator.retry.RetryNTimes: void <init>(int,int)>(1, 1000);
v = virtualinvoke v.<org.apache.curator.framework.CuratorFrameworkFactory$Builder: org.apache.curator.framework.CuratorFrameworkFactory$Builder retryPolicy(org.apache.curator.RetryPolicy)>(v);
v = virtualinvoke v.<org.apache.curator.framework.CuratorFrameworkFactory$Builder: org.apache.curator.framework.CuratorFrameworkFactory$Builder connectionTimeoutMs(int)>(v);
v = virtualinvoke v.<org.apache.curator.framework.CuratorFrameworkFactory$Builder: org.apache.curator.framework.CuratorFrameworkFactory$Builder sessionTimeoutMs(int)>(v);
v = virtualinvoke v.<org.apache.dubbo.common.URL: java.lang.String getAuthority()>();
if v == null goto label;
v = virtualinvoke v.<java.lang.String: int length()>();
if v <= 0 goto label;
v = virtualinvoke v.<java.lang.String: byte[] getBytes()>();
v = virtualinvoke v.<org.apache.curator.framework.CuratorFrameworkFactory$Builder: org.apache.curator.framework.CuratorFrameworkFactory$Builder authorization(java.lang.String,byte[])>("digest", v);
label:
v = virtualinvoke v.<org.apache.curator.framework.CuratorFrameworkFactory$Builder: org.apache.curator.framework.CuratorFramework build()>();
v.<org.apache.dubbo.remoting.zookeeper.curator.CuratorZookeeperClient: org.apache.curator.framework.CuratorFramework client> = v;
v = v.<org.apache.dubbo.remoting.zookeeper.curator.CuratorZookeeperClient: org.apache.curator.framework.CuratorFramework client>;
v = interfaceinvoke v.<org.apache.curator.framework.CuratorFramework: org.apache.curator.framework.listen.Listenable getConnectionStateListenable()>();
v = new org.apache.dubbo.remoting.zookeeper.curator.CuratorZookeeperClient$CuratorConnectionStateListener;
specialinvoke v.<org.apache.dubbo.remoting.zookeeper.curator.CuratorZookeeperClient$CuratorConnectionStateListener: void <init>(org.apache.dubbo.remoting.zookeeper.curator.CuratorZookeeperClient,org.apache.dubbo.common.URL)>(v, v);
interfaceinvoke v.<org.apache.curator.framework.listen.Listenable: void addListener(java.lang.Object)>(v);
v = v.<org.apache.dubbo.remoting.zookeeper.curator.CuratorZookeeperClient: org.apache.curator.framework.CuratorFramework client>;
interfaceinvoke v.<org.apache.curator.framework.CuratorFramework: void start()>();
v = v.<org.apache.dubbo.remoting.zookeeper.curator.CuratorZookeeperClient: org.apache.curator.framework.CuratorFramework client>;
v = <java.util.concurrent.TimeUnit: java.util.concurrent.TimeUnit MILLISECONDS>;
v = interfaceinvoke v.<org.apache.curator.framework.CuratorFramework: boolean blockUntilConnected(int,java.util.concurrent.TimeUnit)>(v, v);
if v != 0 goto label;
v = new java.lang.IllegalStateException;
specialinvoke v.<java.lang.IllegalStateException: void <init>(java.lang.String)>("zookeeper not connected");
throw v;
label:
v := @caughtexception;
v = new java.lang.IllegalStateException;
v = virtualinvoke v.<java.lang.Exception: java.lang.String getMessage()>();
specialinvoke v.<java.lang.IllegalStateException: void <init>(java.lang.String,java.lang.Throwable)>(v, v);
throw v;
label:
return;
catch java.lang.Exception from label to label with label;
}
public void createPersistent(java.lang.String)
{
java.lang.Throwable v;
java.lang.IllegalStateException v;
org.apache.curator.framework.api.CreateBuilder v;
org.apache.dubbo.common.logger.Logger v;
java.lang.Exception v;
org.apache.curator.framework.CuratorFramework v;
java.lang.String v, v, v;
org.apache.dubbo.remoting.zookeeper.curator.CuratorZookeeperClient v;
v := @this: org.apache.dubbo.remoting.zookeeper.curator.CuratorZookeeperClient;
v := @parameter: java.lang.String;
label:
v = v.<org.apache.dubbo.remoting.zookeeper.curator.CuratorZookeeperClient: org.apache.curator.framework.CuratorFramework client>;
v = interfaceinvoke v.<org.apache.curator.framework.CuratorFramework: org.apache.curator.framework.api.CreateBuilder create()>();
interfaceinvoke v.<org.apache.curator.framework.api.CreateBuilder: java.lang.Object forPath(java.lang.String)>(v);
label:
goto label;
label:
v := @caughtexception;
v = <org.apache.dubbo.remoting.zookeeper.curator.CuratorZookeeperClient: org.apache.dubbo.common.logger.Logger logger>;
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[])>("ZNode \u already exists.");
interfaceinvoke v.<org.apache.dubbo.common.logger.Logger: void warn(java.lang.String,java.lang.Throwable)>(v, v);
goto label;
label:
v := @caughtexception;
v = new java.lang.IllegalStateException;
v = virtualinvoke v.<java.lang.Exception: java.lang.String getMessage()>();
specialinvoke v.<java.lang.IllegalStateException: void <init>(java.lang.String,java.lang.Throwable)>(v, v);
throw v;
label:
return;
catch org.apache.zookeeper.KeeperException$NodeExistsException from label to label with label;
catch java.lang.Exception from label to label with label;
}
public void createEphemeral(java.lang.String)
{
java.lang.Throwable v;
org.apache.zookeeper.CreateMode v;
java.lang.IllegalStateException v;
org.apache.curator.framework.api.CreateBuilder v;
org.apache.dubbo.common.logger.Logger v;
java.lang.Exception v;
org.apache.curator.framework.CuratorFramework v;
java.lang.Object v;
java.lang.String v, v, v;
org.apache.dubbo.remoting.zookeeper.curator.CuratorZookeeperClient v;
v := @this: org.apache.dubbo.remoting.zookeeper.curator.CuratorZookeeperClient;
v := @parameter: java.lang.String;
label:
v = v.<org.apache.dubbo.remoting.zookeeper.curator.CuratorZookeeperClient: org.apache.curator.framework.CuratorFramework client>;
v = interfaceinvoke v.<org.apache.curator.framework.CuratorFramework: org.apache.curator.framework.api.CreateBuilder create()>();
v = <org.apache.zookeeper.CreateMode: org.apache.zookeeper.CreateMode EPHEMERAL>;
v = interfaceinvoke v.<org.apache.curator.framework.api.CreateBuilder: java.lang.Object withMode(org.apache.zookeeper.CreateMode)>(v);
interfaceinvoke v.<org.apache.curator.framework.api.ACLBackgroundPathAndBytesable: java.lang.Object forPath(java.lang.String)>(v);
label:
goto label;
label:
v := @caughtexception;
v = <org.apache.dubbo.remoting.zookeeper.curator.CuratorZookeeperClient: org.apache.dubbo.common.logger.Logger logger>;
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[])>("ZNode \u already exists, since we will only try to recreate a node on a session expiration, this duplication might be caused by a delete delay from the zk server, which means the old expired session may still holds this ZNode and the server just hasn\'t got time to do the deletion. In this case, we can just try to delete and create again.");
interfaceinvoke v.<org.apache.dubbo.common.logger.Logger: void warn(java.lang.String,java.lang.Throwable)>(v, v);
virtualinvoke v.<org.apache.dubbo.remoting.zookeeper.curator.CuratorZookeeperClient: void deletePath(java.lang.String)>(v);
virtualinvoke v.<org.apache.dubbo.remoting.zookeeper.curator.CuratorZookeeperClient: void createEphemeral(java.lang.String)>(v);
goto label;
label:
v := @caughtexception;
v = new java.lang.IllegalStateException;
v = virtualinvoke v.<java.lang.Exception: java.lang.String getMessage()>();
specialinvoke v.<java.lang.IllegalStateException: void <init>(java.lang.String,java.lang.Throwable)>(v, v);
throw v;
label:
return;
catch org.apache.zookeeper.KeeperException$NodeExistsException from label to label with label;
catch java.lang.Exception from label to label with label;
}
protected void createPersistent(java.lang.String, java.lang.String)
{
java.lang.Throwable v;
byte[] v;
java.lang.IllegalStateException v, v;
org.apache.curator.framework.api.CreateBuilder v;
org.apache.curator.framework.api.SetDataBuilder v;
java.nio.charset.Charset v;
java.lang.String v, v, v, v;
java.lang.Exception v, v;
org.apache.curator.framework.CuratorFramework v, v;
org.apache.dubbo.remoting.zookeeper.curator.CuratorZookeeperClient v;
v := @this: org.apache.dubbo.remoting.zookeeper.curator.CuratorZookeeperClient;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v = <org.apache.dubbo.remoting.zookeeper.curator.CuratorZookeeperClient: java.nio.charset.Charset CHARSET>;
v = virtualinvoke v.<java.lang.String: byte[] getBytes(java.nio.charset.Charset)>(v);
label:
v = v.<org.apache.dubbo.remoting.zookeeper.curator.CuratorZookeeperClient: org.apache.curator.framework.CuratorFramework client>;
v = interfaceinvoke v.<org.apache.curator.framework.CuratorFramework: org.apache.curator.framework.api.CreateBuilder create()>();
interfaceinvoke v.<org.apache.curator.framework.api.CreateBuilder: java.lang.Object forPath(java.lang.String,byte[])>(v, v);
label:
goto label;
label:
v := @caughtexception;
label:
v = v.<org.apache.dubbo.remoting.zookeeper.curator.CuratorZookeeperClient: org.apache.curator.framework.CuratorFramework client>;
v = interfaceinvoke v.<org.apache.curator.framework.CuratorFramework: org.apache.curator.framework.api.SetDataBuilder setData()>();
interfaceinvoke v.<org.apache.curator.framework.api.SetDataBuilder: java.lang.Object forPath(java.lang.String,byte[])>(v, v);
label:
goto label;
label:
v := @caughtexception;
v = new java.lang.IllegalStateException;
v = virtualinvoke v.<org.apache.zookeeper.KeeperException$NodeExistsException: java.lang.String getMessage()>();
specialinvoke v.<java.lang.IllegalStateException: void <init>(java.lang.String,java.lang.Throwable)>(v, v);
throw v;
label:
v := @caughtexception;
v = new java.lang.IllegalStateException;
v = virtualinvoke v.<java.lang.Exception: java.lang.String getMessage()>();
specialinvoke v.<java.lang.IllegalStateException: void <init>(java.lang.String,java.lang.Throwable)>(v, v);
throw v;
label:
return;
catch org.apache.zookeeper.KeeperException$NodeExistsException from label to label with label;
catch java.lang.Exception from label to label with label;
catch java.lang.Exception from label to label with label;
}
protected void createEphemeral(java.lang.String, java.lang.String)
{
java.lang.Throwable v;
org.apache.zookeeper.CreateMode v;
byte[] v;
java.lang.IllegalStateException v;
org.apache.curator.framework.api.CreateBuilder v;
org.apache.dubbo.common.logger.Logger v;
java.lang.Exception v;
org.apache.curator.framework.CuratorFramework v;
java.nio.charset.Charset v;
java.lang.Object v;
java.lang.String v, v, v, v;
org.apache.dubbo.remoting.zookeeper.curator.CuratorZookeeperClient v;
v := @this: org.apache.dubbo.remoting.zookeeper.curator.CuratorZookeeperClient;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v = <org.apache.dubbo.remoting.zookeeper.curator.CuratorZookeeperClient: java.nio.charset.Charset CHARSET>;
v = virtualinvoke v.<java.lang.String: byte[] getBytes(java.nio.charset.Charset)>(v);
label:
v = v.<org.apache.dubbo.remoting.zookeeper.curator.CuratorZookeeperClient: org.apache.curator.framework.CuratorFramework client>;
v = interfaceinvoke v.<org.apache.curator.framework.CuratorFramework: org.apache.curator.framework.api.CreateBuilder create()>();
v = <org.apache.zookeeper.CreateMode: org.apache.zookeeper.CreateMode EPHEMERAL>;
v = interfaceinvoke v.<org.apache.curator.framework.api.CreateBuilder: java.lang.Object withMode(org.apache.zookeeper.CreateMode)>(v);
interfaceinvoke v.<org.apache.curator.framework.api.ACLBackgroundPathAndBytesable: java.lang.Object forPath(java.lang.String,byte[])>(v, v);
label:
goto label;
label:
v := @caughtexception;
v = <org.apache.dubbo.remoting.zookeeper.curator.CuratorZookeeperClient: org.apache.dubbo.common.logger.Logger logger>;
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[])>("ZNode \u already exists, since we will only try to recreate a node on a session expiration, this duplication might be caused by a delete delay from the zk server, which means the old expired session may still holds this ZNode and the server just hasn\'t got time to do the deletion. In this case, we can just try to delete and create again.");
interfaceinvoke v.<org.apache.dubbo.common.logger.Logger: void warn(java.lang.String,java.lang.Throwable)>(v, v);
virtualinvoke v.<org.apache.dubbo.remoting.zookeeper.curator.CuratorZookeeperClient: void deletePath(java.lang.String)>(v);
virtualinvoke v.<org.apache.dubbo.remoting.zookeeper.curator.CuratorZookeeperClient: void createEphemeral(java.lang.String,java.lang.String)>(v, v);
goto label;
label:
v := @caughtexception;
v = new java.lang.IllegalStateException;
v = virtualinvoke v.<java.lang.Exception: java.lang.String getMessage()>();
specialinvoke v.<java.lang.IllegalStateException: void <init>(java.lang.String,java.lang.Throwable)>(v, v);
throw v;
label:
return;
catch org.apache.zookeeper.KeeperException$NodeExistsException from label to label with label;
catch java.lang.Exception from label to label with label;
}
protected void deletePath(java.lang.String)
{
java.lang.Throwable v;
java.lang.IllegalStateException v;
java.lang.Exception v;
org.apache.curator.framework.CuratorFramework v;
org.apache.curator.framework.api.DeleteBuilder v;
org.apache.curator.framework.api.BackgroundVersionable v;
java.lang.String v, v;
org.apache.dubbo.remoting.zookeeper.curator.CuratorZookeeperClient v;
v := @this: org.apache.dubbo.remoting.zookeeper.curator.CuratorZookeeperClient;
v := @parameter: java.lang.String;
label:
v = v.<org.apache.dubbo.remoting.zookeeper.curator.CuratorZookeeperClient: org.apache.curator.framework.CuratorFramework client>;
v = interfaceinvoke v.<org.apache.curator.framework.CuratorFramework: org.apache.curator.framework.api.DeleteBuilder delete()>();
v = interfaceinvoke v.<org.apache.curator.framework.api.DeleteBuilder: org.apache.curator.framework.api.BackgroundVersionable deletingChildrenIfNeeded()>();
interfaceinvoke v.<org.apache.curator.framework.api.BackgroundVersionable: java.lang.Object forPath(java.lang.String)>(v);
label:
goto label;
label:
v := @caughtexception;
goto label;
label:
v := @caughtexception;
v = new java.lang.IllegalStateException;
v = virtualinvoke v.<java.lang.Exception: java.lang.String getMessage()>();
specialinvoke v.<java.lang.IllegalStateException: void <init>(java.lang.String,java.lang.Throwable)>(v, v);
throw v;
label:
return;
catch org.apache.zookeeper.KeeperException$NoNodeException from label to label with label;
catch java.lang.Exception from label to label with label;
}
public java.util.List getChildren(java.lang.String)
{
java.lang.Throwable v;
java.lang.IllegalStateException v;
org.apache.curator.framework.api.GetChildrenBuilder v;
java.lang.Exception v;
org.apache.curator.framework.CuratorFramework v;
java.lang.Object v;
java.lang.String v, v;
org.apache.dubbo.remoting.zookeeper.curator.CuratorZookeeperClient v;
v := @this: org.apache.dubbo.remoting.zookeeper.curator.CuratorZookeeperClient;
v := @parameter: java.lang.String;
label:
v = v.<org.apache.dubbo.remoting.zookeeper.curator.CuratorZookeeperClient: org.apache.curator.framework.CuratorFramework client>;
v = interfaceinvoke v.<org.apache.curator.framework.CuratorFramework: org.apache.curator.framework.api.GetChildrenBuilder getChildren()>();
v = interfaceinvoke v.<org.apache.curator.framework.api.GetChildrenBuilder: java.lang.Object forPath(java.lang.String)>(v);
label:
return v;
label:
v := @caughtexception;
return null;
label:
v := @caughtexception;
v = new java.lang.IllegalStateException;
v = virtualinvoke v.<java.lang.Exception: java.lang.String getMessage()>();
specialinvoke v.<java.lang.IllegalStateException: void <init>(java.lang.String,java.lang.Throwable)>(v, v);
throw v;
catch org.apache.zookeeper.KeeperException$NoNodeException from label to label with label;
catch java.lang.Exception from label to label with label;
}
public boolean checkExists(java.lang.String)
{
org.apache.curator.framework.CuratorFramework v;
org.apache.curator.framework.api.ExistsBuilder v;
java.lang.Object v;
java.lang.String v;
java.lang.Exception v;
org.apache.dubbo.remoting.zookeeper.curator.CuratorZookeeperClient v;
v := @this: org.apache.dubbo.remoting.zookeeper.curator.CuratorZookeeperClient;
v := @parameter: java.lang.String;
label:
v = v.<org.apache.dubbo.remoting.zookeeper.curator.CuratorZookeeperClient: org.apache.curator.framework.CuratorFramework client>;
v = interfaceinvoke v.<org.apache.curator.framework.CuratorFramework: org.apache.curator.framework.api.ExistsBuilder checkExists()>();
v = interfaceinvoke v.<org.apache.curator.framework.api.ExistsBuilder: java.lang.Object forPath(java.lang.String)>(v);
if v == null goto label;
label:
return 1;
label:
v := @caughtexception;
label:
return 0;
catch java.lang.Exception from label to label with label;
}
public boolean isConnected()
{
org.apache.curator.framework.CuratorFramework v;
org.apache.curator.CuratorZookeeperClient v;
org.apache.dubbo.remoting.zookeeper.curator.CuratorZookeeperClient v;
boolean v;
v := @this: org.apache.dubbo.remoting.zookeeper.curator.CuratorZookeeperClient;
v = v.<org.apache.dubbo.remoting.zookeeper.curator.CuratorZookeeperClient: org.apache.curator.framework.CuratorFramework client>;
v = interfaceinvoke v.<org.apache.curator.framework.CuratorFramework: org.apache.curator.CuratorZookeeperClient getZookeeperClient()>();
v = virtualinvoke v.<org.apache.curator.CuratorZookeeperClient: boolean isConnected()>();
return v;
}
public java.lang.String doGetContent(java.lang.String)
{
java.lang.Throwable v;
java.lang.IllegalStateException v;
org.apache.curator.framework.api.GetDataBuilder v;
java.lang.Exception v;
org.apache.curator.framework.CuratorFramework v;
java.nio.charset.Charset v;
int v;
java.lang.Object v;
java.lang.String v, v, v;
org.apache.dubbo.remoting.zookeeper.curator.CuratorZookeeperClient v;
v := @this: org.apache.dubbo.remoting.zookeeper.curator.CuratorZookeeperClient;
v := @parameter: java.lang.String;
label:
v = v.<org.apache.dubbo.remoting.zookeeper.curator.CuratorZookeeperClient: org.apache.curator.framework.CuratorFramework client>;
v = interfaceinvoke v.<org.apache.curator.framework.CuratorFramework: org.apache.curator.framework.api.GetDataBuilder getData()>();
v = interfaceinvoke v.<org.apache.curator.framework.api.GetDataBuilder: java.lang.Object forPath(java.lang.String)>(v);
if v == null goto label;
v = lengthof v;
if v != 0 goto label;
label:
v = null;
goto label;
label:
v = new java.lang.String;
v = <org.apache.dubbo.remoting.zookeeper.curator.CuratorZookeeperClient: java.nio.charset.Charset CHARSET>;
specialinvoke v.<java.lang.String: void <init>(byte[],java.nio.charset.Charset)>(v, v);
label:
return v;
label:
v := @caughtexception;
goto label;
label:
v := @caughtexception;
v = new java.lang.IllegalStateException;
v = virtualinvoke v.<java.lang.Exception: java.lang.String getMessage()>();
specialinvoke v.<java.lang.IllegalStateException: void <init>(java.lang.String,java.lang.Throwable)>(v, v);
throw v;
label:
return null;
catch org.apache.zookeeper.KeeperException$NoNodeException from label to label with label;
catch java.lang.Exception from label to label with label;
}
public void doClose()
{
org.apache.curator.framework.CuratorFramework v;
org.apache.dubbo.remoting.zookeeper.curator.CuratorZookeeperClient v;
v := @this: org.apache.dubbo.remoting.zookeeper.curator.CuratorZookeeperClient;
v = v.<org.apache.dubbo.remoting.zookeeper.curator.CuratorZookeeperClient: org.apache.curator.framework.CuratorFramework client>;
interfaceinvoke v.<org.apache.curator.framework.CuratorFramework: void close()>();
return;
}
public org.apache.dubbo.remoting.zookeeper.curator.CuratorZookeeperClient$CuratorWatcherImpl createTargetChildListener(java.lang.String, org.apache.dubbo.remoting.zookeeper.ChildListener)
{
org.apache.curator.framework.CuratorFramework v;
org.apache.dubbo.remoting.zookeeper.curator.CuratorZookeeperClient$CuratorWatcherImpl v;
java.lang.String v;
org.apache.dubbo.remoting.zookeeper.ChildListener v;
org.apache.dubbo.remoting.zookeeper.curator.CuratorZookeeperClient v;
v := @this: org.apache.dubbo.remoting.zookeeper.curator.CuratorZookeeperClient;
v := @parameter: java.lang.String;
v := @parameter: org.apache.dubbo.remoting.zookeeper.ChildListener;
v = new org.apache.dubbo.remoting.zookeeper.curator.CuratorZookeeperClient$CuratorWatcherImpl;
v = v.<org.apache.dubbo.remoting.zookeeper.curator.CuratorZookeeperClient: org.apache.curator.framework.CuratorFramework client>;
specialinvoke v.<org.apache.dubbo.remoting.zookeeper.curator.CuratorZookeeperClient$CuratorWatcherImpl: void <init>(org.apache.curator.framework.CuratorFramework,org.apache.dubbo.remoting.zookeeper.ChildListener,java.lang.String)>(v, v, v);
return v;
}
public java.util.List addTargetChildListener(java.lang.String, org.apache.dubbo.remoting.zookeeper.curator.CuratorZookeeperClient$CuratorWatcherImpl)
{
java.lang.Throwable v;
java.lang.IllegalStateException v;
org.apache.curator.framework.api.GetChildrenBuilder v;
org.apache.dubbo.remoting.zookeeper.curator.CuratorZookeeperClient$CuratorWatcherImpl v;
java.lang.Exception v;
org.apache.curator.framework.CuratorFramework v;
java.lang.Object v, v;
java.lang.String v, v;
org.apache.dubbo.remoting.zookeeper.curator.CuratorZookeeperClient v;
v := @this: org.apache.dubbo.remoting.zookeeper.curator.CuratorZookeeperClient;
v := @parameter: java.lang.String;
v := @parameter: org.apache.dubbo.remoting.zookeeper.curator.CuratorZookeeperClient$CuratorWatcherImpl;
label:
v = v.<org.apache.dubbo.remoting.zookeeper.curator.CuratorZookeeperClient: org.apache.curator.framework.CuratorFramework client>;
v = interfaceinvoke v.<org.apache.curator.framework.CuratorFramework: org.apache.curator.framework.api.GetChildrenBuilder getChildren()>();
v = interfaceinvoke v.<org.apache.curator.framework.api.GetChildrenBuilder: java.lang.Object usingWatcher(org.apache.curator.framework.api.CuratorWatcher)>(v);
v = interfaceinvoke v.<org.apache.curator.framework.api.BackgroundPathable: java.lang.Object forPath(java.lang.String)>(v);
label:
return v;
label:
v := @caughtexception;
return null;
label:
v := @caughtexception;
v = new java.lang.IllegalStateException;
v = virtualinvoke v.<java.lang.Exception: java.lang.String getMessage()>();
specialinvoke v.<java.lang.IllegalStateException: void <init>(java.lang.String,java.lang.Throwable)>(v, v);
throw v;
catch org.apache.zookeeper.KeeperException$NoNodeException from label to label with label;
catch java.lang.Exception from label to label with label;
}
protected org.apache.dubbo.remoting.zookeeper.curator.CuratorZookeeperClient$CuratorWatcherImpl createTargetDataListener(java.lang.String, org.apache.dubbo.remoting.zookeeper.DataListener)
{
org.apache.curator.framework.CuratorFramework v;
org.apache.dubbo.remoting.zookeeper.curator.CuratorZookeeperClient$CuratorWatcherImpl v;
org.apache.dubbo.remoting.zookeeper.DataListener v;
java.lang.String v;
org.apache.dubbo.remoting.zookeeper.curator.CuratorZookeeperClient v;
v := @this: org.apache.dubbo.remoting.zookeeper.curator.CuratorZookeeperClient;
v := @parameter: java.lang.String;
v := @parameter: org.apache.dubbo.remoting.zookeeper.DataListener;
v = new org.apache.dubbo.remoting.zookeeper.curator.CuratorZookeeperClient$CuratorWatcherImpl;
v = v.<org.apache.dubbo.remoting.zookeeper.curator.CuratorZookeeperClient: org.apache.curator.framework.CuratorFramework client>;
specialinvoke v.<org.apache.dubbo.remoting.zookeeper.curator.CuratorZookeeperClient$CuratorWatcherImpl: void <init>(org.apache.curator.framework.CuratorFramework,org.apache.dubbo.remoting.zookeeper.DataListener)>(v, v);
return v;
}
protected void addTargetDataListener(java.lang.String, org.apache.dubbo.remoting.zookeeper.curator.CuratorZookeeperClient$CuratorWatcherImpl)
{
java.lang.String v;
org.apache.dubbo.remoting.zookeeper.curator.CuratorZookeeperClient$CuratorWatcherImpl v;
org.apache.dubbo.remoting.zookeeper.curator.CuratorZookeeperClient v;
v := @this: org.apache.dubbo.remoting.zookeeper.curator.CuratorZookeeperClient;
v := @parameter: java.lang.String;
v := @parameter: org.apache.dubbo.remoting.zookeeper.curator.CuratorZookeeperClient$CuratorWatcherImpl;
virtualinvoke v.<org.apache.dubbo.remoting.zookeeper.curator.CuratorZookeeperClient: void addTargetDataListener(java.lang.String,org.apache.dubbo.remoting.zookeeper.curator.CuratorZookeeperClient$CuratorWatcherImpl,java.util.concurrent.Executor)>(v, v, null);
return;
}
protected void addTargetDataListener(java.lang.String, org.apache.dubbo.remoting.zookeeper.curator.CuratorZookeeperClient$CuratorWatcherImpl, java.util.concurrent.Executor)
{
java.lang.IllegalStateException v;
org.apache.dubbo.remoting.zookeeper.curator.CuratorZookeeperClient$CuratorWatcherImpl v;
java.util.concurrent.Executor v;
java.lang.Exception v;
org.apache.curator.framework.CuratorFramework v;
java.util.Map v;
org.apache.curator.framework.listen.Listenable v, v;
org.apache.curator.framework.recipes.cache.TreeCache v;
java.lang.String v, v;
org.apache.curator.framework.recipes.cache.TreeCache$Builder v, v;
org.apache.dubbo.remoting.zookeeper.curator.CuratorZookeeperClient v;
v := @this: org.apache.dubbo.remoting.zookeeper.curator.CuratorZookeeperClient;
v := @parameter: java.lang.String;
v := @parameter: org.apache.dubbo.remoting.zookeeper.curator.CuratorZookeeperClient$CuratorWatcherImpl;
v := @parameter: java.util.concurrent.Executor;
label:
v = v.<org.apache.dubbo.remoting.zookeeper.curator.CuratorZookeeperClient: org.apache.curator.framework.CuratorFramework client>;
v = staticinvoke <org.apache.curator.framework.recipes.cache.TreeCache: org.apache.curator.framework.recipes.cache.TreeCache$Builder newBuilder(org.apache.curator.framework.CuratorFramework,java.lang.String)>(v, v);
v = virtualinvoke v.<org.apache.curator.framework.recipes.cache.TreeCache$Builder: org.apache.curator.framework.recipes.cache.TreeCache$Builder setCacheData(boolean)>(0);
v = virtualinvoke v.<org.apache.curator.framework.recipes.cache.TreeCache$Builder: org.apache.curator.framework.recipes.cache.TreeCache build()>();
v = v.<org.apache.dubbo.remoting.zookeeper.curator.CuratorZookeeperClient: java.util.Map treeCacheMap>;
interfaceinvoke v.<java.util.Map: java.lang.Object putIfAbsent(java.lang.Object,java.lang.Object)>(v, v);
if v != null goto label;
v = virtualinvoke v.<org.apache.curator.framework.recipes.cache.TreeCache: org.apache.curator.framework.listen.Listenable getListenable()>();
interfaceinvoke v.<org.apache.curator.framework.listen.Listenable: void addListener(java.lang.Object)>(v);
goto label;
label:
v = virtualinvoke v.<org.apache.curator.framework.recipes.cache.TreeCache: org.apache.curator.framework.listen.Listenable getListenable()>();
interfaceinvoke v.<org.apache.curator.framework.listen.Listenable: void addListener(java.lang.Object,java.util.concurrent.Executor)>(v, v);
label:
virtualinvoke v.<org.apache.curator.framework.recipes.cache.TreeCache: org.apache.curator.framework.recipes.cache.TreeCache start()>();
label:
goto label;
label:
v := @caughtexception;
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[])>("Add treeCache listener for path:\u0001");
specialinvoke v.<java.lang.IllegalStateException: void <init>(java.lang.String,java.lang.Throwable)>(v, v);
throw v;
label:
return;
catch java.lang.Exception from label to label with label;
}
protected void removeTargetDataListener(java.lang.String, org.apache.dubbo.remoting.zookeeper.curator.CuratorZookeeperClient$CuratorWatcherImpl)
{
org.apache.dubbo.remoting.zookeeper.curator.CuratorZookeeperClient$CuratorWatcherImpl v;
java.util.Map v;
org.apache.curator.framework.listen.Listenable v;
java.lang.Object v;
java.lang.String v;
org.apache.dubbo.remoting.zookeeper.curator.CuratorZookeeperClient v;
v := @this: org.apache.dubbo.remoting.zookeeper.curator.CuratorZookeeperClient;
v := @parameter: java.lang.String;
v := @parameter: org.apache.dubbo.remoting.zookeeper.curator.CuratorZookeeperClient$CuratorWatcherImpl;
v = v.<org.apache.dubbo.remoting.zookeeper.curator.CuratorZookeeperClient: java.util.Map treeCacheMap>;
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
if v == null goto label;
v = virtualinvoke v.<org.apache.curator.framework.recipes.cache.TreeCache: org.apache.curator.framework.listen.Listenable getListenable()>();
interfaceinvoke v.<org.apache.curator.framework.listen.Listenable: void removeListener(java.lang.Object)>(v);
label:
v.<org.apache.dubbo.remoting.zookeeper.curator.CuratorZookeeperClient$CuratorWatcherImpl: org.apache.dubbo.remoting.zookeeper.DataListener dataListener> = null;
return;
}
public void removeTargetChildListener(java.lang.String, org.apache.dubbo.remoting.zookeeper.curator.CuratorZookeeperClient$CuratorWatcherImpl)
{
java.lang.String v;
org.apache.dubbo.remoting.zookeeper.curator.CuratorZookeeperClient$CuratorWatcherImpl v;
org.apache.dubbo.remoting.zookeeper.curator.CuratorZookeeperClient v;
v := @this: org.apache.dubbo.remoting.zookeeper.curator.CuratorZookeeperClient;
v := @parameter: java.lang.String;
v := @parameter: org.apache.dubbo.remoting.zookeeper.curator.CuratorZookeeperClient$CuratorWatcherImpl;
virtualinvoke v.<org.apache.dubbo.remoting.zookeeper.curator.CuratorZookeeperClient$CuratorWatcherImpl: void unwatch()>();
return;
}
org.apache.curator.framework.CuratorFramework getClient()
{
org.apache.curator.framework.CuratorFramework v;
org.apache.dubbo.remoting.zookeeper.curator.CuratorZookeeperClient v;
v := @this: org.apache.dubbo.remoting.zookeeper.curator.CuratorZookeeperClient;
v = v.<org.apache.dubbo.remoting.zookeeper.curator.CuratorZookeeperClient: org.apache.curator.framework.CuratorFramework client>;
return v;
}
static void <clinit>()
{
java.nio.charset.Charset v;
org.apache.dubbo.common.logger.Logger v;
v = staticinvoke <org.apache.dubbo.common.logger.LoggerFactory: org.apache.dubbo.common.logger.Logger getLogger(java.lang.Class)>(class "Lorg/apache/dubbo/remoting/zookeeper/curator/CuratorZookeeperClient;");
<org.apache.dubbo.remoting.zookeeper.curator.CuratorZookeeperClient: org.apache.dubbo.common.logger.Logger logger> = v;
v = <java.nio.charset.StandardCharsets: java.nio.charset.Charset UTF_8>;
<org.apache.dubbo.remoting.zookeeper.curator.CuratorZookeeperClient: java.nio.charset.Charset CHARSET> = v;
return;
}
}