public class oadd.org.apache.curator.framework.imps.CreateBuilderImpl extends java.lang.Object implements oadd.org.apache.curator.framework.api.CreateBuilder, oadd.org.apache.curator.framework.api.CreateBuilder, oadd.org.apache.curator.framework.imps.BackgroundOperation, oadd.org.apache.curator.framework.api.ErrorListenerPathAndBytesable
{
private final org.slf4j.Logger log;
private final oadd.org.apache.curator.framework.imps.CuratorFrameworkImpl client;
private final oadd.org.apache.curator.framework.imps.ProtectedMode protectedMode;
private oadd.org.apache.zookeeper.CreateMode createMode;
private oadd.org.apache.curator.framework.imps.Backgrounding backgrounding;
private boolean createParentsIfNeeded;
private boolean createParentsAsContainers;
private boolean compress;
private boolean setDataIfExists;
private int setDataIfExistsVersion;
private boolean idempotent;
private oadd.org.apache.curator.framework.imps.ACLing acling;
private oadd.org.apache.zookeeper.data.Stat storingStat;
private long ttl;
boolean failNextCreateForTesting;
boolean failBeforeNextCreateForTesting;
boolean failNextIdempotentCheckForTesting;
volatile boolean debugForceFindProtectedNode;
void <init>(oadd.org.apache.curator.framework.imps.CuratorFrameworkImpl)
{
oadd.org.apache.zookeeper.CreateMode v;
org.slf4j.Logger v;
oadd.org.apache.curator.framework.imps.ACLing v;
oadd.org.apache.curator.framework.imps.CreateBuilderImpl v;
oadd.org.apache.curator.framework.imps.CuratorFrameworkImpl v;
oadd.org.apache.curator.framework.api.ACLProvider v;
int v;
oadd.org.apache.curator.framework.imps.ProtectedMode v;
java.lang.Class v;
oadd.org.apache.curator.framework.imps.Backgrounding v;
v := @this: oadd.org.apache.curator.framework.imps.CreateBuilderImpl;
v := @parameter: oadd.org.apache.curator.framework.imps.CuratorFrameworkImpl;
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.imps.CreateBuilderImpl: org.slf4j.Logger log> = v;
v = new oadd.org.apache.curator.framework.imps.ProtectedMode;
specialinvoke v.<oadd.org.apache.curator.framework.imps.ProtectedMode: void <init>()>();
v.<oadd.org.apache.curator.framework.imps.CreateBuilderImpl: oadd.org.apache.curator.framework.imps.ProtectedMode protectedMode> = v;
v = (int) -1;
v.<oadd.org.apache.curator.framework.imps.CreateBuilderImpl: int setDataIfExistsVersion> = v;
v.<oadd.org.apache.curator.framework.imps.CreateBuilderImpl: boolean idempotent> = 0;
v.<oadd.org.apache.curator.framework.imps.CreateBuilderImpl: boolean failNextCreateForTesting> = 0;
v.<oadd.org.apache.curator.framework.imps.CreateBuilderImpl: boolean failBeforeNextCreateForTesting> = 0;
v.<oadd.org.apache.curator.framework.imps.CreateBuilderImpl: boolean failNextIdempotentCheckForTesting> = 0;
v.<oadd.org.apache.curator.framework.imps.CreateBuilderImpl: boolean debugForceFindProtectedNode> = 0;
v.<oadd.org.apache.curator.framework.imps.CreateBuilderImpl: oadd.org.apache.curator.framework.imps.CuratorFrameworkImpl client> = v;
v = <oadd.org.apache.zookeeper.CreateMode: oadd.org.apache.zookeeper.CreateMode PERSISTENT>;
v.<oadd.org.apache.curator.framework.imps.CreateBuilderImpl: oadd.org.apache.zookeeper.CreateMode createMode> = v;
v = new oadd.org.apache.curator.framework.imps.Backgrounding;
specialinvoke v.<oadd.org.apache.curator.framework.imps.Backgrounding: void <init>()>();
v.<oadd.org.apache.curator.framework.imps.CreateBuilderImpl: oadd.org.apache.curator.framework.imps.Backgrounding backgrounding> = v;
v = new oadd.org.apache.curator.framework.imps.ACLing;
v = virtualinvoke v.<oadd.org.apache.curator.framework.imps.CuratorFrameworkImpl: oadd.org.apache.curator.framework.api.ACLProvider getAclProvider()>();
specialinvoke v.<oadd.org.apache.curator.framework.imps.ACLing: void <init>(oadd.org.apache.curator.framework.api.ACLProvider)>(v);
v.<oadd.org.apache.curator.framework.imps.CreateBuilderImpl: oadd.org.apache.curator.framework.imps.ACLing acling> = v;
v.<oadd.org.apache.curator.framework.imps.CreateBuilderImpl: boolean createParentsIfNeeded> = 0;
v.<oadd.org.apache.curator.framework.imps.CreateBuilderImpl: boolean createParentsAsContainers> = 0;
v.<oadd.org.apache.curator.framework.imps.CreateBuilderImpl: boolean compress> = 0;
v.<oadd.org.apache.curator.framework.imps.CreateBuilderImpl: boolean setDataIfExists> = 0;
v.<oadd.org.apache.curator.framework.imps.CreateBuilderImpl: oadd.org.apache.zookeeper.data.Stat storingStat> = null;
v.<oadd.org.apache.curator.framework.imps.CreateBuilderImpl: long ttl> = -1L;
return;
}
public void <init>(oadd.org.apache.curator.framework.imps.CuratorFrameworkImpl, oadd.org.apache.zookeeper.CreateMode, oadd.org.apache.curator.framework.imps.Backgrounding, boolean, boolean, boolean, boolean, boolean, java.util.List, oadd.org.apache.zookeeper.data.Stat, long)
{
oadd.org.apache.zookeeper.CreateMode v;
oadd.org.apache.curator.framework.imps.ACLing v;
long v;
int v;
oadd.org.apache.zookeeper.data.Stat v;
oadd.org.apache.curator.framework.imps.Backgrounding v;
boolean v, v, v, v, v;
org.slf4j.Logger v;
oadd.org.apache.curator.framework.imps.CreateBuilderImpl v;
oadd.org.apache.curator.framework.imps.CuratorFrameworkImpl v;
oadd.org.apache.curator.framework.api.ACLProvider v;
java.util.List v;
oadd.org.apache.curator.framework.imps.ProtectedMode v, v;
java.lang.Class v;
v := @this: oadd.org.apache.curator.framework.imps.CreateBuilderImpl;
v := @parameter: oadd.org.apache.curator.framework.imps.CuratorFrameworkImpl;
v := @parameter: oadd.org.apache.zookeeper.CreateMode;
v := @parameter: oadd.org.apache.curator.framework.imps.Backgrounding;
v := @parameter: boolean;
v := @parameter: boolean;
v := @parameter: boolean;
v := @parameter: boolean;
v := @parameter: boolean;
v := @parameter: java.util.List;
v := @parameter: oadd.org.apache.zookeeper.data.Stat;
v := @parameter: long;
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.imps.CreateBuilderImpl: org.slf4j.Logger log> = v;
v = new oadd.org.apache.curator.framework.imps.ProtectedMode;
specialinvoke v.<oadd.org.apache.curator.framework.imps.ProtectedMode: void <init>()>();
v.<oadd.org.apache.curator.framework.imps.CreateBuilderImpl: oadd.org.apache.curator.framework.imps.ProtectedMode protectedMode> = v;
v = (int) -1;
v.<oadd.org.apache.curator.framework.imps.CreateBuilderImpl: int setDataIfExistsVersion> = v;
v.<oadd.org.apache.curator.framework.imps.CreateBuilderImpl: boolean idempotent> = 0;
v.<oadd.org.apache.curator.framework.imps.CreateBuilderImpl: boolean failNextCreateForTesting> = 0;
v.<oadd.org.apache.curator.framework.imps.CreateBuilderImpl: boolean failBeforeNextCreateForTesting> = 0;
v.<oadd.org.apache.curator.framework.imps.CreateBuilderImpl: boolean failNextIdempotentCheckForTesting> = 0;
v.<oadd.org.apache.curator.framework.imps.CreateBuilderImpl: boolean debugForceFindProtectedNode> = 0;
v.<oadd.org.apache.curator.framework.imps.CreateBuilderImpl: oadd.org.apache.curator.framework.imps.CuratorFrameworkImpl client> = v;
v.<oadd.org.apache.curator.framework.imps.CreateBuilderImpl: oadd.org.apache.zookeeper.CreateMode createMode> = v;
v.<oadd.org.apache.curator.framework.imps.CreateBuilderImpl: oadd.org.apache.curator.framework.imps.Backgrounding backgrounding> = v;
v.<oadd.org.apache.curator.framework.imps.CreateBuilderImpl: boolean createParentsIfNeeded> = v;
v.<oadd.org.apache.curator.framework.imps.CreateBuilderImpl: boolean createParentsAsContainers> = v;
v.<oadd.org.apache.curator.framework.imps.CreateBuilderImpl: boolean compress> = v;
v.<oadd.org.apache.curator.framework.imps.CreateBuilderImpl: boolean setDataIfExists> = v;
v = new oadd.org.apache.curator.framework.imps.ACLing;
v = virtualinvoke v.<oadd.org.apache.curator.framework.imps.CuratorFrameworkImpl: oadd.org.apache.curator.framework.api.ACLProvider getAclProvider()>();
specialinvoke v.<oadd.org.apache.curator.framework.imps.ACLing: void <init>(oadd.org.apache.curator.framework.api.ACLProvider,java.util.List)>(v, v);
v.<oadd.org.apache.curator.framework.imps.CreateBuilderImpl: oadd.org.apache.curator.framework.imps.ACLing acling> = v;
v.<oadd.org.apache.curator.framework.imps.CreateBuilderImpl: oadd.org.apache.zookeeper.data.Stat storingStat> = v;
v.<oadd.org.apache.curator.framework.imps.CreateBuilderImpl: long ttl> = v;
if v == 0 goto label;
v = v.<oadd.org.apache.curator.framework.imps.CreateBuilderImpl: oadd.org.apache.curator.framework.imps.ProtectedMode protectedMode>;
virtualinvoke v.<oadd.org.apache.curator.framework.imps.ProtectedMode: void setProtectedMode()>();
label:
return;
}
public void setSetDataIfExistsVersion(int)
{
int v;
oadd.org.apache.curator.framework.imps.CreateBuilderImpl v;
v := @this: oadd.org.apache.curator.framework.imps.CreateBuilderImpl;
v := @parameter: int;
v.<oadd.org.apache.curator.framework.imps.CreateBuilderImpl: int setDataIfExistsVersion> = v;
return;
}
public oadd.org.apache.curator.framework.api.CreateBuilder orSetData()
{
int v;
oadd.org.apache.curator.framework.api.CreateBuilder v;
oadd.org.apache.curator.framework.imps.CreateBuilderImpl v;
v := @this: oadd.org.apache.curator.framework.imps.CreateBuilderImpl;
v = (int) -1;
v = virtualinvoke v.<oadd.org.apache.curator.framework.imps.CreateBuilderImpl: oadd.org.apache.curator.framework.api.CreateBuilder orSetData(int)>(v);
return v;
}
public oadd.org.apache.curator.framework.api.CreateBuilder orSetData(int)
{
int v;
oadd.org.apache.curator.framework.imps.CreateBuilderImpl v;
v := @this: oadd.org.apache.curator.framework.imps.CreateBuilderImpl;
v := @parameter: int;
v.<oadd.org.apache.curator.framework.imps.CreateBuilderImpl: boolean setDataIfExists> = 1;
v.<oadd.org.apache.curator.framework.imps.CreateBuilderImpl: int setDataIfExistsVersion> = v;
return v;
}
public oadd.org.apache.curator.framework.api.CreateBuilder idempotent()
{
oadd.org.apache.curator.framework.imps.CreateBuilderImpl v;
v := @this: oadd.org.apache.curator.framework.imps.CreateBuilderImpl;
v.<oadd.org.apache.curator.framework.imps.CreateBuilderImpl: boolean idempotent> = 1;
return v;
}
public oadd.org.apache.curator.framework.api.CreateBuilderMain withTtl(long)
{
long v;
oadd.org.apache.curator.framework.imps.CreateBuilderImpl v;
v := @this: oadd.org.apache.curator.framework.imps.CreateBuilderImpl;
v := @parameter: long;
v.<oadd.org.apache.curator.framework.imps.CreateBuilderImpl: long ttl> = v;
return v;
}
oadd.org.apache.curator.framework.api.transaction.TransactionCreateBuilder asTransactionCreateBuilder(java.lang.Object, oadd.org.apache.curator.framework.imps.CuratorMultiTransactionRecord)
{
oadd.org.apache.curator.framework.imps.CuratorMultiTransactionRecord v;
java.lang.Object v;
oadd.org.apache.curator.framework.imps.CreateBuilderImpl$1 v;
oadd.org.apache.curator.framework.imps.CreateBuilderImpl v;
v := @this: oadd.org.apache.curator.framework.imps.CreateBuilderImpl;
v := @parameter: java.lang.Object;
v := @parameter: oadd.org.apache.curator.framework.imps.CuratorMultiTransactionRecord;
v = new oadd.org.apache.curator.framework.imps.CreateBuilderImpl$1;
specialinvoke v.<oadd.org.apache.curator.framework.imps.CreateBuilderImpl$1: void <init>(oadd.org.apache.curator.framework.imps.CreateBuilderImpl,oadd.org.apache.curator.framework.imps.CuratorMultiTransactionRecord,java.lang.Object)>(v, v, v);
return v;
}
public oadd.org.apache.curator.framework.api.CreateBackgroundModeStatACLable compressed()
{
oadd.org.apache.curator.framework.imps.CreateBuilderImpl$2 v;
oadd.org.apache.curator.framework.imps.CreateBuilderImpl v;
v := @this: oadd.org.apache.curator.framework.imps.CreateBuilderImpl;
v.<oadd.org.apache.curator.framework.imps.CreateBuilderImpl: boolean compress> = 1;
v = new oadd.org.apache.curator.framework.imps.CreateBuilderImpl$2;
specialinvoke v.<oadd.org.apache.curator.framework.imps.CreateBuilderImpl$2: void <init>(oadd.org.apache.curator.framework.imps.CreateBuilderImpl)>(v);
return v;
}
public oadd.org.apache.curator.framework.api.ACLBackgroundPathAndBytesable withACL(java.util.List)
{
java.util.List v;
oadd.org.apache.curator.framework.imps.CreateBuilderImpl v;
oadd.org.apache.curator.framework.api.ACLBackgroundPathAndBytesable v;
v := @this: oadd.org.apache.curator.framework.imps.CreateBuilderImpl;
v := @parameter: java.util.List;
v = virtualinvoke v.<oadd.org.apache.curator.framework.imps.CreateBuilderImpl: oadd.org.apache.curator.framework.api.ACLBackgroundPathAndBytesable withACL(java.util.List,boolean)>(v, 0);
return v;
}
public oadd.org.apache.curator.framework.api.ACLBackgroundPathAndBytesable withACL(java.util.List, boolean)
{
java.util.List v;
oadd.org.apache.curator.framework.imps.CreateBuilderImpl$3 v;
oadd.org.apache.curator.framework.imps.ACLing v;
oadd.org.apache.curator.framework.imps.CreateBuilderImpl v;
oadd.org.apache.curator.framework.imps.CuratorFrameworkImpl v;
oadd.org.apache.curator.framework.api.ACLProvider v;
boolean v;
v := @this: oadd.org.apache.curator.framework.imps.CreateBuilderImpl;
v := @parameter: java.util.List;
v := @parameter: boolean;
v = new oadd.org.apache.curator.framework.imps.ACLing;
v = v.<oadd.org.apache.curator.framework.imps.CreateBuilderImpl: 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.framework.imps.ACLing: void <init>(oadd.org.apache.curator.framework.api.ACLProvider,java.util.List,boolean)>(v, v, v);
v.<oadd.org.apache.curator.framework.imps.CreateBuilderImpl: oadd.org.apache.curator.framework.imps.ACLing acling> = v;
v = new oadd.org.apache.curator.framework.imps.CreateBuilderImpl$3;
specialinvoke v.<oadd.org.apache.curator.framework.imps.CreateBuilderImpl$3: void <init>(oadd.org.apache.curator.framework.imps.CreateBuilderImpl)>(v);
return v;
}
public oadd.org.apache.curator.framework.api.ProtectACLCreateModeStatPathAndBytesable creatingParentContainersIfNeeded()
{
oadd.org.apache.curator.framework.api.ProtectACLCreateModeStatPathAndBytesable v;
oadd.org.apache.curator.framework.imps.CreateBuilderImpl v;
v := @this: oadd.org.apache.curator.framework.imps.CreateBuilderImpl;
specialinvoke v.<oadd.org.apache.curator.framework.imps.CreateBuilderImpl: void setCreateParentsAsContainers()>();
v = virtualinvoke v.<oadd.org.apache.curator.framework.imps.CreateBuilderImpl: oadd.org.apache.curator.framework.api.ProtectACLCreateModeStatPathAndBytesable creatingParentsIfNeeded()>();
return v;
}
private void setCreateParentsAsContainers()
{
oadd.org.apache.curator.framework.imps.CreateBuilderImpl v;
oadd.org.apache.curator.framework.imps.CuratorFrameworkImpl v;
boolean v;
v := @this: oadd.org.apache.curator.framework.imps.CreateBuilderImpl;
v = v.<oadd.org.apache.curator.framework.imps.CreateBuilderImpl: oadd.org.apache.curator.framework.imps.CuratorFrameworkImpl client>;
v = virtualinvoke v.<oadd.org.apache.curator.framework.imps.CuratorFrameworkImpl: boolean useContainerParentsIfAvailable()>();
if v == 0 goto label;
v.<oadd.org.apache.curator.framework.imps.CreateBuilderImpl: boolean createParentsAsContainers> = 1;
label:
return;
}
public oadd.org.apache.curator.framework.api.ProtectACLCreateModeStatPathAndBytesable creatingParentsIfNeeded()
{
oadd.org.apache.curator.framework.imps.CreateBuilderImpl v;
oadd.org.apache.curator.framework.imps.CreateBuilderImpl$4 v;
v := @this: oadd.org.apache.curator.framework.imps.CreateBuilderImpl;
v.<oadd.org.apache.curator.framework.imps.CreateBuilderImpl: boolean createParentsIfNeeded> = 1;
v = new oadd.org.apache.curator.framework.imps.CreateBuilderImpl$4;
specialinvoke v.<oadd.org.apache.curator.framework.imps.CreateBuilderImpl$4: void <init>(oadd.org.apache.curator.framework.imps.CreateBuilderImpl)>(v);
return v;
}
public oadd.org.apache.curator.framework.api.ACLCreateModeStatBackgroundPathAndBytesable withProtection()
{
oadd.org.apache.curator.framework.api.ACLCreateModeStatBackgroundPathAndBytesable v;
oadd.org.apache.curator.framework.imps.ProtectedMode v;
oadd.org.apache.curator.framework.imps.CreateBuilderImpl v;
v := @this: oadd.org.apache.curator.framework.imps.CreateBuilderImpl;
v = v.<oadd.org.apache.curator.framework.imps.CreateBuilderImpl: oadd.org.apache.curator.framework.imps.ProtectedMode protectedMode>;
virtualinvoke v.<oadd.org.apache.curator.framework.imps.ProtectedMode: void setProtectedMode()>();
v = specialinvoke v.<oadd.org.apache.curator.framework.imps.CreateBuilderImpl: oadd.org.apache.curator.framework.api.ACLCreateModeStatBackgroundPathAndBytesable asACLCreateModeStatBackgroundPathAndBytesable()>();
return v;
}
public oadd.org.apache.curator.framework.api.ACLPathAndBytesable withProtectedEphemeralSequential()
{
oadd.org.apache.zookeeper.CreateMode v;
oadd.org.apache.curator.framework.imps.CreateBuilderImpl$5 v;
oadd.org.apache.curator.framework.imps.ProtectedMode v;
oadd.org.apache.curator.framework.imps.CreateBuilderImpl v;
v := @this: oadd.org.apache.curator.framework.imps.CreateBuilderImpl;
v = v.<oadd.org.apache.curator.framework.imps.CreateBuilderImpl: oadd.org.apache.curator.framework.imps.ProtectedMode protectedMode>;
virtualinvoke v.<oadd.org.apache.curator.framework.imps.ProtectedMode: void setProtectedMode()>();
v = <oadd.org.apache.zookeeper.CreateMode: oadd.org.apache.zookeeper.CreateMode EPHEMERAL_SEQUENTIAL>;
v.<oadd.org.apache.curator.framework.imps.CreateBuilderImpl: oadd.org.apache.zookeeper.CreateMode createMode> = v;
v = new oadd.org.apache.curator.framework.imps.CreateBuilderImpl$5;
specialinvoke v.<oadd.org.apache.curator.framework.imps.CreateBuilderImpl$5: void <init>(oadd.org.apache.curator.framework.imps.CreateBuilderImpl)>(v);
return v;
}
public oadd.org.apache.curator.framework.api.ACLBackgroundPathAndBytesable withMode(oadd.org.apache.zookeeper.CreateMode)
{
oadd.org.apache.zookeeper.CreateMode v;
oadd.org.apache.curator.framework.imps.CreateBuilderImpl v;
v := @this: oadd.org.apache.curator.framework.imps.CreateBuilderImpl;
v := @parameter: oadd.org.apache.zookeeper.CreateMode;
v.<oadd.org.apache.curator.framework.imps.CreateBuilderImpl: oadd.org.apache.zookeeper.CreateMode createMode> = v;
return v;
}
public oadd.org.apache.curator.framework.api.ErrorListenerPathAndBytesable inBackground(oadd.org.apache.curator.framework.api.BackgroundCallback, java.lang.Object)
{
oadd.org.apache.curator.framework.api.BackgroundCallback v;
java.lang.Object v;
oadd.org.apache.curator.framework.imps.CreateBuilderImpl v;
oadd.org.apache.curator.framework.imps.Backgrounding v;
v := @this: oadd.org.apache.curator.framework.imps.CreateBuilderImpl;
v := @parameter: oadd.org.apache.curator.framework.api.BackgroundCallback;
v := @parameter: java.lang.Object;
v = new oadd.org.apache.curator.framework.imps.Backgrounding;
specialinvoke v.<oadd.org.apache.curator.framework.imps.Backgrounding: void <init>(oadd.org.apache.curator.framework.api.BackgroundCallback,java.lang.Object)>(v, v);
v.<oadd.org.apache.curator.framework.imps.CreateBuilderImpl: oadd.org.apache.curator.framework.imps.Backgrounding backgrounding> = v;
return v;
}
public oadd.org.apache.curator.framework.api.ErrorListenerPathAndBytesable inBackground(oadd.org.apache.curator.framework.api.BackgroundCallback, java.lang.Object, java.util.concurrent.Executor)
{
oadd.org.apache.curator.framework.api.BackgroundCallback v;
java.util.concurrent.Executor v;
java.lang.Object v;
oadd.org.apache.curator.framework.imps.CreateBuilderImpl v;
oadd.org.apache.curator.framework.imps.CuratorFrameworkImpl v;
oadd.org.apache.curator.framework.imps.Backgrounding v;
v := @this: oadd.org.apache.curator.framework.imps.CreateBuilderImpl;
v := @parameter: oadd.org.apache.curator.framework.api.BackgroundCallback;
v := @parameter: java.lang.Object;
v := @parameter: java.util.concurrent.Executor;
v = new oadd.org.apache.curator.framework.imps.Backgrounding;
v = v.<oadd.org.apache.curator.framework.imps.CreateBuilderImpl: oadd.org.apache.curator.framework.imps.CuratorFrameworkImpl client>;
specialinvoke v.<oadd.org.apache.curator.framework.imps.Backgrounding: void <init>(oadd.org.apache.curator.framework.imps.CuratorFrameworkImpl,oadd.org.apache.curator.framework.api.BackgroundCallback,java.lang.Object,java.util.concurrent.Executor)>(v, v, v, v);
v.<oadd.org.apache.curator.framework.imps.CreateBuilderImpl: oadd.org.apache.curator.framework.imps.Backgrounding backgrounding> = v;
return v;
}
public oadd.org.apache.curator.framework.api.ErrorListenerPathAndBytesable inBackground(oadd.org.apache.curator.framework.api.BackgroundCallback)
{
oadd.org.apache.curator.framework.api.BackgroundCallback v;
oadd.org.apache.curator.framework.imps.CreateBuilderImpl v;
oadd.org.apache.curator.framework.imps.Backgrounding v;
v := @this: oadd.org.apache.curator.framework.imps.CreateBuilderImpl;
v := @parameter: oadd.org.apache.curator.framework.api.BackgroundCallback;
v = new oadd.org.apache.curator.framework.imps.Backgrounding;
specialinvoke v.<oadd.org.apache.curator.framework.imps.Backgrounding: void <init>(oadd.org.apache.curator.framework.api.BackgroundCallback)>(v);
v.<oadd.org.apache.curator.framework.imps.CreateBuilderImpl: oadd.org.apache.curator.framework.imps.Backgrounding backgrounding> = v;
return v;
}
public oadd.org.apache.curator.framework.api.ErrorListenerPathAndBytesable inBackground(oadd.org.apache.curator.framework.api.BackgroundCallback, java.util.concurrent.Executor)
{
oadd.org.apache.curator.framework.api.BackgroundCallback v;
java.util.concurrent.Executor v;
oadd.org.apache.curator.framework.imps.CreateBuilderImpl v;
oadd.org.apache.curator.framework.imps.CuratorFrameworkImpl v;
oadd.org.apache.curator.framework.imps.Backgrounding v;
v := @this: oadd.org.apache.curator.framework.imps.CreateBuilderImpl;
v := @parameter: oadd.org.apache.curator.framework.api.BackgroundCallback;
v := @parameter: java.util.concurrent.Executor;
v = new oadd.org.apache.curator.framework.imps.Backgrounding;
v = v.<oadd.org.apache.curator.framework.imps.CreateBuilderImpl: oadd.org.apache.curator.framework.imps.CuratorFrameworkImpl client>;
specialinvoke v.<oadd.org.apache.curator.framework.imps.Backgrounding: void <init>(oadd.org.apache.curator.framework.imps.CuratorFrameworkImpl,oadd.org.apache.curator.framework.api.BackgroundCallback,java.util.concurrent.Executor)>(v, v, v);
v.<oadd.org.apache.curator.framework.imps.CreateBuilderImpl: oadd.org.apache.curator.framework.imps.Backgrounding backgrounding> = v;
return v;
}
public oadd.org.apache.curator.framework.api.ErrorListenerPathAndBytesable inBackground()
{
oadd.org.apache.curator.framework.imps.CreateBuilderImpl v;
oadd.org.apache.curator.framework.imps.Backgrounding v;
v := @this: oadd.org.apache.curator.framework.imps.CreateBuilderImpl;
v = new oadd.org.apache.curator.framework.imps.Backgrounding;
specialinvoke v.<oadd.org.apache.curator.framework.imps.Backgrounding: void <init>(boolean)>(1);
v.<oadd.org.apache.curator.framework.imps.CreateBuilderImpl: oadd.org.apache.curator.framework.imps.Backgrounding backgrounding> = v;
return v;
}
public oadd.org.apache.curator.framework.api.ErrorListenerPathAndBytesable inBackground(java.lang.Object)
{
java.lang.Object v;
oadd.org.apache.curator.framework.imps.CreateBuilderImpl v;
oadd.org.apache.curator.framework.imps.Backgrounding v;
v := @this: oadd.org.apache.curator.framework.imps.CreateBuilderImpl;
v := @parameter: java.lang.Object;
v = new oadd.org.apache.curator.framework.imps.Backgrounding;
specialinvoke v.<oadd.org.apache.curator.framework.imps.Backgrounding: void <init>(java.lang.Object)>(v);
v.<oadd.org.apache.curator.framework.imps.CreateBuilderImpl: oadd.org.apache.curator.framework.imps.Backgrounding backgrounding> = v;
return v;
}
public oadd.org.apache.curator.framework.api.PathAndBytesable withUnhandledErrorListener(oadd.org.apache.curator.framework.api.UnhandledErrorListener)
{
oadd.org.apache.curator.framework.api.UnhandledErrorListener v;
oadd.org.apache.curator.framework.imps.CreateBuilderImpl v;
oadd.org.apache.curator.framework.imps.Backgrounding v, v;
v := @this: oadd.org.apache.curator.framework.imps.CreateBuilderImpl;
v := @parameter: oadd.org.apache.curator.framework.api.UnhandledErrorListener;
v = new oadd.org.apache.curator.framework.imps.Backgrounding;
v = v.<oadd.org.apache.curator.framework.imps.CreateBuilderImpl: oadd.org.apache.curator.framework.imps.Backgrounding backgrounding>;
specialinvoke v.<oadd.org.apache.curator.framework.imps.Backgrounding: void <init>(oadd.org.apache.curator.framework.imps.Backgrounding,oadd.org.apache.curator.framework.api.UnhandledErrorListener)>(v, v);
v.<oadd.org.apache.curator.framework.imps.CreateBuilderImpl: oadd.org.apache.curator.framework.imps.Backgrounding backgrounding> = v;
return v;
}
public java.lang.String forPath(java.lang.String) throws java.lang.Exception
{
byte[] v;
java.lang.String v, v;
oadd.org.apache.curator.framework.imps.CreateBuilderImpl v;
oadd.org.apache.curator.framework.imps.CuratorFrameworkImpl v;
v := @this: oadd.org.apache.curator.framework.imps.CreateBuilderImpl;
v := @parameter: java.lang.String;
v = v.<oadd.org.apache.curator.framework.imps.CreateBuilderImpl: oadd.org.apache.curator.framework.imps.CuratorFrameworkImpl client>;
v = virtualinvoke v.<oadd.org.apache.curator.framework.imps.CuratorFrameworkImpl: byte[] getDefaultData()>();
v = virtualinvoke v.<oadd.org.apache.curator.framework.imps.CreateBuilderImpl: java.lang.String forPath(java.lang.String,byte[])>(v, v);
return v;
}
public java.lang.String forPath(java.lang.String, byte[]) throws java.lang.Exception
{
byte[] v;
oadd.org.apache.curator.framework.schema.Schema v;
oadd.org.apache.zookeeper.CreateMode v, v;
oadd.org.apache.curator.framework.imps.ACLing v;
oadd.org.apache.curator.framework.schema.SchemaSet v;
java.lang.String v, v, v, v, v;
oadd.org.apache.curator.framework.imps.Backgrounding v;
boolean v, v, v;
oadd.org.apache.curator.framework.api.CompressionProvider v;
oadd.org.apache.curator.framework.imps.CreateBuilderImpl v;
oadd.org.apache.curator.framework.imps.CuratorFrameworkImpl v, v, v, v;
java.util.List v;
v := @this: oadd.org.apache.curator.framework.imps.CreateBuilderImpl;
v := @parameter: java.lang.String;
v := @parameter: byte[];
v = v.<oadd.org.apache.curator.framework.imps.CreateBuilderImpl: boolean compress>;
if v == 0 goto label;
v = v.<oadd.org.apache.curator.framework.imps.CreateBuilderImpl: oadd.org.apache.curator.framework.imps.CuratorFrameworkImpl client>;
v = virtualinvoke v.<oadd.org.apache.curator.framework.imps.CuratorFrameworkImpl: oadd.org.apache.curator.framework.api.CompressionProvider getCompressionProvider()>();
v = interfaceinvoke v.<oadd.org.apache.curator.framework.api.CompressionProvider: byte[] compress(java.lang.String,byte[])>(v, v);
label:
v = v.<oadd.org.apache.curator.framework.imps.CreateBuilderImpl: oadd.org.apache.curator.framework.imps.CuratorFrameworkImpl client>;
v = v.<oadd.org.apache.curator.framework.imps.CreateBuilderImpl: oadd.org.apache.zookeeper.CreateMode createMode>;
v = virtualinvoke v.<oadd.org.apache.zookeeper.CreateMode: boolean isSequential()>();
v = virtualinvoke v.<oadd.org.apache.curator.framework.imps.CuratorFrameworkImpl: java.lang.String fixForNamespace(java.lang.String,boolean)>(v, v);
v = virtualinvoke v.<oadd.org.apache.curator.framework.imps.CreateBuilderImpl: java.lang.String adjustPath(java.lang.String)>(v);
v = v.<oadd.org.apache.curator.framework.imps.CreateBuilderImpl: oadd.org.apache.curator.framework.imps.ACLing acling>;
v = virtualinvoke v.<oadd.org.apache.curator.framework.imps.ACLing: java.util.List getAclList(java.lang.String)>(v);
v = v.<oadd.org.apache.curator.framework.imps.CreateBuilderImpl: oadd.org.apache.curator.framework.imps.CuratorFrameworkImpl client>;
v = virtualinvoke v.<oadd.org.apache.curator.framework.imps.CuratorFrameworkImpl: oadd.org.apache.curator.framework.schema.SchemaSet getSchemaSet()>();
v = virtualinvoke v.<oadd.org.apache.curator.framework.schema.SchemaSet: oadd.org.apache.curator.framework.schema.Schema getSchema(java.lang.String)>(v);
v = v.<oadd.org.apache.curator.framework.imps.CreateBuilderImpl: oadd.org.apache.zookeeper.CreateMode createMode>;
virtualinvoke v.<oadd.org.apache.curator.framework.schema.Schema: void validateCreate(oadd.org.apache.zookeeper.CreateMode,java.lang.String,byte[],java.util.List)>(v, v, v, v);
v = null;
v = v.<oadd.org.apache.curator.framework.imps.CreateBuilderImpl: oadd.org.apache.curator.framework.imps.Backgrounding backgrounding>;
v = virtualinvoke v.<oadd.org.apache.curator.framework.imps.Backgrounding: boolean inBackground()>();
if v == 0 goto label;
specialinvoke v.<oadd.org.apache.curator.framework.imps.CreateBuilderImpl: void pathInBackground(java.lang.String,byte[],java.lang.String)>(v, v, v);
goto label;
label:
v = specialinvoke v.<oadd.org.apache.curator.framework.imps.CreateBuilderImpl: java.lang.String protectedPathInForeground(java.lang.String,byte[],java.util.List)>(v, v, v);
v = v.<oadd.org.apache.curator.framework.imps.CreateBuilderImpl: oadd.org.apache.curator.framework.imps.CuratorFrameworkImpl client>;
v = virtualinvoke v.<oadd.org.apache.curator.framework.imps.CuratorFrameworkImpl: java.lang.String unfixForNamespace(java.lang.String)>(v);
label:
return v;
}
private java.lang.String protectedPathInForeground(java.lang.String, byte[], java.util.List) throws java.lang.Exception
{
byte[] v;
java.lang.String v, v, v, v;
boolean v, v, v;
oadd.org.apache.curator.framework.imps.FindAndDeleteProtectedNodeInBackground v;
oadd.org.apache.curator.utils.ZKPaths$PathAndNode v;
oadd.org.apache.curator.framework.imps.CreateBuilderImpl v;
oadd.org.apache.curator.framework.imps.CuratorFrameworkImpl v;
java.lang.Exception v;
java.util.List v;
oadd.org.apache.curator.framework.imps.ProtectedMode v, v, v;
v := @this: oadd.org.apache.curator.framework.imps.CreateBuilderImpl;
v := @parameter: java.lang.String;
v := @parameter: byte[];
v := @parameter: java.util.List;
label:
v = specialinvoke v.<oadd.org.apache.curator.framework.imps.CreateBuilderImpl: java.lang.String pathInForeground(java.lang.String,byte[],java.util.List)>(v, v, v);
label:
return v;
label:
v := @caughtexception;
staticinvoke <oadd.org.apache.curator.utils.ThreadUtils: boolean checkInterrupted(java.lang.Throwable)>(v);
v = v instanceof oadd.org.apache.zookeeper.KeeperException$ConnectionLossException;
if v != 0 goto label;
v = v instanceof oadd.org.apache.zookeeper.KeeperException;
if v != 0 goto label;
label:
v = v.<oadd.org.apache.curator.framework.imps.CreateBuilderImpl: oadd.org.apache.curator.framework.imps.ProtectedMode protectedMode>;
v = virtualinvoke v.<oadd.org.apache.curator.framework.imps.ProtectedMode: boolean doProtected()>();
if v == 0 goto label;
v = new oadd.org.apache.curator.framework.imps.FindAndDeleteProtectedNodeInBackground;
v = v.<oadd.org.apache.curator.framework.imps.CreateBuilderImpl: oadd.org.apache.curator.framework.imps.CuratorFrameworkImpl client>;
v = staticinvoke <oadd.org.apache.curator.utils.ZKPaths: oadd.org.apache.curator.utils.ZKPaths$PathAndNode getPathAndNode(java.lang.String)>(v);
v = virtualinvoke v.<oadd.org.apache.curator.utils.ZKPaths$PathAndNode: java.lang.String getPath()>();
v = v.<oadd.org.apache.curator.framework.imps.CreateBuilderImpl: oadd.org.apache.curator.framework.imps.ProtectedMode protectedMode>;
v = virtualinvoke v.<oadd.org.apache.curator.framework.imps.ProtectedMode: java.lang.String protectedId()>();
specialinvoke v.<oadd.org.apache.curator.framework.imps.FindAndDeleteProtectedNodeInBackground: void <init>(oadd.org.apache.curator.framework.imps.CuratorFrameworkImpl,java.lang.String,java.lang.String)>(v, v, v);
virtualinvoke v.<oadd.org.apache.curator.framework.imps.FindAndDeleteProtectedNodeInBackground: void execute()>();
v = v.<oadd.org.apache.curator.framework.imps.CreateBuilderImpl: oadd.org.apache.curator.framework.imps.ProtectedMode protectedMode>;
virtualinvoke v.<oadd.org.apache.curator.framework.imps.ProtectedMode: void resetProtectedId()>();
label:
throw v;
catch java.lang.Exception from label to label with label;
}
public void performBackgroundOperation(oadd.org.apache.curator.framework.imps.OperationAndData) throws java.lang.Exception
{
java.lang.Throwable v;
oadd.org.apache.curator.framework.imps.CreateBuilderImpl$6 v;
byte[] v;
oadd.org.apache.zookeeper.CreateMode v;
oadd.org.apache.curator.framework.imps.ACLing v;
long v;
oadd.org.apache.curator.CuratorZookeeperClient v;
java.lang.String v, v;
oadd.org.apache.zookeeper.ZooKeeper v;
oadd.org.apache.curator.drivers.OperationTrace v;
oadd.org.apache.curator.framework.imps.Backgrounding v, v;
oadd.org.apache.curator.framework.imps.CreateBuilderImpl v;
oadd.org.apache.curator.framework.imps.CuratorFrameworkImpl v, v;
java.util.List v;
oadd.org.apache.curator.framework.imps.OperationAndData v;
java.lang.Object v, v, v, v;
v := @this: oadd.org.apache.curator.framework.imps.CreateBuilderImpl;
v := @parameter: oadd.org.apache.curator.framework.imps.OperationAndData;
label:
v = v.<oadd.org.apache.curator.framework.imps.CreateBuilderImpl: 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 = virtualinvoke v.<oadd.org.apache.curator.CuratorZookeeperClient: oadd.org.apache.curator.drivers.OperationTrace startAdvancedTracer(java.lang.String)>("CreateBuilderImpl-Background");
v = virtualinvoke v.<oadd.org.apache.curator.framework.imps.OperationAndData: java.lang.Object getData()>();
v = virtualinvoke v.<oadd.org.apache.curator.framework.imps.PathAndBytes: byte[] getData()>();
v = new oadd.org.apache.curator.framework.imps.CreateBuilderImpl$6;
specialinvoke v.<oadd.org.apache.curator.framework.imps.CreateBuilderImpl$6: void <init>(oadd.org.apache.curator.framework.imps.CreateBuilderImpl,oadd.org.apache.curator.drivers.OperationTrace,byte[],oadd.org.apache.curator.framework.imps.OperationAndData)>(v, v, v, v);
v = v.<oadd.org.apache.curator.framework.imps.CreateBuilderImpl: oadd.org.apache.curator.framework.imps.CuratorFrameworkImpl client>;
v = virtualinvoke v.<oadd.org.apache.curator.framework.imps.CuratorFrameworkImpl: oadd.org.apache.zookeeper.ZooKeeper getZooKeeper()>();
v = virtualinvoke v.<oadd.org.apache.curator.framework.imps.OperationAndData: java.lang.Object getData()>();
v = virtualinvoke v.<oadd.org.apache.curator.framework.imps.PathAndBytes: java.lang.String getPath()>();
v = v.<oadd.org.apache.curator.framework.imps.CreateBuilderImpl: oadd.org.apache.curator.framework.imps.ACLing acling>;
v = virtualinvoke v.<oadd.org.apache.curator.framework.imps.OperationAndData: java.lang.Object getData()>();
v = virtualinvoke v.<oadd.org.apache.curator.framework.imps.PathAndBytes: java.lang.String getPath()>();
v = virtualinvoke v.<oadd.org.apache.curator.framework.imps.ACLing: java.util.List getAclList(java.lang.String)>(v);
v = v.<oadd.org.apache.curator.framework.imps.CreateBuilderImpl: oadd.org.apache.zookeeper.CreateMode createMode>;
v = v.<oadd.org.apache.curator.framework.imps.CreateBuilderImpl: oadd.org.apache.curator.framework.imps.Backgrounding backgrounding>;
v = virtualinvoke v.<oadd.org.apache.curator.framework.imps.Backgrounding: java.lang.Object getContext()>();
v = v.<oadd.org.apache.curator.framework.imps.CreateBuilderImpl: long ttl>;
virtualinvoke v.<oadd.org.apache.zookeeper.ZooKeeper: void create(java.lang.String,byte[],java.util.List,oadd.org.apache.zookeeper.CreateMode,oadd.org.apache.zookeeper.AsyncCallback$Create2Callback,java.lang.Object,long)>(v, v, v, v, v, v, v);
label:
goto label;
label:
v := @caughtexception;
v = v.<oadd.org.apache.curator.framework.imps.CreateBuilderImpl: oadd.org.apache.curator.framework.imps.Backgrounding backgrounding>;
virtualinvoke v.<oadd.org.apache.curator.framework.imps.Backgrounding: void checkError(java.lang.Throwable,oadd.org.apache.curator.framework.imps.Watching)>(v, null);
label:
return;
catch java.lang.Throwable from label to label with label;
}
public oadd.org.apache.curator.framework.api.CreateProtectACLCreateModePathAndBytesable storingStatIn(oadd.org.apache.zookeeper.data.Stat)
{
oadd.org.apache.curator.framework.imps.CreateBuilderImpl$7 v;
oadd.org.apache.curator.framework.imps.CreateBuilderImpl v;
oadd.org.apache.zookeeper.data.Stat v;
v := @this: oadd.org.apache.curator.framework.imps.CreateBuilderImpl;
v := @parameter: oadd.org.apache.zookeeper.data.Stat;
v.<oadd.org.apache.curator.framework.imps.CreateBuilderImpl: oadd.org.apache.zookeeper.data.Stat storingStat> = v;
v = new oadd.org.apache.curator.framework.imps.CreateBuilderImpl$7;
specialinvoke v.<oadd.org.apache.curator.framework.imps.CreateBuilderImpl$7: void <init>(oadd.org.apache.curator.framework.imps.CreateBuilderImpl)>(v);
return v;
}
static void backgroundCreateParentsThenNode(oadd.org.apache.curator.framework.imps.CuratorFrameworkImpl, oadd.org.apache.curator.framework.imps.OperationAndData, java.lang.String, oadd.org.apache.curator.framework.imps.Backgrounding, oadd.org.apache.curator.utils.InternalACLProvider, boolean)
{
oadd.org.apache.curator.framework.imps.CreateBuilderImpl$8 v;
oadd.org.apache.curator.utils.InternalACLProvider v;
oadd.org.apache.curator.framework.imps.CuratorFrameworkImpl v;
oadd.org.apache.curator.framework.imps.OperationAndData v, v;
java.lang.Object v, v;
java.lang.String v;
oadd.org.apache.curator.framework.imps.Backgrounding v;
boolean v;
v := @parameter: oadd.org.apache.curator.framework.imps.CuratorFrameworkImpl;
v := @parameter: oadd.org.apache.curator.framework.imps.OperationAndData;
v := @parameter: java.lang.String;
v := @parameter: oadd.org.apache.curator.framework.imps.Backgrounding;
v := @parameter: oadd.org.apache.curator.utils.InternalACLProvider;
v := @parameter: boolean;
v = new oadd.org.apache.curator.framework.imps.CreateBuilderImpl$8;
specialinvoke v.<oadd.org.apache.curator.framework.imps.CreateBuilderImpl$8: void <init>(oadd.org.apache.curator.framework.imps.CuratorFrameworkImpl,java.lang.String,oadd.org.apache.curator.utils.InternalACLProvider,boolean,oadd.org.apache.curator.framework.imps.OperationAndData)>(v, v, v, v, v);
v = new oadd.org.apache.curator.framework.imps.OperationAndData;
v = virtualinvoke v.<oadd.org.apache.curator.framework.imps.OperationAndData: java.lang.Object getData()>();
v = virtualinvoke v.<oadd.org.apache.curator.framework.imps.Backgrounding: java.lang.Object getContext()>();
specialinvoke v.<oadd.org.apache.curator.framework.imps.OperationAndData: void <init>(oadd.org.apache.curator.framework.imps.BackgroundOperation,java.lang.Object,oadd.org.apache.curator.framework.api.BackgroundCallback,oadd.org.apache.curator.framework.imps.OperationAndData$ErrorCallback,java.lang.Object,oadd.org.apache.curator.framework.imps.Watching)>(v, v, null, null, v, null);
virtualinvoke v.<oadd.org.apache.curator.framework.imps.CuratorFrameworkImpl: boolean queueOperation(oadd.org.apache.curator.framework.imps.OperationAndData)>(v);
return;
}
private void backgroundSetData(oadd.org.apache.curator.framework.imps.CuratorFrameworkImpl, oadd.org.apache.curator.framework.imps.OperationAndData, java.lang.String, oadd.org.apache.curator.framework.imps.Backgrounding)
{
oadd.org.apache.curator.framework.imps.CreateBuilderImpl$9 v;
oadd.org.apache.curator.framework.imps.CreateBuilderImpl v;
oadd.org.apache.curator.framework.imps.CuratorFrameworkImpl v;
oadd.org.apache.curator.framework.imps.CreateBuilderImpl$10 v;
oadd.org.apache.curator.framework.imps.OperationAndData v, v;
java.lang.String v;
oadd.org.apache.curator.framework.imps.Backgrounding v;
v := @this: oadd.org.apache.curator.framework.imps.CreateBuilderImpl;
v := @parameter: oadd.org.apache.curator.framework.imps.CuratorFrameworkImpl;
v := @parameter: oadd.org.apache.curator.framework.imps.OperationAndData;
v := @parameter: java.lang.String;
v := @parameter: oadd.org.apache.curator.framework.imps.Backgrounding;
v = new oadd.org.apache.curator.framework.imps.CreateBuilderImpl$9;
specialinvoke v.<oadd.org.apache.curator.framework.imps.CreateBuilderImpl$9: void <init>(oadd.org.apache.curator.framework.imps.CreateBuilderImpl,oadd.org.apache.curator.framework.imps.CuratorFrameworkImpl,oadd.org.apache.curator.framework.imps.OperationAndData)>(v, v, v);
v = new oadd.org.apache.curator.framework.imps.CreateBuilderImpl$10;
specialinvoke v.<oadd.org.apache.curator.framework.imps.CreateBuilderImpl$10: void <init>(oadd.org.apache.curator.framework.imps.CreateBuilderImpl,oadd.org.apache.curator.framework.imps.CuratorFrameworkImpl,java.lang.String,oadd.org.apache.curator.framework.imps.OperationAndData,oadd.org.apache.zookeeper.AsyncCallback$StatCallback,oadd.org.apache.curator.framework.imps.Backgrounding)>(v, v, v, v, v, v);
v = new oadd.org.apache.curator.framework.imps.OperationAndData;
specialinvoke v.<oadd.org.apache.curator.framework.imps.OperationAndData: void <init>(oadd.org.apache.curator.framework.imps.BackgroundOperation,java.lang.Object,oadd.org.apache.curator.framework.api.BackgroundCallback,oadd.org.apache.curator.framework.imps.OperationAndData$ErrorCallback,java.lang.Object,oadd.org.apache.curator.framework.imps.Watching)>(v, null, null, null, null, null);
virtualinvoke v.<oadd.org.apache.curator.framework.imps.CuratorFrameworkImpl: boolean queueOperation(oadd.org.apache.curator.framework.imps.OperationAndData)>(v);
return;
}
private void backgroundCheckIdempotent(oadd.org.apache.curator.framework.imps.CuratorFrameworkImpl, oadd.org.apache.curator.framework.imps.OperationAndData, java.lang.String, oadd.org.apache.curator.framework.imps.Backgrounding)
{
oadd.org.apache.curator.framework.imps.CreateBuilderImpl v;
oadd.org.apache.curator.framework.imps.CuratorFrameworkImpl v;
oadd.org.apache.curator.framework.imps.CreateBuilderImpl$11 v;
oadd.org.apache.curator.framework.imps.CreateBuilderImpl$12 v;
oadd.org.apache.curator.framework.imps.OperationAndData v, v;
java.lang.String v;
oadd.org.apache.curator.framework.imps.Backgrounding v;
v := @this: oadd.org.apache.curator.framework.imps.CreateBuilderImpl;
v := @parameter: oadd.org.apache.curator.framework.imps.CuratorFrameworkImpl;
v := @parameter: oadd.org.apache.curator.framework.imps.OperationAndData;
v := @parameter: java.lang.String;
v := @parameter: oadd.org.apache.curator.framework.imps.Backgrounding;
v = new oadd.org.apache.curator.framework.imps.CreateBuilderImpl$11;
specialinvoke v.<oadd.org.apache.curator.framework.imps.CreateBuilderImpl$11: void <init>(oadd.org.apache.curator.framework.imps.CreateBuilderImpl,oadd.org.apache.curator.framework.imps.CuratorFrameworkImpl,oadd.org.apache.curator.framework.imps.OperationAndData)>(v, v, v);
v = new oadd.org.apache.curator.framework.imps.CreateBuilderImpl$12;
specialinvoke v.<oadd.org.apache.curator.framework.imps.CreateBuilderImpl$12: void <init>(oadd.org.apache.curator.framework.imps.CreateBuilderImpl,oadd.org.apache.curator.framework.imps.CuratorFrameworkImpl,java.lang.String,oadd.org.apache.zookeeper.AsyncCallback$DataCallback,oadd.org.apache.curator.framework.imps.Backgrounding)>(v, v, v, v, v);
v = new oadd.org.apache.curator.framework.imps.OperationAndData;
specialinvoke v.<oadd.org.apache.curator.framework.imps.OperationAndData: void <init>(oadd.org.apache.curator.framework.imps.BackgroundOperation,java.lang.Object,oadd.org.apache.curator.framework.api.BackgroundCallback,oadd.org.apache.curator.framework.imps.OperationAndData$ErrorCallback,java.lang.Object,oadd.org.apache.curator.framework.imps.Watching)>(v, null, null, null, null, null);
virtualinvoke v.<oadd.org.apache.curator.framework.imps.CuratorFrameworkImpl: boolean queueOperation(oadd.org.apache.curator.framework.imps.OperationAndData)>(v);
return;
}
private void sendBackgroundResponse(int, java.lang.String, java.lang.Object, java.lang.String, oadd.org.apache.zookeeper.data.Stat, oadd.org.apache.curator.framework.imps.OperationAndData)
{
oadd.org.apache.curator.framework.api.CuratorEventType v;
oadd.org.apache.curator.framework.imps.CuratorEventImpl v;
oadd.org.apache.curator.framework.imps.CreateBuilderImpl v;
oadd.org.apache.curator.framework.imps.CuratorFrameworkImpl v, v, v, v;
int v;
oadd.org.apache.curator.framework.imps.OperationAndData v;
java.lang.Object v;
java.lang.String v, v, v, v;
oadd.org.apache.zookeeper.data.Stat v;
v := @this: oadd.org.apache.curator.framework.imps.CreateBuilderImpl;
v := @parameter: int;
v := @parameter: java.lang.String;
v := @parameter: java.lang.Object;
v := @parameter: java.lang.String;
v := @parameter: oadd.org.apache.zookeeper.data.Stat;
v := @parameter: oadd.org.apache.curator.framework.imps.OperationAndData;
v = v.<oadd.org.apache.curator.framework.imps.CreateBuilderImpl: oadd.org.apache.curator.framework.imps.CuratorFrameworkImpl client>;
v = virtualinvoke v.<oadd.org.apache.curator.framework.imps.CuratorFrameworkImpl: java.lang.String unfixForNamespace(java.lang.String)>(v);
v = v.<oadd.org.apache.curator.framework.imps.CreateBuilderImpl: oadd.org.apache.curator.framework.imps.CuratorFrameworkImpl client>;
v = virtualinvoke v.<oadd.org.apache.curator.framework.imps.CuratorFrameworkImpl: java.lang.String unfixForNamespace(java.lang.String)>(v);
v = new oadd.org.apache.curator.framework.imps.CuratorEventImpl;
v = v.<oadd.org.apache.curator.framework.imps.CreateBuilderImpl: oadd.org.apache.curator.framework.imps.CuratorFrameworkImpl client>;
v = <oadd.org.apache.curator.framework.api.CuratorEventType: oadd.org.apache.curator.framework.api.CuratorEventType CREATE>;
specialinvoke v.<oadd.org.apache.curator.framework.imps.CuratorEventImpl: void <init>(oadd.org.apache.curator.framework.imps.CuratorFrameworkImpl,oadd.org.apache.curator.framework.api.CuratorEventType,int,java.lang.String,java.lang.String,java.lang.Object,oadd.org.apache.zookeeper.data.Stat,byte[],java.util.List,oadd.org.apache.zookeeper.WatchedEvent,java.util.List,java.util.List)>(v, v, v, v, v, v, v, null, null, null, null, null);
v = v.<oadd.org.apache.curator.framework.imps.CreateBuilderImpl: oadd.org.apache.curator.framework.imps.CuratorFrameworkImpl client>;
virtualinvoke v.<oadd.org.apache.curator.framework.imps.CuratorFrameworkImpl: void processBackgroundOperation(oadd.org.apache.curator.framework.imps.OperationAndData,oadd.org.apache.curator.framework.api.CuratorEvent)>(v, v);
return;
}
private oadd.org.apache.curator.framework.api.ACLCreateModePathAndBytesable asACLCreateModePathAndBytesable()
{
oadd.org.apache.curator.framework.imps.CreateBuilderImpl$13 v;
oadd.org.apache.curator.framework.imps.CreateBuilderImpl v;
v := @this: oadd.org.apache.curator.framework.imps.CreateBuilderImpl;
v = new oadd.org.apache.curator.framework.imps.CreateBuilderImpl$13;
specialinvoke v.<oadd.org.apache.curator.framework.imps.CreateBuilderImpl$13: void <init>(oadd.org.apache.curator.framework.imps.CreateBuilderImpl)>(v);
return v;
}
private oadd.org.apache.curator.framework.api.CreateBackgroundModeACLable asCreateBackgroundModeACLable()
{
oadd.org.apache.curator.framework.imps.CreateBuilderImpl v;
oadd.org.apache.curator.framework.imps.CreateBuilderImpl$14 v;
v := @this: oadd.org.apache.curator.framework.imps.CreateBuilderImpl;
v = new oadd.org.apache.curator.framework.imps.CreateBuilderImpl$14;
specialinvoke v.<oadd.org.apache.curator.framework.imps.CreateBuilderImpl$14: void <init>(oadd.org.apache.curator.framework.imps.CreateBuilderImpl)>(v);
return v;
}
private oadd.org.apache.curator.framework.api.ACLCreateModeStatBackgroundPathAndBytesable asACLCreateModeStatBackgroundPathAndBytesable()
{
oadd.org.apache.curator.framework.imps.CreateBuilderImpl v;
oadd.org.apache.curator.framework.imps.CreateBuilderImpl$15 v;
v := @this: oadd.org.apache.curator.framework.imps.CreateBuilderImpl;
v = new oadd.org.apache.curator.framework.imps.CreateBuilderImpl$15;
specialinvoke v.<oadd.org.apache.curator.framework.imps.CreateBuilderImpl$15: void <init>(oadd.org.apache.curator.framework.imps.CreateBuilderImpl)>(v);
return v;
}
private void pathInBackground(java.lang.String, byte[], java.lang.String)
{
byte[] v;
oadd.org.apache.curator.framework.imps.CreateBuilderImpl$17 v;
java.util.concurrent.atomic.AtomicBoolean v;
oadd.org.apache.curator.framework.imps.PathAndBytes v;
oadd.org.apache.curator.framework.imps.CreateBuilderImpl v;
oadd.org.apache.curator.framework.imps.CuratorFrameworkImpl v;
oadd.org.apache.curator.framework.api.BackgroundCallback v;
oadd.org.apache.curator.framework.imps.CreateBuilderImpl$16 v;
java.lang.Object v;
java.lang.String v, v;
oadd.org.apache.curator.framework.imps.Backgrounding v, v;
v := @this: oadd.org.apache.curator.framework.imps.CreateBuilderImpl;
v := @parameter: java.lang.String;
v := @parameter: byte[];
v := @parameter: java.lang.String;
v = new java.util.concurrent.atomic.AtomicBoolean;
specialinvoke v.<java.util.concurrent.atomic.AtomicBoolean: void <init>(boolean)>(1);
v = new oadd.org.apache.curator.framework.imps.CreateBuilderImpl$17;
v = new oadd.org.apache.curator.framework.imps.PathAndBytes;
specialinvoke v.<oadd.org.apache.curator.framework.imps.PathAndBytes: void <init>(java.lang.String,byte[])>(v, v);
v = v.<oadd.org.apache.curator.framework.imps.CreateBuilderImpl: oadd.org.apache.curator.framework.imps.Backgrounding backgrounding>;
v = virtualinvoke v.<oadd.org.apache.curator.framework.imps.Backgrounding: oadd.org.apache.curator.framework.api.BackgroundCallback getCallback()>();
v = new oadd.org.apache.curator.framework.imps.CreateBuilderImpl$16;
specialinvoke v.<oadd.org.apache.curator.framework.imps.CreateBuilderImpl$16: void <init>(oadd.org.apache.curator.framework.imps.CreateBuilderImpl,java.lang.String)>(v, v);
v = v.<oadd.org.apache.curator.framework.imps.CreateBuilderImpl: oadd.org.apache.curator.framework.imps.Backgrounding backgrounding>;
v = virtualinvoke v.<oadd.org.apache.curator.framework.imps.Backgrounding: java.lang.Object getContext()>();
specialinvoke v.<oadd.org.apache.curator.framework.imps.CreateBuilderImpl$17: void <init>(oadd.org.apache.curator.framework.imps.CreateBuilderImpl,oadd.org.apache.curator.framework.imps.BackgroundOperation,oadd.org.apache.curator.framework.imps.PathAndBytes,oadd.org.apache.curator.framework.api.BackgroundCallback,oadd.org.apache.curator.framework.imps.OperationAndData$ErrorCallback,java.lang.Object,oadd.org.apache.curator.framework.imps.Watching,java.util.concurrent.atomic.AtomicBoolean,java.lang.String,java.lang.String,byte[])>(v, v, v, v, v, v, null, v, v, v, v);
v = v.<oadd.org.apache.curator.framework.imps.CreateBuilderImpl: oadd.org.apache.curator.framework.imps.CuratorFrameworkImpl client>;
virtualinvoke v.<oadd.org.apache.curator.framework.imps.CuratorFrameworkImpl: void processBackgroundOperation(oadd.org.apache.curator.framework.imps.OperationAndData,oadd.org.apache.curator.framework.api.CuratorEvent)>(v, null);
return;
}
private java.lang.String pathInForeground(java.lang.String, byte[], java.util.List) throws java.lang.Exception
{
byte[] v;
java.util.concurrent.atomic.AtomicBoolean v;
oadd.org.apache.curator.framework.imps.CreateBuilderImpl$18 v;
oadd.org.apache.curator.CuratorZookeeperClient v, v;
oadd.org.apache.curator.framework.imps.CreateBuilderImpl v;
oadd.org.apache.curator.framework.imps.CuratorFrameworkImpl v, v;
java.util.List v;
java.lang.Object v;
java.lang.String v;
oadd.org.apache.curator.drivers.OperationTrace v, v, v;
v := @this: oadd.org.apache.curator.framework.imps.CreateBuilderImpl;
v := @parameter: java.lang.String;
v := @parameter: byte[];
v := @parameter: java.util.List;
v = v.<oadd.org.apache.curator.framework.imps.CreateBuilderImpl: 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 = virtualinvoke v.<oadd.org.apache.curator.CuratorZookeeperClient: oadd.org.apache.curator.drivers.OperationTrace startAdvancedTracer(java.lang.String)>("CreateBuilderImpl-Foreground");
v = new java.util.concurrent.atomic.AtomicBoolean;
specialinvoke v.<java.util.concurrent.atomic.AtomicBoolean: void <init>(boolean)>(1);
v = v.<oadd.org.apache.curator.framework.imps.CreateBuilderImpl: 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.CreateBuilderImpl$18;
specialinvoke v.<oadd.org.apache.curator.framework.imps.CreateBuilderImpl$18: void <init>(oadd.org.apache.curator.framework.imps.CreateBuilderImpl,java.util.concurrent.atomic.AtomicBoolean,java.lang.String,byte[],java.util.List)>(v, v, v, v, v);
v = staticinvoke <oadd.org.apache.curator.RetryLoop: java.lang.Object callWithRetry(oadd.org.apache.curator.CuratorZookeeperClient,java.util.concurrent.Callable)>(v, v);
v = virtualinvoke v.<oadd.org.apache.curator.drivers.OperationTrace: oadd.org.apache.curator.drivers.OperationTrace setRequestBytesLength(byte[])>(v);
v = virtualinvoke v.<oadd.org.apache.curator.drivers.OperationTrace: oadd.org.apache.curator.drivers.OperationTrace setPath(java.lang.String)>(v);
virtualinvoke v.<oadd.org.apache.curator.drivers.OperationTrace: void commit()>();
return v;
}
private java.lang.String findProtectedNodeInForeground(java.lang.String) throws java.lang.Exception
{
oadd.org.apache.curator.CuratorZookeeperClient v, v;
oadd.org.apache.curator.framework.imps.CreateBuilderImpl$19 v;
oadd.org.apache.curator.framework.imps.CreateBuilderImpl v;
oadd.org.apache.curator.framework.imps.CuratorFrameworkImpl v, v;
java.lang.Object v;
java.lang.String v;
oadd.org.apache.curator.drivers.OperationTrace v, v;
v := @this: oadd.org.apache.curator.framework.imps.CreateBuilderImpl;
v := @parameter: java.lang.String;
v = v.<oadd.org.apache.curator.framework.imps.CreateBuilderImpl: 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 = virtualinvoke v.<oadd.org.apache.curator.CuratorZookeeperClient: oadd.org.apache.curator.drivers.OperationTrace startAdvancedTracer(java.lang.String)>("CreateBuilderImpl-findProtectedNodeInForeground");
v = v.<oadd.org.apache.curator.framework.imps.CreateBuilderImpl: 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.CreateBuilderImpl$19;
specialinvoke v.<oadd.org.apache.curator.framework.imps.CreateBuilderImpl$19: void <init>(oadd.org.apache.curator.framework.imps.CreateBuilderImpl,java.lang.String)>(v, v);
v = staticinvoke <oadd.org.apache.curator.RetryLoop: java.lang.Object callWithRetry(oadd.org.apache.curator.CuratorZookeeperClient,java.util.concurrent.Callable)>(v, v);
v = virtualinvoke v.<oadd.org.apache.curator.drivers.OperationTrace: oadd.org.apache.curator.drivers.OperationTrace setPath(java.lang.String)>(v);
virtualinvoke v.<oadd.org.apache.curator.drivers.OperationTrace: void commit()>();
return v;
}
java.lang.String adjustPath(java.lang.String) throws java.lang.Exception
{
oadd.org.apache.curator.framework.imps.ProtectedMode v;
java.lang.String v, v, v;
oadd.org.apache.curator.framework.imps.CreateBuilderImpl v;
v := @this: oadd.org.apache.curator.framework.imps.CreateBuilderImpl;
v := @parameter: java.lang.String;
v = v.<oadd.org.apache.curator.framework.imps.CreateBuilderImpl: oadd.org.apache.curator.framework.imps.ProtectedMode protectedMode>;
v = virtualinvoke v.<oadd.org.apache.curator.framework.imps.ProtectedMode: java.lang.String protectedId()>();
v = staticinvoke <oadd.org.apache.curator.framework.imps.ProtectedUtils: java.lang.String toProtectedZNodePath(java.lang.String,java.lang.String)>(v, v);
return v;
}
static java.lang.String findNode(java.util.List, java.lang.String, java.lang.String)
{
oadd.org.apache.curator.framework.imps.CreateBuilderImpl$20 v;
java.util.List v;
java.lang.Object v;
java.lang.String v, v, v;
v := @parameter: java.util.List;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v = staticinvoke <oadd.org.apache.curator.framework.imps.ProtectedUtils: java.lang.String getProtectedPrefix(java.lang.String)>(v);
v = new oadd.org.apache.curator.framework.imps.CreateBuilderImpl$20;
specialinvoke v.<oadd.org.apache.curator.framework.imps.CreateBuilderImpl$20: void <init>(java.lang.String)>(v);
v = staticinvoke <oadd.org.apache.curator.shaded.com.google.common.collect.Iterables: java.lang.Object find(java.lang.Iterable,oadd.org.apache.curator.shaded.com.google.common.base.Predicate,java.lang.Object)>(v, v, null);
if v == null goto label;
v = staticinvoke <oadd.org.apache.curator.utils.ZKPaths: java.lang.String makePath(java.lang.String,java.lang.String)>(v, v);
label:
return v;
}
}