final class oadd.io.netty.channel.embedded.EmbeddedEventLoop extends oadd.io.netty.util.concurrent.AbstractScheduledEventExecutor implements oadd.io.netty.channel.EventLoop
{
private final java.util.Queue tasks;
void <init>()
{
oadd.io.netty.channel.embedded.EmbeddedEventLoop v;
java.util.ArrayDeque v;
v := @this: oadd.io.netty.channel.embedded.EmbeddedEventLoop;
specialinvoke v.<oadd.io.netty.util.concurrent.AbstractScheduledEventExecutor: void <init>()>();
v = new java.util.ArrayDeque;
specialinvoke v.<java.util.ArrayDeque: void <init>(int)>(2);
v.<oadd.io.netty.channel.embedded.EmbeddedEventLoop: java.util.Queue tasks> = v;
return;
}
public oadd.io.netty.channel.EventLoopGroup parent()
{
oadd.io.netty.channel.embedded.EmbeddedEventLoop v;
oadd.io.netty.util.concurrent.EventExecutorGroup v;
v := @this: oadd.io.netty.channel.embedded.EmbeddedEventLoop;
v = specialinvoke v.<oadd.io.netty.util.concurrent.AbstractScheduledEventExecutor: oadd.io.netty.util.concurrent.EventExecutorGroup parent()>();
return v;
}
public oadd.io.netty.channel.EventLoop next()
{
oadd.io.netty.channel.embedded.EmbeddedEventLoop v;
oadd.io.netty.util.concurrent.EventExecutor v;
v := @this: oadd.io.netty.channel.embedded.EmbeddedEventLoop;
v = specialinvoke v.<oadd.io.netty.util.concurrent.AbstractScheduledEventExecutor: oadd.io.netty.util.concurrent.EventExecutor next()>();
return v;
}
public void execute(java.lang.Runnable)
{
oadd.io.netty.channel.embedded.EmbeddedEventLoop v;
java.lang.Object v;
java.util.Queue v;
java.lang.Runnable v;
v := @this: oadd.io.netty.channel.embedded.EmbeddedEventLoop;
v := @parameter: java.lang.Runnable;
v = v.<oadd.io.netty.channel.embedded.EmbeddedEventLoop: java.util.Queue tasks>;
v = staticinvoke <oadd.io.netty.util.internal.ObjectUtil: java.lang.Object checkNotNull(java.lang.Object,java.lang.String)>(v, "command");
interfaceinvoke v.<java.util.Queue: boolean add(java.lang.Object)>(v);
return;
}
void runTasks()
{
oadd.io.netty.channel.embedded.EmbeddedEventLoop v;
java.lang.Object v;
java.util.Queue v;
v := @this: oadd.io.netty.channel.embedded.EmbeddedEventLoop;
label:
v = v.<oadd.io.netty.channel.embedded.EmbeddedEventLoop: java.util.Queue tasks>;
v = interfaceinvoke v.<java.util.Queue: java.lang.Object poll()>();
if v == null goto label;
interfaceinvoke v.<java.lang.Runnable: void run()>();
goto label;
label:
return;
}
long runScheduledTasks()
{
oadd.io.netty.channel.embedded.EmbeddedEventLoop v;
long v, v;
java.lang.Runnable v;
v := @this: oadd.io.netty.channel.embedded.EmbeddedEventLoop;
v = staticinvoke <oadd.io.netty.util.concurrent.AbstractScheduledEventExecutor: long nanoTime()>();
label:
v = virtualinvoke v.<oadd.io.netty.channel.embedded.EmbeddedEventLoop: java.lang.Runnable pollScheduledTask(long)>(v);
if v != null goto label;
v = virtualinvoke v.<oadd.io.netty.channel.embedded.EmbeddedEventLoop: long nextScheduledTaskNano()>();
return v;
label:
interfaceinvoke v.<java.lang.Runnable: void run()>();
goto label;
}
long nextScheduledTask()
{
oadd.io.netty.channel.embedded.EmbeddedEventLoop v;
long v;
v := @this: oadd.io.netty.channel.embedded.EmbeddedEventLoop;
v = virtualinvoke v.<oadd.io.netty.channel.embedded.EmbeddedEventLoop: long nextScheduledTaskNano()>();
return v;
}
protected void cancelScheduledTasks()
{
oadd.io.netty.channel.embedded.EmbeddedEventLoop v;
v := @this: oadd.io.netty.channel.embedded.EmbeddedEventLoop;
specialinvoke v.<oadd.io.netty.util.concurrent.AbstractScheduledEventExecutor: void cancelScheduledTasks()>();
return;
}
public oadd.io.netty.util.concurrent.Future shutdownGracefully(long, long, java.util.concurrent.TimeUnit)
{
java.util.concurrent.TimeUnit v;
java.lang.UnsupportedOperationException v;
oadd.io.netty.channel.embedded.EmbeddedEventLoop v;
long v, v;
v := @this: oadd.io.netty.channel.embedded.EmbeddedEventLoop;
v := @parameter: long;
v := @parameter: long;
v := @parameter: java.util.concurrent.TimeUnit;
v = new java.lang.UnsupportedOperationException;
specialinvoke v.<java.lang.UnsupportedOperationException: void <init>()>();
throw v;
}
public oadd.io.netty.util.concurrent.Future terminationFuture()
{
java.lang.UnsupportedOperationException v;
oadd.io.netty.channel.embedded.EmbeddedEventLoop v;
v := @this: oadd.io.netty.channel.embedded.EmbeddedEventLoop;
v = new java.lang.UnsupportedOperationException;
specialinvoke v.<java.lang.UnsupportedOperationException: void <init>()>();
throw v;
}
public void shutdown()
{
java.lang.UnsupportedOperationException v;
oadd.io.netty.channel.embedded.EmbeddedEventLoop v;
v := @this: oadd.io.netty.channel.embedded.EmbeddedEventLoop;
v = new java.lang.UnsupportedOperationException;
specialinvoke v.<java.lang.UnsupportedOperationException: void <init>()>();
throw v;
}
public boolean isShuttingDown()
{
oadd.io.netty.channel.embedded.EmbeddedEventLoop v;
v := @this: oadd.io.netty.channel.embedded.EmbeddedEventLoop;
return 0;
}
public boolean isShutdown()
{
oadd.io.netty.channel.embedded.EmbeddedEventLoop v;
v := @this: oadd.io.netty.channel.embedded.EmbeddedEventLoop;
return 0;
}
public boolean isTerminated()
{
oadd.io.netty.channel.embedded.EmbeddedEventLoop v;
v := @this: oadd.io.netty.channel.embedded.EmbeddedEventLoop;
return 0;
}
public boolean awaitTermination(long, java.util.concurrent.TimeUnit)
{
java.util.concurrent.TimeUnit v;
oadd.io.netty.channel.embedded.EmbeddedEventLoop v;
long v;
v := @this: oadd.io.netty.channel.embedded.EmbeddedEventLoop;
v := @parameter: long;
v := @parameter: java.util.concurrent.TimeUnit;
return 0;
}
public oadd.io.netty.channel.ChannelFuture register(oadd.io.netty.channel.Channel)
{
oadd.io.netty.channel.embedded.EmbeddedEventLoop v;
oadd.io.netty.channel.Channel v;
oadd.io.netty.channel.DefaultChannelPromise v;
oadd.io.netty.channel.ChannelFuture v;
v := @this: oadd.io.netty.channel.embedded.EmbeddedEventLoop;
v := @parameter: oadd.io.netty.channel.Channel;
v = new oadd.io.netty.channel.DefaultChannelPromise;
specialinvoke v.<oadd.io.netty.channel.DefaultChannelPromise: void <init>(oadd.io.netty.channel.Channel,oadd.io.netty.util.concurrent.EventExecutor)>(v, v);
v = virtualinvoke v.<oadd.io.netty.channel.embedded.EmbeddedEventLoop: oadd.io.netty.channel.ChannelFuture register(oadd.io.netty.channel.ChannelPromise)>(v);
return v;
}
public oadd.io.netty.channel.ChannelFuture register(oadd.io.netty.channel.ChannelPromise)
{
oadd.io.netty.channel.embedded.EmbeddedEventLoop v;
oadd.io.netty.channel.Channel$Unsafe v;
oadd.io.netty.channel.Channel v;
oadd.io.netty.channel.ChannelPromise v;
v := @this: oadd.io.netty.channel.embedded.EmbeddedEventLoop;
v := @parameter: oadd.io.netty.channel.ChannelPromise;
staticinvoke <oadd.io.netty.util.internal.ObjectUtil: java.lang.Object checkNotNull(java.lang.Object,java.lang.String)>(v, "promise");
v = interfaceinvoke v.<oadd.io.netty.channel.ChannelPromise: oadd.io.netty.channel.Channel channel()>();
v = interfaceinvoke v.<oadd.io.netty.channel.Channel: oadd.io.netty.channel.Channel$Unsafe unsafe()>();
interfaceinvoke v.<oadd.io.netty.channel.Channel$Unsafe: void register(oadd.io.netty.channel.EventLoop,oadd.io.netty.channel.ChannelPromise)>(v, v);
return v;
}
public oadd.io.netty.channel.ChannelFuture register(oadd.io.netty.channel.Channel, oadd.io.netty.channel.ChannelPromise)
{
oadd.io.netty.channel.embedded.EmbeddedEventLoop v;
oadd.io.netty.channel.Channel$Unsafe v;
oadd.io.netty.channel.Channel v;
oadd.io.netty.channel.ChannelPromise v;
v := @this: oadd.io.netty.channel.embedded.EmbeddedEventLoop;
v := @parameter: oadd.io.netty.channel.Channel;
v := @parameter: oadd.io.netty.channel.ChannelPromise;
v = interfaceinvoke v.<oadd.io.netty.channel.Channel: oadd.io.netty.channel.Channel$Unsafe unsafe()>();
interfaceinvoke v.<oadd.io.netty.channel.Channel$Unsafe: void register(oadd.io.netty.channel.EventLoop,oadd.io.netty.channel.ChannelPromise)>(v, v);
return v;
}
public boolean inEventLoop()
{
oadd.io.netty.channel.embedded.EmbeddedEventLoop v;
v := @this: oadd.io.netty.channel.embedded.EmbeddedEventLoop;
return 1;
}
public boolean inEventLoop(java.lang.Thread)
{
oadd.io.netty.channel.embedded.EmbeddedEventLoop v;
java.lang.Thread v;
v := @this: oadd.io.netty.channel.embedded.EmbeddedEventLoop;
v := @parameter: java.lang.Thread;
return 1;
}
}