public class oadd.org.apache.curator.framework.EnsureContainers extends java.lang.Object
{
private final oadd.org.apache.curator.framework.CuratorFramework client;
private final java.lang.String path;
private final java.util.concurrent.atomic.AtomicBoolean ensureNeeded;
public void <init>(oadd.org.apache.curator.framework.CuratorFramework, java.lang.String)
{
oadd.org.apache.curator.framework.EnsureContainers v;
java.util.concurrent.atomic.AtomicBoolean v;
java.lang.String v;
oadd.org.apache.curator.framework.CuratorFramework v;
v := @this: oadd.org.apache.curator.framework.EnsureContainers;
v := @parameter: oadd.org.apache.curator.framework.CuratorFramework;
v := @parameter: java.lang.String;
specialinvoke v.<java.lang.Object: void <init>()>();
v = new java.util.concurrent.atomic.AtomicBoolean;
specialinvoke v.<java.util.concurrent.atomic.AtomicBoolean: void <init>(boolean)>(1);
v.<oadd.org.apache.curator.framework.EnsureContainers: java.util.concurrent.atomic.AtomicBoolean ensureNeeded> = v;
v.<oadd.org.apache.curator.framework.EnsureContainers: oadd.org.apache.curator.framework.CuratorFramework client> = v;
v.<oadd.org.apache.curator.framework.EnsureContainers: java.lang.String path> = v;
return;
}
public void ensure() throws java.lang.Exception
{
oadd.org.apache.curator.framework.EnsureContainers v;
java.util.concurrent.atomic.AtomicBoolean v;
boolean v;
v := @this: oadd.org.apache.curator.framework.EnsureContainers;
v = v.<oadd.org.apache.curator.framework.EnsureContainers: java.util.concurrent.atomic.AtomicBoolean ensureNeeded>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicBoolean: boolean get()>();
if v == 0 goto label;
specialinvoke v.<oadd.org.apache.curator.framework.EnsureContainers: void internalEnsure()>();
label:
return;
}
public void reset()
{
oadd.org.apache.curator.framework.EnsureContainers v;
java.util.concurrent.atomic.AtomicBoolean v;
v := @this: oadd.org.apache.curator.framework.EnsureContainers;
v = v.<oadd.org.apache.curator.framework.EnsureContainers: java.util.concurrent.atomic.AtomicBoolean ensureNeeded>;
virtualinvoke v.<java.util.concurrent.atomic.AtomicBoolean: void set(boolean)>(1);
return;
}
private synchronized void internalEnsure() throws java.lang.Exception
{
oadd.org.apache.curator.framework.EnsureContainers v;
java.util.concurrent.atomic.AtomicBoolean v;
java.lang.String v;
oadd.org.apache.curator.framework.CuratorFramework v;
boolean v;
v := @this: oadd.org.apache.curator.framework.EnsureContainers;
v = v.<oadd.org.apache.curator.framework.EnsureContainers: java.util.concurrent.atomic.AtomicBoolean ensureNeeded>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicBoolean: boolean compareAndSet(boolean,boolean)>(1, 0);
if v == 0 goto label;
v = v.<oadd.org.apache.curator.framework.EnsureContainers: oadd.org.apache.curator.framework.CuratorFramework client>;
v = v.<oadd.org.apache.curator.framework.EnsureContainers: java.lang.String path>;
interfaceinvoke v.<oadd.org.apache.curator.framework.CuratorFramework: void createContainers(java.lang.String)>(v);
label:
return;
}
}