class io.netty.util.concurrent.RejectedExecutionHandlers$2 extends java.lang.Object implements io.netty.util.concurrent.RejectedExecutionHandler
{
final int val$retries;
final long val$backOffNanos;
void <init>(int, long)
{
int v;
long v;
io.netty.util.concurrent.RejectedExecutionHandlers$2 v;
v := @this: io.netty.util.concurrent.RejectedExecutionHandlers$2;
v := @parameter: int;
v := @parameter: long;
v.<io.netty.util.concurrent.RejectedExecutionHandlers$2: int val$retries> = v;
v.<io.netty.util.concurrent.RejectedExecutionHandlers$2: long val$backOffNanos> = v;
specialinvoke v.<java.lang.Object: void <init>()>();
return;
}
public void rejected(java.lang.Runnable, io.netty.util.concurrent.SingleThreadEventExecutor)
{
io.netty.util.concurrent.SingleThreadEventExecutor v;
io.netty.util.concurrent.RejectedExecutionHandlers$2 v;
long v;
java.lang.Runnable v;
java.util.concurrent.RejectedExecutionException v;
int v, v;
boolean v, v;
v := @this: io.netty.util.concurrent.RejectedExecutionHandlers$2;
v := @parameter: java.lang.Runnable;
v := @parameter: io.netty.util.concurrent.SingleThreadEventExecutor;
v = virtualinvoke v.<io.netty.util.concurrent.SingleThreadEventExecutor: boolean inEventLoop()>();
if v != 0 goto label;
v = 0;
label:
v = v.<io.netty.util.concurrent.RejectedExecutionHandlers$2: int val$retries>;
if v >= v goto label;
virtualinvoke v.<io.netty.util.concurrent.SingleThreadEventExecutor: void wakeup(boolean)>(0);
v = v.<io.netty.util.concurrent.RejectedExecutionHandlers$2: long val$backOffNanos>;
staticinvoke <java.util.concurrent.locks.LockSupport: void parkNanos(long)>(v);
v = virtualinvoke v.<io.netty.util.concurrent.SingleThreadEventExecutor: boolean offerTask(java.lang.Runnable)>(v);
if v == 0 goto label;
return;
label:
v = v + 1;
goto label;
label:
v = new java.util.concurrent.RejectedExecutionException;
specialinvoke v.<java.util.concurrent.RejectedExecutionException: void <init>()>();
throw v;
}
}