public class org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder extends org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.ByteToMessageDecoder implements org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketFrameDecoder
{
private static final org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.logging.InternalLogger logger;
private static final byte OPCODE_CONT;
private static final byte OPCODE_TEXT;
private static final byte OPCODE_BINARY;
private static final byte OPCODE_CLOSE;
private static final byte OPCODE_PING;
private static final byte OPCODE_PONG;
private final org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketDecoderConfig config;
private int fragmentedFramesCount;
private boolean frameFinalFlag;
private boolean frameMasked;
private int frameRsv;
private int frameOpcode;
private long framePayloadLength;
private byte[] maskingKey;
private int framePayloadLen;
private boolean receivedClosingHandshake;
private org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder$State state;
public void <init>(boolean, boolean, int)
{
int v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder v;
boolean v, v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder;
v := @parameter: boolean;
v := @parameter: boolean;
v := @parameter: int;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder: void <init>(boolean,boolean,int,boolean)>(v, v, v, 0);
return;
}
public void <init>(boolean, boolean, int, boolean)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketDecoderConfig$Builder v, v, v, v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketDecoderConfig v;
int v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder v;
boolean v, v, v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder;
v := @parameter: boolean;
v := @parameter: boolean;
v := @parameter: int;
v := @parameter: boolean;
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketDecoderConfig: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketDecoderConfig$Builder newBuilder()>();
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketDecoderConfig$Builder: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketDecoderConfig$Builder expectMaskedFrames(boolean)>(v);
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketDecoderConfig$Builder: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketDecoderConfig$Builder allowExtensions(boolean)>(v);
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketDecoderConfig$Builder: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketDecoderConfig$Builder maxFramePayloadLength(int)>(v);
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketDecoderConfig$Builder: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketDecoderConfig$Builder allowMaskMismatch(boolean)>(v);
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketDecoderConfig$Builder: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketDecoderConfig build()>();
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder: void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketDecoderConfig)>(v);
return;
}
public void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketDecoderConfig)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketDecoderConfig v;
java.lang.Object v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder$State v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketDecoderConfig;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.ByteToMessageDecoder: void <init>()>();
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder$State: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder$State READING_FIRST>;
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder$State state> = v;
v = 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, "decoderConfig");
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketDecoderConfig config> = v;
return;
}
protected void decode(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext, org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf, java.util.List) throws java.lang.Exception
{
byte[] v, v, v;
java.lang.Integer v;
byte v, v, v, v, v, v, v, v, v;
java.lang.Long v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketCloseStatus v;
long v, v, v, v, v, v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.TextWebSocketFrame v;
short v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder v;
int[] v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.BinaryWebSocketFrame 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, v, v, v, v, v, 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.http.websocketx.CloseWebSocketFrame v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.logging.InternalLogger v, v, v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.PingWebSocketFrame v;
java.lang.Throwable v;
java.lang.Error v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder$State v, v, v, v, v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.PongWebSocketFrame v;
java.lang.String v, v, v, v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext v;
java.lang.UnsupportedOperationException v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.ContinuationWebSocketFrame v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf v, v;
boolean 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.http.websocketx.WebSocketDecoderConfig v, v, v, v, v;
java.util.List v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBufAllocator v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf;
v := @parameter: java.util.List;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder: boolean receivedClosingHandshake>;
if v == 0 goto label;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder: int actualReadableBytes()>();
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)>(v);
return;
label:
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder$1: int[] $SwitchMap$io$netty$handler$codec$http$websocketx$WebSocket08FrameDecoder$State>;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder$State state>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder$State: 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;
default: goto label;
};
label:
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: boolean isReadable()>();
if v != 0 goto label;
return;
label:
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder: long framePayloadLength> = 0L;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: byte readByte()>();
v = v & 128;
if v == 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder: boolean frameFinalFlag> = v;
v = v & 112;
v = v >> 4;
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder: int frameRsv> = v;
v = v & 15;
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder: int frameOpcode> = v;
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.logging.InternalLogger logger>;
v = interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.logging.InternalLogger: boolean isTraceEnabled()>();
if v == 0 goto label;
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.logging.InternalLogger logger>;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder: int frameOpcode>;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.logging.InternalLogger: void trace(java.lang.String,java.lang.Object)>("Decoding WebSocket Frame opCode={}", v);
label:
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder$State: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder$State READING_SECOND>;
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder$State state> = v;
label:
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: boolean isReadable()>();
if v != 0 goto label;
return;
label:
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: byte readByte()>();
v = v & 128;
if v == 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder: boolean frameMasked> = v;
v = v & 127;
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder: int framePayloadLen1> = v;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder: int frameRsv>;
if v == 0 goto label;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketDecoderConfig config>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketDecoderConfig: boolean allowExtensions()>();
if v != 0 goto label;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder: int frameRsv>;
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[])>("RSV != 0 and no extension negotiated, RSV:\u0001");
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder: void protocolViolation(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf,java.lang.String)>(v, v, v);
return;
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketDecoderConfig config>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketDecoderConfig: boolean allowMaskMismatch()>();
if v != 0 goto label;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketDecoderConfig config>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketDecoderConfig: boolean expectMaskedFrames()>();
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder: boolean frameMasked>;
if v == v goto label;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder: void protocolViolation(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf,java.lang.String)>(v, v, "received a frame that is not masked as expected");
return;
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder: int frameOpcode>;
if v <= 7 goto label;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder: boolean frameFinalFlag>;
if v != 0 goto label;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder: void protocolViolation(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf,java.lang.String)>(v, v, "fragmented control frame");
return;
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder: int framePayloadLen1>;
if v <= 125 goto label;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder: void protocolViolation(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf,java.lang.String)>(v, v, "control frame with payload length > 125 octets");
return;
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder: int frameOpcode>;
if v == 8 goto label;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder: int frameOpcode>;
if v == 9 goto label;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder: int frameOpcode>;
if v == 10 goto label;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder: int frameOpcode>;
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[])>("control frame using reserved opcode \u0001");
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder: void protocolViolation(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf,java.lang.String)>(v, v, v);
return;
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder: int frameOpcode>;
if v != 8 goto label;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder: int framePayloadLen1>;
if v != 1 goto label;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder: void protocolViolation(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf,java.lang.String)>(v, v, "received close control frame with payload len 1");
return;
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder: int frameOpcode>;
if v == 0 goto label;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder: int frameOpcode>;
if v == 1 goto label;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder: int frameOpcode>;
if v == 2 goto label;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder: int frameOpcode>;
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[])>("data frame using reserved opcode \u0001");
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder: void protocolViolation(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf,java.lang.String)>(v, v, v);
return;
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder: int fragmentedFramesCount>;
if v != 0 goto label;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder: int frameOpcode>;
if v != 0 goto label;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder: void protocolViolation(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf,java.lang.String)>(v, v, "received continuation data frame outside fragmented message");
return;
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder: int fragmentedFramesCount>;
if v == 0 goto label;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder: int frameOpcode>;
if v == 0 goto label;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder: int frameOpcode>;
if v == 9 goto label;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder: void protocolViolation(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf,java.lang.String)>(v, v, "received non-continuation data frame while inside fragmented message");
return;
label:
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder$State: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder$State READING_SIZE>;
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder$State state> = v;
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder: int framePayloadLen1>;
if v != 126 goto label;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: int readableBytes()>();
if v >= 2 goto label;
return;
label:
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.http.websocketx.WebSocket08FrameDecoder: long framePayloadLength> = v;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder: long framePayloadLength>;
v = v cmp 126L;
if v >= 0 goto label;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder: void protocolViolation(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf,java.lang.String)>(v, v, "invalid data frame length (not using minimal length encoding)");
return;
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder: int framePayloadLen1>;
if v != 127 goto label;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: int readableBytes()>();
if v >= 8 goto label;
return;
label:
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: long readLong()>();
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder: long framePayloadLength> = v;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder: long framePayloadLength>;
v = v cmp 65536L;
if v >= 0 goto label;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder: void protocolViolation(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf,java.lang.String)>(v, v, "invalid data frame length (not using minimal length encoding)");
return;
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder: int framePayloadLen1>;
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder: long framePayloadLength> = v;
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder: long framePayloadLength>;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketDecoderConfig config>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketDecoderConfig: int maxFramePayloadLength()>();
v = v cmp v;
if v <= 0 goto label;
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketCloseStatus: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketCloseStatus MESSAGE_TOO_BIG>;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketDecoderConfig config>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketDecoderConfig: int maxFramePayloadLength()>();
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[])>("Max frame length of \u has been exceeded.");
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder: void protocolViolation(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketCloseStatus,java.lang.String)>(v, v, v, v);
return;
label:
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.logging.InternalLogger logger>;
v = interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.logging.InternalLogger: boolean isTraceEnabled()>();
if v == 0 goto label;
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.logging.InternalLogger logger>;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder: long framePayloadLength>;
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.logging.InternalLogger: void trace(java.lang.String,java.lang.Object)>("Decoding WebSocket Frame length={}", v);
label:
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder$State: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder$State MASKING_KEY>;
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder$State state> = v;
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder: boolean frameMasked>;
if v == 0 goto label;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: int readableBytes()>();
if v >= 4 goto label;
return;
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder: byte[] maskingKey>;
if v != null goto label;
v = newarray (byte)[4];
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder: byte[] maskingKey> = v;
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder: byte[] maskingKey>;
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 readBytes(byte[])>(v);
label:
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder$State: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder$State PAYLOAD>;
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder$State state> = v;
label:
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: int readableBytes()>();
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder: long framePayloadLength>;
v = v cmp v;
if v >= 0 goto label;
return;
label:
v = null;
label:
v = interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBufAllocator alloc()>();
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder: long framePayloadLength>;
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder: int toFrameLength(long)>(v);
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBufUtil: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf readBytes(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBufAllocator,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf,int)>(v, v, v);
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder$State: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder$State READING_FIRST>;
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder$State state> = v;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder: boolean frameMasked>;
if v == 0 goto label;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder: void unmask(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf)>(v);
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder: int frameOpcode>;
if v != 9 goto label;
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.PingWebSocketFrame;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder: boolean frameFinalFlag>;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder: int frameRsv>;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.PingWebSocketFrame: void <init>(boolean,int,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf)>(v, v, v);
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
label:
return;
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder: int frameOpcode>;
if v != 10 goto label;
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.PongWebSocketFrame;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder: boolean frameFinalFlag>;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder: int frameRsv>;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.PongWebSocketFrame: void <init>(boolean,int,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf)>(v, v, v);
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
label:
return;
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder: int frameOpcode>;
if v != 8 goto label;
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder: boolean receivedClosingHandshake> = 1;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder: void checkCloseFrameBody(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf)>(v, v);
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.CloseWebSocketFrame;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder: boolean frameFinalFlag>;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder: int frameRsv>;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.CloseWebSocketFrame: void <init>(boolean,int,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf)>(v, v, v);
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
label:
return;
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder: boolean frameFinalFlag>;
if v == 0 goto label;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder: int frameOpcode>;
if v == 9 goto label;
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder: int fragmentedFramesCount> = 0;
goto label;
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder: int fragmentedFramesCount>;
v = v + 1;
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder: int fragmentedFramesCount> = v;
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder: int frameOpcode>;
if v != 1 goto label;
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.TextWebSocketFrame;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder: boolean frameFinalFlag>;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder: int frameRsv>;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.TextWebSocketFrame: void <init>(boolean,int,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf)>(v, v, v);
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
label:
return;
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder: int frameOpcode>;
if v != 2 goto label;
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.BinaryWebSocketFrame;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder: boolean frameFinalFlag>;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder: int frameRsv>;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.BinaryWebSocketFrame: void <init>(boolean,int,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf)>(v, v, v);
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
label:
return;
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder: int frameOpcode>;
if v != 0 goto label;
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.ContinuationWebSocketFrame;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder: boolean frameFinalFlag>;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder: int frameRsv>;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.ContinuationWebSocketFrame: void <init>(boolean,int,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf)>(v, v, v);
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
label:
return;
label:
v = new java.lang.UnsupportedOperationException;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder: int frameOpcode>;
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[])>("Cannot decode web socket frame with opcode: \u0001");
specialinvoke v.<java.lang.UnsupportedOperationException: void <init>(java.lang.String)>(v);
throw v;
label:
v := @caughtexception;
if v == null goto label;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: boolean release()>();
label:
throw v;
label:
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: boolean isReadable()>();
if v == 0 goto label;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: byte readByte()>();
label:
return;
label:
v = new java.lang.Error;
specialinvoke v.<java.lang.Error: void <init>(java.lang.String)>("Shouldn\'t reach here.");
throw v;
catch java.lang.Throwable from label to label with label;
catch java.lang.Throwable from label to label with label;
catch java.lang.Throwable from label to label with label;
catch java.lang.Throwable from label to label with label;
catch java.lang.Throwable from label to label with label;
catch java.lang.Throwable from label to label with label;
}
private void unmask(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf)
{
byte[] v, v, v, v, v;
byte v, v, v, v, v, v, v;
java.nio.ByteOrder v, v;
short v, v, v, v;
int v, v, v, v, v, v, v, v, v, v, v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder;
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 readerIndex()>();
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: int writerIndex()>();
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: java.nio.ByteOrder order()>();
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder: byte[] maskingKey>;
v = v[0];
v = v & 255;
v = v << 24;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder: byte[] maskingKey>;
v = v[1];
v = v & 255;
v = v << 16;
v = v | v;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder: byte[] maskingKey>;
v = v[2];
v = v & 255;
v = v << 8;
v = v | v;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder: byte[] maskingKey>;
v = v[3];
v = v & 255;
v = v | v;
v = <java.nio.ByteOrder: java.nio.ByteOrder LITTLE_ENDIAN>;
if v != v goto label;
v = staticinvoke <java.lang.Integer: int reverseBytes(int)>(v);
label:
v = v + 3;
if v >= v goto label;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: int getInt(int)>(v);
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 setInt(int,int)>(v, v);
v = v + 4;
goto label;
label:
if v >= v goto label;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: byte getByte(int)>(v);
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder: byte[] maskingKey>;
v = v % 4;
v = v[v];
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 setByte(int,int)>(v, v);
v = v + 1;
goto label;
label:
return;
}
private void protocolViolation(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext, org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf, java.lang.String)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf v;
java.lang.String v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketCloseStatus v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf;
v := @parameter: java.lang.String;
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketCloseStatus: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketCloseStatus PROTOCOL_ERROR>;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder: void protocolViolation(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketCloseStatus,java.lang.String)>(v, v, v, v);
return;
}
private void protocolViolation(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext, org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf, org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketCloseStatus, java.lang.String)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf v;
java.lang.String v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.CorruptedWebSocketFrameException v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketCloseStatus v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketCloseStatus;
v := @parameter: java.lang.String;
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.CorruptedWebSocketFrameException;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.CorruptedWebSocketFrameException: void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketCloseStatus,java.lang.String)>(v, v);
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder: void protocolViolation(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.CorruptedWebSocketFrameException)>(v, v, v);
return;
}
private void protocolViolation(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext, org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf, org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.CorruptedWebSocketFrameException)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder$State v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFutureListener v;
int v;
java.lang.String v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext v;
boolean v, v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.CloseWebSocketFrame v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel 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.ReferenceCounted v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketDecoderConfig v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.CorruptedWebSocketFrameException v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketCloseStatus v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.CorruptedWebSocketFrameException;
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder$State: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder$State CORRUPT>;
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder$State state> = v;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: int readableBytes()>();
if v <= 0 goto 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)>(v);
label:
v = interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel channel()>();
v = interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel: boolean isActive()>();
if v == 0 goto label;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketDecoderConfig config>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketDecoderConfig: boolean closeOnProtocolViolation()>();
if v == 0 goto label;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder: boolean receivedClosingHandshake>;
if v == 0 goto label;
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.Unpooled: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf EMPTY_BUFFER>;
goto label;
label:
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.CorruptedWebSocketFrameException: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketCloseStatus closeStatus()>();
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.CorruptedWebSocketFrameException: java.lang.String getMessage()>();
if v != null goto label;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketCloseStatus: java.lang.String reasonText()>();
label:
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.CloseWebSocketFrame;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.CloseWebSocketFrame: void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketCloseStatus,java.lang.String)>(v, v);
v = v;
label:
v = interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture writeAndFlush(java.lang.Object)>(v);
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFutureListener: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFutureListener CLOSE>;
interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture addListener(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.GenericFutureListener)>(v);
label:
throw v;
}
private static int toFrameLength(long)
{
byte v;
long v;
java.lang.String v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.TooLongFrameException v;
v := @parameter: long;
v = v cmp 2147483647L;
if v <= 0 goto label;
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.TooLongFrameException;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (long)>(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[])>("Length:\u0001");
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.TooLongFrameException: void <init>(java.lang.String)>(v);
throw v;
label:
return v;
}
protected void checkCloseFrameBody(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext, org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf)
{
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.http.websocketx.Utf8Validator v;
short v;
int v, v;
java.lang.String v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.CorruptedWebSocketFrameException v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketCloseStatus v;
boolean v, v, v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf;
if v == null goto label;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: boolean isReadable()>();
if v != 0 goto label;
label:
return;
label:
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: int readableBytes()>();
if v != 1 goto label;
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketCloseStatus: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketCloseStatus INVALID_PAYLOAD_DATA>;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder: void protocolViolation(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketCloseStatus,java.lang.String)>(v, v, v, "Invalid close frame body");
label:
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: int readerIndex()>();
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)>(0);
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: short readShort()>();
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketCloseStatus: boolean isValidStatusCode(int)>(v);
if v != 0 goto label;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (short)>(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 close frame getStatus code: \u0001");
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder: void protocolViolation(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf,java.lang.String)>(v, v, v);
label:
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: boolean isReadable()>();
if v == 0 goto label;
label:
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.Utf8Validator;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.Utf8Validator: void <init>()>();
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.Utf8Validator: void check(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf)>(v);
label:
goto label;
label:
v := @caughtexception;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder: void protocolViolation(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.CorruptedWebSocketFrameException)>(v, v, 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 readerIndex(int)>(v);
return;
catch org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.CorruptedWebSocketFrameException from label to label with label;
}
static void <clinit>()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.logging.InternalLogger v;
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.logging.InternalLoggerFactory: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.logging.InternalLogger getInstance(java.lang.Class)>(class "Lorg/apache/hive/kudu/org/apache/kudu/shaded/io/netty/handler/codec/http/websocketx/WebSocket08FrameDecoder;");
<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.logging.InternalLogger logger> = v;
return;
}
}