public class org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.nio.NioEventLoopGroup extends org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.MultithreadEventLoopGroup
{
public void <init>()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.nio.NioEventLoopGroup v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.nio.NioEventLoopGroup;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.nio.NioEventLoopGroup: void <init>(int)>(0);
return;
}
public void <init>(int)
{
int v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.nio.NioEventLoopGroup v;
java.util.concurrent.Executor v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.nio.NioEventLoopGroup;
v := @parameter: int;
v = null;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.nio.NioEventLoopGroup: void <init>(int,java.util.concurrent.Executor)>(v, v);
return;
}
public void <init>(java.util.concurrent.ThreadFactory)
{
java.nio.channels.spi.SelectorProvider v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.nio.NioEventLoopGroup v;
java.util.concurrent.ThreadFactory v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.nio.NioEventLoopGroup;
v := @parameter: java.util.concurrent.ThreadFactory;
v = staticinvoke <java.nio.channels.spi.SelectorProvider: java.nio.channels.spi.SelectorProvider provider()>();
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.nio.NioEventLoopGroup: void <init>(int,java.util.concurrent.ThreadFactory,java.nio.channels.spi.SelectorProvider)>(0, v, v);
return;
}
public void <init>(int, java.util.concurrent.ThreadFactory)
{
java.nio.channels.spi.SelectorProvider v;
int v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.nio.NioEventLoopGroup v;
java.util.concurrent.ThreadFactory v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.nio.NioEventLoopGroup;
v := @parameter: int;
v := @parameter: java.util.concurrent.ThreadFactory;
v = staticinvoke <java.nio.channels.spi.SelectorProvider: java.nio.channels.spi.SelectorProvider provider()>();
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.nio.NioEventLoopGroup: void <init>(int,java.util.concurrent.ThreadFactory,java.nio.channels.spi.SelectorProvider)>(v, v, v);
return;
}
public void <init>(int, java.util.concurrent.Executor)
{
java.nio.channels.spi.SelectorProvider v;
java.util.concurrent.Executor v;
int v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.nio.NioEventLoopGroup v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.nio.NioEventLoopGroup;
v := @parameter: int;
v := @parameter: java.util.concurrent.Executor;
v = staticinvoke <java.nio.channels.spi.SelectorProvider: java.nio.channels.spi.SelectorProvider provider()>();
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.nio.NioEventLoopGroup: void <init>(int,java.util.concurrent.Executor,java.nio.channels.spi.SelectorProvider)>(v, v, v);
return;
}
public void <init>(int, java.util.concurrent.ThreadFactory, java.nio.channels.spi.SelectorProvider)
{
java.nio.channels.spi.SelectorProvider v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.SelectStrategyFactory v;
int v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.nio.NioEventLoopGroup v;
java.util.concurrent.ThreadFactory v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.nio.NioEventLoopGroup;
v := @parameter: int;
v := @parameter: java.util.concurrent.ThreadFactory;
v := @parameter: java.nio.channels.spi.SelectorProvider;
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultSelectStrategyFactory: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.SelectStrategyFactory INSTANCE>;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.nio.NioEventLoopGroup: void <init>(int,java.util.concurrent.ThreadFactory,java.nio.channels.spi.SelectorProvider,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.SelectStrategyFactory)>(v, v, v, v);
return;
}
public void <init>(int, java.util.concurrent.ThreadFactory, java.nio.channels.spi.SelectorProvider, org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.SelectStrategyFactory)
{
java.nio.channels.spi.SelectorProvider v;
java.lang.Object[] v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.RejectedExecutionHandler v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.SelectStrategyFactory v;
int v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.nio.NioEventLoopGroup v;
java.util.concurrent.ThreadFactory v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.nio.NioEventLoopGroup;
v := @parameter: int;
v := @parameter: java.util.concurrent.ThreadFactory;
v := @parameter: java.nio.channels.spi.SelectorProvider;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.SelectStrategyFactory;
v = newarray (java.lang.Object)[3];
v[0] = v;
v[1] = v;
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.RejectedExecutionHandlers: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.RejectedExecutionHandler reject()>();
v[2] = v;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.MultithreadEventLoopGroup: void <init>(int,java.util.concurrent.ThreadFactory,java.lang.Object[])>(v, v, v);
return;
}
public void <init>(int, java.util.concurrent.Executor, java.nio.channels.spi.SelectorProvider)
{
java.nio.channels.spi.SelectorProvider v;
java.util.concurrent.Executor v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.SelectStrategyFactory v;
int v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.nio.NioEventLoopGroup v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.nio.NioEventLoopGroup;
v := @parameter: int;
v := @parameter: java.util.concurrent.Executor;
v := @parameter: java.nio.channels.spi.SelectorProvider;
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultSelectStrategyFactory: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.SelectStrategyFactory INSTANCE>;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.nio.NioEventLoopGroup: void <init>(int,java.util.concurrent.Executor,java.nio.channels.spi.SelectorProvider,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.SelectStrategyFactory)>(v, v, v, v);
return;
}
public void <init>(int, java.util.concurrent.Executor, java.nio.channels.spi.SelectorProvider, org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.SelectStrategyFactory)
{
java.nio.channels.spi.SelectorProvider v;
java.lang.Object[] v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.RejectedExecutionHandler v;
java.util.concurrent.Executor v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.SelectStrategyFactory v;
int v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.nio.NioEventLoopGroup v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.nio.NioEventLoopGroup;
v := @parameter: int;
v := @parameter: java.util.concurrent.Executor;
v := @parameter: java.nio.channels.spi.SelectorProvider;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.SelectStrategyFactory;
v = newarray (java.lang.Object)[3];
v[0] = v;
v[1] = v;
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.RejectedExecutionHandlers: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.RejectedExecutionHandler reject()>();
v[2] = v;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.MultithreadEventLoopGroup: void <init>(int,java.util.concurrent.Executor,java.lang.Object[])>(v, v, v);
return;
}
public void <init>(int, java.util.concurrent.Executor, org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.EventExecutorChooserFactory, java.nio.channels.spi.SelectorProvider, org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.SelectStrategyFactory)
{
java.lang.Object[] v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.RejectedExecutionHandler v;
java.util.concurrent.Executor v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.SelectStrategyFactory v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.nio.NioEventLoopGroup v;
java.nio.channels.spi.SelectorProvider v;
int v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.EventExecutorChooserFactory v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.nio.NioEventLoopGroup;
v := @parameter: int;
v := @parameter: java.util.concurrent.Executor;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.EventExecutorChooserFactory;
v := @parameter: java.nio.channels.spi.SelectorProvider;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.SelectStrategyFactory;
v = newarray (java.lang.Object)[3];
v[0] = v;
v[1] = v;
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.RejectedExecutionHandlers: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.RejectedExecutionHandler reject()>();
v[2] = v;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.MultithreadEventLoopGroup: void <init>(int,java.util.concurrent.Executor,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.EventExecutorChooserFactory,java.lang.Object[])>(v, v, v, v);
return;
}
public void <init>(int, java.util.concurrent.Executor, org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.EventExecutorChooserFactory, java.nio.channels.spi.SelectorProvider, org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.SelectStrategyFactory, org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.RejectedExecutionHandler)
{
java.lang.Object[] v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.RejectedExecutionHandler v;
java.util.concurrent.Executor v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.SelectStrategyFactory v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.nio.NioEventLoopGroup v;
java.nio.channels.spi.SelectorProvider v;
int v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.EventExecutorChooserFactory v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.nio.NioEventLoopGroup;
v := @parameter: int;
v := @parameter: java.util.concurrent.Executor;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.EventExecutorChooserFactory;
v := @parameter: java.nio.channels.spi.SelectorProvider;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.SelectStrategyFactory;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.RejectedExecutionHandler;
v = newarray (java.lang.Object)[3];
v[0] = v;
v[1] = v;
v[2] = v;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.MultithreadEventLoopGroup: void <init>(int,java.util.concurrent.Executor,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.EventExecutorChooserFactory,java.lang.Object[])>(v, v, v, v);
return;
}
public void <init>(int, java.util.concurrent.Executor, org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.EventExecutorChooserFactory, java.nio.channels.spi.SelectorProvider, org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.SelectStrategyFactory, org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.RejectedExecutionHandler, org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.EventLoopTaskQueueFactory)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.EventLoopTaskQueueFactory v;
java.lang.Object[] v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.RejectedExecutionHandler v;
java.util.concurrent.Executor v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.SelectStrategyFactory v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.nio.NioEventLoopGroup v;
java.nio.channels.spi.SelectorProvider v;
int v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.EventExecutorChooserFactory v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.nio.NioEventLoopGroup;
v := @parameter: int;
v := @parameter: java.util.concurrent.Executor;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.EventExecutorChooserFactory;
v := @parameter: java.nio.channels.spi.SelectorProvider;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.SelectStrategyFactory;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.RejectedExecutionHandler;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.EventLoopTaskQueueFactory;
v = newarray (java.lang.Object)[4];
v[0] = v;
v[1] = v;
v[2] = v;
v[3] = v;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.MultithreadEventLoopGroup: void <init>(int,java.util.concurrent.Executor,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.EventExecutorChooserFactory,java.lang.Object[])>(v, v, v, v);
return;
}
public void setIoRatio(int)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.EventExecutor v;
java.util.Iterator v;
int v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.nio.NioEventLoopGroup v;
boolean v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.nio.NioEventLoopGroup;
v := @parameter: int;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.nio.NioEventLoopGroup: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.nio.NioEventLoop: void setIoRatio(int)>(v);
goto label;
label:
return;
}
public void rebuildSelectors()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.EventExecutor v;
java.util.Iterator v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.nio.NioEventLoopGroup v;
boolean v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.nio.NioEventLoopGroup;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.nio.NioEventLoopGroup: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.nio.NioEventLoop: void rebuildSelector()>();
goto label;
label:
return;
}
protected transient org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.EventLoop newChild(java.util.concurrent.Executor, java.lang.Object[]) throws java.lang.Exception
{
java.lang.Object[] v;
java.util.concurrent.Executor v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.nio.NioEventLoopGroup v;
int v;
java.lang.Object v, v, v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.SelectStrategy v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.nio.NioEventLoop v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.nio.NioEventLoopGroup;
v := @parameter: java.util.concurrent.Executor;
v := @parameter: java.lang.Object[];
v = lengthof v;
if v != 4 goto label;
v = v[3];
goto label;
label:
v = null;
label:
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.nio.NioEventLoop;
v = v[0];
v = v[1];
v = interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.SelectStrategyFactory: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.SelectStrategy newSelectStrategy()>();
v = v[2];
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.nio.NioEventLoop: void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.nio.NioEventLoopGroup,java.util.concurrent.Executor,java.nio.channels.spi.SelectorProvider,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.SelectStrategy,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.RejectedExecutionHandler,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.EventLoopTaskQueueFactory)>(v, v, v, v, v, v);
return v;
}
}