class oadd.org.apache.curator.framework.imps.NamespaceImpl extends java.lang.Object
{
private final oadd.org.apache.curator.framework.imps.CuratorFrameworkImpl client;
private final java.lang.String namespace;
private final java.util.concurrent.atomic.AtomicBoolean ensurePathNeeded;
void <init>(oadd.org.apache.curator.framework.imps.CuratorFrameworkImpl, java.lang.String)
{
java.util.concurrent.atomic.AtomicBoolean v;
java.lang.IllegalArgumentException v, v;
oadd.org.apache.curator.framework.imps.CuratorFrameworkImpl v;
oadd.org.apache.curator.framework.imps.NamespaceImpl v;
java.lang.String v, v, v, v;
boolean v;
v := @this: oadd.org.apache.curator.framework.imps.NamespaceImpl;
v := @parameter: oadd.org.apache.curator.framework.imps.CuratorFrameworkImpl;
v := @parameter: java.lang.String;
specialinvoke v.<java.lang.Object: void <init>()>();
if v == null goto label;
label:
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[])>("/\u0001");
staticinvoke <oadd.org.apache.curator.utils.PathUtils: java.lang.String validatePath(java.lang.String)>(v);
label:
goto label;
label:
v := @caughtexception;
v = new java.lang.IllegalArgumentException;
v = virtualinvoke v.<java.lang.IllegalArgumentException: java.lang.String getMessage()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,java.lang.String)>(v, 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[])>("Invalid namespace: \u, \u0001");
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.String)>(v);
throw v;
label:
v.<oadd.org.apache.curator.framework.imps.NamespaceImpl: oadd.org.apache.curator.framework.imps.CuratorFrameworkImpl client> = v;
v.<oadd.org.apache.curator.framework.imps.NamespaceImpl: java.lang.String namespace> = v;
v = new java.util.concurrent.atomic.AtomicBoolean;
if v == null goto label;
v = 1;
goto label;
label:
v = 0;
label:
specialinvoke v.<java.util.concurrent.atomic.AtomicBoolean: void <init>(boolean)>(v);
v.<oadd.org.apache.curator.framework.imps.NamespaceImpl: java.util.concurrent.atomic.AtomicBoolean ensurePathNeeded> = v;
return;
catch java.lang.IllegalArgumentException from label to label with label;
}
java.lang.String getNamespace()
{
java.lang.String v;
oadd.org.apache.curator.framework.imps.NamespaceImpl v;
v := @this: oadd.org.apache.curator.framework.imps.NamespaceImpl;
v = v.<oadd.org.apache.curator.framework.imps.NamespaceImpl: java.lang.String namespace>;
return v;
}
java.lang.String unfixForNamespace(java.lang.String)
{
oadd.org.apache.curator.framework.imps.NamespaceImpl v;
int v, v, v;
java.lang.String v, v, v, v, v;
boolean v, v;
v := @this: oadd.org.apache.curator.framework.imps.NamespaceImpl;
v := @parameter: java.lang.String;
v = v.<oadd.org.apache.curator.framework.imps.NamespaceImpl: java.lang.String namespace>;
if v == null goto label;
if v == null goto label;
v = v.<oadd.org.apache.curator.framework.imps.NamespaceImpl: java.lang.String namespace>;
v = staticinvoke <oadd.org.apache.curator.utils.ZKPaths: java.lang.String makePath(java.lang.String,java.lang.String)>(v, null);
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>("/");
if v != 0 goto label;
v = virtualinvoke v.<java.lang.String: boolean startsWith(java.lang.String)>(v);
if v == 0 goto label;
v = virtualinvoke v.<java.lang.String: int length()>();
v = virtualinvoke v.<java.lang.String: int length()>();
if v <= v goto label;
v = virtualinvoke v.<java.lang.String: int length()>();
v = virtualinvoke v.<java.lang.String: java.lang.String substring(int)>(v);
goto label;
label:
v = "/";
label:
v = v;
label:
return v;
}
java.lang.String fixForNamespace(java.lang.String, boolean)
{
java.util.concurrent.atomic.AtomicBoolean v, v;
oadd.org.apache.curator.CuratorZookeeperClient v;
oadd.org.apache.curator.framework.imps.CuratorFrameworkImpl v, v;
java.lang.Exception v;
oadd.org.apache.curator.framework.imps.NamespaceImpl$1 v;
oadd.org.apache.curator.framework.imps.NamespaceImpl v;
java.lang.String v, v, v;
boolean v, v;
v := @this: oadd.org.apache.curator.framework.imps.NamespaceImpl;
v := @parameter: java.lang.String;
v := @parameter: boolean;
v = v.<oadd.org.apache.curator.framework.imps.NamespaceImpl: java.util.concurrent.atomic.AtomicBoolean ensurePathNeeded>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicBoolean: boolean get()>();
if v == 0 goto label;
label:
v = v.<oadd.org.apache.curator.framework.imps.NamespaceImpl: oadd.org.apache.curator.framework.imps.CuratorFrameworkImpl client>;
v = virtualinvoke v.<oadd.org.apache.curator.framework.imps.CuratorFrameworkImpl: oadd.org.apache.curator.CuratorZookeeperClient getZookeeperClient()>();
v = new oadd.org.apache.curator.framework.imps.NamespaceImpl$1;
specialinvoke v.<oadd.org.apache.curator.framework.imps.NamespaceImpl$1: void <init>(oadd.org.apache.curator.framework.imps.NamespaceImpl,oadd.org.apache.curator.CuratorZookeeperClient)>(v, v);
staticinvoke <oadd.org.apache.curator.RetryLoop: java.lang.Object callWithRetry(oadd.org.apache.curator.CuratorZookeeperClient,java.util.concurrent.Callable)>(v, v);
v = v.<oadd.org.apache.curator.framework.imps.NamespaceImpl: java.util.concurrent.atomic.AtomicBoolean ensurePathNeeded>;
virtualinvoke v.<java.util.concurrent.atomic.AtomicBoolean: void set(boolean)>(0);
label:
goto label;
label:
v := @caughtexception;
staticinvoke <oadd.org.apache.curator.utils.ThreadUtils: boolean checkInterrupted(java.lang.Throwable)>(v);
v = v.<oadd.org.apache.curator.framework.imps.NamespaceImpl: oadd.org.apache.curator.framework.imps.CuratorFrameworkImpl client>;
virtualinvoke v.<oadd.org.apache.curator.framework.imps.CuratorFrameworkImpl: void logError(java.lang.String,java.lang.Throwable)>("Ensure path threw exception", v);
label:
v = v.<oadd.org.apache.curator.framework.imps.NamespaceImpl: java.lang.String namespace>;
v = staticinvoke <oadd.org.apache.curator.utils.ZKPaths: java.lang.String fixForNamespace(java.lang.String,java.lang.String,boolean)>(v, v, v);
return v;
catch java.lang.Exception from label to label with label;
}
oadd.org.apache.curator.utils.EnsurePath newNamespaceAwareEnsurePath(java.lang.String)
{
oadd.org.apache.curator.framework.imps.NamespaceImpl v;
oadd.org.apache.curator.utils.EnsurePath v;
java.lang.String v, v;
oadd.org.apache.curator.framework.imps.CuratorFrameworkImpl v;
oadd.org.apache.curator.framework.api.ACLProvider v;
v := @this: oadd.org.apache.curator.framework.imps.NamespaceImpl;
v := @parameter: java.lang.String;
v = new oadd.org.apache.curator.utils.EnsurePath;
v = virtualinvoke v.<oadd.org.apache.curator.framework.imps.NamespaceImpl: java.lang.String fixForNamespace(java.lang.String,boolean)>(v, 0);
v = v.<oadd.org.apache.curator.framework.imps.NamespaceImpl: oadd.org.apache.curator.framework.imps.CuratorFrameworkImpl client>;
v = virtualinvoke v.<oadd.org.apache.curator.framework.imps.CuratorFrameworkImpl: oadd.org.apache.curator.framework.api.ACLProvider getAclProvider()>();
specialinvoke v.<oadd.org.apache.curator.utils.EnsurePath: void <init>(java.lang.String,oadd.org.apache.curator.utils.InternalACLProvider)>(v, v);
return v;
}
}