public abstract class org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel extends org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.DefaultAttributeMap implements org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel
{
private static final org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.logging.InternalLogger logger;
private final org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel parent;
private final org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelId id;
private final org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel$Unsafe unsafe;
private final org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultChannelPipeline pipeline;
private final org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.VoidChannelPromise unsafeVoidPromise;
private final org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel$CloseFuture closeFuture;
private volatile java.net.SocketAddress localAddress;
private volatile java.net.SocketAddress remoteAddress;
private volatile org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.EventLoop eventLoop;
private volatile boolean registered;
private boolean closeInitiated;
private java.lang.Throwable initialCloseCause;
private boolean strValActive;
private java.lang.String strVal;
protected 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.Channel v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel$CloseFuture v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelId v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel$AbstractUnsafe v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.VoidChannelPromise v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultChannelPipeline v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.DefaultAttributeMap: void <init>()>();
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.VoidChannelPromise;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.VoidChannelPromise: void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel,boolean)>(v, 0);
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.VoidChannelPromise unsafeVoidPromise> = v;
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel$CloseFuture;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel$CloseFuture: void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel)>(v);
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel$CloseFuture closeFuture> = v;
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel parent> = v;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelId newId()>();
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelId id> = v;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel$AbstractUnsafe newUnsafe()>();
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel$Unsafe unsafe> = v;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultChannelPipeline newChannelPipeline()>();
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultChannelPipeline pipeline> = v;
return;
}
protected 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.ChannelId)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel$CloseFuture v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelId v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel$AbstractUnsafe v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.VoidChannelPromise v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultChannelPipeline v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel;
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.ChannelId;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.DefaultAttributeMap: void <init>()>();
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.VoidChannelPromise;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.VoidChannelPromise: void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel,boolean)>(v, 0);
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.VoidChannelPromise unsafeVoidPromise> = v;
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel$CloseFuture;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel$CloseFuture: void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel)>(v);
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel$CloseFuture closeFuture> = v;
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel parent> = v;
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelId id> = v;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel$AbstractUnsafe newUnsafe()>();
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel$Unsafe unsafe> = v;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultChannelPipeline newChannelPipeline()>();
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultChannelPipeline pipeline> = v;
return;
}
public final org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelId id()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelId v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelId id>;
return v;
}
protected org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelId newId()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultChannelId v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel;
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultChannelId: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultChannelId newInstance()>();
return v;
}
protected org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultChannelPipeline newChannelPipeline()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultChannelPipeline v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel;
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultChannelPipeline;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultChannelPipeline: void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel)>(v);
return v;
}
public boolean isWritable()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelOutboundBuffer v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel$Unsafe v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel v;
boolean v, v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel$Unsafe unsafe>;
v = interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel$Unsafe: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelOutboundBuffer outboundBuffer()>();
if v == null goto label;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelOutboundBuffer: boolean isWritable()>();
if v == 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
return v;
}
public long bytesBeforeUnwritable()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelOutboundBuffer v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel$Unsafe v;
long v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel$Unsafe unsafe>;
v = interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel$Unsafe: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelOutboundBuffer outboundBuffer()>();
if v == null goto label;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelOutboundBuffer: long bytesBeforeUnwritable()>();
goto label;
label:
v = 0L;
label:
return v;
}
public long bytesBeforeWritable()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelOutboundBuffer v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel$Unsafe v;
long v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel$Unsafe unsafe>;
v = interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel$Unsafe: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelOutboundBuffer outboundBuffer()>();
if v == null goto label;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelOutboundBuffer: long bytesBeforeWritable()>();
goto label;
label:
v = 9223372036854775807L;
label:
return v;
}
public org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel parent()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel 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.AbstractChannel;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel parent>;
return v;
}
public org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPipeline pipeline()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultChannelPipeline v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultChannelPipeline pipeline>;
return v;
}
public org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBufAllocator alloc()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBufAllocator v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelConfig v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelConfig config()>();
v = interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelConfig: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBufAllocator getAllocator()>();
return v;
}
public org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.EventLoop eventLoop()
{
java.lang.IllegalStateException v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.EventLoop v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.EventLoop eventLoop>;
if v != null goto label;
v = new java.lang.IllegalStateException;
specialinvoke v.<java.lang.IllegalStateException: void <init>(java.lang.String)>("channel not registered to an event loop");
throw v;
label:
return v;
}
public java.net.SocketAddress localAddress()
{
java.lang.Throwable v;
java.net.SocketAddress v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel$Unsafe v;
java.lang.Error v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel: java.net.SocketAddress localAddress>;
if v != null goto label;
label:
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel$Unsafe unsafe()>();
v = interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel$Unsafe: java.net.SocketAddress localAddress()>();
v = v;
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel: java.net.SocketAddress localAddress> = v;
label:
goto label;
label:
v := @caughtexception;
throw v;
label:
v := @caughtexception;
return null;
label:
return v;
catch java.lang.Error from label to label with label;
catch java.lang.Throwable from label to label with label;
}
protected void invalidateLocalAddress()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel;
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel: java.net.SocketAddress localAddress> = null;
return;
}
public java.net.SocketAddress remoteAddress()
{
java.lang.Throwable v;
java.net.SocketAddress v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel$Unsafe v;
java.lang.Error v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel: java.net.SocketAddress remoteAddress>;
if v != null goto label;
label:
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel$Unsafe unsafe()>();
v = interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel$Unsafe: java.net.SocketAddress remoteAddress()>();
v = v;
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel: java.net.SocketAddress remoteAddress> = v;
label:
goto label;
label:
v := @caughtexception;
throw v;
label:
v := @caughtexception;
return null;
label:
return v;
catch java.lang.Error from label to label with label;
catch java.lang.Throwable from label to label with label;
}
protected void invalidateRemoteAddress()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel;
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel: java.net.SocketAddress remoteAddress> = null;
return;
}
public boolean isRegistered()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel v;
boolean v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel: boolean registered>;
return v;
}
public org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture bind(java.net.SocketAddress)
{
java.net.SocketAddress v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultChannelPipeline v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel;
v := @parameter: java.net.SocketAddress;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultChannelPipeline pipeline>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultChannelPipeline: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture bind(java.net.SocketAddress)>(v);
return v;
}
public org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture connect(java.net.SocketAddress)
{
java.net.SocketAddress v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultChannelPipeline v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel;
v := @parameter: java.net.SocketAddress;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultChannelPipeline pipeline>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultChannelPipeline: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture connect(java.net.SocketAddress)>(v);
return v;
}
public org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture connect(java.net.SocketAddress, java.net.SocketAddress)
{
java.net.SocketAddress v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultChannelPipeline v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel;
v := @parameter: java.net.SocketAddress;
v := @parameter: java.net.SocketAddress;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultChannelPipeline pipeline>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultChannelPipeline: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture connect(java.net.SocketAddress,java.net.SocketAddress)>(v, v);
return v;
}
public org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture disconnect()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultChannelPipeline v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultChannelPipeline pipeline>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultChannelPipeline: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture disconnect()>();
return v;
}
public org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture close()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultChannelPipeline v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultChannelPipeline pipeline>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultChannelPipeline: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture close()>();
return v;
}
public org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture deregister()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultChannelPipeline v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultChannelPipeline pipeline>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultChannelPipeline: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture deregister()>();
return v;
}
public org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel flush()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultChannelPipeline v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultChannelPipeline pipeline>;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultChannelPipeline: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPipeline flush()>();
return v;
}
public org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture bind(java.net.SocketAddress, org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise v;
java.net.SocketAddress v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultChannelPipeline v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel;
v := @parameter: java.net.SocketAddress;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultChannelPipeline pipeline>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultChannelPipeline: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture bind(java.net.SocketAddress,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise)>(v, v);
return v;
}
public org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture connect(java.net.SocketAddress, org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise v;
java.net.SocketAddress v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultChannelPipeline v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel;
v := @parameter: java.net.SocketAddress;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultChannelPipeline pipeline>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultChannelPipeline: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture connect(java.net.SocketAddress,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise)>(v, v);
return v;
}
public org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture connect(java.net.SocketAddress, java.net.SocketAddress, org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise v;
java.net.SocketAddress v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultChannelPipeline v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel;
v := @parameter: java.net.SocketAddress;
v := @parameter: java.net.SocketAddress;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultChannelPipeline pipeline>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultChannelPipeline: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture connect(java.net.SocketAddress,java.net.SocketAddress,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise)>(v, v, v);
return v;
}
public org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture disconnect(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultChannelPipeline v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultChannelPipeline pipeline>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultChannelPipeline: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture disconnect(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise)>(v);
return v;
}
public org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture close(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultChannelPipeline v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultChannelPipeline pipeline>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultChannelPipeline: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture close(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise)>(v);
return v;
}
public org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture deregister(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultChannelPipeline v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultChannelPipeline pipeline>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultChannelPipeline: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture deregister(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise)>(v);
return v;
}
public org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel read()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultChannelPipeline v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultChannelPipeline pipeline>;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultChannelPipeline: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPipeline read()>();
return v;
}
public org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture write(java.lang.Object)
{
java.lang.Object v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultChannelPipeline v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel;
v := @parameter: java.lang.Object;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultChannelPipeline pipeline>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultChannelPipeline: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture write(java.lang.Object)>(v);
return v;
}
public org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture write(java.lang.Object, org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise v;
java.lang.Object v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultChannelPipeline v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel;
v := @parameter: java.lang.Object;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultChannelPipeline pipeline>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultChannelPipeline: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture write(java.lang.Object,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise)>(v, v);
return v;
}
public org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture writeAndFlush(java.lang.Object)
{
java.lang.Object v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultChannelPipeline v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel;
v := @parameter: java.lang.Object;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultChannelPipeline pipeline>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultChannelPipeline: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture writeAndFlush(java.lang.Object)>(v);
return v;
}
public org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture writeAndFlush(java.lang.Object, org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise v;
java.lang.Object v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultChannelPipeline v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel;
v := @parameter: java.lang.Object;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultChannelPipeline pipeline>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultChannelPipeline: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture writeAndFlush(java.lang.Object,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise)>(v, v);
return v;
}
public org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise newPromise()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultChannelPipeline v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultChannelPipeline pipeline>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultChannelPipeline: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise newPromise()>();
return v;
}
public org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelProgressivePromise newProgressivePromise()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelProgressivePromise v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultChannelPipeline v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultChannelPipeline pipeline>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultChannelPipeline: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelProgressivePromise newProgressivePromise()>();
return v;
}
public org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture newSucceededFuture()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultChannelPipeline v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultChannelPipeline pipeline>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultChannelPipeline: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture newSucceededFuture()>();
return v;
}
public org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture newFailedFuture(java.lang.Throwable)
{
java.lang.Throwable v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultChannelPipeline v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel;
v := @parameter: java.lang.Throwable;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultChannelPipeline pipeline>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultChannelPipeline: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture newFailedFuture(java.lang.Throwable)>(v);
return v;
}
public org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture closeFuture()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel$CloseFuture v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel$CloseFuture closeFuture>;
return v;
}
public org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel$Unsafe unsafe()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel$Unsafe v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel$Unsafe unsafe>;
return v;
}
protected abstract org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel$AbstractUnsafe newUnsafe();
public final int hashCode()
{
int v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelId v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelId id>;
v = virtualinvoke v.<java.lang.Object: int hashCode()>();
return v;
}
public final boolean equals(java.lang.Object)
{
java.lang.Object v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel v;
boolean v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel;
v := @parameter: java.lang.Object;
if v != v goto label;
v = 1;
goto label;
label:
v = 0;
label:
return v;
}
public final int compareTo(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel)
{
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.ChannelId v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel;
if v != v goto label;
return 0;
label:
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelId id()>();
v = interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelId id()>();
v = interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelId: int compareTo(java.lang.Object)>(v);
return v;
}
public java.lang.String toString()
{
java.net.SocketAddress v, v;
java.lang.String v, v, v, v, v, v, v, v, v, v;
boolean v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel v;
java.lang.StringBuilder v, v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelId v, v, v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel: boolean isActive()>();
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel: boolean strValActive>;
if v != v goto label;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel: java.lang.String strVal>;
if v == null goto label;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel: java.lang.String strVal>;
return v;
label:
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel: java.net.SocketAddress remoteAddress()>();
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel: java.net.SocketAddress localAddress()>();
if v == null goto label;
specialinvoke v.<java.lang.StringBuilder: void <init>(int)>(96);
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelId id>;
v = interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelId: java.lang.String asShortText()>();
if v == 0 goto label;
v = " - ";
goto label;
label:
v = " ! ";
label:
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,java.net.SocketAddress,java.lang.String,java.net.SocketAddress)>(v, v, v, v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("[id: 0x\u, L:\u0001\u0001R:\u]");
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel: java.lang.String strVal> = v;
goto label;
label:
if v == null goto label;
specialinvoke v.<java.lang.StringBuilder: void <init>(int)>(64);
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelId id>;
v = interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelId: java.lang.String asShortText()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,java.net.SocketAddress)>(v, v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("[id: 0x\u, L:\u]");
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel: java.lang.String strVal> = v;
goto label;
label:
specialinvoke v.<java.lang.StringBuilder: void <init>(int)>(16);
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelId id>;
v = interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelId: java.lang.String asShortText()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("[id: 0x\u]");
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel: java.lang.String strVal> = v;
label:
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel: boolean strValActive> = v;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel: java.lang.String strVal>;
return v;
}
public final org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise voidPromise()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultChannelPipeline v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultChannelPipeline pipeline>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultChannelPipeline: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise voidPromise()>();
return v;
}
protected abstract boolean isCompatible(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.EventLoop);
protected abstract java.net.SocketAddress localAddress0();
protected abstract java.net.SocketAddress remoteAddress0();
protected void doRegister() throws java.lang.Exception
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel;
return;
}
protected abstract void doBind(java.net.SocketAddress) throws java.lang.Exception;
protected abstract void doDisconnect() throws java.lang.Exception;
protected abstract void doClose() throws java.lang.Exception;
protected void doShutdownOutput() throws java.lang.Exception
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel: void doClose()>();
return;
}
protected void doDeregister() throws java.lang.Exception
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel;
return;
}
protected abstract void doBeginRead() throws java.lang.Exception;
protected abstract void doWrite(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelOutboundBuffer) throws java.lang.Exception;
protected java.lang.Object filterOutboundMessage(java.lang.Object) throws java.lang.Exception
{
java.lang.Object v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel;
v := @parameter: java.lang.Object;
return v;
}
protected void validateFileRegion(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultFileRegion, long) throws java.io.IOException
{
long v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultFileRegion v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultFileRegion;
v := @parameter: long;
staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultFileRegion: void validate(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultFileRegion,long)>(v, v);
return;
}
static void <clinit>()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.logging.InternalLogger v;
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.logging.InternalLoggerFactory: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.logging.InternalLogger getInstance(java.lang.Class)>(class "Lorg/apache/hive/kudu/org/apache/kudu/shaded/io/netty/channel/AbstractChannel;");
<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.AbstractChannel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.logging.InternalLogger logger> = v;
return;
}
}