public final class org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueDomainSocketChannel extends org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueStreamChannel 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.kqueue.KQueueDomainSocketChannelConfig 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.kqueue.KQueueDomainSocketChannelConfig v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueDomainSocketChannel v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.BsdSocket v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueDomainSocketChannel;
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.BsdSocket: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.BsdSocket newSocketDomain()>();
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueStreamChannel: 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.kqueue.BsdSocket,boolean)>(null, v, 0);
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueDomainSocketChannelConfig;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueDomainSocketChannelConfig: void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel)>(v);
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueDomainSocketChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueDomainSocketChannelConfig config> = v;
return;
}
public void <init>(int)
{
int v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueDomainSocketChannel v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.BsdSocket v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueDomainSocketChannel;
v := @parameter: int;
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.BsdSocket;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.BsdSocket: void <init>(int)>(v);
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueDomainSocketChannel: 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.kqueue.BsdSocket)>(null, 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.kqueue.BsdSocket)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.BsdSocket v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueDomainSocketChannelConfig v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueDomainSocketChannel v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueDomainSocketChannel;
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.kqueue.BsdSocket;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueStreamChannel: 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.kqueue.BsdSocket,boolean)>(v, v, 1);
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueDomainSocketChannelConfig;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueDomainSocketChannelConfig: void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel)>(v);
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueDomainSocketChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueDomainSocketChannelConfig config> = v;
return;
}
protected org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel$AbstractKQueueUnsafe newUnsafe()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueDomainSocketChannel v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueDomainSocketChannel$KQueueDomainUnsafe v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueDomainSocketChannel;
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueDomainSocketChannel$KQueueDomainUnsafe;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueDomainSocketChannel$KQueueDomainUnsafe: void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueDomainSocketChannel)>(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.kqueue.KQueueDomainSocketChannel 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.kqueue.KQueueDomainSocketChannel;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueDomainSocketChannel: 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.kqueue.KQueueDomainSocketChannel 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.kqueue.KQueueDomainSocketChannel;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueDomainSocketChannel: 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
{
java.net.SocketAddress v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueDomainSocketChannel v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.BsdSocket v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueDomainSocketChannel;
v := @parameter: java.net.SocketAddress;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueDomainSocketChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.BsdSocket socket>;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.BsdSocket: void bind(java.net.SocketAddress)>(v);
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueDomainSocketChannel: 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.kqueue.KQueueDomainSocketChannelConfig config()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueDomainSocketChannelConfig v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueDomainSocketChannel v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueDomainSocketChannel;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueDomainSocketChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueDomainSocketChannelConfig 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.kqueue.KQueueDomainSocketChannel v;
boolean v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueDomainSocketChannel;
v := @parameter: java.net.SocketAddress;
v := @parameter: java.net.SocketAddress;
v = specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueStreamChannel: 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.kqueue.KQueueDomainSocketChannel: 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.kqueue.KQueueDomainSocketChannel: 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()
{
java.net.SocketAddress v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueDomainSocketChannel v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueDomainSocketChannel;
v = specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueStreamChannel: java.net.SocketAddress remoteAddress()>();
return v;
}
public org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.unix.DomainSocketAddress localAddress()
{
java.net.SocketAddress v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueDomainSocketChannel v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueDomainSocketChannel;
v = specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueStreamChannel: 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;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.BsdSocket v;
int v, v, v;
java.lang.Object v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueDomainSocketChannel v;
boolean v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueDomainSocketChannel;
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.kqueue.KQueueDomainSocketChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.BsdSocket 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.kqueue.BsdSocket: 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.kqueue.AbstractKQueueStreamChannel: 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)
{
java.lang.Object v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueDomainSocketChannel v;
boolean v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueDomainSocketChannel;
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.kqueue.AbstractKQueueStreamChannel: 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.unix.PeerCredentials v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueDomainSocketChannel v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.BsdSocket v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueDomainSocketChannel;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueDomainSocketChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.BsdSocket socket>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.BsdSocket: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.unix.PeerCredentials getPeerCredentials()>();
return v;
}
}