public final class org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollDomainSocketChannel 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.unix.DomainSocketChannel
{
private final org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollDomainSocketChannelConfig config;
private volatile org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.unix.DomainSocketAddress local;
private volatile org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.unix.DomainSocketAddress remote;
public void <init>()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollDomainSocketChannel 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.EpollDomainSocketChannelConfig v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollDomainSocketChannel;
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 newSocketDomain()>();
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 = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollDomainSocketChannelConfig;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollDomainSocketChannelConfig: void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollChannel)>(v);
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollDomainSocketChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollDomainSocketChannelConfig 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.unix.FileDescriptor)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel v;
int v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollDomainSocketChannel 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.unix.FileDescriptor v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollDomainSocketChannelConfig v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollDomainSocketChannel;
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.unix.FileDescriptor;
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.LinuxSocket;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.unix.FileDescriptor: int intValue()>();
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.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)>(v, v);
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollDomainSocketChannelConfig;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollDomainSocketChannelConfig: void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollChannel)>(v);
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollDomainSocketChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollDomainSocketChannelConfig config> = v;
return;
}
public void <init>(int)
{
int v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollDomainSocketChannel v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollDomainSocketChannelConfig v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollDomainSocketChannel;
v := @parameter: int;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel: void <init>(int)>(v);
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollDomainSocketChannelConfig;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollDomainSocketChannelConfig: void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollChannel)>(v);
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollDomainSocketChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollDomainSocketChannelConfig config> = v;
return;
}
public 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)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollDomainSocketChannel 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.EpollDomainSocketChannelConfig v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollDomainSocketChannel;
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;
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)>(v, v);
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollDomainSocketChannelConfig;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollDomainSocketChannelConfig: void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollChannel)>(v);
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollDomainSocketChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollDomainSocketChannelConfig config> = v;
return;
}
public void <init>(int, boolean)
{
int v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollDomainSocketChannel 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.EpollDomainSocketChannelConfig v;
boolean v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollDomainSocketChannel;
v := @parameter: int;
v := @parameter: boolean;
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.AbstractEpollStreamChannel: void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.LinuxSocket,boolean)>(v, v);
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollDomainSocketChannelConfig;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollDomainSocketChannelConfig: void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollChannel)>(v);
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollDomainSocketChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollDomainSocketChannelConfig config> = v;
return;
}
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.EpollDomainSocketChannel v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollDomainSocketChannel$EpollDomainUnsafe v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollDomainSocketChannel;
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollDomainSocketChannel$EpollDomainUnsafe;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollDomainSocketChannel$EpollDomainUnsafe: void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollDomainSocketChannel)>(v);
return v;
}
protected org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.unix.DomainSocketAddress localAddress0()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollDomainSocketChannel v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.unix.DomainSocketAddress v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollDomainSocketChannel;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollDomainSocketChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.unix.DomainSocketAddress local>;
return v;
}
protected org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.unix.DomainSocketAddress remoteAddress0()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollDomainSocketChannel v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.unix.DomainSocketAddress v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollDomainSocketChannel;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollDomainSocketChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.unix.DomainSocketAddress remote>;
return v;
}
protected void doBind(java.net.SocketAddress) throws java.lang.Exception
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollDomainSocketChannel v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.LinuxSocket v;
java.net.SocketAddress v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollDomainSocketChannel;
v := @parameter: java.net.SocketAddress;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollDomainSocketChannel: 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 bind(java.net.SocketAddress)>(v);
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollDomainSocketChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.unix.DomainSocketAddress local> = v;
return;
}
public org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollDomainSocketChannelConfig config()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollDomainSocketChannel v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollDomainSocketChannelConfig v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollDomainSocketChannel;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollDomainSocketChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollDomainSocketChannelConfig config>;
return v;
}
protected boolean doConnect(java.net.SocketAddress, java.net.SocketAddress) throws java.lang.Exception
{
java.net.SocketAddress v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollDomainSocketChannel v;
boolean v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollDomainSocketChannel;
v := @parameter: java.net.SocketAddress;
v := @parameter: java.net.SocketAddress;
v = specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel: boolean doConnect(java.net.SocketAddress,java.net.SocketAddress)>(v, v);
if v == 0 goto label;
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollDomainSocketChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.unix.DomainSocketAddress local> = v;
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollDomainSocketChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.unix.DomainSocketAddress remote> = v;
return 1;
label:
return 0;
}
public org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.unix.DomainSocketAddress remoteAddress()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollDomainSocketChannel v;
java.net.SocketAddress v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollDomainSocketChannel;
v = specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel: java.net.SocketAddress remoteAddress()>();
return v;
}
public org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.unix.DomainSocketAddress localAddress()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollDomainSocketChannel v;
java.net.SocketAddress v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollDomainSocketChannel;
v = specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel: java.net.SocketAddress localAddress()>();
return v;
}
protected int doWriteSingle(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelOutboundBuffer) throws java.lang.Exception
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelOutboundBuffer v;
int v, v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollDomainSocketChannel v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.LinuxSocket v;
java.lang.Object v;
boolean v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollDomainSocketChannel;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelOutboundBuffer;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelOutboundBuffer: java.lang.Object current()>();
v = v instanceof org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.unix.FileDescriptor;
if v == 0 goto label;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollDomainSocketChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.LinuxSocket socket>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.unix.FileDescriptor: int intValue()>();
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.LinuxSocket: int sendFd(int)>(v);
if v <= 0 goto label;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelOutboundBuffer: boolean remove()>();
return 1;
label:
v = specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel: int doWriteSingle(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelOutboundBuffer)>(v);
return v;
}
protected java.lang.Object filterOutboundMessage(java.lang.Object)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollDomainSocketChannel v;
java.lang.Object v, v;
boolean v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollDomainSocketChannel;
v := @parameter: java.lang.Object;
v = v instanceof org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.unix.FileDescriptor;
if v == 0 goto label;
return v;
label:
v = specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.AbstractEpollStreamChannel: java.lang.Object filterOutboundMessage(java.lang.Object)>(v);
return v;
}
public org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.unix.PeerCredentials peerCredentials() throws java.io.IOException
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollDomainSocketChannel 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.unix.PeerCredentials v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollDomainSocketChannel;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.EpollDomainSocketChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.LinuxSocket socket>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.epoll.LinuxSocket: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.unix.PeerCredentials getPeerCredentials()>();
return v;
}
}