abstract class oadd.org.apache.curator.retry.SleepingRetry extends java.lang.Object implements oadd.org.apache.curator.RetryPolicy
{
private final int n;
protected void <init>(int)
{
int v;
oadd.org.apache.curator.retry.SleepingRetry v;
v := @this: oadd.org.apache.curator.retry.SleepingRetry;
v := @parameter: int;
specialinvoke v.<java.lang.Object: void <init>()>();
v.<oadd.org.apache.curator.retry.SleepingRetry: int n> = v;
return;
}
public int getN()
{
int v;
oadd.org.apache.curator.retry.SleepingRetry v;
v := @this: oadd.org.apache.curator.retry.SleepingRetry;
v = v.<oadd.org.apache.curator.retry.SleepingRetry: int n>;
return v;
}
public boolean allowRetry(int, long, oadd.org.apache.curator.RetrySleeper)
{
long v, v;
java.util.concurrent.TimeUnit v;
java.lang.InterruptedException v;
oadd.org.apache.curator.retry.SleepingRetry v;
java.lang.Thread v;
int v, v;
oadd.org.apache.curator.RetrySleeper v;
v := @this: oadd.org.apache.curator.retry.SleepingRetry;
v := @parameter: int;
v := @parameter: long;
v := @parameter: oadd.org.apache.curator.RetrySleeper;
v = v.<oadd.org.apache.curator.retry.SleepingRetry: int n>;
if v >= v goto label;
label:
v = virtualinvoke v.<oadd.org.apache.curator.retry.SleepingRetry: long getSleepTimeMs(int,long)>(v, v);
v = <java.util.concurrent.TimeUnit: java.util.concurrent.TimeUnit MILLISECONDS>;
interfaceinvoke v.<oadd.org.apache.curator.RetrySleeper: void sleepFor(long,java.util.concurrent.TimeUnit)>(v, v);
label:
goto label;
label:
v := @caughtexception;
v = staticinvoke <java.lang.Thread: java.lang.Thread currentThread()>();
virtualinvoke v.<java.lang.Thread: void interrupt()>();
return 0;
label:
return 1;
label:
return 0;
catch java.lang.InterruptedException from label to label with label;
}
protected abstract long getSleepTimeMs(int, long);
}