public final class org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyMessage extends org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.AbstractReferenceCounted
{
private static final org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.ResourceLeakDetector leakDetector;
private final org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.ResourceLeakTracker leak;
private final org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyProtocolVersion protocolVersion;
private final org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyCommand command;
private final org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyProxiedProtocol proxiedProtocol;
private final java.lang.String sourceAddress;
private final java.lang.String destinationAddress;
private final int sourcePort;
private final int destinationPort;
private final java.util.List tlvs;
static final boolean $assertionsDisabled;
private void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyProtocolVersion, org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyCommand, org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyProxiedProtocol, java.lang.String, java.lang.String, java.lang.String, java.lang.String)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyProtocolVersion v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyProxiedProtocol v;
int v, v;
java.lang.String v, v, v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyCommand v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyMessage v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyMessage;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyProtocolVersion;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyCommand;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyProxiedProtocol;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyMessage: int portStringToInt(java.lang.String)>(v);
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyMessage: int portStringToInt(java.lang.String)>(v);
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyMessage: void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyProtocolVersion,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyCommand,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyProxiedProtocol,java.lang.String,java.lang.String,int,int)>(v, v, v, v, v, v, v);
return;
}
private void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyProtocolVersion, org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyCommand, org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyProxiedProtocol, java.lang.String, java.lang.String, int, int)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyProtocolVersion v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyProxiedProtocol v;
java.util.List v;
int v, v;
java.lang.String v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyCommand v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyMessage v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyMessage;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyProtocolVersion;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyCommand;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyProxiedProtocol;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: int;
v := @parameter: int;
v = staticinvoke <java.util.Collections: java.util.List emptyList()>();
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyMessage: void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyProtocolVersion,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyCommand,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyProxiedProtocol,java.lang.String,java.lang.String,int,int,java.util.List)>(v, v, v, v, v, v, v, v);
return;
}
private void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyProtocolVersion, org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyCommand, org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyProxiedProtocol, java.lang.String, java.lang.String, int, int, java.util.List)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.ResourceLeakTracker v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyProtocolVersion v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyProxiedProtocol v;
java.util.List v, v;
int v, v;
java.lang.String v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyCommand v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyProxiedProtocol$AddressFamily v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.ResourceLeakDetector v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyMessage v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyMessage;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyProtocolVersion;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyCommand;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyProxiedProtocol;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: int;
v := @parameter: int;
v := @parameter: java.util.List;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.AbstractReferenceCounted: void <init>()>();
staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.ObjectUtil: java.lang.Object checkNotNull(java.lang.Object,java.lang.String)>(v, "proxiedProtocol");
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyProxiedProtocol: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyProxiedProtocol$AddressFamily addressFamily()>();
staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyMessage: void checkAddress(java.lang.String,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyProxiedProtocol$AddressFamily)>(v, v);
staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyMessage: void checkAddress(java.lang.String,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyProxiedProtocol$AddressFamily)>(v, v);
staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyMessage: void checkPort(int)>(v);
staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyMessage: void checkPort(int)>(v);
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyMessage: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyProtocolVersion protocolVersion> = v;
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyMessage: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyCommand command> = v;
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyMessage: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyProxiedProtocol proxiedProtocol> = v;
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyMessage: java.lang.String sourceAddress> = v;
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyMessage: java.lang.String destinationAddress> = v;
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyMessage: int sourcePort> = v;
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyMessage: int destinationPort> = v;
v = staticinvoke <java.util.Collections: java.util.List unmodifiableList(java.util.List)>(v);
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyMessage: java.util.List tlvs> = v;
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyMessage: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.ResourceLeakDetector leakDetector>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.ResourceLeakDetector: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.ResourceLeakTracker track(java.lang.Object)>(v);
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyMessage: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.ResourceLeakTracker leak> = v;
return;
}
static org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyMessage decodeHeader(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf)
{
byte v, v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyMessage v, v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyProxiedProtocol v, v;
java.lang.String v, v, v, v, v, v, v, v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyProxiedProtocol$AddressFamily v, v, v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyProtocolException v, v, v, v, v, v, v, v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.ByteProcessor v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyCommand v, v, v, v;
java.util.List v;
java.nio.charset.Charset v, v;
int v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyProtocolVersion v, v, v, v;
java.lang.IllegalArgumentException v, v, v;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf;
staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.ObjectUtil: java.lang.Object checkNotNull(java.lang.Object,java.lang.String)>(v, "header");
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: int readableBytes()>();
if v >= 16 goto label;
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyProtocolException;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: int readableBytes()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (int)>(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[])>("incomplete header: \u bytes (expected: 16+ bytes)");
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyProtocolException: void <init>(java.lang.String)>(v);
throw v;
label:
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf skipBytes(int)>(12);
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: byte readByte()>();
label:
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyProtocolVersion: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyProtocolVersion valueOf(byte)>(v);
label:
goto label;
label:
v := @caughtexception;
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyProtocolException;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyProtocolException: void <init>(java.lang.Throwable)>(v);
throw v;
label:
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyProtocolVersion: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyProtocolVersion V2>;
if v == v goto label;
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyProtocolException;
v = staticinvoke <java.lang.Integer: java.lang.String toHexString(int)>(v);
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[])>("version 1 unsupported: 0x\u0001");
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyProtocolException: void <init>(java.lang.String)>(v);
throw v;
label:
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyCommand: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyCommand valueOf(byte)>(v);
label:
goto label;
label:
v := @caughtexception;
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyProtocolException;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyProtocolException: void <init>(java.lang.Throwable)>(v);
throw v;
label:
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyCommand: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyCommand LOCAL>;
if v != v goto label;
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyProtocolVersion: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyProtocolVersion V2>;
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyCommand: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyCommand LOCAL>;
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyMessage: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyMessage unknownMsg(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyProtocolVersion,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyCommand)>(v, v);
return v;
label:
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: byte readByte()>();
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyProxiedProtocol: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyProxiedProtocol valueOf(byte)>(v);
label:
goto label;
label:
v := @caughtexception;
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyProtocolException;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyProtocolException: void <init>(java.lang.Throwable)>(v);
throw v;
label:
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyProxiedProtocol: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyProxiedProtocol UNKNOWN>;
if v != v goto label;
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyProtocolVersion: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyProtocolVersion V2>;
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyCommand: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyCommand PROXY>;
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyMessage: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyMessage unknownMsg(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyProtocolVersion,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyCommand)>(v, v);
return v;
label:
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: int readUnsignedShort()>();
v = 0;
v = 0;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyProxiedProtocol: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyProxiedProtocol$AddressFamily addressFamily()>();
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyProxiedProtocol$AddressFamily: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyProxiedProtocol$AddressFamily AF_UNIX>;
if v != v goto label;
if v < 216 goto label;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: int readableBytes()>();
if v >= 216 goto label;
label:
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyProtocolException;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: int readableBytes()>();
v = staticinvoke <java.lang.Math: int min(int,int)>(v, v);
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (int)>(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[])>("incomplete UNIX socket address information: \u bytes (expected: 216+ bytes)");
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyProtocolException: void <init>(java.lang.String)>(v);
throw v;
label:
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: int readerIndex()>();
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.ByteProcessor: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.ByteProcessor FIND_NUL>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: int forEachByte(int,int,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.ByteProcessor)>(v, 108, v);
v = (int) -1;
if v != v goto label;
v = 108;
goto label;
label:
v = v - v;
label:
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.CharsetUtil: java.nio.charset.Charset US_ASCII>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: java.lang.String toString(int,int,java.nio.charset.Charset)>(v, v, v);
v = v + 108;
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.ByteProcessor: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.ByteProcessor FIND_NUL>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: int forEachByte(int,int,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.ByteProcessor)>(v, 108, v);
v = (int) -1;
if v != v goto label;
v = 108;
goto label;
label:
v = v - v;
label:
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.CharsetUtil: java.nio.charset.Charset US_ASCII>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: java.lang.String toString(int,int,java.nio.charset.Charset)>(v, v, v);
v = v + 108;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf readerIndex(int)>(v);
goto label;
label:
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyProxiedProtocol$AddressFamily: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyProxiedProtocol$AddressFamily AF_IPv4>;
if v != v goto label;
if v < 12 goto label;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: int readableBytes()>();
if v >= 12 goto label;
label:
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyProtocolException;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: int readableBytes()>();
v = staticinvoke <java.lang.Math: int min(int,int)>(v, v);
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (int)>(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[])>("incomplete IPv address information: \u bytes (expected: 12+ bytes)");
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyProtocolException: void <init>(java.lang.String)>(v);
throw v;
label:
v = 4;
goto label;
label:
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyProxiedProtocol$AddressFamily: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyProxiedProtocol$AddressFamily AF_IPv6>;
if v != v goto label;
if v < 36 goto label;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: int readableBytes()>();
if v >= 36 goto label;
label:
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyProtocolException;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: int readableBytes()>();
v = staticinvoke <java.lang.Math: int min(int,int)>(v, v);
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (int)>(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[])>("incomplete IPv address information: \u bytes (expected: 36+ bytes)");
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyProtocolException: void <init>(java.lang.String)>(v);
throw v;
label:
v = 16;
goto label;
label:
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyProtocolException;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyProxiedProtocol$AddressFamily)>(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[])>("unable to parse address information (unknown address family: \u)");
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyProtocolException: void <init>(java.lang.String)>(v);
throw v;
label:
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyMessage: java.lang.String ipBytesToString(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf,int)>(v, v);
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyMessage: java.lang.String ipBytesToString(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf,int)>(v, v);
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: int readUnsignedShort()>();
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: int readUnsignedShort()>();
label:
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyMessage: java.util.List readTlvs(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf)>(v);
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyMessage;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyMessage: void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyProtocolVersion,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyCommand,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyProxiedProtocol,java.lang.String,java.lang.String,int,int,java.util.List)>(v, v, v, v, v, v, v, v);
return v;
catch java.lang.IllegalArgumentException from label to label with label;
catch java.lang.IllegalArgumentException from label to label with label;
catch java.lang.IllegalArgumentException from label to label with label;
}
private static java.util.List readTlvs(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf)
{
java.util.List v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyTLV v, v;
boolean v;
java.util.ArrayList v;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf;
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyMessage: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyTLV readNextTLV(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf)>(v);
if v != null goto label;
v = staticinvoke <java.util.Collections: java.util.List emptyList()>();
return v;
label:
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>(int)>(4);
label:
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = v instanceof org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxySSLTLV;
if v == 0 goto label;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxySSLTLV: java.util.List encapsulatedTLVs()>();
interfaceinvoke v.<java.util.List: boolean addAll(java.util.Collection)>(v);
label:
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyMessage: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyTLV readNextTLV(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf)>(v);
v = v;
if v != null goto label;
return v;
}
private static org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyTLV readNextTLV(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyTLV$Type v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyTLV v, v;
java.util.ArrayList v;
byte v, v;
int[] v;
int v, v, v, v, v, v, v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf v, v, v, v;
java.util.List v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxySSLTLV v, v;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: int readableBytes()>();
if v >= 4 goto label;
return null;
label:
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: byte readByte()>();
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyTLV$Type: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyTLV$Type typeForByteValue(byte)>(v);
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: int readUnsignedShort()>();
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyMessage$1: int[] $SwitchMap$io$netty$handler$codec$haproxy$HAProxyTLV$Type>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyTLV$Type: int ordinal()>();
v = v[v];
tableswitch(v)
{
case 1: goto label;
case 2: goto label;
case 3: goto label;
case 4: goto label;
case 5: goto label;
case 6: goto label;
case 7: goto label;
default: goto label;
};
label:
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: int readerIndex()>();
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf retainedSlice(int,int)>(v, v);
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf readSlice(int)>(v);
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: byte readByte()>();
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: int readInt()>();
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: int readableBytes()>();
if v < 4 goto label;
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>(int)>(4);
label:
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyMessage: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyTLV readNextTLV(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf)>(v);
if v == null goto label;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: int readableBytes()>();
if v >= 4 goto label;
label:
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxySSLTLV;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxySSLTLV: void <init>(int,byte,java.util.List,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf)>(v, v, v, v);
return v;
label:
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxySSLTLV;
v = staticinvoke <java.util.Collections: java.util.List emptyList()>();
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxySSLTLV: void <init>(int,byte,java.util.List,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf)>(v, v, v, v);
return v;
label:
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyTLV;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf readRetainedSlice(int)>(v);
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyTLV: void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyTLV$Type,byte,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf)>(v, v, v);
return v;
label:
return null;
}
static org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyMessage decodeHeader(java.lang.String)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyCommand v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyMessage v, v;
boolean v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyProxiedProtocol v, v, v, v, v;
java.lang.String[] v;
int v;
java.lang.String v, v, v, v, v, v, v, v, v, v, v, v, v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyProtocolException v, v, v, v, v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyProtocolVersion v, v;
java.lang.IllegalArgumentException v;
v := @parameter: java.lang.String;
if v != null goto label;
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyProtocolException;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyProtocolException: void <init>(java.lang.String)>("header");
throw v;
label:
v = virtualinvoke v.<java.lang.String: java.lang.String[] split(java.lang.String)>(" ");
v = lengthof v;
if v >= 2 goto label;
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyProtocolException;
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[])>("invalid header: \u (expected: \'PROXY\' and proxied protocol values)");
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyProtocolException: void <init>(java.lang.String)>(v);
throw v;
label:
v = "PROXY";
v = v[0];
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>(v);
if v != 0 goto label;
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyProtocolException;
v = v[0];
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[])>("unknown identifier: \u0001");
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyProtocolException: void <init>(java.lang.String)>(v);
throw v;
label:
v = v[1];
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyProxiedProtocol: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyProxiedProtocol valueOf(java.lang.String)>(v);
label:
goto label;
label:
v := @caughtexception;
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyProtocolException;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyProtocolException: void <init>(java.lang.Throwable)>(v);
throw v;
label:
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyProxiedProtocol: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyProxiedProtocol TCP4>;
if v == v goto label;
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyProxiedProtocol: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyProxiedProtocol TCP6>;
if v == v goto label;
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyProxiedProtocol: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyProxiedProtocol UNKNOWN>;
if v == v goto label;
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyProtocolException;
v = v[1];
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[])>("unsupported v proxied protocol: \u0001");
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyProtocolException: void <init>(java.lang.String)>(v);
throw v;
label:
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyProxiedProtocol: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyProxiedProtocol UNKNOWN>;
if v != v goto label;
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyProtocolVersion: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyProtocolVersion V1>;
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyCommand: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyCommand PROXY>;
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyMessage: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyMessage unknownMsg(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyProtocolVersion,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyCommand)>(v, v);
return v;
label:
if v == 6 goto label;
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyProtocolException;
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[])>("invalid TCP4/6 header: \u (expected: 6 parts)");
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyProtocolException: void <init>(java.lang.String)>(v);
throw v;
label:
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyMessage;
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyProtocolVersion: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyProtocolVersion V1>;
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyCommand: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyCommand PROXY>;
v = v[2];
v = v[3];
v = v[4];
v = v[5];
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyMessage: void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyProtocolVersion,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyCommand,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyProxiedProtocol,java.lang.String,java.lang.String,java.lang.String,java.lang.String)>(v, v, v, v, v, v, v);
return v;
catch java.lang.IllegalArgumentException from label to label with label;
}
private static org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyMessage unknownMsg(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyProtocolVersion, org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyCommand)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyProtocolVersion v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyProxiedProtocol v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyCommand v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyMessage v;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyProtocolVersion;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyCommand;
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyMessage;
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyProxiedProtocol: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyProxiedProtocol UNKNOWN>;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyMessage: void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyProtocolVersion,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyCommand,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyProxiedProtocol,java.lang.String,java.lang.String,int,int)>(v, v, v, null, null, 0, 0);
return v;
}
private static java.lang.String ipBytesToString(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf, int)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf v;
short v;
byte v;
int v, v, v, v, v, v;
java.lang.StringBuilder v;
java.lang.String v, v;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf;
v := @parameter: int;
v = new java.lang.StringBuilder;
specialinvoke v.<java.lang.StringBuilder: void <init>()>();
if v != 4 goto label;
v = 0;
label:
if v >= 4 goto label;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: byte readByte()>();
v = v & 255;
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(int)>(v);
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(char)>(46);
v = v + 1;
goto label;
label:
v = 0;
label:
if v >= 8 goto label;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: int readUnsignedShort()>();
v = staticinvoke <java.lang.Integer: java.lang.String toHexString(int)>(v);
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>(v);
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(char)>(58);
v = v + 1;
goto label;
label:
v = virtualinvoke v.<java.lang.StringBuilder: int length()>();
v = v - 1;
virtualinvoke v.<java.lang.StringBuilder: void setLength(int)>(v);
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.String toString()>();
return v;
}
private static int portStringToInt(java.lang.String)
{
java.lang.NumberFormatException v;
int v, v;
java.lang.String v, v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyProtocolException v, v;
v := @parameter: java.lang.String;
label:
v = staticinvoke <java.lang.Integer: int parseInt(java.lang.String)>(v);
label:
goto label;
label:
v := @caughtexception;
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyProtocolException;
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[])>("invalid port: \u0001");
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyProtocolException: void <init>(java.lang.String,java.lang.Throwable)>(v, v);
throw v;
label:
if v <= 0 goto label;
v = (int) 65535;
if v <= v goto label;
label:
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyProtocolException;
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[])>("invalid port: \u (expected: 1 ~ 65535)");
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyProtocolException: void <init>(java.lang.String)>(v);
throw v;
label:
return v;
catch java.lang.NumberFormatException from label to label with label;
}
private static void checkAddress(java.lang.String, org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyProxiedProtocol$AddressFamily)
{
java.lang.Error v;
int[] v, v;
int v, v, v, v;
java.lang.String v, v, v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyProxiedProtocol$AddressFamily v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyProtocolException v, v, v;
boolean v, v;
v := @parameter: java.lang.String;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyProxiedProtocol$AddressFamily;
staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.ObjectUtil: java.lang.Object checkNotNull(java.lang.Object,java.lang.String)>(v, "addrFamily");
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyMessage$1: int[] $SwitchMap$io$netty$handler$codec$haproxy$HAProxyProxiedProtocol$AddressFamily>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyProxiedProtocol$AddressFamily: int ordinal()>();
v = v[v];
lookupswitch(v)
{
case 1: goto label;
case 2: goto label;
default: goto label;
};
label:
if v == null goto label;
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyProtocolException;
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[])>("unable to validate an AF_UNSPEC address: \u0001");
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyProtocolException: void <init>(java.lang.String)>(v);
throw v;
label:
return;
label:
return;
label:
staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.ObjectUtil: java.lang.Object checkNotNull(java.lang.Object,java.lang.String)>(v, "address");
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyMessage$1: int[] $SwitchMap$io$netty$handler$codec$haproxy$HAProxyProxiedProtocol$AddressFamily>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyProxiedProtocol$AddressFamily: int ordinal()>();
v = v[v];
lookupswitch(v)
{
case 3: goto label;
case 4: goto label;
default: goto label;
};
label:
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.NetUtil: boolean isValidIpV4Address(java.lang.String)>(v);
if v != 0 goto label;
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyProtocolException;
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[])>("invalid IPv address: \u0001");
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyProtocolException: void <init>(java.lang.String)>(v);
throw v;
label:
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.NetUtil: boolean isValidIpV6Address(java.lang.String)>(v);
if v != 0 goto label;
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyProtocolException;
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[])>("invalid IPv address: \u0001");
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyProtocolException: void <init>(java.lang.String)>(v);
throw v;
label:
v = new java.lang.Error;
specialinvoke v.<java.lang.Error: void <init>()>();
throw v;
label:
return;
}
private static void checkPort(int)
{
int v, v;
java.lang.String v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyProtocolException v;
v := @parameter: int;
if v < 0 goto label;
v = (int) 65535;
if v <= v goto label;
label:
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyProtocolException;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (int)>(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[])>("invalid port: \u (expected: 1 ~ 65535)");
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyProtocolException: void <init>(java.lang.String)>(v);
throw v;
label:
return;
}
public org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyProtocolVersion protocolVersion()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyProtocolVersion v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyMessage v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyMessage;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyMessage: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyProtocolVersion protocolVersion>;
return v;
}
public org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyCommand command()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyCommand v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyMessage v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyMessage;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyMessage: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyCommand command>;
return v;
}
public org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyProxiedProtocol proxiedProtocol()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyProxiedProtocol v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyMessage v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyMessage;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyMessage: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyProxiedProtocol proxiedProtocol>;
return v;
}
public java.lang.String sourceAddress()
{
java.lang.String v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyMessage v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyMessage;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyMessage: java.lang.String sourceAddress>;
return v;
}
public java.lang.String destinationAddress()
{
java.lang.String v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyMessage v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyMessage;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyMessage: java.lang.String destinationAddress>;
return v;
}
public int sourcePort()
{
int v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyMessage v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyMessage;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyMessage: int sourcePort>;
return v;
}
public int destinationPort()
{
int v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyMessage v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyMessage;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyMessage: int destinationPort>;
return v;
}
public java.util.List tlvs()
{
java.util.List v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyMessage v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyMessage;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyMessage: java.util.List tlvs>;
return v;
}
public org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyMessage touch()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyMessage v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.ReferenceCounted v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyMessage;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyMessage: void tryRecord()>();
v = specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.AbstractReferenceCounted: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.ReferenceCounted touch()>();
return v;
}
public org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyMessage touch(java.lang.Object)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.ResourceLeakTracker v, v;
java.lang.Object v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyMessage v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyMessage;
v := @parameter: java.lang.Object;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyMessage: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.ResourceLeakTracker leak>;
if v == null goto label;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyMessage: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.ResourceLeakTracker leak>;
interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.ResourceLeakTracker: void record(java.lang.Object)>(v);
label:
return v;
}
public org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyMessage retain()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyMessage v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.ReferenceCounted v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyMessage;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyMessage: void tryRecord()>();
v = specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.AbstractReferenceCounted: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.ReferenceCounted retain()>();
return v;
}
public org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyMessage retain(int)
{
int v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyMessage v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.ReferenceCounted v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyMessage;
v := @parameter: int;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyMessage: void tryRecord()>();
v = specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.AbstractReferenceCounted: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.ReferenceCounted retain(int)>(v);
return v;
}
public boolean release()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyMessage v;
boolean v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyMessage;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyMessage: void tryRecord()>();
v = specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.AbstractReferenceCounted: boolean release()>();
return v;
}
public boolean release(int)
{
int v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyMessage v;
boolean v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyMessage;
v := @parameter: int;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyMessage: void tryRecord()>();
v = specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.AbstractReferenceCounted: boolean release(int)>(v);
return v;
}
private void tryRecord()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.ResourceLeakTracker v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyMessage v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyMessage;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyMessage: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.ResourceLeakTracker leak>;
if v == null goto label;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyMessage: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.ResourceLeakTracker leak>;
interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.ResourceLeakTracker: void record()>();
label:
return;
}
protected void deallocate()
{
java.lang.Throwable v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.ResourceLeakTracker v, v;
java.util.Iterator v;
java.lang.AssertionError v, v;
java.util.List v;
java.lang.Object v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyMessage v;
boolean v, v, v, v, v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyMessage;
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyMessage: java.util.List tlvs>;
v = interfaceinvoke v.<java.util.List: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyTLV: boolean release()>();
goto label;
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyMessage: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.ResourceLeakTracker leak>;
if v == null goto label;
v = interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.ResourceLeakTracker: boolean close(java.lang.Object)>(v);
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyMessage: boolean $assertionsDisabled>;
if v != 0 goto label;
if v != 0 goto label;
v = new java.lang.AssertionError;
specialinvoke v.<java.lang.AssertionError: void <init>()>();
throw v;
label:
v := @caughtexception;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyMessage: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.ResourceLeakTracker leak>;
if v == null goto label;
v = interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.ResourceLeakTracker: boolean close(java.lang.Object)>(v);
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyMessage: boolean $assertionsDisabled>;
if v != 0 goto label;
if v != 0 goto label;
v = new java.lang.AssertionError;
specialinvoke v.<java.lang.AssertionError: void <init>()>();
throw v;
label:
throw v;
label:
return;
catch java.lang.Throwable from label to label with label;
}
static void <clinit>()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.ResourceLeakDetectorFactory v;
java.lang.Class v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.ResourceLeakDetector v;
boolean v, v;
v = class "Lorg/apache/hive/kudu/org/apache/kudu/shaded/io/netty/handler/codec/haproxy/HAProxyMessage;";
v = virtualinvoke v.<java.lang.Class: boolean desiredAssertionStatus()>();
if v != 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyMessage: boolean $assertionsDisabled> = v;
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.ResourceLeakDetectorFactory: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.ResourceLeakDetectorFactory instance()>();
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.ResourceLeakDetectorFactory: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.ResourceLeakDetector newResourceLeakDetector(java.lang.Class)>(class "Lorg/apache/hive/kudu/org/apache/kudu/shaded/io/netty/handler/codec/haproxy/HAProxyMessage;");
<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.haproxy.HAProxyMessage: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.ResourceLeakDetector leakDetector> = v;
return;
}
}