public class oadd.org.apache.curator.framework.recipes.locks.InterProcessReadWriteLock extends java.lang.Object
{
private final oadd.org.apache.curator.framework.recipes.locks.InterProcessMutex readMutex;
private final oadd.org.apache.curator.framework.recipes.locks.InterProcessMutex writeMutex;
private static final java.lang.String READ_LOCK_NAME;
private static final java.lang.String WRITE_LOCK_NAME;
public void <init>(oadd.org.apache.curator.framework.CuratorFramework, java.lang.String)
{
java.lang.String v;
oadd.org.apache.curator.framework.CuratorFramework v;
oadd.org.apache.curator.framework.recipes.locks.InterProcessReadWriteLock v;
v := @this: oadd.org.apache.curator.framework.recipes.locks.InterProcessReadWriteLock;
v := @parameter: oadd.org.apache.curator.framework.CuratorFramework;
v := @parameter: java.lang.String;
specialinvoke v.<oadd.org.apache.curator.framework.recipes.locks.InterProcessReadWriteLock: void <init>(oadd.org.apache.curator.framework.CuratorFramework,java.lang.String,byte[])>(v, v, null);
return;
}
public void <init>(oadd.org.apache.curator.framework.CuratorFramework, java.lang.String, byte[])
{
byte[] v, v;
oadd.org.apache.curator.framework.CuratorFramework v;
oadd.org.apache.curator.framework.recipes.locks.InterProcessReadWriteLock$1 v;
oadd.org.apache.curator.framework.recipes.locks.InterProcessReadWriteLock$2 v;
oadd.org.apache.curator.framework.recipes.locks.InterProcessReadWriteLock v;
int v;
oadd.org.apache.curator.framework.recipes.locks.InterProcessReadWriteLock$InternalInterProcessMutex v, v;
java.lang.String v;
v := @this: oadd.org.apache.curator.framework.recipes.locks.InterProcessReadWriteLock;
v := @parameter: oadd.org.apache.curator.framework.CuratorFramework;
v := @parameter: java.lang.String;
v := @parameter: byte[];
specialinvoke v.<java.lang.Object: void <init>()>();
if v != null goto label;
v = null;
goto label;
label:
v = lengthof v;
v = staticinvoke <java.util.Arrays: byte[] copyOf(byte[],int)>(v, v);
label:
v = new oadd.org.apache.curator.framework.recipes.locks.InterProcessReadWriteLock$InternalInterProcessMutex;
v = new oadd.org.apache.curator.framework.recipes.locks.InterProcessReadWriteLock$1;
specialinvoke v.<oadd.org.apache.curator.framework.recipes.locks.InterProcessReadWriteLock$1: void <init>(oadd.org.apache.curator.framework.recipes.locks.InterProcessReadWriteLock)>(v);
specialinvoke v.<oadd.org.apache.curator.framework.recipes.locks.InterProcessReadWriteLock$InternalInterProcessMutex: void <init>(oadd.org.apache.curator.framework.CuratorFramework,java.lang.String,java.lang.String,byte[],int,oadd.org.apache.curator.framework.recipes.locks.LockInternalsDriver)>(v, v, "__WRIT__", v, 1, v);
v.<oadd.org.apache.curator.framework.recipes.locks.InterProcessReadWriteLock: oadd.org.apache.curator.framework.recipes.locks.InterProcessMutex writeMutex> = v;
v = new oadd.org.apache.curator.framework.recipes.locks.InterProcessReadWriteLock$InternalInterProcessMutex;
v = new oadd.org.apache.curator.framework.recipes.locks.InterProcessReadWriteLock$2;
specialinvoke v.<oadd.org.apache.curator.framework.recipes.locks.InterProcessReadWriteLock$2: void <init>(oadd.org.apache.curator.framework.recipes.locks.InterProcessReadWriteLock)>(v);
specialinvoke v.<oadd.org.apache.curator.framework.recipes.locks.InterProcessReadWriteLock$InternalInterProcessMutex: void <init>(oadd.org.apache.curator.framework.CuratorFramework,java.lang.String,java.lang.String,byte[],int,oadd.org.apache.curator.framework.recipes.locks.LockInternalsDriver)>(v, v, "__READ__", v, 2147483647, v);
v.<oadd.org.apache.curator.framework.recipes.locks.InterProcessReadWriteLock: oadd.org.apache.curator.framework.recipes.locks.InterProcessMutex readMutex> = v;
return;
}
public oadd.org.apache.curator.framework.recipes.locks.InterProcessMutex readLock()
{
oadd.org.apache.curator.framework.recipes.locks.InterProcessMutex v;
oadd.org.apache.curator.framework.recipes.locks.InterProcessReadWriteLock v;
v := @this: oadd.org.apache.curator.framework.recipes.locks.InterProcessReadWriteLock;
v = v.<oadd.org.apache.curator.framework.recipes.locks.InterProcessReadWriteLock: oadd.org.apache.curator.framework.recipes.locks.InterProcessMutex readMutex>;
return v;
}
public oadd.org.apache.curator.framework.recipes.locks.InterProcessMutex writeLock()
{
oadd.org.apache.curator.framework.recipes.locks.InterProcessMutex v;
oadd.org.apache.curator.framework.recipes.locks.InterProcessReadWriteLock v;
v := @this: oadd.org.apache.curator.framework.recipes.locks.InterProcessReadWriteLock;
v = v.<oadd.org.apache.curator.framework.recipes.locks.InterProcessReadWriteLock: oadd.org.apache.curator.framework.recipes.locks.InterProcessMutex writeMutex>;
return v;
}
private oadd.org.apache.curator.framework.recipes.locks.PredicateResults readLockPredicate(java.util.List, java.lang.String) throws java.lang.Exception
{
int v, v, v, v;
java.lang.String v;
boolean v, v, v, v, v, v;
java.util.Iterator v;
oadd.org.apache.curator.framework.recipes.locks.PredicateResults v, v;
java.util.List v;
oadd.org.apache.curator.framework.recipes.locks.InterProcessMutex v;
oadd.org.apache.curator.framework.recipes.locks.InterProcessReadWriteLock v;
java.lang.Object v, v;
v := @this: oadd.org.apache.curator.framework.recipes.locks.InterProcessReadWriteLock;
v := @parameter: java.util.List;
v := @parameter: java.lang.String;
v = v.<oadd.org.apache.curator.framework.recipes.locks.InterProcessReadWriteLock: oadd.org.apache.curator.framework.recipes.locks.InterProcessMutex writeMutex>;
v = virtualinvoke v.<oadd.org.apache.curator.framework.recipes.locks.InterProcessMutex: boolean isOwnedByCurrentThread()>();
if v == 0 goto label;
v = new oadd.org.apache.curator.framework.recipes.locks.PredicateResults;
specialinvoke v.<oadd.org.apache.curator.framework.recipes.locks.PredicateResults: void <init>(java.lang.String,boolean)>(null, 1);
return v;
label:
v = 0;
v = 2147483647;
v = (int) -1;
v = v;
v = interfaceinvoke v.<java.util.List: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = virtualinvoke v.<java.lang.String: boolean contains(java.lang.CharSequence)>("__WRIT__");
if v == 0 goto label;
v = staticinvoke <java.lang.Math: int min(int,int)>(v, v);
goto label;
label:
v = virtualinvoke v.<java.lang.String: boolean startsWith(java.lang.String)>(v);
if v == 0 goto label;
v = v;
goto label;
label:
v = v + 1;
goto label;
label:
staticinvoke <oadd.org.apache.curator.framework.recipes.locks.StandardLockInternalsDriver: void validateOurIndex(java.lang.String,int)>(v, v);
if v >= v goto label;
v = 1;
goto label;
label:
v = 0;
label:
v = v;
if v != 0 goto label;
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(v);
label:
v = new oadd.org.apache.curator.framework.recipes.locks.PredicateResults;
specialinvoke v.<oadd.org.apache.curator.framework.recipes.locks.PredicateResults: void <init>(java.lang.String,boolean)>(v, v);
return v;
}
}