public class oadd.org.apache.curator.framework.recipes.nodes.PersistentNode extends java.lang.Object implements java.io.Closeable
{
private final java.util.concurrent.atomic.AtomicReference initialCreateLatch;
private final org.slf4j.Logger log;
private final oadd.org.apache.curator.framework.WatcherRemoveCuratorFramework client;
private final java.util.concurrent.atomic.AtomicReference nodePath;
private final java.lang.String basePath;
private final oadd.org.apache.zookeeper.CreateMode mode;
private final long ttl;
private final java.util.concurrent.atomic.AtomicReference data;
private final java.util.concurrent.atomic.AtomicReference state;
private volatile boolean authFailure;
private volatile boolean parentCreationFailure;
private final oadd.org.apache.curator.framework.api.BackgroundCallback backgroundCallback;
private final boolean useProtection;
private final boolean useParentCreation;
private final java.util.concurrent.atomic.AtomicReference createMethod;
private final oadd.org.apache.curator.framework.listen.StandardListenerManager listeners;
private final oadd.org.apache.curator.framework.api.CuratorWatcher watcher;
private final oadd.org.apache.curator.framework.api.BackgroundCallback checkExistsCallback;
private final oadd.org.apache.curator.framework.api.BackgroundCallback setDataCallback;
private final oadd.org.apache.curator.framework.state.ConnectionStateListener connectionStateListener;
volatile java.util.concurrent.CountDownLatch debugCreateNodeLatch;
final java.util.concurrent.atomic.AtomicLong debugWaitMsForBackgroundBeforeClose;
public void <init>(oadd.org.apache.curator.framework.CuratorFramework, oadd.org.apache.zookeeper.CreateMode, boolean, java.lang.String, byte[])
{
byte[] v;
oadd.org.apache.zookeeper.CreateMode v;
java.lang.String v;
oadd.org.apache.curator.framework.CuratorFramework v;
oadd.org.apache.curator.framework.recipes.nodes.PersistentNode v;
boolean v;
v := @this: oadd.org.apache.curator.framework.recipes.nodes.PersistentNode;
v := @parameter: oadd.org.apache.curator.framework.CuratorFramework;
v := @parameter: oadd.org.apache.zookeeper.CreateMode;
v := @parameter: boolean;
v := @parameter: java.lang.String;
v := @parameter: byte[];
specialinvoke v.<oadd.org.apache.curator.framework.recipes.nodes.PersistentNode: void <init>(oadd.org.apache.curator.framework.CuratorFramework,oadd.org.apache.zookeeper.CreateMode,boolean,java.lang.String,byte[],long,boolean)>(v, v, v, v, v, -1L, 1);
return;
}
public void <init>(oadd.org.apache.curator.framework.CuratorFramework, oadd.org.apache.zookeeper.CreateMode, boolean, java.lang.String, byte[], boolean)
{
byte[] v;
oadd.org.apache.zookeeper.CreateMode v;
java.lang.String v;
oadd.org.apache.curator.framework.CuratorFramework v;
oadd.org.apache.curator.framework.recipes.nodes.PersistentNode v;
boolean v, v;
v := @this: oadd.org.apache.curator.framework.recipes.nodes.PersistentNode;
v := @parameter: oadd.org.apache.curator.framework.CuratorFramework;
v := @parameter: oadd.org.apache.zookeeper.CreateMode;
v := @parameter: boolean;
v := @parameter: java.lang.String;
v := @parameter: byte[];
v := @parameter: boolean;
specialinvoke v.<oadd.org.apache.curator.framework.recipes.nodes.PersistentNode: void <init>(oadd.org.apache.curator.framework.CuratorFramework,oadd.org.apache.zookeeper.CreateMode,boolean,java.lang.String,byte[],long,boolean)>(v, v, v, v, v, -1L, v);
return;
}
public void <init>(oadd.org.apache.curator.framework.CuratorFramework, oadd.org.apache.zookeeper.CreateMode, boolean, java.lang.String, byte[], long, boolean)
{
byte[] v, v;
oadd.org.apache.zookeeper.CreateMode v;
oadd.org.apache.curator.framework.listen.StandardListenerManager v;
boolean v, v;
oadd.org.apache.curator.framework.recipes.nodes.PersistentNode$5 v;
oadd.org.apache.curator.framework.recipes.nodes.PersistentNode$3 v;
oadd.org.apache.curator.framework.recipes.nodes.PersistentNode$4 v;
oadd.org.apache.curator.framework.CuratorFramework v;
oadd.org.apache.curator.framework.WatcherRemoveCuratorFramework v;
java.util.concurrent.CountDownLatch v;
oadd.org.apache.curator.framework.recipes.nodes.PersistentNode$1 v;
oadd.org.apache.curator.framework.recipes.nodes.PersistentNode$2 v;
long v;
oadd.org.apache.curator.framework.recipes.nodes.PersistentNode v;
java.util.concurrent.atomic.AtomicReference v, v, v, v, v, v;
int v;
java.lang.String v, v;
org.slf4j.Logger v;
java.util.concurrent.atomic.AtomicLong v;
oadd.org.apache.curator.framework.recipes.nodes.PersistentNode$State v;
java.lang.Class v;
java.lang.Object v, v, v;
v := @this: oadd.org.apache.curator.framework.recipes.nodes.PersistentNode;
v := @parameter: oadd.org.apache.curator.framework.CuratorFramework;
v := @parameter: oadd.org.apache.zookeeper.CreateMode;
v := @parameter: boolean;
v := @parameter: java.lang.String;
v := @parameter: byte[];
v := @parameter: long;
v := @parameter: boolean;
specialinvoke v.<java.lang.Object: void <init>()>();
v = new java.util.concurrent.atomic.AtomicReference;
v = new java.util.concurrent.CountDownLatch;
specialinvoke v.<java.util.concurrent.CountDownLatch: void <init>(int)>(1);
specialinvoke v.<java.util.concurrent.atomic.AtomicReference: void <init>(java.lang.Object)>(v);
v.<oadd.org.apache.curator.framework.recipes.nodes.PersistentNode: java.util.concurrent.atomic.AtomicReference initialCreateLatch> = v;
v = virtualinvoke v.<java.lang.Object: java.lang.Class getClass()>();
v = staticinvoke <org.slf4j.LoggerFactory: org.slf4j.Logger getLogger(java.lang.Class)>(v);
v.<oadd.org.apache.curator.framework.recipes.nodes.PersistentNode: org.slf4j.Logger log> = v;
v = new java.util.concurrent.atomic.AtomicReference;
specialinvoke v.<java.util.concurrent.atomic.AtomicReference: void <init>(java.lang.Object)>(null);
v.<oadd.org.apache.curator.framework.recipes.nodes.PersistentNode: java.util.concurrent.atomic.AtomicReference nodePath> = v;
v = new java.util.concurrent.atomic.AtomicReference;
specialinvoke v.<java.util.concurrent.atomic.AtomicReference: void <init>()>();
v.<oadd.org.apache.curator.framework.recipes.nodes.PersistentNode: java.util.concurrent.atomic.AtomicReference data> = v;
v = new java.util.concurrent.atomic.AtomicReference;
v = <oadd.org.apache.curator.framework.recipes.nodes.PersistentNode$State: oadd.org.apache.curator.framework.recipes.nodes.PersistentNode$State LATENT>;
specialinvoke v.<java.util.concurrent.atomic.AtomicReference: void <init>(java.lang.Object)>(v);
v.<oadd.org.apache.curator.framework.recipes.nodes.PersistentNode: java.util.concurrent.atomic.AtomicReference state> = v;
v = new java.util.concurrent.atomic.AtomicReference;
specialinvoke v.<java.util.concurrent.atomic.AtomicReference: void <init>(java.lang.Object)>(null);
v.<oadd.org.apache.curator.framework.recipes.nodes.PersistentNode: java.util.concurrent.atomic.AtomicReference createMethod> = v;
v = staticinvoke <oadd.org.apache.curator.framework.listen.StandardListenerManager: oadd.org.apache.curator.framework.listen.StandardListenerManager standard()>();
v.<oadd.org.apache.curator.framework.recipes.nodes.PersistentNode: oadd.org.apache.curator.framework.listen.StandardListenerManager listeners> = v;
v = new oadd.org.apache.curator.framework.recipes.nodes.PersistentNode$1;
specialinvoke v.<oadd.org.apache.curator.framework.recipes.nodes.PersistentNode$1: void <init>(oadd.org.apache.curator.framework.recipes.nodes.PersistentNode)>(v);
v.<oadd.org.apache.curator.framework.recipes.nodes.PersistentNode: oadd.org.apache.curator.framework.api.CuratorWatcher watcher> = v;
v = new oadd.org.apache.curator.framework.recipes.nodes.PersistentNode$2;
specialinvoke v.<oadd.org.apache.curator.framework.recipes.nodes.PersistentNode$2: void <init>(oadd.org.apache.curator.framework.recipes.nodes.PersistentNode)>(v);
v.<oadd.org.apache.curator.framework.recipes.nodes.PersistentNode: oadd.org.apache.curator.framework.api.BackgroundCallback checkExistsCallback> = v;
v = new oadd.org.apache.curator.framework.recipes.nodes.PersistentNode$3;
specialinvoke v.<oadd.org.apache.curator.framework.recipes.nodes.PersistentNode$3: void <init>(oadd.org.apache.curator.framework.recipes.nodes.PersistentNode)>(v);
v.<oadd.org.apache.curator.framework.recipes.nodes.PersistentNode: oadd.org.apache.curator.framework.api.BackgroundCallback setDataCallback> = v;
v = new oadd.org.apache.curator.framework.recipes.nodes.PersistentNode$4;
specialinvoke v.<oadd.org.apache.curator.framework.recipes.nodes.PersistentNode$4: void <init>(oadd.org.apache.curator.framework.recipes.nodes.PersistentNode)>(v);
v.<oadd.org.apache.curator.framework.recipes.nodes.PersistentNode: oadd.org.apache.curator.framework.state.ConnectionStateListener connectionStateListener> = v;
v.<oadd.org.apache.curator.framework.recipes.nodes.PersistentNode: java.util.concurrent.CountDownLatch debugCreateNodeLatch> = null;
v = new java.util.concurrent.atomic.AtomicLong;
specialinvoke v.<java.util.concurrent.atomic.AtomicLong: void <init>(long)>(0L);
v.<oadd.org.apache.curator.framework.recipes.nodes.PersistentNode: java.util.concurrent.atomic.AtomicLong debugWaitMsForBackgroundBeforeClose> = v;
v.<oadd.org.apache.curator.framework.recipes.nodes.PersistentNode: boolean useProtection> = v;
v.<oadd.org.apache.curator.framework.recipes.nodes.PersistentNode: boolean useParentCreation> = v;
v = staticinvoke <oadd.org.apache.curator.shaded.com.google.common.base.Preconditions: java.lang.Object checkNotNull(java.lang.Object,java.lang.Object)>(v, "client cannot be null");
v = interfaceinvoke v.<oadd.org.apache.curator.framework.CuratorFramework: oadd.org.apache.curator.framework.WatcherRemoveCuratorFramework newWatcherRemoveCuratorFramework()>();
v.<oadd.org.apache.curator.framework.recipes.nodes.PersistentNode: oadd.org.apache.curator.framework.WatcherRemoveCuratorFramework client> = v;
v = staticinvoke <oadd.org.apache.curator.utils.PathUtils: java.lang.String validatePath(java.lang.String)>(v);
v.<oadd.org.apache.curator.framework.recipes.nodes.PersistentNode: java.lang.String basePath> = v;
v = staticinvoke <oadd.org.apache.curator.shaded.com.google.common.base.Preconditions: java.lang.Object checkNotNull(java.lang.Object,java.lang.Object)>(v, "mode cannot be null");
v.<oadd.org.apache.curator.framework.recipes.nodes.PersistentNode: oadd.org.apache.zookeeper.CreateMode mode> = v;
v.<oadd.org.apache.curator.framework.recipes.nodes.PersistentNode: long ttl> = v;
v = staticinvoke <oadd.org.apache.curator.shaded.com.google.common.base.Preconditions: java.lang.Object checkNotNull(java.lang.Object,java.lang.Object)>(v, "data cannot be null");
v = new oadd.org.apache.curator.framework.recipes.nodes.PersistentNode$5;
specialinvoke v.<oadd.org.apache.curator.framework.recipes.nodes.PersistentNode$5: void <init>(oadd.org.apache.curator.framework.recipes.nodes.PersistentNode)>(v);
v.<oadd.org.apache.curator.framework.recipes.nodes.PersistentNode: oadd.org.apache.curator.framework.api.BackgroundCallback backgroundCallback> = v;
v = v.<oadd.org.apache.curator.framework.recipes.nodes.PersistentNode: java.util.concurrent.atomic.AtomicReference data>;
v = lengthof v;
v = staticinvoke <java.util.Arrays: byte[] copyOf(byte[],int)>(v, v);
virtualinvoke v.<java.util.concurrent.atomic.AtomicReference: void set(java.lang.Object)>(v);
return;
}
private void processBackgroundCallbackClosedState(oadd.org.apache.curator.framework.api.CuratorEvent)
{
oadd.org.apache.curator.framework.api.CuratorEvent v;
org.slf4j.Logger v;
oadd.org.apache.zookeeper.KeeperException$Code v, v;
oadd.org.apache.curator.framework.WatcherRemoveCuratorFramework v;
oadd.org.apache.curator.framework.recipes.nodes.PersistentNode v;
java.lang.Exception v;
int v, v, v, v;
java.lang.Object v, v;
java.lang.String v;
oadd.org.apache.curator.framework.api.DeleteBuilder v;
v := @this: oadd.org.apache.curator.framework.recipes.nodes.PersistentNode;
v := @parameter: oadd.org.apache.curator.framework.api.CuratorEvent;
v = null;
v = interfaceinvoke v.<oadd.org.apache.curator.framework.api.CuratorEvent: int getResultCode()>();
v = <oadd.org.apache.zookeeper.KeeperException$Code: oadd.org.apache.zookeeper.KeeperException$Code NODEEXISTS>;
v = virtualinvoke v.<oadd.org.apache.zookeeper.KeeperException$Code: int intValue()>();
if v != v goto label;
v = interfaceinvoke v.<oadd.org.apache.curator.framework.api.CuratorEvent: java.lang.String getPath()>();
goto label;
label:
v = interfaceinvoke v.<oadd.org.apache.curator.framework.api.CuratorEvent: int getResultCode()>();
v = <oadd.org.apache.zookeeper.KeeperException$Code: oadd.org.apache.zookeeper.KeeperException$Code OK>;
v = virtualinvoke v.<oadd.org.apache.zookeeper.KeeperException$Code: int intValue()>();
if v != v goto label;
v = interfaceinvoke v.<oadd.org.apache.curator.framework.api.CuratorEvent: java.lang.String getName()>();
label:
if v == null goto label;
label:
v = v.<oadd.org.apache.curator.framework.recipes.nodes.PersistentNode: oadd.org.apache.curator.framework.WatcherRemoveCuratorFramework client>;
v = interfaceinvoke v.<oadd.org.apache.curator.framework.WatcherRemoveCuratorFramework: oadd.org.apache.curator.framework.api.DeleteBuilder delete()>();
v = interfaceinvoke v.<oadd.org.apache.curator.framework.api.DeleteBuilder: java.lang.Object guaranteed()>();
v = interfaceinvoke v.<oadd.org.apache.curator.framework.api.ChildrenDeletable: java.lang.Object inBackground()>();
interfaceinvoke v.<oadd.org.apache.curator.framework.api.ErrorListenerPathable: java.lang.Object forPath(java.lang.String)>(v);
label:
goto label;
label:
v := @caughtexception;
v = v.<oadd.org.apache.curator.framework.recipes.nodes.PersistentNode: org.slf4j.Logger log>;
interfaceinvoke v.<org.slf4j.Logger: void error(java.lang.String,java.lang.Throwable)>("Could not delete node after close", v);
label:
return;
catch java.lang.Exception from label to label with label;
}
private void processBackgroundCallback(oadd.org.apache.curator.framework.api.CuratorEvent) throws java.lang.Exception
{
byte[] v;
oadd.org.apache.curator.framework.api.CuratorEvent v;
oadd.org.apache.zookeeper.KeeperException$Code v, v, v, v;
oadd.org.apache.curator.framework.api.SetDataBuilder v;
oadd.org.apache.curator.framework.recipes.nodes.PersistentNode v;
java.util.concurrent.atomic.AtomicReference v;
oadd.org.apache.curator.framework.api.BackgroundCallback v;
int v, v, v, v, v, v, v, v;
java.lang.Boolean v;
java.lang.String v, v, v, v;
boolean v, v;
org.slf4j.Logger v, v;
oadd.org.apache.curator.framework.WatcherRemoveCuratorFramework v;
java.lang.Object v;
v := @this: oadd.org.apache.curator.framework.recipes.nodes.PersistentNode;
v := @parameter: oadd.org.apache.curator.framework.api.CuratorEvent;
v = null;
v = 0;
v = interfaceinvoke v.<oadd.org.apache.curator.framework.api.CuratorEvent: int getResultCode()>();
v = <oadd.org.apache.zookeeper.KeeperException$Code: oadd.org.apache.zookeeper.KeeperException$Code NODEEXISTS>;
v = virtualinvoke v.<oadd.org.apache.zookeeper.KeeperException$Code: int intValue()>();
if v != v goto label;
v = interfaceinvoke v.<oadd.org.apache.curator.framework.api.CuratorEvent: java.lang.String getPath()>();
v = 1;
goto label;
label:
v = interfaceinvoke v.<oadd.org.apache.curator.framework.api.CuratorEvent: int getResultCode()>();
v = <oadd.org.apache.zookeeper.KeeperException$Code: oadd.org.apache.zookeeper.KeeperException$Code OK>;
v = virtualinvoke v.<oadd.org.apache.zookeeper.KeeperException$Code: int intValue()>();
if v != v goto label;
v = interfaceinvoke v.<oadd.org.apache.curator.framework.api.CuratorEvent: java.lang.String getName()>();
goto label;
label:
v = interfaceinvoke v.<oadd.org.apache.curator.framework.api.CuratorEvent: int getResultCode()>();
v = <oadd.org.apache.zookeeper.KeeperException$Code: oadd.org.apache.zookeeper.KeeperException$Code NOAUTH>;
v = virtualinvoke v.<oadd.org.apache.zookeeper.KeeperException$Code: int intValue()>();
if v != v goto label;
v = v.<oadd.org.apache.curator.framework.recipes.nodes.PersistentNode: org.slf4j.Logger log>;
v = interfaceinvoke v.<oadd.org.apache.curator.framework.api.CuratorEvent: java.lang.String getPath()>();
interfaceinvoke v.<org.slf4j.Logger: void warn(java.lang.String,java.lang.Object)>("Client does not have authorisation to create node at path {}", v);
v.<oadd.org.apache.curator.framework.recipes.nodes.PersistentNode: boolean authFailure> = 1;
return;
label:
v = interfaceinvoke v.<oadd.org.apache.curator.framework.api.CuratorEvent: int getResultCode()>();
v = <oadd.org.apache.zookeeper.KeeperException$Code: oadd.org.apache.zookeeper.KeeperException$Code NONODE>;
v = virtualinvoke v.<oadd.org.apache.zookeeper.KeeperException$Code: int intValue()>();
if v != v goto label;
v = v.<oadd.org.apache.curator.framework.recipes.nodes.PersistentNode: org.slf4j.Logger log>;
v = interfaceinvoke v.<oadd.org.apache.curator.framework.api.CuratorEvent: java.lang.String getPath()>();
v = v.<oadd.org.apache.curator.framework.recipes.nodes.PersistentNode: boolean useParentCreation>;
v = staticinvoke <java.lang.Boolean: java.lang.Boolean valueOf(boolean)>(v);
interfaceinvoke v.<org.slf4j.Logger: void warn(java.lang.String,java.lang.Object,java.lang.Object)>("Client cannot create parent hierarchy for path {} with useParentCreation set to {}", v, v);
v.<oadd.org.apache.curator.framework.recipes.nodes.PersistentNode: boolean parentCreationFailure> = 1;
return;
label:
if v == null goto label;
v.<oadd.org.apache.curator.framework.recipes.nodes.PersistentNode: boolean authFailure> = 0;
v = v.<oadd.org.apache.curator.framework.recipes.nodes.PersistentNode: java.util.concurrent.atomic.AtomicReference nodePath>;
virtualinvoke v.<java.util.concurrent.atomic.AtomicReference: void set(java.lang.Object)>(v);
specialinvoke v.<oadd.org.apache.curator.framework.recipes.nodes.PersistentNode: void watchNode()>();
if v == 0 goto label;
v = v.<oadd.org.apache.curator.framework.recipes.nodes.PersistentNode: oadd.org.apache.curator.framework.WatcherRemoveCuratorFramework client>;
v = interfaceinvoke v.<oadd.org.apache.curator.framework.WatcherRemoveCuratorFramework: oadd.org.apache.curator.framework.api.SetDataBuilder setData()>();
v = v.<oadd.org.apache.curator.framework.recipes.nodes.PersistentNode: oadd.org.apache.curator.framework.api.BackgroundCallback setDataCallback>;
v = interfaceinvoke v.<oadd.org.apache.curator.framework.api.SetDataBuilder: java.lang.Object inBackground(oadd.org.apache.curator.framework.api.BackgroundCallback)>(v);
v = virtualinvoke v.<oadd.org.apache.curator.framework.recipes.nodes.PersistentNode: java.lang.String getActualPath()>();
v = virtualinvoke v.<oadd.org.apache.curator.framework.recipes.nodes.PersistentNode: byte[] getData()>();
interfaceinvoke v.<oadd.org.apache.curator.framework.api.ErrorListenerPathAndBytesable: java.lang.Object forPath(java.lang.String,byte[])>(v, v);
goto label;
label:
specialinvoke v.<oadd.org.apache.curator.framework.recipes.nodes.PersistentNode: void initialisationComplete()>();
specialinvoke v.<oadd.org.apache.curator.framework.recipes.nodes.PersistentNode: void notifyListeners()>();
goto label;
label:
specialinvoke v.<oadd.org.apache.curator.framework.recipes.nodes.PersistentNode: void createNode()>();
label:
return;
}
private void initialisationComplete()
{
java.lang.Object v;
oadd.org.apache.curator.framework.recipes.nodes.PersistentNode v;
java.util.concurrent.atomic.AtomicReference v;
v := @this: oadd.org.apache.curator.framework.recipes.nodes.PersistentNode;
v = v.<oadd.org.apache.curator.framework.recipes.nodes.PersistentNode: java.util.concurrent.atomic.AtomicReference initialCreateLatch>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicReference: java.lang.Object getAndSet(java.lang.Object)>(null);
if v == null goto label;
virtualinvoke v.<java.util.concurrent.CountDownLatch: void countDown()>();
label:
return;
}
public void start()
{
oadd.org.apache.curator.framework.listen.Listenable v;
oadd.org.apache.curator.framework.state.ConnectionStateListener v;
oadd.org.apache.curator.framework.WatcherRemoveCuratorFramework v;
oadd.org.apache.curator.framework.recipes.nodes.PersistentNode v;
java.util.concurrent.atomic.AtomicReference v;
oadd.org.apache.curator.framework.recipes.nodes.PersistentNode$State v, v;
boolean v;
v := @this: oadd.org.apache.curator.framework.recipes.nodes.PersistentNode;
v = v.<oadd.org.apache.curator.framework.recipes.nodes.PersistentNode: java.util.concurrent.atomic.AtomicReference state>;
v = <oadd.org.apache.curator.framework.recipes.nodes.PersistentNode$State: oadd.org.apache.curator.framework.recipes.nodes.PersistentNode$State LATENT>;
v = <oadd.org.apache.curator.framework.recipes.nodes.PersistentNode$State: oadd.org.apache.curator.framework.recipes.nodes.PersistentNode$State STARTED>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicReference: boolean compareAndSet(java.lang.Object,java.lang.Object)>(v, v);
staticinvoke <oadd.org.apache.curator.shaded.com.google.common.base.Preconditions: void checkState(boolean,java.lang.Object)>(v, "Already started");
v = v.<oadd.org.apache.curator.framework.recipes.nodes.PersistentNode: oadd.org.apache.curator.framework.WatcherRemoveCuratorFramework client>;
v = interfaceinvoke v.<oadd.org.apache.curator.framework.WatcherRemoveCuratorFramework: oadd.org.apache.curator.framework.listen.Listenable getConnectionStateListenable()>();
v = v.<oadd.org.apache.curator.framework.recipes.nodes.PersistentNode: oadd.org.apache.curator.framework.state.ConnectionStateListener connectionStateListener>;
interfaceinvoke v.<oadd.org.apache.curator.framework.listen.Listenable: void addListener(java.lang.Object)>(v);
specialinvoke v.<oadd.org.apache.curator.framework.recipes.nodes.PersistentNode: void createNode()>();
return;
}
public boolean waitForInitialCreate(long, java.util.concurrent.TimeUnit) throws java.lang.InterruptedException
{
long v;
oadd.org.apache.curator.framework.recipes.nodes.PersistentNode v;
java.util.concurrent.atomic.AtomicReference v, v;
java.util.concurrent.TimeUnit v;
oadd.org.apache.curator.framework.recipes.nodes.PersistentNode$State v;
java.lang.Object v, v;
boolean v, v, v;
v := @this: oadd.org.apache.curator.framework.recipes.nodes.PersistentNode;
v := @parameter: long;
v := @parameter: java.util.concurrent.TimeUnit;
v = v.<oadd.org.apache.curator.framework.recipes.nodes.PersistentNode: java.util.concurrent.atomic.AtomicReference state>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicReference: java.lang.Object get()>();
v = <oadd.org.apache.curator.framework.recipes.nodes.PersistentNode$State: oadd.org.apache.curator.framework.recipes.nodes.PersistentNode$State STARTED>;
if v != v goto label;
v = 1;
goto label;
label:
v = 0;
label:
staticinvoke <oadd.org.apache.curator.shaded.com.google.common.base.Preconditions: void checkState(boolean,java.lang.Object)>(v, "Not started");
v = v.<oadd.org.apache.curator.framework.recipes.nodes.PersistentNode: java.util.concurrent.atomic.AtomicReference initialCreateLatch>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicReference: java.lang.Object get()>();
if v == null goto label;
v = virtualinvoke v.<java.util.concurrent.CountDownLatch: boolean await(long,java.util.concurrent.TimeUnit)>(v, v);
if v == 0 goto label;
label:
v = 1;
goto label;
label:
v = 0;
label:
return v;
}
public void close() throws java.io.IOException
{
oadd.org.apache.curator.framework.state.ConnectionStateListener v;
long v, v;
oadd.org.apache.curator.framework.recipes.nodes.PersistentNode v;
java.util.concurrent.atomic.AtomicReference v;
byte v;
java.lang.Thread v;
boolean v;
oadd.org.apache.curator.framework.listen.Listenable v;
java.io.IOException v;
oadd.org.apache.curator.framework.WatcherRemoveCuratorFramework v, v;
java.lang.Exception v;
java.util.concurrent.atomic.AtomicLong v, v;
java.lang.InterruptedException v;
oadd.org.apache.curator.framework.recipes.nodes.PersistentNode$State v, v;
v := @this: oadd.org.apache.curator.framework.recipes.nodes.PersistentNode;
v = v.<oadd.org.apache.curator.framework.recipes.nodes.PersistentNode: java.util.concurrent.atomic.AtomicLong debugWaitMsForBackgroundBeforeClose>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicLong: long get()>();
v = v cmp 0L;
if v <= 0 goto label;
label:
v = v.<oadd.org.apache.curator.framework.recipes.nodes.PersistentNode: java.util.concurrent.atomic.AtomicLong debugWaitMsForBackgroundBeforeClose>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicLong: long get()>();
staticinvoke <java.lang.Thread: void sleep(long)>(v);
label:
goto label;
label:
v := @caughtexception;
v = staticinvoke <java.lang.Thread: java.lang.Thread currentThread()>();
virtualinvoke v.<java.lang.Thread: void interrupt()>();
label:
v = v.<oadd.org.apache.curator.framework.recipes.nodes.PersistentNode: java.util.concurrent.atomic.AtomicReference state>;
v = <oadd.org.apache.curator.framework.recipes.nodes.PersistentNode$State: oadd.org.apache.curator.framework.recipes.nodes.PersistentNode$State STARTED>;
v = <oadd.org.apache.curator.framework.recipes.nodes.PersistentNode$State: oadd.org.apache.curator.framework.recipes.nodes.PersistentNode$State CLOSED>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicReference: boolean compareAndSet(java.lang.Object,java.lang.Object)>(v, v);
if v != 0 goto label;
return;
label:
v = v.<oadd.org.apache.curator.framework.recipes.nodes.PersistentNode: oadd.org.apache.curator.framework.WatcherRemoveCuratorFramework client>;
v = interfaceinvoke v.<oadd.org.apache.curator.framework.WatcherRemoveCuratorFramework: oadd.org.apache.curator.framework.listen.Listenable getConnectionStateListenable()>();
v = v.<oadd.org.apache.curator.framework.recipes.nodes.PersistentNode: oadd.org.apache.curator.framework.state.ConnectionStateListener connectionStateListener>;
interfaceinvoke v.<oadd.org.apache.curator.framework.listen.Listenable: void removeListener(java.lang.Object)>(v);
label:
virtualinvoke v.<oadd.org.apache.curator.framework.recipes.nodes.PersistentNode: void deleteNode()>();
label:
goto label;
label:
v := @caughtexception;
staticinvoke <oadd.org.apache.curator.utils.ThreadUtils: boolean checkInterrupted(java.lang.Throwable)>(v);
v = new java.io.IOException;
specialinvoke v.<java.io.IOException: void <init>(java.lang.Throwable)>(v);
throw v;
label:
v = v.<oadd.org.apache.curator.framework.recipes.nodes.PersistentNode: oadd.org.apache.curator.framework.WatcherRemoveCuratorFramework client>;
interfaceinvoke v.<oadd.org.apache.curator.framework.WatcherRemoveCuratorFramework: void removeWatchers()>();
return;
catch java.lang.InterruptedException from label to label with label;
catch java.lang.Exception from label to label with label;
}
public oadd.org.apache.curator.framework.listen.Listenable getListenable()
{
oadd.org.apache.curator.framework.listen.StandardListenerManager v;
oadd.org.apache.curator.framework.recipes.nodes.PersistentNode v;
v := @this: oadd.org.apache.curator.framework.recipes.nodes.PersistentNode;
v = v.<oadd.org.apache.curator.framework.recipes.nodes.PersistentNode: oadd.org.apache.curator.framework.listen.StandardListenerManager listeners>;
return v;
}
public java.lang.String getActualPath()
{
java.lang.Object v;
oadd.org.apache.curator.framework.recipes.nodes.PersistentNode v;
java.util.concurrent.atomic.AtomicReference v;
v := @this: oadd.org.apache.curator.framework.recipes.nodes.PersistentNode;
v = v.<oadd.org.apache.curator.framework.recipes.nodes.PersistentNode: java.util.concurrent.atomic.AtomicReference nodePath>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicReference: java.lang.Object get()>();
return v;
}
public void setData(byte[]) throws java.lang.Exception
{
byte[] v, v, v;
oadd.org.apache.curator.framework.api.SetDataBuilder v;
oadd.org.apache.curator.framework.recipes.nodes.PersistentNode v;
java.util.concurrent.atomic.AtomicReference v, v;
oadd.org.apache.curator.framework.api.BackgroundCallback v;
int v;
java.lang.String v;
boolean v, v, v, v;
oadd.org.apache.curator.framework.WatcherRemoveCuratorFramework v;
java.lang.Object v, v, v;
v := @this: oadd.org.apache.curator.framework.recipes.nodes.PersistentNode;
v := @parameter: byte[];
v = staticinvoke <oadd.org.apache.curator.shaded.com.google.common.base.Preconditions: java.lang.Object checkNotNull(java.lang.Object,java.lang.Object)>(v, "data cannot be null");
v = v.<oadd.org.apache.curator.framework.recipes.nodes.PersistentNode: java.util.concurrent.atomic.AtomicReference nodePath>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicReference: java.lang.Object get()>();
if v == null goto label;
v = 1;
goto label;
label:
v = 0;
label:
staticinvoke <oadd.org.apache.curator.shaded.com.google.common.base.Preconditions: void checkState(boolean,java.lang.Object)>(v, "initial create has not been processed. Call waitForInitialCreate() to ensure.");
v = v.<oadd.org.apache.curator.framework.recipes.nodes.PersistentNode: boolean parentCreationFailure>;
if v != 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
staticinvoke <oadd.org.apache.curator.shaded.com.google.common.base.Preconditions: void checkState(boolean,java.lang.Object)>(v, "Failed to create parent nodes.");
v = v.<oadd.org.apache.curator.framework.recipes.nodes.PersistentNode: java.util.concurrent.atomic.AtomicReference data>;
v = lengthof v;
v = staticinvoke <java.util.Arrays: byte[] copyOf(byte[],int)>(v, v);
virtualinvoke v.<java.util.concurrent.atomic.AtomicReference: void set(java.lang.Object)>(v);
v = specialinvoke v.<oadd.org.apache.curator.framework.recipes.nodes.PersistentNode: boolean isActive()>();
if v == 0 goto label;
v = v.<oadd.org.apache.curator.framework.recipes.nodes.PersistentNode: oadd.org.apache.curator.framework.WatcherRemoveCuratorFramework client>;
v = interfaceinvoke v.<oadd.org.apache.curator.framework.WatcherRemoveCuratorFramework: oadd.org.apache.curator.framework.api.SetDataBuilder setData()>();
v = v.<oadd.org.apache.curator.framework.recipes.nodes.PersistentNode: oadd.org.apache.curator.framework.api.BackgroundCallback setDataCallback>;
v = interfaceinvoke v.<oadd.org.apache.curator.framework.api.SetDataBuilder: java.lang.Object inBackground(oadd.org.apache.curator.framework.api.BackgroundCallback)>(v);
v = virtualinvoke v.<oadd.org.apache.curator.framework.recipes.nodes.PersistentNode: java.lang.String getActualPath()>();
v = virtualinvoke v.<oadd.org.apache.curator.framework.recipes.nodes.PersistentNode: byte[] getData()>();
interfaceinvoke v.<oadd.org.apache.curator.framework.api.ErrorListenerPathAndBytesable: java.lang.Object forPath(java.lang.String,byte[])>(v, v);
label:
return;
}
public byte[] getData()
{
java.lang.Object v;
oadd.org.apache.curator.framework.recipes.nodes.PersistentNode v;
java.util.concurrent.atomic.AtomicReference v;
v := @this: oadd.org.apache.curator.framework.recipes.nodes.PersistentNode;
v = v.<oadd.org.apache.curator.framework.recipes.nodes.PersistentNode: java.util.concurrent.atomic.AtomicReference data>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicReference: java.lang.Object get()>();
return v;
}
protected void deleteNode() throws java.lang.Exception
{
java.lang.Object v, v;
oadd.org.apache.zookeeper.KeeperException$NoNodeException v;
oadd.org.apache.curator.framework.WatcherRemoveCuratorFramework v;
oadd.org.apache.curator.framework.api.DeleteBuilder v;
oadd.org.apache.curator.framework.recipes.nodes.PersistentNode v;
java.util.concurrent.atomic.AtomicReference v;
v := @this: oadd.org.apache.curator.framework.recipes.nodes.PersistentNode;
v = v.<oadd.org.apache.curator.framework.recipes.nodes.PersistentNode: java.util.concurrent.atomic.AtomicReference nodePath>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicReference: java.lang.Object getAndSet(java.lang.Object)>(null);
if v == null goto label;
label:
v = v.<oadd.org.apache.curator.framework.recipes.nodes.PersistentNode: oadd.org.apache.curator.framework.WatcherRemoveCuratorFramework client>;
v = interfaceinvoke v.<oadd.org.apache.curator.framework.WatcherRemoveCuratorFramework: oadd.org.apache.curator.framework.api.DeleteBuilder delete()>();
v = interfaceinvoke v.<oadd.org.apache.curator.framework.api.DeleteBuilder: java.lang.Object guaranteed()>();
interfaceinvoke v.<oadd.org.apache.curator.framework.api.ChildrenDeletable: java.lang.Object forPath(java.lang.String)>(v);
label:
goto label;
label:
v := @caughtexception;
label:
return;
catch oadd.org.apache.zookeeper.KeeperException$NoNodeException from label to label with label;
}
private void createNode()
{
oadd.org.apache.zookeeper.CreateMode v, v, v;
oadd.org.apache.curator.framework.api.BackgroundCallback v;
oadd.org.apache.curator.framework.api.CreateBuilder v;
java.lang.Thread v;
boolean v, v, v, v, v, v, v, v;
oadd.org.apache.curator.framework.WatcherRemoveCuratorFramework v, v;
java.lang.Exception v;
java.util.concurrent.CountDownLatch v, v;
oadd.org.apache.curator.framework.api.CreateModable v;
oadd.org.apache.curator.framework.api.Statable v;
long v;
oadd.org.apache.curator.framework.recipes.nodes.PersistentNode v;
java.util.concurrent.atomic.AtomicReference v, v, v, v, v;
java.lang.String v, v, v, v, v;
oadd.org.apache.curator.framework.api.CreateBuilderMain v;
java.lang.RuntimeException v;
oadd.org.apache.curator.framework.api.ProtectACLCreateModeStatPathAndBytesable v;
java.lang.InterruptedException v;
java.lang.Object v, v, v, v, v, v;
v := @this: oadd.org.apache.curator.framework.recipes.nodes.PersistentNode;
v = specialinvoke v.<oadd.org.apache.curator.framework.recipes.nodes.PersistentNode: boolean isActive()>();
if v != 0 goto label;
return;
label:
v = v.<oadd.org.apache.curator.framework.recipes.nodes.PersistentNode: java.util.concurrent.CountDownLatch debugCreateNodeLatch>;
if v == null goto label;
label:
v = v.<oadd.org.apache.curator.framework.recipes.nodes.PersistentNode: java.util.concurrent.CountDownLatch debugCreateNodeLatch>;
virtualinvoke v.<java.util.concurrent.CountDownLatch: void await()>();
label:
goto label;
label:
v := @caughtexception;
v = staticinvoke <java.lang.Thread: java.lang.Thread currentThread()>();
virtualinvoke v.<java.lang.Thread: void interrupt()>();
return;
label:
v = v.<oadd.org.apache.curator.framework.recipes.nodes.PersistentNode: java.util.concurrent.atomic.AtomicReference nodePath>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicReference: java.lang.Object get()>();
if v == null goto label;
v = v.<oadd.org.apache.curator.framework.recipes.nodes.PersistentNode: boolean useProtection>;
if v != 0 goto label;
v = v;
goto label;
label:
if v == null goto label;
v = v.<oadd.org.apache.curator.framework.recipes.nodes.PersistentNode: oadd.org.apache.zookeeper.CreateMode mode>;
v = virtualinvoke v.<oadd.org.apache.zookeeper.CreateMode: boolean isSequential()>();
if v == 0 goto label;
v = v.<oadd.org.apache.curator.framework.recipes.nodes.PersistentNode: java.lang.String basePath>;
v = staticinvoke <oadd.org.apache.curator.utils.ZKPaths: java.lang.String extractSequentialSuffix(java.lang.String)>(v);
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[])>("\u0001\u0001");
goto label;
label:
v = v.<oadd.org.apache.curator.framework.recipes.nodes.PersistentNode: java.lang.String basePath>;
label:
v = v.<oadd.org.apache.curator.framework.recipes.nodes.PersistentNode: java.util.concurrent.atomic.AtomicReference createMethod>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicReference: java.lang.Object get()>();
if v != null goto label;
v = v.<oadd.org.apache.curator.framework.recipes.nodes.PersistentNode: oadd.org.apache.zookeeper.CreateMode mode>;
v = virtualinvoke v.<oadd.org.apache.zookeeper.CreateMode: boolean isTTL()>();
if v == 0 goto label;
v = v.<oadd.org.apache.curator.framework.recipes.nodes.PersistentNode: oadd.org.apache.curator.framework.WatcherRemoveCuratorFramework client>;
v = interfaceinvoke v.<oadd.org.apache.curator.framework.WatcherRemoveCuratorFramework: oadd.org.apache.curator.framework.api.CreateBuilder create()>();
v = v.<oadd.org.apache.curator.framework.recipes.nodes.PersistentNode: long ttl>;
v = interfaceinvoke v.<oadd.org.apache.curator.framework.api.CreateBuilder: oadd.org.apache.curator.framework.api.CreateBuilderMain withTtl(long)>(v);
goto label;
label:
v = v.<oadd.org.apache.curator.framework.recipes.nodes.PersistentNode: oadd.org.apache.curator.framework.WatcherRemoveCuratorFramework client>;
v = interfaceinvoke v.<oadd.org.apache.curator.framework.WatcherRemoveCuratorFramework: oadd.org.apache.curator.framework.api.CreateBuilder create()>();
label:
v = v.<oadd.org.apache.curator.framework.recipes.nodes.PersistentNode: boolean useParentCreation>;
if v == 0 goto label;
v = v.<oadd.org.apache.curator.framework.recipes.nodes.PersistentNode: boolean useProtection>;
if v == 0 goto label;
v = interfaceinvoke v.<oadd.org.apache.curator.framework.api.CreateBuilderMain: oadd.org.apache.curator.framework.api.ProtectACLCreateModeStatPathAndBytesable creatingParentContainersIfNeeded()>();
v = interfaceinvoke v.<oadd.org.apache.curator.framework.api.ProtectACLCreateModeStatPathAndBytesable: oadd.org.apache.curator.framework.api.ACLCreateModeBackgroundPathAndBytesable withProtection()>();
goto label;
label:
v = interfaceinvoke v.<oadd.org.apache.curator.framework.api.CreateBuilderMain: oadd.org.apache.curator.framework.api.ProtectACLCreateModeStatPathAndBytesable creatingParentContainersIfNeeded()>();
label:
v = v;
goto label;
label:
v = v.<oadd.org.apache.curator.framework.recipes.nodes.PersistentNode: boolean useProtection>;
if v == 0 goto label;
v = interfaceinvoke v.<oadd.org.apache.curator.framework.api.CreateBuilderMain: oadd.org.apache.curator.framework.api.ACLCreateModeStatBackgroundPathAndBytesable withProtection()>();
goto label;
label:
v = v;
label:
v = v;
label:
v = v.<oadd.org.apache.curator.framework.recipes.nodes.PersistentNode: java.util.concurrent.atomic.AtomicReference createMethod>;
virtualinvoke v.<java.util.concurrent.atomic.AtomicReference: boolean compareAndSet(java.lang.Object,java.lang.Object)>(null, v);
v = v.<oadd.org.apache.curator.framework.recipes.nodes.PersistentNode: java.util.concurrent.atomic.AtomicReference createMethod>;
virtualinvoke v.<java.util.concurrent.atomic.AtomicReference: java.lang.Object get()>();
label:
if v == null goto label;
v = 1;
goto label;
label:
v = 0;
label:
v = specialinvoke v.<oadd.org.apache.curator.framework.recipes.nodes.PersistentNode: oadd.org.apache.zookeeper.CreateMode getCreateMode(boolean)>(v);
v = interfaceinvoke v.<oadd.org.apache.curator.framework.api.CreateModable: java.lang.Object withMode(oadd.org.apache.zookeeper.CreateMode)>(v);
v = v.<oadd.org.apache.curator.framework.recipes.nodes.PersistentNode: oadd.org.apache.curator.framework.api.BackgroundCallback backgroundCallback>;
v = interfaceinvoke v.<oadd.org.apache.curator.framework.api.ACLBackgroundPathAndBytesable: java.lang.Object inBackground(oadd.org.apache.curator.framework.api.BackgroundCallback)>(v);
v = v.<oadd.org.apache.curator.framework.recipes.nodes.PersistentNode: java.util.concurrent.atomic.AtomicReference data>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicReference: java.lang.Object get()>();
interfaceinvoke v.<oadd.org.apache.curator.framework.api.ErrorListenerPathAndBytesable: java.lang.Object forPath(java.lang.String,byte[])>(v, v);
label:
goto label;
label:
v := @caughtexception;
staticinvoke <oadd.org.apache.curator.utils.ThreadUtils: boolean checkInterrupted(java.lang.Throwable)>(v);
v = new java.lang.RuntimeException;
v = v.<oadd.org.apache.curator.framework.recipes.nodes.PersistentNode: java.lang.String basePath>;
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[])>("Creating node. BasePath: \u0001");
specialinvoke v.<java.lang.RuntimeException: void <init>(java.lang.String,java.lang.Throwable)>(v, v);
throw v;
label:
return;
catch java.lang.InterruptedException from label to label with label;
catch java.lang.Exception from label to label with label;
}
private oadd.org.apache.zookeeper.CreateMode getCreateMode(boolean)
{
oadd.org.apache.zookeeper.CreateMode v, v, v, v, v;
oadd.org.apache.curator.framework.recipes.nodes.PersistentNode v;
int[] v;
int v, v;
boolean v;
v := @this: oadd.org.apache.curator.framework.recipes.nodes.PersistentNode;
v := @parameter: boolean;
if v == 0 goto label;
v = <oadd.org.apache.curator.framework.recipes.nodes.PersistentNode$6: int[] $SwitchMap$org$apache$zookeeper$CreateMode>;
v = v.<oadd.org.apache.curator.framework.recipes.nodes.PersistentNode: oadd.org.apache.zookeeper.CreateMode mode>;
v = virtualinvoke v.<oadd.org.apache.zookeeper.CreateMode: int ordinal()>();
v = v[v];
tableswitch(v)
{
case 1: goto label;
case 2: goto label;
case 3: goto label;
default: goto label;
};
label:
v = <oadd.org.apache.zookeeper.CreateMode: oadd.org.apache.zookeeper.CreateMode EPHEMERAL>;
return v;
label:
v = <oadd.org.apache.zookeeper.CreateMode: oadd.org.apache.zookeeper.CreateMode PERSISTENT>;
return v;
label:
v = <oadd.org.apache.zookeeper.CreateMode: oadd.org.apache.zookeeper.CreateMode PERSISTENT_WITH_TTL>;
return v;
label:
v = v.<oadd.org.apache.curator.framework.recipes.nodes.PersistentNode: oadd.org.apache.zookeeper.CreateMode mode>;
return v;
}
private void watchNode() throws java.lang.Exception
{
oadd.org.apache.curator.framework.WatcherRemoveCuratorFramework v;
oadd.org.apache.curator.framework.recipes.nodes.PersistentNode v;
java.util.concurrent.atomic.AtomicReference v;
oadd.org.apache.curator.framework.api.BackgroundCallback v;
oadd.org.apache.curator.framework.api.ExistsBuilder v;
java.lang.Object v, v, v;
boolean v;
oadd.org.apache.curator.framework.api.CuratorWatcher v;
v := @this: oadd.org.apache.curator.framework.recipes.nodes.PersistentNode;
v = specialinvoke v.<oadd.org.apache.curator.framework.recipes.nodes.PersistentNode: boolean isActive()>();
if v != 0 goto label;
return;
label:
v = v.<oadd.org.apache.curator.framework.recipes.nodes.PersistentNode: java.util.concurrent.atomic.AtomicReference nodePath>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicReference: java.lang.Object get()>();
if v == null goto label;
v = v.<oadd.org.apache.curator.framework.recipes.nodes.PersistentNode: oadd.org.apache.curator.framework.WatcherRemoveCuratorFramework client>;
v = interfaceinvoke v.<oadd.org.apache.curator.framework.WatcherRemoveCuratorFramework: oadd.org.apache.curator.framework.api.ExistsBuilder checkExists()>();
v = v.<oadd.org.apache.curator.framework.recipes.nodes.PersistentNode: oadd.org.apache.curator.framework.api.CuratorWatcher watcher>;
v = interfaceinvoke v.<oadd.org.apache.curator.framework.api.ExistsBuilder: java.lang.Object usingWatcher(oadd.org.apache.curator.framework.api.CuratorWatcher)>(v);
v = v.<oadd.org.apache.curator.framework.recipes.nodes.PersistentNode: oadd.org.apache.curator.framework.api.BackgroundCallback checkExistsCallback>;
v = interfaceinvoke v.<oadd.org.apache.curator.framework.api.BackgroundPathable: java.lang.Object inBackground(oadd.org.apache.curator.framework.api.BackgroundCallback)>(v);
interfaceinvoke v.<oadd.org.apache.curator.framework.api.ErrorListenerPathable: java.lang.Object forPath(java.lang.String)>(v);
label:
return;
}
private void notifyListeners()
{
java.util.function.Consumer v;
oadd.org.apache.curator.framework.listen.StandardListenerManager v;
java.lang.String v;
oadd.org.apache.curator.framework.recipes.nodes.PersistentNode v;
v := @this: oadd.org.apache.curator.framework.recipes.nodes.PersistentNode;
v = virtualinvoke v.<oadd.org.apache.curator.framework.recipes.nodes.PersistentNode: java.lang.String getActualPath()>();
v = v.<oadd.org.apache.curator.framework.recipes.nodes.PersistentNode: oadd.org.apache.curator.framework.listen.StandardListenerManager listeners>;
v = staticinvoke <oadd.org.apache.curator.framework.recipes.nodes.PersistentNode$lambda_notifyListeners_0__1036: java.util.function.Consumer bootstrap$(oadd.org.apache.curator.framework.recipes.nodes.PersistentNode,java.lang.String)>(v, v);
virtualinvoke v.<oadd.org.apache.curator.framework.listen.StandardListenerManager: void forEach(java.util.function.Consumer)>(v);
return;
}
private boolean isActive()
{
oadd.org.apache.curator.framework.recipes.nodes.PersistentNode$State v;
java.lang.Object v;
oadd.org.apache.curator.framework.recipes.nodes.PersistentNode v;
java.util.concurrent.atomic.AtomicReference v;
boolean v;
v := @this: oadd.org.apache.curator.framework.recipes.nodes.PersistentNode;
v = v.<oadd.org.apache.curator.framework.recipes.nodes.PersistentNode: java.util.concurrent.atomic.AtomicReference state>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicReference: java.lang.Object get()>();
v = <oadd.org.apache.curator.framework.recipes.nodes.PersistentNode$State: oadd.org.apache.curator.framework.recipes.nodes.PersistentNode$State STARTED>;
if v != v goto label;
v = 1;
goto label;
label:
v = 0;
label:
return v;
}
boolean isAuthFailure()
{
oadd.org.apache.curator.framework.recipes.nodes.PersistentNode v;
boolean v;
v := @this: oadd.org.apache.curator.framework.recipes.nodes.PersistentNode;
v = v.<oadd.org.apache.curator.framework.recipes.nodes.PersistentNode: boolean authFailure>;
return v;
}
boolean isParentCreationFailure()
{
oadd.org.apache.curator.framework.recipes.nodes.PersistentNode v;
boolean v;
v := @this: oadd.org.apache.curator.framework.recipes.nodes.PersistentNode;
v = v.<oadd.org.apache.curator.framework.recipes.nodes.PersistentNode: boolean parentCreationFailure>;
return v;
}
}