public final class org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueSocketChannelConfig extends org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueChannelConfig implements org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.socket.SocketChannelConfig
{
private volatile boolean allowHalfClosure;
void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueSocketChannel)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueSocketChannel v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueSocketChannelConfig v;
boolean v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueSocketChannelConfig;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueSocketChannel;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueChannelConfig: void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.AbstractKQueueChannel)>(v);
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.PlatformDependent: boolean canEnableTcpNoDelayByDefault()>();
if v == 0 goto label;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueSocketChannelConfig: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueSocketChannelConfig setTcpNoDelay(boolean)>(1);
label:
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueSocketChannelConfig: void calculateMaxBytesPerGatheringWrite()>();
return;
}
public java.util.Map getOptions()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelOption v, v, v, v, v, v, v, v, v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelOption[] v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueSocketChannelConfig v;
java.util.Map v, v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueSocketChannelConfig;
v = specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueChannelConfig: java.util.Map getOptions()>();
v = newarray (org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelOption)[10];
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelOption: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelOption SO_RCVBUF>;
v[0] = v;
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelOption: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelOption SO_SNDBUF>;
v[1] = v;
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelOption: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelOption TCP_NODELAY>;
v[2] = v;
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelOption: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelOption SO_KEEPALIVE>;
v[3] = v;
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelOption: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelOption SO_REUSEADDR>;
v[4] = v;
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelOption: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelOption SO_LINGER>;
v[5] = v;
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelOption: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelOption IP_TOS>;
v[6] = v;
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelOption: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelOption ALLOW_HALF_CLOSURE>;
v[7] = v;
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueChannelOption: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelOption SO_SNDLOWAT>;
v[8] = v;
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueChannelOption: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelOption TCP_NOPUSH>;
v[9] = v;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueSocketChannelConfig: java.util.Map getOptions(java.util.Map,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelOption[])>(v, v);
return v;
}
public java.lang.Object getOption(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelOption)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelOption v, v, v, v, v, v, v, v, v, v, v;
java.lang.Integer v, v, v, v, v;
boolean v, v, v, v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueSocketChannelConfig v;
int v, v, v, v, v;
java.lang.Boolean v, v, v, v, v;
java.lang.Object v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueSocketChannelConfig;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelOption;
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelOption: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelOption SO_RCVBUF>;
if v != v goto label;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueSocketChannelConfig: int getReceiveBufferSize()>();
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
return v;
label:
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelOption: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelOption SO_SNDBUF>;
if v != v goto label;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueSocketChannelConfig: int getSendBufferSize()>();
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
return v;
label:
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelOption: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelOption TCP_NODELAY>;
if v != v goto label;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueSocketChannelConfig: boolean isTcpNoDelay()>();
v = staticinvoke <java.lang.Boolean: java.lang.Boolean valueOf(boolean)>(v);
return v;
label:
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelOption: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelOption SO_KEEPALIVE>;
if v != v goto label;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueSocketChannelConfig: boolean isKeepAlive()>();
v = staticinvoke <java.lang.Boolean: java.lang.Boolean valueOf(boolean)>(v);
return v;
label:
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelOption: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelOption SO_REUSEADDR>;
if v != v goto label;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueSocketChannelConfig: boolean isReuseAddress()>();
v = staticinvoke <java.lang.Boolean: java.lang.Boolean valueOf(boolean)>(v);
return v;
label:
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelOption: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelOption SO_LINGER>;
if v != v goto label;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueSocketChannelConfig: int getSoLinger()>();
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
return v;
label:
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelOption: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelOption IP_TOS>;
if v != v goto label;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueSocketChannelConfig: int getTrafficClass()>();
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
return v;
label:
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelOption: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelOption ALLOW_HALF_CLOSURE>;
if v != v goto label;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueSocketChannelConfig: boolean isAllowHalfClosure()>();
v = staticinvoke <java.lang.Boolean: java.lang.Boolean valueOf(boolean)>(v);
return v;
label:
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueChannelOption: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelOption SO_SNDLOWAT>;
if v != v goto label;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueSocketChannelConfig: int getSndLowAt()>();
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
return v;
label:
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueChannelOption: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelOption TCP_NOPUSH>;
if v != v goto label;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueSocketChannelConfig: boolean isTcpNoPush()>();
v = staticinvoke <java.lang.Boolean: java.lang.Boolean valueOf(boolean)>(v);
return v;
label:
v = specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueChannelConfig: java.lang.Object getOption(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelOption)>(v);
return v;
}
public boolean setOption(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelOption, java.lang.Object)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelOption v, v, v, v, v, v, v, v, v, v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueSocketChannelConfig v;
int v, v, v, v, v;
boolean v, v, v, v, v, v;
java.lang.Object v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueSocketChannelConfig;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelOption;
v := @parameter: java.lang.Object;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueSocketChannelConfig: void validate(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelOption,java.lang.Object)>(v, v);
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelOption: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelOption SO_RCVBUF>;
if v != v goto label;
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueSocketChannelConfig: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueSocketChannelConfig setReceiveBufferSize(int)>(v);
goto label;
label:
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelOption: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelOption SO_SNDBUF>;
if v != v goto label;
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueSocketChannelConfig: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueSocketChannelConfig setSendBufferSize(int)>(v);
goto label;
label:
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelOption: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelOption TCP_NODELAY>;
if v != v goto label;
v = virtualinvoke v.<java.lang.Boolean: boolean booleanValue()>();
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueSocketChannelConfig: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueSocketChannelConfig setTcpNoDelay(boolean)>(v);
goto label;
label:
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelOption: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelOption SO_KEEPALIVE>;
if v != v goto label;
v = virtualinvoke v.<java.lang.Boolean: boolean booleanValue()>();
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueSocketChannelConfig: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueSocketChannelConfig setKeepAlive(boolean)>(v);
goto label;
label:
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelOption: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelOption SO_REUSEADDR>;
if v != v goto label;
v = virtualinvoke v.<java.lang.Boolean: boolean booleanValue()>();
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueSocketChannelConfig: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueSocketChannelConfig setReuseAddress(boolean)>(v);
goto label;
label:
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelOption: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelOption SO_LINGER>;
if v != v goto label;
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueSocketChannelConfig: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueSocketChannelConfig setSoLinger(int)>(v);
goto label;
label:
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelOption: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelOption IP_TOS>;
if v != v goto label;
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueSocketChannelConfig: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueSocketChannelConfig setTrafficClass(int)>(v);
goto label;
label:
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelOption: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelOption ALLOW_HALF_CLOSURE>;
if v != v goto label;
v = virtualinvoke v.<java.lang.Boolean: boolean booleanValue()>();
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueSocketChannelConfig: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueSocketChannelConfig setAllowHalfClosure(boolean)>(v);
goto label;
label:
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueChannelOption: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelOption SO_SNDLOWAT>;
if v != v goto label;
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueSocketChannelConfig: void setSndLowAt(int)>(v);
goto label;
label:
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueChannelOption: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelOption TCP_NOPUSH>;
if v != v goto label;
v = virtualinvoke v.<java.lang.Boolean: boolean booleanValue()>();
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueSocketChannelConfig: void setTcpNoPush(boolean)>(v);
goto label;
label:
v = specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueChannelConfig: boolean setOption(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelOption,java.lang.Object)>(v, v);
return v;
label:
return 1;
}
public int getReceiveBufferSize()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelException 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.KQueueSocketChannelConfig v;
int v;
java.io.IOException v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueSocketChannelConfig;
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueSocketChannelConfig: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel channel>;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueSocketChannel: 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: int getReceiveBufferSize()>();
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 int getSendBufferSize()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelException 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.KQueueSocketChannelConfig v;
int v;
java.io.IOException v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueSocketChannelConfig;
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueSocketChannelConfig: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel channel>;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueSocketChannel: 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: int getSendBufferSize()>();
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 int getSoLinger()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelException 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.KQueueSocketChannelConfig v;
int v;
java.io.IOException v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueSocketChannelConfig;
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueSocketChannelConfig: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel channel>;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueSocketChannel: 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: int getSoLinger()>();
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 int getTrafficClass()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelException 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.KQueueSocketChannelConfig v;
int v;
java.io.IOException v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueSocketChannelConfig;
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueSocketChannelConfig: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel channel>;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueSocketChannel: 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: int getTrafficClass()>();
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 boolean isKeepAlive()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelException 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.KQueueSocketChannelConfig v;
java.io.IOException v;
boolean v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueSocketChannelConfig;
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueSocketChannelConfig: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel channel>;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueSocketChannel: 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: boolean isKeepAlive()>();
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 boolean isReuseAddress()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelException 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.KQueueSocketChannelConfig v;
java.io.IOException v;
boolean v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueSocketChannelConfig;
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueSocketChannelConfig: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel channel>;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueSocketChannel: 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: boolean isReuseAddress()>();
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 boolean isTcpNoDelay()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelException 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.KQueueSocketChannelConfig v;
java.io.IOException v;
boolean v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueSocketChannelConfig;
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueSocketChannelConfig: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel channel>;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueSocketChannel: 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: boolean isTcpNoDelay()>();
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 int getSndLowAt()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelException 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.KQueueSocketChannelConfig v;
int v;
java.io.IOException v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueSocketChannelConfig;
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueSocketChannelConfig: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel channel>;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueSocketChannel: 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: int getSndLowAt()>();
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 void setSndLowAt(int)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelException 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.KQueueSocketChannelConfig v;
int v;
java.io.IOException v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueSocketChannelConfig;
v := @parameter: int;
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueSocketChannelConfig: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel channel>;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueSocketChannel: 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 setSndLowAt(int)>(v);
label:
goto label;
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;
label:
return;
catch java.io.IOException from label to label with label;
}
public boolean isTcpNoPush()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelException 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.KQueueSocketChannelConfig v;
java.io.IOException v;
boolean v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueSocketChannelConfig;
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueSocketChannelConfig: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel channel>;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueSocketChannel: 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: boolean isTcpNoPush()>();
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 void setTcpNoPush(boolean)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelException 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.KQueueSocketChannelConfig v;
java.io.IOException v;
boolean v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueSocketChannelConfig;
v := @parameter: boolean;
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueSocketChannelConfig: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel channel>;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueSocketChannel: 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 setTcpNoPush(boolean)>(v);
label:
goto label;
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;
label:
return;
catch java.io.IOException from label to label with label;
}
public org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueSocketChannelConfig setKeepAlive(boolean)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelException 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.KQueueSocketChannelConfig v;
java.io.IOException v;
boolean v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueSocketChannelConfig;
v := @parameter: boolean;
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueSocketChannelConfig: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel channel>;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueSocketChannel: 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 setKeepAlive(boolean)>(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 org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueSocketChannelConfig setReceiveBufferSize(int)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelException 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.KQueueSocketChannelConfig v;
int v;
java.io.IOException v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueSocketChannelConfig;
v := @parameter: int;
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueSocketChannelConfig: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel channel>;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueSocketChannel: 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 setReceiveBufferSize(int)>(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 org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueSocketChannelConfig setReuseAddress(boolean)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelException 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.KQueueSocketChannelConfig v;
java.io.IOException v;
boolean v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueSocketChannelConfig;
v := @parameter: boolean;
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueSocketChannelConfig: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel channel>;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueSocketChannel: 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 setReuseAddress(boolean)>(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 org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueSocketChannelConfig setSendBufferSize(int)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelException 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.KQueueSocketChannelConfig v;
int v;
java.io.IOException v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueSocketChannelConfig;
v := @parameter: int;
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueSocketChannelConfig: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel channel>;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueSocketChannel: 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 setSendBufferSize(int)>(v);
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueSocketChannelConfig: void calculateMaxBytesPerGatheringWrite()>();
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 org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueSocketChannelConfig setSoLinger(int)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelException 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.KQueueSocketChannelConfig v;
int v;
java.io.IOException v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueSocketChannelConfig;
v := @parameter: int;
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueSocketChannelConfig: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel channel>;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueSocketChannel: 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 setSoLinger(int)>(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 org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueSocketChannelConfig setTcpNoDelay(boolean)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelException 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.KQueueSocketChannelConfig v;
java.io.IOException v;
boolean v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueSocketChannelConfig;
v := @parameter: boolean;
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueSocketChannelConfig: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel channel>;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueSocketChannel: 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 setTcpNoDelay(boolean)>(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 org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueSocketChannelConfig setTrafficClass(int)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelException 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.KQueueSocketChannelConfig v;
int v;
java.io.IOException v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueSocketChannelConfig;
v := @parameter: int;
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueSocketChannelConfig: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel channel>;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueSocketChannel: 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 setTrafficClass(int)>(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 boolean isAllowHalfClosure()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueSocketChannelConfig v;
boolean v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueSocketChannelConfig;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueSocketChannelConfig: boolean allowHalfClosure>;
return v;
}
public org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueSocketChannelConfig setRcvAllocTransportProvidesGuess(boolean)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueSocketChannelConfig v;
boolean v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueSocketChannelConfig;
v := @parameter: boolean;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueChannelConfig: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueChannelConfig setRcvAllocTransportProvidesGuess(boolean)>(v);
return v;
}
public org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueSocketChannelConfig setPerformancePreferences(int, int, int)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueSocketChannelConfig v;
int v, v, v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueSocketChannelConfig;
v := @parameter: int;
v := @parameter: int;
v := @parameter: int;
return v;
}
public org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueSocketChannelConfig setAllowHalfClosure(boolean)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueSocketChannelConfig v;
boolean v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueSocketChannelConfig;
v := @parameter: boolean;
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueSocketChannelConfig: boolean allowHalfClosure> = v;
return v;
}
public org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueSocketChannelConfig setConnectTimeoutMillis(int)
{
int v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueSocketChannelConfig v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueSocketChannelConfig;
v := @parameter: int;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueChannelConfig: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueChannelConfig setConnectTimeoutMillis(int)>(v);
return v;
}
public org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueSocketChannelConfig setMaxMessagesPerRead(int)
{
int v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueSocketChannelConfig v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueSocketChannelConfig;
v := @parameter: int;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueChannelConfig: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueChannelConfig setMaxMessagesPerRead(int)>(v);
return v;
}
public org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueSocketChannelConfig setWriteSpinCount(int)
{
int v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueSocketChannelConfig v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueSocketChannelConfig;
v := @parameter: int;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueChannelConfig: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueChannelConfig setWriteSpinCount(int)>(v);
return v;
}
public org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueSocketChannelConfig setAllocator(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBufAllocator)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBufAllocator v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueSocketChannelConfig v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueSocketChannelConfig;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBufAllocator;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueChannelConfig: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueChannelConfig setAllocator(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBufAllocator)>(v);
return v;
}
public org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueSocketChannelConfig setRecvByteBufAllocator(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.RecvByteBufAllocator)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.RecvByteBufAllocator v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueSocketChannelConfig v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueSocketChannelConfig;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.RecvByteBufAllocator;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueChannelConfig: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueChannelConfig setRecvByteBufAllocator(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.RecvByteBufAllocator)>(v);
return v;
}
public org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueSocketChannelConfig setAutoRead(boolean)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueSocketChannelConfig v;
boolean v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueSocketChannelConfig;
v := @parameter: boolean;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueChannelConfig: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueChannelConfig setAutoRead(boolean)>(v);
return v;
}
public org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueSocketChannelConfig setAutoClose(boolean)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueSocketChannelConfig v;
boolean v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueSocketChannelConfig;
v := @parameter: boolean;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueChannelConfig: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelConfig setAutoClose(boolean)>(v);
return v;
}
public org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueSocketChannelConfig setWriteBufferHighWaterMark(int)
{
int v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueSocketChannelConfig v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueSocketChannelConfig;
v := @parameter: int;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueChannelConfig: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueChannelConfig setWriteBufferHighWaterMark(int)>(v);
return v;
}
public org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueSocketChannelConfig setWriteBufferLowWaterMark(int)
{
int v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueSocketChannelConfig v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueSocketChannelConfig;
v := @parameter: int;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueChannelConfig: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueChannelConfig setWriteBufferLowWaterMark(int)>(v);
return v;
}
public org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueSocketChannelConfig setWriteBufferWaterMark(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.WriteBufferWaterMark)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.WriteBufferWaterMark v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueSocketChannelConfig v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueSocketChannelConfig;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.WriteBufferWaterMark;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueChannelConfig: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueChannelConfig setWriteBufferWaterMark(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.WriteBufferWaterMark)>(v);
return v;
}
public org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueSocketChannelConfig setMessageSizeEstimator(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.MessageSizeEstimator)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.MessageSizeEstimator v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueSocketChannelConfig v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueSocketChannelConfig;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.MessageSizeEstimator;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueChannelConfig: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueChannelConfig setMessageSizeEstimator(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.MessageSizeEstimator)>(v);
return v;
}
private void calculateMaxBytesPerGatheringWrite()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueSocketChannelConfig v;
int v, v, v, v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueSocketChannelConfig;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueSocketChannelConfig: int getSendBufferSize()>();
v = v << 1;
if v <= 0 goto label;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueSocketChannelConfig: int getSendBufferSize()>();
v = v << 1;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.kqueue.KQueueSocketChannelConfig: void setMaxBytesPerGatheringWrite(long)>(v);
label:
return;
}
}