public final class org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollSocketChannel extends org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel implements org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.socket.SocketChannel
{
private final org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollSocketChannelConfig 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.EpollSocketChannelConfig 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.EpollSocketChannel v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollSocketChannel;
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.AbstractEpollStreamChannel: 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.EpollSocketChannel: java.util.Collection tcpMd5SigAddresses> = v;
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollSocketChannelConfig;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollSocketChannelConfig: void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollSocketChannel)>(v);
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollSocketChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollSocketChannelConfig config> = v;
return;
}
public void <init>(int)
{
java.util.List v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollSocketChannelConfig v;
int v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollSocketChannel v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollSocketChannel;
v := @parameter: int;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel: void <init>(int)>(v);
v = staticinvoke <java.util.Collections: java.util.List emptyList()>();
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollSocketChannel: java.util.Collection tcpMd5SigAddresses> = v;
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollSocketChannelConfig;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollSocketChannelConfig: void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollSocketChannel)>(v);
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollSocketChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollSocketChannelConfig 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.EpollSocketChannelConfig 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.EpollSocketChannel v;
boolean v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollSocketChannel;
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.AbstractEpollStreamChannel: 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.EpollSocketChannel: java.util.Collection tcpMd5SigAddresses> = v;
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollSocketChannelConfig;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollSocketChannelConfig: void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollSocketChannel)>(v);
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollSocketChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollSocketChannelConfig config> = v;
return;
}
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)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollSocketChannelConfig v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel v;
java.util.Collection v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollSocketChannel v;
java.net.InetSocketAddress v;
java.util.List 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.EpollSocketChannel;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.LinuxSocket;
v := @parameter: java.net.InetSocketAddress;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel: 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.SocketAddress)>(v, v, v);
v = staticinvoke <java.util.Collections: java.util.List emptyList()>();
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollSocketChannel: java.util.Collection tcpMd5SigAddresses> = v;
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollSocketChannelConfig;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollSocketChannelConfig: void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollSocketChannel)>(v);
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollSocketChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollSocketChannelConfig config> = v;
v = v instanceof org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollServerSocketChannel;
if v == 0 goto label;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollServerSocketChannel: java.util.Collection tcpMd5SigAddresses()>();
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollSocketChannel: java.util.Collection tcpMd5SigAddresses> = v;
label:
return;
}
public org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollTcpInfo tcpInfo()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollSocketChannel v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollTcpInfo v, v;
v := @this: 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.EpollTcpInfo;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollTcpInfo: void <init>()>();
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollSocketChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollTcpInfo tcpInfo(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollTcpInfo)>(v);
return v;
}
public org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollTcpInfo tcpInfo(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollTcpInfo)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelException v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.LinuxSocket v;
java.io.IOException v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollSocketChannel v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollTcpInfo v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollSocketChannel;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollTcpInfo;
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollSocketChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.LinuxSocket socket>;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.LinuxSocket: void getTcpInfo(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollTcpInfo)>(v);
label:
return v;
label:
v := @caughtexception;
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelException;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelException: void <init>(java.lang.Throwable)>(v);
throw v;
catch java.io.IOException from label to label with label;
}
public java.net.InetSocketAddress remoteAddress()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollSocketChannel v;
java.net.SocketAddress v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollSocketChannel;
v = specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel: java.net.SocketAddress remoteAddress()>();
return v;
}
public java.net.InetSocketAddress localAddress()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollSocketChannel v;
java.net.SocketAddress v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollSocketChannel;
v = specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel: java.net.SocketAddress localAddress()>();
return v;
}
public org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollSocketChannelConfig config()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollSocketChannel v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollSocketChannelConfig v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollSocketChannel;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollSocketChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollSocketChannelConfig config>;
return v;
}
public org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.socket.ServerSocketChannel parent()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollSocketChannel v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollSocketChannel;
v = specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel parent()>();
return v;
}
protected org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollChannel$AbstractEpollUnsafe newUnsafe()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollSocketChannel v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollSocketChannel$EpollSocketChannelUnsafe v;
v := @this: 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.EpollSocketChannel$EpollSocketChannelUnsafe;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollSocketChannel$EpollSocketChannelUnsafe: void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollSocketChannel)>(v);
return v;
}
void setTcpMd5Sig(java.util.Map) throws java.io.IOException
{
java.util.Collection v, v;
java.util.Map v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollSocketChannel v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollSocketChannel;
v := @parameter: java.util.Map;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollSocketChannel: 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.EpollSocketChannel: java.util.Collection tcpMd5SigAddresses> = v;
return;
}
}