public class oadd.org.apache.curator.framework.recipes.shared.SharedValue extends java.lang.Object implements java.io.Closeable, oadd.org.apache.curator.framework.recipes.shared.SharedValueReader
{
private static final int UNINITIALIZED_VERSION;
private final org.slf4j.Logger log;
private final oadd.org.apache.curator.framework.listen.StandardListenerManager listeners;
private final oadd.org.apache.curator.framework.WatcherRemoveCuratorFramework client;
private final java.lang.String path;
private final byte[] seedValue;
private final java.util.concurrent.atomic.AtomicReference state;
private final java.util.concurrent.atomic.AtomicReference currentValue;
private final oadd.org.apache.curator.framework.api.CuratorWatcher watcher;
private final oadd.org.apache.curator.framework.state.ConnectionStateListener connectionStateListener;
private final oadd.org.apache.curator.framework.api.BackgroundCallback upadateAndNotifyListenerCallback;
public void <init>(oadd.org.apache.curator.framework.CuratorFramework, java.lang.String, byte[])
{
byte[] v, v, v;
oadd.org.apache.curator.framework.recipes.shared.SharedValue$State v;
oadd.org.apache.curator.framework.listen.StandardListenerManager v;
java.util.concurrent.atomic.AtomicReference v, v;
int v, v, v;
oadd.org.apache.curator.framework.recipes.shared.SharedValue v;
java.lang.String v, v;
org.slf4j.Logger v;
oadd.org.apache.curator.framework.recipes.shared.VersionedValue v;
oadd.org.apache.curator.framework.CuratorFramework v;
oadd.org.apache.curator.framework.WatcherRemoveCuratorFramework v;
oadd.org.apache.curator.framework.recipes.shared.SharedValue$SharedValueCuratorWatcher v;
oadd.org.apache.curator.framework.recipes.shared.SharedValue$2 v;
oadd.org.apache.curator.framework.recipes.shared.SharedValue$1 v;
java.lang.Class v;
v := @this: oadd.org.apache.curator.framework.recipes.shared.SharedValue;
v := @parameter: oadd.org.apache.curator.framework.CuratorFramework;
v := @parameter: java.lang.String;
v := @parameter: byte[];
specialinvoke v.<java.lang.Object: void <init>()>();
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.shared.SharedValue: org.slf4j.Logger log> = 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.shared.SharedValue: oadd.org.apache.curator.framework.listen.StandardListenerManager listeners> = v;
v = new java.util.concurrent.atomic.AtomicReference;
v = <oadd.org.apache.curator.framework.recipes.shared.SharedValue$State: oadd.org.apache.curator.framework.recipes.shared.SharedValue$State LATENT>;
specialinvoke v.<java.util.concurrent.atomic.AtomicReference: void <init>(java.lang.Object)>(v);
v.<oadd.org.apache.curator.framework.recipes.shared.SharedValue: java.util.concurrent.atomic.AtomicReference state> = v;
v = new oadd.org.apache.curator.framework.recipes.shared.SharedValue$1;
specialinvoke v.<oadd.org.apache.curator.framework.recipes.shared.SharedValue$1: void <init>(oadd.org.apache.curator.framework.recipes.shared.SharedValue)>(v);
v.<oadd.org.apache.curator.framework.recipes.shared.SharedValue: oadd.org.apache.curator.framework.state.ConnectionStateListener connectionStateListener> = v;
v = new oadd.org.apache.curator.framework.recipes.shared.SharedValue$2;
specialinvoke v.<oadd.org.apache.curator.framework.recipes.shared.SharedValue$2: void <init>(oadd.org.apache.curator.framework.recipes.shared.SharedValue)>(v);
v.<oadd.org.apache.curator.framework.recipes.shared.SharedValue: oadd.org.apache.curator.framework.api.BackgroundCallback upadateAndNotifyListenerCallback> = v;
v = interfaceinvoke v.<oadd.org.apache.curator.framework.CuratorFramework: oadd.org.apache.curator.framework.WatcherRemoveCuratorFramework newWatcherRemoveCuratorFramework()>();
v.<oadd.org.apache.curator.framework.recipes.shared.SharedValue: 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.shared.SharedValue: java.lang.String path> = v;
v = lengthof v;
v = staticinvoke <java.util.Arrays: byte[] copyOf(byte[],int)>(v, v);
v.<oadd.org.apache.curator.framework.recipes.shared.SharedValue: byte[] seedValue> = v;
v = new oadd.org.apache.curator.framework.recipes.shared.SharedValue$SharedValueCuratorWatcher;
specialinvoke v.<oadd.org.apache.curator.framework.recipes.shared.SharedValue$SharedValueCuratorWatcher: void <init>(oadd.org.apache.curator.framework.recipes.shared.SharedValue)>(v);
v.<oadd.org.apache.curator.framework.recipes.shared.SharedValue: oadd.org.apache.curator.framework.api.CuratorWatcher watcher> = v;
v = new java.util.concurrent.atomic.AtomicReference;
v = new oadd.org.apache.curator.framework.recipes.shared.VersionedValue;
v = lengthof v;
v = staticinvoke <java.util.Arrays: byte[] copyOf(byte[],int)>(v, v);
v = (int) -1;
specialinvoke v.<oadd.org.apache.curator.framework.recipes.shared.VersionedValue: void <init>(int,java.lang.Object)>(v, v);
specialinvoke v.<java.util.concurrent.atomic.AtomicReference: void <init>(java.lang.Object)>(v);
v.<oadd.org.apache.curator.framework.recipes.shared.SharedValue: java.util.concurrent.atomic.AtomicReference currentValue> = v;
return;
}
protected void <init>(oadd.org.apache.curator.framework.WatcherRemoveCuratorFramework, java.lang.String, byte[], oadd.org.apache.curator.framework.api.CuratorWatcher)
{
byte[] v, v, v;
oadd.org.apache.curator.framework.recipes.shared.SharedValue$State v;
oadd.org.apache.curator.framework.listen.StandardListenerManager v;
java.util.concurrent.atomic.AtomicReference v, v;
int v, v, v;
oadd.org.apache.curator.framework.recipes.shared.SharedValue v;
java.lang.String v, v;
org.slf4j.Logger v;
oadd.org.apache.curator.framework.recipes.shared.VersionedValue v;
oadd.org.apache.curator.framework.WatcherRemoveCuratorFramework v;
oadd.org.apache.curator.framework.recipes.shared.SharedValue$2 v;
oadd.org.apache.curator.framework.recipes.shared.SharedValue$1 v;
java.lang.Class v;
oadd.org.apache.curator.framework.api.CuratorWatcher v;
v := @this: oadd.org.apache.curator.framework.recipes.shared.SharedValue;
v := @parameter: oadd.org.apache.curator.framework.WatcherRemoveCuratorFramework;
v := @parameter: java.lang.String;
v := @parameter: byte[];
v := @parameter: oadd.org.apache.curator.framework.api.CuratorWatcher;
specialinvoke v.<java.lang.Object: void <init>()>();
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.shared.SharedValue: org.slf4j.Logger log> = 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.shared.SharedValue: oadd.org.apache.curator.framework.listen.StandardListenerManager listeners> = v;
v = new java.util.concurrent.atomic.AtomicReference;
v = <oadd.org.apache.curator.framework.recipes.shared.SharedValue$State: oadd.org.apache.curator.framework.recipes.shared.SharedValue$State LATENT>;
specialinvoke v.<java.util.concurrent.atomic.AtomicReference: void <init>(java.lang.Object)>(v);
v.<oadd.org.apache.curator.framework.recipes.shared.SharedValue: java.util.concurrent.atomic.AtomicReference state> = v;
v = new oadd.org.apache.curator.framework.recipes.shared.SharedValue$1;
specialinvoke v.<oadd.org.apache.curator.framework.recipes.shared.SharedValue$1: void <init>(oadd.org.apache.curator.framework.recipes.shared.SharedValue)>(v);
v.<oadd.org.apache.curator.framework.recipes.shared.SharedValue: oadd.org.apache.curator.framework.state.ConnectionStateListener connectionStateListener> = v;
v = new oadd.org.apache.curator.framework.recipes.shared.SharedValue$2;
specialinvoke v.<oadd.org.apache.curator.framework.recipes.shared.SharedValue$2: void <init>(oadd.org.apache.curator.framework.recipes.shared.SharedValue)>(v);
v.<oadd.org.apache.curator.framework.recipes.shared.SharedValue: oadd.org.apache.curator.framework.api.BackgroundCallback upadateAndNotifyListenerCallback> = v;
v.<oadd.org.apache.curator.framework.recipes.shared.SharedValue: 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.shared.SharedValue: java.lang.String path> = v;
v = lengthof v;
v = staticinvoke <java.util.Arrays: byte[] copyOf(byte[],int)>(v, v);
v.<oadd.org.apache.curator.framework.recipes.shared.SharedValue: byte[] seedValue> = v;
v.<oadd.org.apache.curator.framework.recipes.shared.SharedValue: oadd.org.apache.curator.framework.api.CuratorWatcher watcher> = v;
v = new java.util.concurrent.atomic.AtomicReference;
v = new oadd.org.apache.curator.framework.recipes.shared.VersionedValue;
v = lengthof v;
v = staticinvoke <java.util.Arrays: byte[] copyOf(byte[],int)>(v, v);
v = (int) -1;
specialinvoke v.<oadd.org.apache.curator.framework.recipes.shared.VersionedValue: void <init>(int,java.lang.Object)>(v, v);
specialinvoke v.<java.util.concurrent.atomic.AtomicReference: void <init>(java.lang.Object)>(v);
v.<oadd.org.apache.curator.framework.recipes.shared.SharedValue: java.util.concurrent.atomic.AtomicReference currentValue> = v;
return;
}
public byte[] getValue()
{
byte[] v;
int v;
java.lang.Object v, v, v;
oadd.org.apache.curator.framework.recipes.shared.SharedValue v;
java.util.concurrent.atomic.AtomicReference v;
v := @this: oadd.org.apache.curator.framework.recipes.shared.SharedValue;
v = v.<oadd.org.apache.curator.framework.recipes.shared.SharedValue: java.util.concurrent.atomic.AtomicReference currentValue>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicReference: java.lang.Object get()>();
v = virtualinvoke v.<oadd.org.apache.curator.framework.recipes.shared.VersionedValue: java.lang.Object getValue()>();
v = virtualinvoke v.<oadd.org.apache.curator.framework.recipes.shared.VersionedValue: java.lang.Object getValue()>();
v = lengthof v;
v = staticinvoke <java.util.Arrays: byte[] copyOf(byte[],int)>(v, v);
return v;
}
public oadd.org.apache.curator.framework.recipes.shared.VersionedValue getVersionedValue()
{
byte[] v;
oadd.org.apache.curator.framework.recipes.shared.VersionedValue v;
java.util.concurrent.atomic.AtomicReference v;
int v, v;
java.lang.Object v, v, v;
oadd.org.apache.curator.framework.recipes.shared.SharedValue v;
v := @this: oadd.org.apache.curator.framework.recipes.shared.SharedValue;
v = v.<oadd.org.apache.curator.framework.recipes.shared.SharedValue: java.util.concurrent.atomic.AtomicReference currentValue>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicReference: java.lang.Object get()>();
v = new oadd.org.apache.curator.framework.recipes.shared.VersionedValue;
v = virtualinvoke v.<oadd.org.apache.curator.framework.recipes.shared.VersionedValue: int getVersion()>();
v = virtualinvoke v.<oadd.org.apache.curator.framework.recipes.shared.VersionedValue: java.lang.Object getValue()>();
v = virtualinvoke v.<oadd.org.apache.curator.framework.recipes.shared.VersionedValue: java.lang.Object getValue()>();
v = lengthof v;
v = staticinvoke <java.util.Arrays: byte[] copyOf(byte[],int)>(v, v);
specialinvoke v.<oadd.org.apache.curator.framework.recipes.shared.VersionedValue: void <init>(int,java.lang.Object)>(v, v);
return v;
}
public void setValue(byte[]) throws java.lang.Exception
{
byte[] v, v;
oadd.org.apache.curator.framework.recipes.shared.SharedValue$State v;
oadd.org.apache.curator.framework.api.SetDataBuilder v;
oadd.org.apache.curator.framework.WatcherRemoveCuratorFramework v;
java.util.concurrent.atomic.AtomicReference v;
int v, v;
java.lang.Object v, v;
oadd.org.apache.curator.framework.recipes.shared.SharedValue v;
java.lang.String v;
boolean v;
v := @this: oadd.org.apache.curator.framework.recipes.shared.SharedValue;
v := @parameter: byte[];
v = v.<oadd.org.apache.curator.framework.recipes.shared.SharedValue: 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.shared.SharedValue$State: oadd.org.apache.curator.framework.recipes.shared.SharedValue$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.shared.SharedValue: 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.shared.SharedValue: java.lang.String path>;
v = interfaceinvoke v.<oadd.org.apache.curator.framework.api.SetDataBuilder: java.lang.Object forPath(java.lang.String,byte[])>(v, v);
v = virtualinvoke v.<oadd.org.apache.zookeeper.data.Stat: int getVersion()>();
v = lengthof v;
v = staticinvoke <java.util.Arrays: byte[] copyOf(byte[],int)>(v, v);
specialinvoke v.<oadd.org.apache.curator.framework.recipes.shared.SharedValue: void updateValue(int,byte[])>(v, v);
return;
}
public boolean trySetValue(byte[]) throws java.lang.Exception
{
byte[] v;
java.lang.Object v;
oadd.org.apache.curator.framework.recipes.shared.SharedValue v;
java.util.concurrent.atomic.AtomicReference v;
boolean v;
v := @this: oadd.org.apache.curator.framework.recipes.shared.SharedValue;
v := @parameter: byte[];
v = v.<oadd.org.apache.curator.framework.recipes.shared.SharedValue: java.util.concurrent.atomic.AtomicReference currentValue>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicReference: java.lang.Object get()>();
v = virtualinvoke v.<oadd.org.apache.curator.framework.recipes.shared.SharedValue: boolean trySetValue(oadd.org.apache.curator.framework.recipes.shared.VersionedValue,byte[])>(v, v);
return v;
}
public boolean trySetValue(oadd.org.apache.curator.framework.recipes.shared.VersionedValue, byte[]) throws java.lang.Exception
{
byte[] v, v;
oadd.org.apache.curator.framework.recipes.shared.SharedValue$State v;
oadd.org.apache.curator.framework.api.SetDataBuilder v;
java.util.concurrent.atomic.AtomicReference v, v;
int v, v, v, v, v;
oadd.org.apache.curator.framework.recipes.shared.SharedValue v;
java.lang.String v;
boolean v, v;
oadd.org.apache.curator.framework.recipes.shared.VersionedValue v;
oadd.org.apache.curator.framework.WatcherRemoveCuratorFramework v;
oadd.org.apache.zookeeper.KeeperException$BadVersionException v;
java.lang.Object v, v, v, v, v, v;
v := @this: oadd.org.apache.curator.framework.recipes.shared.SharedValue;
v := @parameter: oadd.org.apache.curator.framework.recipes.shared.VersionedValue;
v := @parameter: byte[];
v = v.<oadd.org.apache.curator.framework.recipes.shared.SharedValue: 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.shared.SharedValue$State: oadd.org.apache.curator.framework.recipes.shared.SharedValue$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.shared.SharedValue: java.util.concurrent.atomic.AtomicReference currentValue>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicReference: java.lang.Object get()>();
v = virtualinvoke v.<oadd.org.apache.curator.framework.recipes.shared.VersionedValue: int getVersion()>();
v = virtualinvoke v.<oadd.org.apache.curator.framework.recipes.shared.VersionedValue: int getVersion()>();
if v != v goto label;
v = virtualinvoke v.<oadd.org.apache.curator.framework.recipes.shared.VersionedValue: java.lang.Object getValue()>();
v = virtualinvoke v.<oadd.org.apache.curator.framework.recipes.shared.VersionedValue: java.lang.Object getValue()>();
v = staticinvoke <java.util.Arrays: boolean equals(byte[],byte[])>(v, v);
if v != 0 goto label;
label:
return 0;
label:
v = v.<oadd.org.apache.curator.framework.recipes.shared.SharedValue: 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 = virtualinvoke v.<oadd.org.apache.curator.framework.recipes.shared.VersionedValue: int getVersion()>();
v = interfaceinvoke v.<oadd.org.apache.curator.framework.api.SetDataBuilder: java.lang.Object withVersion(int)>(v);
v = v.<oadd.org.apache.curator.framework.recipes.shared.SharedValue: java.lang.String path>;
v = interfaceinvoke v.<oadd.org.apache.curator.framework.api.BackgroundPathAndBytesable: java.lang.Object forPath(java.lang.String,byte[])>(v, v);
v = virtualinvoke v.<oadd.org.apache.zookeeper.data.Stat: int getVersion()>();
v = lengthof v;
v = staticinvoke <java.util.Arrays: byte[] copyOf(byte[],int)>(v, v);
specialinvoke v.<oadd.org.apache.curator.framework.recipes.shared.SharedValue: void updateValue(int,byte[])>(v, v);
label:
return 1;
label:
v := @caughtexception;
specialinvoke v.<oadd.org.apache.curator.framework.recipes.shared.SharedValue: void readValue()>();
return 0;
catch oadd.org.apache.zookeeper.KeeperException$BadVersionException from label to label with label;
}
private void updateValue(int, byte[])
{
byte[] v;
oadd.org.apache.curator.framework.recipes.shared.VersionedValue v;
java.util.concurrent.atomic.AtomicReference v, v;
int v, v;
java.lang.Object v;
oadd.org.apache.curator.framework.recipes.shared.SharedValue v;
boolean v;
v := @this: oadd.org.apache.curator.framework.recipes.shared.SharedValue;
v := @parameter: int;
v := @parameter: byte[];
label:
v = v.<oadd.org.apache.curator.framework.recipes.shared.SharedValue: java.util.concurrent.atomic.AtomicReference currentValue>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicReference: java.lang.Object get()>();
v = virtualinvoke v.<oadd.org.apache.curator.framework.recipes.shared.VersionedValue: int getVersion()>();
if v < v goto label;
return;
label:
v = v.<oadd.org.apache.curator.framework.recipes.shared.SharedValue: java.util.concurrent.atomic.AtomicReference currentValue>;
v = new oadd.org.apache.curator.framework.recipes.shared.VersionedValue;
specialinvoke v.<oadd.org.apache.curator.framework.recipes.shared.VersionedValue: void <init>(int,java.lang.Object)>(v, v);
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicReference: boolean compareAndSet(java.lang.Object,java.lang.Object)>(v, v);
if v == 0 goto label;
return;
}
public oadd.org.apache.curator.framework.listen.Listenable getListenable()
{
oadd.org.apache.curator.framework.listen.StandardListenerManager v;
oadd.org.apache.curator.framework.recipes.shared.SharedValue v;
v := @this: oadd.org.apache.curator.framework.recipes.shared.SharedValue;
v = v.<oadd.org.apache.curator.framework.recipes.shared.SharedValue: oadd.org.apache.curator.framework.listen.StandardListenerManager listeners>;
return v;
}
public void start() throws java.lang.Exception
{
oadd.org.apache.curator.framework.listen.Listenable v;
byte[] v;
oadd.org.apache.curator.framework.recipes.shared.SharedValue$State v, v;
oadd.org.apache.zookeeper.KeeperException$NodeExistsException v;
oadd.org.apache.curator.framework.state.ConnectionStateListener v;
oadd.org.apache.curator.framework.WatcherRemoveCuratorFramework v, v;
oadd.org.apache.curator.framework.api.ProtectACLCreateModeStatPathAndBytesable v;
java.util.concurrent.atomic.AtomicReference v;
oadd.org.apache.curator.framework.api.CreateBuilder v;
oadd.org.apache.curator.framework.recipes.shared.SharedValue v;
java.lang.String v;
boolean v;
v := @this: oadd.org.apache.curator.framework.recipes.shared.SharedValue;
v = v.<oadd.org.apache.curator.framework.recipes.shared.SharedValue: java.util.concurrent.atomic.AtomicReference state>;
v = <oadd.org.apache.curator.framework.recipes.shared.SharedValue$State: oadd.org.apache.curator.framework.recipes.shared.SharedValue$State LATENT>;
v = <oadd.org.apache.curator.framework.recipes.shared.SharedValue$State: oadd.org.apache.curator.framework.recipes.shared.SharedValue$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, "Cannot be started more than once");
v = v.<oadd.org.apache.curator.framework.recipes.shared.SharedValue: 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.shared.SharedValue: oadd.org.apache.curator.framework.state.ConnectionStateListener connectionStateListener>;
interfaceinvoke v.<oadd.org.apache.curator.framework.listen.Listenable: void addListener(java.lang.Object)>(v);
label:
v = v.<oadd.org.apache.curator.framework.recipes.shared.SharedValue: 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 = interfaceinvoke v.<oadd.org.apache.curator.framework.api.CreateBuilder: oadd.org.apache.curator.framework.api.ProtectACLCreateModeStatPathAndBytesable creatingParentContainersIfNeeded()>();
v = v.<oadd.org.apache.curator.framework.recipes.shared.SharedValue: java.lang.String path>;
v = v.<oadd.org.apache.curator.framework.recipes.shared.SharedValue: byte[] seedValue>;
interfaceinvoke v.<oadd.org.apache.curator.framework.api.ProtectACLCreateModeStatPathAndBytesable: java.lang.Object forPath(java.lang.String,byte[])>(v, v);
label:
goto label;
label:
v := @caughtexception;
label:
specialinvoke v.<oadd.org.apache.curator.framework.recipes.shared.SharedValue: void readValue()>();
return;
catch oadd.org.apache.zookeeper.KeeperException$NodeExistsException from label to label with label;
}
public void close() throws java.io.IOException
{
oadd.org.apache.curator.framework.listen.Listenable v;
oadd.org.apache.curator.framework.recipes.shared.SharedValue$State v;
oadd.org.apache.curator.framework.state.ConnectionStateListener v;
oadd.org.apache.curator.framework.listen.StandardListenerManager v;
oadd.org.apache.curator.framework.WatcherRemoveCuratorFramework v, v;
java.util.concurrent.atomic.AtomicReference v;
oadd.org.apache.curator.framework.recipes.shared.SharedValue v;
v := @this: oadd.org.apache.curator.framework.recipes.shared.SharedValue;
v = v.<oadd.org.apache.curator.framework.recipes.shared.SharedValue: java.util.concurrent.atomic.AtomicReference state>;
v = <oadd.org.apache.curator.framework.recipes.shared.SharedValue$State: oadd.org.apache.curator.framework.recipes.shared.SharedValue$State CLOSED>;
virtualinvoke v.<java.util.concurrent.atomic.AtomicReference: void set(java.lang.Object)>(v);
v = v.<oadd.org.apache.curator.framework.recipes.shared.SharedValue: oadd.org.apache.curator.framework.WatcherRemoveCuratorFramework client>;
interfaceinvoke v.<oadd.org.apache.curator.framework.WatcherRemoveCuratorFramework: void removeWatchers()>();
v = v.<oadd.org.apache.curator.framework.recipes.shared.SharedValue: 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.shared.SharedValue: oadd.org.apache.curator.framework.state.ConnectionStateListener connectionStateListener>;
interfaceinvoke v.<oadd.org.apache.curator.framework.listen.Listenable: void removeListener(java.lang.Object)>(v);
v = v.<oadd.org.apache.curator.framework.recipes.shared.SharedValue: oadd.org.apache.curator.framework.listen.StandardListenerManager listeners>;
virtualinvoke v.<oadd.org.apache.curator.framework.listen.StandardListenerManager: void clear()>();
return;
}
private void readValue() throws java.lang.Exception
{
oadd.org.apache.curator.framework.api.GetDataBuilder v;
oadd.org.apache.curator.framework.WatcherRemoveCuratorFramework v;
int v;
java.lang.Object v, v, v;
oadd.org.apache.curator.framework.recipes.shared.SharedValue v;
java.lang.String v;
oadd.org.apache.zookeeper.data.Stat v;
oadd.org.apache.curator.framework.api.CuratorWatcher v;
v := @this: oadd.org.apache.curator.framework.recipes.shared.SharedValue;
v = new oadd.org.apache.zookeeper.data.Stat;
specialinvoke v.<oadd.org.apache.zookeeper.data.Stat: void <init>()>();
v = v.<oadd.org.apache.curator.framework.recipes.shared.SharedValue: oadd.org.apache.curator.framework.WatcherRemoveCuratorFramework client>;
v = interfaceinvoke v.<oadd.org.apache.curator.framework.WatcherRemoveCuratorFramework: oadd.org.apache.curator.framework.api.GetDataBuilder getData()>();
v = interfaceinvoke v.<oadd.org.apache.curator.framework.api.GetDataBuilder: java.lang.Object storingStatIn(oadd.org.apache.zookeeper.data.Stat)>(v);
v = v.<oadd.org.apache.curator.framework.recipes.shared.SharedValue: oadd.org.apache.curator.framework.api.CuratorWatcher watcher>;
v = interfaceinvoke v.<oadd.org.apache.curator.framework.api.WatchPathable: java.lang.Object usingWatcher(oadd.org.apache.curator.framework.api.CuratorWatcher)>(v);
v = v.<oadd.org.apache.curator.framework.recipes.shared.SharedValue: java.lang.String path>;
v = interfaceinvoke v.<oadd.org.apache.curator.framework.api.Pathable: java.lang.Object forPath(java.lang.String)>(v);
v = virtualinvoke v.<oadd.org.apache.zookeeper.data.Stat: int getVersion()>();
specialinvoke v.<oadd.org.apache.curator.framework.recipes.shared.SharedValue: void updateValue(int,byte[])>(v, v);
return;
}
private void readValueAndNotifyListenersInBackground() throws java.lang.Exception
{
oadd.org.apache.curator.framework.api.GetDataBuilder v;
oadd.org.apache.curator.framework.WatcherRemoveCuratorFramework v;
oadd.org.apache.curator.framework.api.BackgroundCallback v;
java.lang.Object v, v;
oadd.org.apache.curator.framework.recipes.shared.SharedValue v;
java.lang.String v;
oadd.org.apache.curator.framework.api.CuratorWatcher v;
v := @this: oadd.org.apache.curator.framework.recipes.shared.SharedValue;
v = v.<oadd.org.apache.curator.framework.recipes.shared.SharedValue: oadd.org.apache.curator.framework.WatcherRemoveCuratorFramework client>;
v = interfaceinvoke v.<oadd.org.apache.curator.framework.WatcherRemoveCuratorFramework: oadd.org.apache.curator.framework.api.GetDataBuilder getData()>();
v = v.<oadd.org.apache.curator.framework.recipes.shared.SharedValue: oadd.org.apache.curator.framework.api.CuratorWatcher watcher>;
v = interfaceinvoke v.<oadd.org.apache.curator.framework.api.GetDataBuilder: java.lang.Object usingWatcher(oadd.org.apache.curator.framework.api.CuratorWatcher)>(v);
v = v.<oadd.org.apache.curator.framework.recipes.shared.SharedValue: oadd.org.apache.curator.framework.api.BackgroundCallback upadateAndNotifyListenerCallback>;
v = interfaceinvoke v.<oadd.org.apache.curator.framework.api.BackgroundPathable: java.lang.Object inBackground(oadd.org.apache.curator.framework.api.BackgroundCallback)>(v);
v = v.<oadd.org.apache.curator.framework.recipes.shared.SharedValue: java.lang.String path>;
interfaceinvoke v.<oadd.org.apache.curator.framework.api.ErrorListenerPathable: java.lang.Object forPath(java.lang.String)>(v);
return;
}
private void notifyListeners()
{
java.util.function.Consumer v;
byte[] v;
oadd.org.apache.curator.framework.listen.StandardListenerManager v;
oadd.org.apache.curator.framework.recipes.shared.SharedValue v;
v := @this: oadd.org.apache.curator.framework.recipes.shared.SharedValue;
v = virtualinvoke v.<oadd.org.apache.curator.framework.recipes.shared.SharedValue: byte[] getValue()>();
v = v.<oadd.org.apache.curator.framework.recipes.shared.SharedValue: oadd.org.apache.curator.framework.listen.StandardListenerManager listeners>;
v = staticinvoke <oadd.org.apache.curator.framework.recipes.shared.SharedValue$lambda_notifyListeners_0__1039: java.util.function.Consumer bootstrap$(oadd.org.apache.curator.framework.recipes.shared.SharedValue,byte[])>(v, v);
virtualinvoke v.<oadd.org.apache.curator.framework.listen.StandardListenerManager: void forEach(java.util.function.Consumer)>(v);
return;
}
private void notifyListenerOfStateChanged(oadd.org.apache.curator.framework.state.ConnectionState)
{
java.util.function.Consumer v;
oadd.org.apache.curator.framework.state.ConnectionState v;
oadd.org.apache.curator.framework.listen.StandardListenerManager v;
oadd.org.apache.curator.framework.recipes.shared.SharedValue v;
v := @this: oadd.org.apache.curator.framework.recipes.shared.SharedValue;
v := @parameter: oadd.org.apache.curator.framework.state.ConnectionState;
v = v.<oadd.org.apache.curator.framework.recipes.shared.SharedValue: oadd.org.apache.curator.framework.listen.StandardListenerManager listeners>;
v = staticinvoke <oadd.org.apache.curator.framework.recipes.shared.SharedValue$lambda_notifyListenerOfStateChanged_1__1040: java.util.function.Consumer bootstrap$(oadd.org.apache.curator.framework.recipes.shared.SharedValue,oadd.org.apache.curator.framework.state.ConnectionState)>(v, v);
virtualinvoke v.<oadd.org.apache.curator.framework.listen.StandardListenerManager: void forEach(java.util.function.Consumer)>(v);
return;
}
}