public abstract class io.netty.channel.SingleThreadEventLoop extends io.netty.util.concurrent.SingleThreadEventExecutor implements io.netty.channel.EventLoop
{
protected static final int DEFAULT_MAX_PENDING_TASKS;
private final java.util.Queue tailTasks;
protected void <init>(io.netty.channel.EventLoopGroup, java.util.concurrent.ThreadFactory, boolean)
{
io.netty.channel.EventLoopGroup v;
io.netty.channel.SingleThreadEventLoop v;
int v;
java.util.concurrent.ThreadFactory v;
io.netty.util.concurrent.RejectedExecutionHandler v;
boolean v;
v := @this: io.netty.channel.SingleThreadEventLoop;
v := @parameter: io.netty.channel.EventLoopGroup;
v := @parameter: java.util.concurrent.ThreadFactory;
v := @parameter: boolean;
v = <io.netty.channel.SingleThreadEventLoop: int DEFAULT_MAX_PENDING_TASKS>;
v = staticinvoke <io.netty.util.concurrent.RejectedExecutionHandlers: io.netty.util.concurrent.RejectedExecutionHandler reject()>();
specialinvoke v.<io.netty.channel.SingleThreadEventLoop: void <init>(io.netty.channel.EventLoopGroup,java.util.concurrent.ThreadFactory,boolean,int,io.netty.util.concurrent.RejectedExecutionHandler)>(v, v, v, v, v);
return;
}
protected void <init>(io.netty.channel.EventLoopGroup, java.util.concurrent.Executor, boolean)
{
io.netty.channel.EventLoopGroup v;
java.util.concurrent.Executor v;
io.netty.channel.SingleThreadEventLoop v;
int v;
io.netty.util.concurrent.RejectedExecutionHandler v;
boolean v;
v := @this: io.netty.channel.SingleThreadEventLoop;
v := @parameter: io.netty.channel.EventLoopGroup;
v := @parameter: java.util.concurrent.Executor;
v := @parameter: boolean;
v = <io.netty.channel.SingleThreadEventLoop: int DEFAULT_MAX_PENDING_TASKS>;
v = staticinvoke <io.netty.util.concurrent.RejectedExecutionHandlers: io.netty.util.concurrent.RejectedExecutionHandler reject()>();
specialinvoke v.<io.netty.channel.SingleThreadEventLoop: void <init>(io.netty.channel.EventLoopGroup,java.util.concurrent.Executor,boolean,int,io.netty.util.concurrent.RejectedExecutionHandler)>(v, v, v, v, v);
return;
}
protected void <init>(io.netty.channel.EventLoopGroup, java.util.concurrent.ThreadFactory, boolean, int, io.netty.util.concurrent.RejectedExecutionHandler)
{
io.netty.channel.EventLoopGroup v;
io.netty.channel.SingleThreadEventLoop v;
int v;
java.util.Queue v;
java.util.concurrent.ThreadFactory v;
io.netty.util.concurrent.RejectedExecutionHandler v;
boolean v;
v := @this: io.netty.channel.SingleThreadEventLoop;
v := @parameter: io.netty.channel.EventLoopGroup;
v := @parameter: java.util.concurrent.ThreadFactory;
v := @parameter: boolean;
v := @parameter: int;
v := @parameter: io.netty.util.concurrent.RejectedExecutionHandler;
specialinvoke v.<io.netty.util.concurrent.SingleThreadEventExecutor: void <init>(io.netty.util.concurrent.EventExecutorGroup,java.util.concurrent.ThreadFactory,boolean,int,io.netty.util.concurrent.RejectedExecutionHandler)>(v, v, v, v, v);
v = virtualinvoke v.<io.netty.channel.SingleThreadEventLoop: java.util.Queue newTaskQueue(int)>(v);
v.<io.netty.channel.SingleThreadEventLoop: java.util.Queue tailTasks> = v;
return;
}
protected void <init>(io.netty.channel.EventLoopGroup, java.util.concurrent.Executor, boolean, int, io.netty.util.concurrent.RejectedExecutionHandler)
{
io.netty.channel.EventLoopGroup v;
java.util.concurrent.Executor v;
io.netty.channel.SingleThreadEventLoop v;
int v;
java.util.Queue v;
io.netty.util.concurrent.RejectedExecutionHandler v;
boolean v;
v := @this: io.netty.channel.SingleThreadEventLoop;
v := @parameter: io.netty.channel.EventLoopGroup;
v := @parameter: java.util.concurrent.Executor;
v := @parameter: boolean;
v := @parameter: int;
v := @parameter: io.netty.util.concurrent.RejectedExecutionHandler;
specialinvoke v.<io.netty.util.concurrent.SingleThreadEventExecutor: void <init>(io.netty.util.concurrent.EventExecutorGroup,java.util.concurrent.Executor,boolean,int,io.netty.util.concurrent.RejectedExecutionHandler)>(v, v, v, v, v);
v = virtualinvoke v.<io.netty.channel.SingleThreadEventLoop: java.util.Queue newTaskQueue(int)>(v);
v.<io.netty.channel.SingleThreadEventLoop: java.util.Queue tailTasks> = v;
return;
}
protected void <init>(io.netty.channel.EventLoopGroup, java.util.concurrent.Executor, boolean, java.util.Queue, java.util.Queue, io.netty.util.concurrent.RejectedExecutionHandler)
{
io.netty.channel.EventLoopGroup v;
java.util.concurrent.Executor v;
io.netty.channel.SingleThreadEventLoop v;
java.lang.Object v;
java.util.Queue v, v;
io.netty.util.concurrent.RejectedExecutionHandler v;
boolean v;
v := @this: io.netty.channel.SingleThreadEventLoop;
v := @parameter: io.netty.channel.EventLoopGroup;
v := @parameter: java.util.concurrent.Executor;
v := @parameter: boolean;
v := @parameter: java.util.Queue;
v := @parameter: java.util.Queue;
v := @parameter: io.netty.util.concurrent.RejectedExecutionHandler;
specialinvoke v.<io.netty.util.concurrent.SingleThreadEventExecutor: void <init>(io.netty.util.concurrent.EventExecutorGroup,java.util.concurrent.Executor,boolean,java.util.Queue,io.netty.util.concurrent.RejectedExecutionHandler)>(v, v, v, v, v);
v = staticinvoke <io.netty.util.internal.ObjectUtil: java.lang.Object checkNotNull(java.lang.Object,java.lang.String)>(v, "tailTaskQueue");
v.<io.netty.channel.SingleThreadEventLoop: java.util.Queue tailTasks> = v;
return;
}
public io.netty.channel.EventLoopGroup parent()
{
io.netty.util.concurrent.EventExecutorGroup v;
io.netty.channel.SingleThreadEventLoop v;
v := @this: io.netty.channel.SingleThreadEventLoop;
v = specialinvoke v.<io.netty.util.concurrent.SingleThreadEventExecutor: io.netty.util.concurrent.EventExecutorGroup parent()>();
return v;
}
public io.netty.channel.EventLoop next()
{
io.netty.util.concurrent.EventExecutor v;
io.netty.channel.SingleThreadEventLoop v;
v := @this: io.netty.channel.SingleThreadEventLoop;
v = specialinvoke v.<io.netty.util.concurrent.SingleThreadEventExecutor: io.netty.util.concurrent.EventExecutor next()>();
return v;
}
public io.netty.channel.ChannelFuture register(io.netty.channel.Channel)
{
io.netty.channel.Channel v;
io.netty.channel.SingleThreadEventLoop v;
io.netty.channel.DefaultChannelPromise v;
io.netty.channel.ChannelFuture v;
v := @this: io.netty.channel.SingleThreadEventLoop;
v := @parameter: io.netty.channel.Channel;
v = new io.netty.channel.DefaultChannelPromise;
specialinvoke v.<io.netty.channel.DefaultChannelPromise: void <init>(io.netty.channel.Channel,io.netty.util.concurrent.EventExecutor)>(v, v);
v = virtualinvoke v.<io.netty.channel.SingleThreadEventLoop: io.netty.channel.ChannelFuture register(io.netty.channel.ChannelPromise)>(v);
return v;
}
public io.netty.channel.ChannelFuture register(io.netty.channel.ChannelPromise)
{
io.netty.channel.Channel v;
io.netty.channel.ChannelPromise v;
io.netty.channel.SingleThreadEventLoop v;
io.netty.channel.Channel$Unsafe v;
v := @this: io.netty.channel.SingleThreadEventLoop;
v := @parameter: io.netty.channel.ChannelPromise;
staticinvoke <io.netty.util.internal.ObjectUtil: java.lang.Object checkNotNull(java.lang.Object,java.lang.String)>(v, "promise");
v = interfaceinvoke v.<io.netty.channel.ChannelPromise: io.netty.channel.Channel channel()>();
v = interfaceinvoke v.<io.netty.channel.Channel: io.netty.channel.Channel$Unsafe unsafe()>();
interfaceinvoke v.<io.netty.channel.Channel$Unsafe: void register(io.netty.channel.EventLoop,io.netty.channel.ChannelPromise)>(v, v);
return v;
}
public io.netty.channel.ChannelFuture register(io.netty.channel.Channel, io.netty.channel.ChannelPromise)
{
io.netty.channel.Channel v;
io.netty.channel.ChannelPromise v;
io.netty.channel.SingleThreadEventLoop v;
io.netty.channel.Channel$Unsafe v;
v := @this: io.netty.channel.SingleThreadEventLoop;
v := @parameter: io.netty.channel.Channel;
v := @parameter: io.netty.channel.ChannelPromise;
staticinvoke <io.netty.util.internal.ObjectUtil: java.lang.Object checkNotNull(java.lang.Object,java.lang.String)>(v, "promise");
staticinvoke <io.netty.util.internal.ObjectUtil: java.lang.Object checkNotNull(java.lang.Object,java.lang.String)>(v, "channel");
v = interfaceinvoke v.<io.netty.channel.Channel: io.netty.channel.Channel$Unsafe unsafe()>();
interfaceinvoke v.<io.netty.channel.Channel$Unsafe: void register(io.netty.channel.EventLoop,io.netty.channel.ChannelPromise)>(v, v);
return v;
}
public final void executeAfterEventLoopIteration(java.lang.Runnable)
{
java.lang.Runnable v;
io.netty.channel.SingleThreadEventLoop v;
java.util.Queue v;
boolean v, v, v, v, v;
v := @this: io.netty.channel.SingleThreadEventLoop;
v := @parameter: java.lang.Runnable;
staticinvoke <io.netty.util.internal.ObjectUtil: java.lang.Object checkNotNull(java.lang.Object,java.lang.String)>(v, "task");
v = virtualinvoke v.<io.netty.channel.SingleThreadEventLoop: boolean isShutdown()>();
if v == 0 goto label;
staticinvoke <io.netty.channel.SingleThreadEventLoop: void reject()>();
label:
v = v.<io.netty.channel.SingleThreadEventLoop: java.util.Queue tailTasks>;
v = interfaceinvoke v.<java.util.Queue: boolean offer(java.lang.Object)>(v);
if v != 0 goto label;
virtualinvoke v.<io.netty.channel.SingleThreadEventLoop: void reject(java.lang.Runnable)>(v);
label:
v = v instanceof io.netty.util.concurrent.AbstractEventExecutor$LazyRunnable;
if v != 0 goto label;
v = virtualinvoke v.<io.netty.channel.SingleThreadEventLoop: boolean wakesUpForTask(java.lang.Runnable)>(v);
if v == 0 goto label;
v = virtualinvoke v.<io.netty.channel.SingleThreadEventLoop: boolean inEventLoop()>();
virtualinvoke v.<io.netty.channel.SingleThreadEventLoop: void wakeup(boolean)>(v);
label:
return;
}
final boolean removeAfterEventLoopIterationTask(java.lang.Runnable)
{
io.netty.channel.SingleThreadEventLoop v;
java.lang.Object v;
java.util.Queue v;
java.lang.Runnable v;
boolean v;
v := @this: io.netty.channel.SingleThreadEventLoop;
v := @parameter: java.lang.Runnable;
v = v.<io.netty.channel.SingleThreadEventLoop: java.util.Queue tailTasks>;
v = staticinvoke <io.netty.util.internal.ObjectUtil: java.lang.Object checkNotNull(java.lang.Object,java.lang.String)>(v, "task");
v = interfaceinvoke v.<java.util.Queue: boolean remove(java.lang.Object)>(v);
return v;
}
protected void afterRunningAllTasks()
{
java.util.Queue v;
io.netty.channel.SingleThreadEventLoop v;
v := @this: io.netty.channel.SingleThreadEventLoop;
v = v.<io.netty.channel.SingleThreadEventLoop: java.util.Queue tailTasks>;
virtualinvoke v.<io.netty.channel.SingleThreadEventLoop: boolean runAllTasksFrom(java.util.Queue)>(v);
return;
}
protected boolean hasTasks()
{
io.netty.channel.SingleThreadEventLoop v;
java.util.Queue v;
boolean v, v, v;
v := @this: io.netty.channel.SingleThreadEventLoop;
v = specialinvoke v.<io.netty.util.concurrent.SingleThreadEventExecutor: boolean hasTasks()>();
if v != 0 goto label;
v = v.<io.netty.channel.SingleThreadEventLoop: java.util.Queue tailTasks>;
v = interfaceinvoke v.<java.util.Queue: boolean isEmpty()>();
if v != 0 goto label;
label:
v = 1;
goto label;
label:
v = 0;
label:
return v;
}
public int pendingTasks()
{
io.netty.channel.SingleThreadEventLoop v;
int v, v, v;
java.util.Queue v;
v := @this: io.netty.channel.SingleThreadEventLoop;
v = specialinvoke v.<io.netty.util.concurrent.SingleThreadEventExecutor: int pendingTasks()>();
v = v.<io.netty.channel.SingleThreadEventLoop: java.util.Queue tailTasks>;
v = interfaceinvoke v.<java.util.Queue: int size()>();
v = v + v;
return v;
}
public int registeredChannels()
{
int v;
io.netty.channel.SingleThreadEventLoop v;
v := @this: io.netty.channel.SingleThreadEventLoop;
v = (int) -1;
return v;
}
public java.util.Iterator registeredChannelsIterator()
{
java.lang.UnsupportedOperationException v;
io.netty.channel.SingleThreadEventLoop v;
v := @this: io.netty.channel.SingleThreadEventLoop;
v = new java.lang.UnsupportedOperationException;
specialinvoke v.<java.lang.UnsupportedOperationException: void <init>(java.lang.String)>("registeredChannelsIterator");
throw v;
}
static void <clinit>()
{
int v, v;
v = staticinvoke <io.netty.util.internal.SystemPropertyUtil: int getInt(java.lang.String,int)>("io.netty.eventLoop.maxPendingTasks", 2147483647);
v = staticinvoke <java.lang.Math: int max(int,int)>(16, v);
<io.netty.channel.SingleThreadEventLoop: int DEFAULT_MAX_PENDING_TASKS> = v;
return;
}
}