public final class org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollServerSocketChannel extends org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollServerChannel implements org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.socket.ServerSocketChannel
{
private final org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollServerSocketChannelConfig config;
private volatile java.util.Collection tcpMd5SigAddresses;
public void <init>()
{
java.util.List v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollServerSocketChannel v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollServerSocketChannelConfig v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.LinuxSocket v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollServerSocketChannel;
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.LinuxSocket: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.LinuxSocket newSocketStream()>();
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollServerChannel: void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.LinuxSocket,boolean)>(v, 0);
v = staticinvoke <java.util.Collections: java.util.List emptyList()>();
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollServerSocketChannel: java.util.Collection tcpMd5SigAddresses> = v;
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollServerSocketChannelConfig;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollServerSocketChannelConfig: void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollServerSocketChannel)>(v);
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollServerSocketChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollServerSocketChannelConfig config> = v;
return;
}
public void <init>(int)
{
int v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.LinuxSocket v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollServerSocketChannel v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollServerSocketChannel;
v := @parameter: int;
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.LinuxSocket;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.LinuxSocket: void <init>(int)>(v);
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollServerSocketChannel: void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.LinuxSocket)>(v);
return;
}
void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.LinuxSocket)
{
java.util.List v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollServerSocketChannel v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollServerSocketChannelConfig v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.LinuxSocket v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollServerSocketChannel;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.LinuxSocket;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollServerChannel: void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.LinuxSocket)>(v);
v = staticinvoke <java.util.Collections: java.util.List emptyList()>();
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollServerSocketChannel: java.util.Collection tcpMd5SigAddresses> = v;
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollServerSocketChannelConfig;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollServerSocketChannelConfig: void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollServerSocketChannel)>(v);
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollServerSocketChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollServerSocketChannelConfig config> = v;
return;
}
void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.LinuxSocket, boolean)
{
java.util.List v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollServerSocketChannel v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollServerSocketChannelConfig v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.LinuxSocket v;
boolean v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollServerSocketChannel;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.LinuxSocket;
v := @parameter: boolean;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollServerChannel: void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.LinuxSocket,boolean)>(v, v);
v = staticinvoke <java.util.Collections: java.util.List emptyList()>();
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollServerSocketChannel: java.util.Collection tcpMd5SigAddresses> = v;
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollServerSocketChannelConfig;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollServerSocketChannelConfig: void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollServerSocketChannel)>(v);
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollServerSocketChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollServerSocketChannelConfig config> = v;
return;
}
protected boolean isCompatible(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.EventLoop)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.EventLoop v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollServerSocketChannel v;
boolean v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollServerSocketChannel;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.EventLoop;
v = v instanceof org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollEventLoop;
return v;
}
protected void doBind(java.net.SocketAddress) throws java.lang.Exception
{
java.net.SocketAddress v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollServerSocketChannelConfig v, v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollServerSocketChannel v;
int v, v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.LinuxSocket v, v;
boolean v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollServerSocketChannel;
v := @parameter: java.net.SocketAddress;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollServerChannel: void doBind(java.net.SocketAddress)>(v);
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.Native: boolean IS_SUPPORTING_TCP_FASTOPEN>;
if v == 0 goto label;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollServerSocketChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollServerSocketChannelConfig config>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollServerSocketChannelConfig: int getTcpFastopen()>();
if v <= 0 goto label;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollServerSocketChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.LinuxSocket socket>;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollServerSocketChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollServerSocketChannelConfig config>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollServerSocketChannelConfig: int getTcpFastopen()>();
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.LinuxSocket: void setTcpFastOpen(int)>(v);
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollServerSocketChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.LinuxSocket socket>;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollServerSocketChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollServerSocketChannelConfig config>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollServerSocketChannelConfig: int getBacklog()>();
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.LinuxSocket: void listen(int)>(v);
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollServerSocketChannel: boolean active> = 1;
return;
}
public java.net.InetSocketAddress remoteAddress()
{
java.net.SocketAddress v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollServerSocketChannel v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollServerSocketChannel;
v = specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollServerChannel: java.net.SocketAddress remoteAddress()>();
return v;
}
public java.net.InetSocketAddress localAddress()
{
java.net.SocketAddress v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollServerSocketChannel v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollServerSocketChannel;
v = specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollServerChannel: java.net.SocketAddress localAddress()>();
return v;
}
public org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollServerSocketChannelConfig config()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollServerSocketChannel v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollServerSocketChannelConfig v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollServerSocketChannel;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollServerSocketChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollServerSocketChannelConfig config>;
return v;
}
protected org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel newChildChannel(int, byte[], int, int) throws java.lang.Exception
{
byte[] v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollSocketChannel v;
java.net.InetSocketAddress v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollServerSocketChannel v;
int v, v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.LinuxSocket v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollServerSocketChannel;
v := @parameter: int;
v := @parameter: byte[];
v := @parameter: int;
v := @parameter: int;
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollSocketChannel;
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.LinuxSocket;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.LinuxSocket: void <init>(int)>(v);
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.unix.NativeInetAddress: java.net.InetSocketAddress address(byte[],int,int)>(v, v, v);
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollSocketChannel: void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.LinuxSocket,java.net.InetSocketAddress)>(v, v, v);
return v;
}
java.util.Collection tcpMd5SigAddresses()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollServerSocketChannel v;
java.util.Collection v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollServerSocketChannel;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollServerSocketChannel: java.util.Collection tcpMd5SigAddresses>;
return v;
}
void setTcpMd5Sig(java.util.Map) throws java.io.IOException
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollServerSocketChannel v;
java.util.Collection v, v;
java.util.Map v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollServerSocketChannel;
v := @parameter: java.util.Map;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollServerSocketChannel: java.util.Collection tcpMd5SigAddresses>;
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.TcpMd5Util: java.util.Collection newTcpMd5Sigs(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollChannel,java.util.Collection,java.util.Map)>(v, v, v);
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollServerSocketChannel: java.util.Collection tcpMd5SigAddresses> = v;
return;
}
}