public class org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompSubframeDecoder extends org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.ReplayingDecoder
{
private static final int DEFAULT_CHUNK_SIZE;
private static final int DEFAULT_MAX_LINE_LENGTH;
private final org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompSubframeDecoder$Utf8LineParser commandParser;
private final org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompSubframeDecoder$HeaderParser headerParser;
private final int maxChunkSize;
private int alreadyReadChunkSize;
private org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.LastStompContentSubframe lastContent;
private long contentLength;
public void <init>()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompSubframeDecoder v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompSubframeDecoder;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompSubframeDecoder: void <init>(int,int)>(1024, 8132);
return;
}
public void <init>(boolean)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompSubframeDecoder v;
boolean v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompSubframeDecoder;
v := @parameter: boolean;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompSubframeDecoder: void <init>(int,int,boolean)>(1024, 8132, v);
return;
}
public void <init>(int, int)
{
int v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompSubframeDecoder v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompSubframeDecoder;
v := @parameter: int;
v := @parameter: int;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompSubframeDecoder: void <init>(int,int,boolean)>(v, v, 0);
return;
}
public void <init>(int, int, boolean)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.AppendableCharSequence v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompSubframeDecoder v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompSubframeDecoder$HeaderParser v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompSubframeDecoder$State v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompSubframeDecoder$Utf8LineParser v;
int v, v;
boolean v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompSubframeDecoder;
v := @parameter: int;
v := @parameter: int;
v := @parameter: boolean;
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompSubframeDecoder$State: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompSubframeDecoder$State SKIP_CONTROL_CHARACTERS>;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.ReplayingDecoder: void <init>(java.lang.Object)>(v);
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompSubframeDecoder: long contentLength> = -1L;
staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.ObjectUtil: int checkPositive(int,java.lang.String)>(v, "maxLineLength");
staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.ObjectUtil: int checkPositive(int,java.lang.String)>(v, "maxChunkSize");
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompSubframeDecoder: int maxChunkSize> = v;
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompSubframeDecoder$Utf8LineParser;
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.AppendableCharSequence;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.AppendableCharSequence: void <init>(int)>(16);
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompSubframeDecoder$Utf8LineParser: void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.AppendableCharSequence,int)>(v, v);
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompSubframeDecoder: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompSubframeDecoder$Utf8LineParser commandParser> = v;
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompSubframeDecoder$HeaderParser;
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.AppendableCharSequence;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.AppendableCharSequence: void <init>(int)>(128);
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompSubframeDecoder$HeaderParser: void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.AppendableCharSequence,int,boolean)>(v, v, v);
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompSubframeDecoder: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompSubframeDecoder$HeaderParser headerParser> = 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
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompSubframeDecoder$State v, v, v, v, v, v, v;
byte v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.DefaultStompContentSubframe v, v;
int[] v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.LastStompContentSubframe v, v, v;
java.lang.Exception v, v;
java.util.List v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.DefaultLastStompContentSubframe v, v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.DecoderResult v, v;
long v, v, v, v;
int 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.channel.ChannelHandlerContext v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompSubframeDecoder v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf v, v, v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.DefaultStompHeadersSubframe v, v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompCommand v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBufAllocator v, v;
java.lang.Object v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompHeaders v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompSubframeDecoder;
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 = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompSubframeDecoder$1: int[] $SwitchMap$io$netty$handler$codec$stomp$StompSubframeDecoder$State>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompSubframeDecoder: java.lang.Object state()>();
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompSubframeDecoder$State: int ordinal()>();
v = v[v];
tableswitch(v)
{
case 1: goto label;
case 2: goto label;
case 3: goto label;
default: goto label;
};
label:
staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompSubframeDecoder: void skipControlCharacters(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf)>(v);
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompSubframeDecoder$State: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompSubframeDecoder$State READ_HEADERS>;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompSubframeDecoder: void checkpoint(java.lang.Object)>(v);
label:
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompCommand: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompCommand UNKNOWN>;
v = null;
label:
v = specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompSubframeDecoder: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompCommand readCommand(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.stomp.DefaultStompHeadersSubframe;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.DefaultStompHeadersSubframe: void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompCommand)>(v);
v = v;
v = interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompHeadersSubframe: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompHeaders headers()>();
v = specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompSubframeDecoder: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompSubframeDecoder$State readHeaders(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompHeaders)>(v, v);
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompSubframeDecoder: void checkpoint(java.lang.Object)>(v);
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
label:
goto label;
label:
v := @caughtexception;
if v != null goto label;
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.DefaultStompHeadersSubframe;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.DefaultStompHeadersSubframe: void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompCommand)>(v);
v = v;
label:
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.DecoderResult: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.DecoderResult failure(java.lang.Throwable)>(v);
interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompHeadersSubframe: void setDecoderResult(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.DecoderResult)>(v);
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompSubframeDecoder$State: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompSubframeDecoder$State BAD_FRAME>;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompSubframeDecoder: void checkpoint(java.lang.Object)>(v);
return;
label:
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompSubframeDecoder: 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.stomp.StompSubframeDecoder$1: int[] $SwitchMap$io$netty$handler$codec$stomp$StompSubframeDecoder$State>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompSubframeDecoder: java.lang.Object state()>();
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompSubframeDecoder$State: int ordinal()>();
v = v[v];
lookupswitch(v)
{
case 4: goto label;
case 5: goto label;
default: goto label;
};
label:
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: int readableBytes()>();
if v != 0 goto label;
label:
return;
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompSubframeDecoder: int maxChunkSize>;
if v <= v goto label;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompSubframeDecoder: int maxChunkSize>;
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompSubframeDecoder: long contentLength>;
v = v cmp 0L;
if v < 0 goto label;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompSubframeDecoder: long contentLength>;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompSubframeDecoder: int alreadyReadChunkSize>;
v = v - v;
if v <= v goto label;
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.buffer.ByteBufAllocator alloc()>();
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 = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompSubframeDecoder: int alreadyReadChunkSize>;
v = v + v;
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompSubframeDecoder: int alreadyReadChunkSize> = v;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompSubframeDecoder: long contentLength>;
v = v cmp v;
if v < 0 goto label;
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.DefaultLastStompContentSubframe;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.DefaultLastStompContentSubframe: void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf)>(v);
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompSubframeDecoder: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.LastStompContentSubframe lastContent> = v;
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompSubframeDecoder$State: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompSubframeDecoder$State FINALIZE_FRAME_READ>;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompSubframeDecoder: void checkpoint(java.lang.Object)>(v);
goto label;
label:
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.DefaultStompContentSubframe;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.DefaultStompContentSubframe: void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf)>(v);
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
label:
return;
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: int writerIndex()>();
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBufUtil: int indexOf(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf,int,int,byte)>(v, v, v, 0);
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: int readerIndex()>();
if v != v goto label;
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompSubframeDecoder$State: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompSubframeDecoder$State FINALIZE_FRAME_READ>;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompSubframeDecoder: void checkpoint(java.lang.Object)>(v);
goto label;
label:
if v <= 0 goto label;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: int readerIndex()>();
v = v - v;
goto label;
label:
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: int readerIndex()>();
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.buffer.ByteBufAllocator alloc()>();
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 = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompSubframeDecoder: int alreadyReadChunkSize>;
v = v + v;
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompSubframeDecoder: int alreadyReadChunkSize> = v;
if v <= 0 goto label;
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.DefaultLastStompContentSubframe;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.DefaultLastStompContentSubframe: void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf)>(v);
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompSubframeDecoder: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.LastStompContentSubframe lastContent> = v;
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompSubframeDecoder$State: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompSubframeDecoder$State FINALIZE_FRAME_READ>;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompSubframeDecoder: void checkpoint(java.lang.Object)>(v);
goto label;
label:
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.DefaultStompContentSubframe;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.DefaultStompContentSubframe: void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf)>(v);
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
label:
return;
label:
staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompSubframeDecoder: void skipNullCharacter(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf)>(v);
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompSubframeDecoder: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.LastStompContentSubframe lastContent>;
if v != null goto label;
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.LastStompContentSubframe: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.LastStompContentSubframe EMPTY_LAST_CONTENT>;
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompSubframeDecoder: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.LastStompContentSubframe lastContent> = v;
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompSubframeDecoder: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.LastStompContentSubframe lastContent>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompSubframeDecoder: void resetDecoder()>();
label:
goto label;
label:
v := @caughtexception;
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.DefaultLastStompContentSubframe;
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>;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.DefaultLastStompContentSubframe: void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf)>(v);
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.DecoderResult: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.DecoderResult failure(java.lang.Throwable)>(v);
interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompContentSubframe: void setDecoderResult(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.DecoderResult)>(v);
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompSubframeDecoder$State: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompSubframeDecoder$State BAD_FRAME>;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompSubframeDecoder: void checkpoint(java.lang.Object)>(v);
label:
return;
catch java.lang.Exception from label to label with label;
catch java.lang.Exception from label to label with label;
catch java.lang.Exception from label to label with label;
catch java.lang.Exception from label to label with label;
catch java.lang.Exception from label to label with label;
}
private org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompCommand readCommand(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.AppendableCharSequence v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompSubframeDecoder v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf v;
java.lang.IllegalArgumentException v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompCommand v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompSubframeDecoder$Utf8LineParser v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.DecoderException v, v;
java.lang.String v, v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompSubframeDecoder;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompSubframeDecoder: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompSubframeDecoder$Utf8LineParser commandParser>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompSubframeDecoder$Utf8LineParser: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.AppendableCharSequence parse(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf)>(v);
if v != null goto label;
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.DecoderException;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.DecoderException: void <init>(java.lang.String)>("Failed to read command from channel");
throw v;
label:
v = virtualinvoke v.<java.lang.Object: java.lang.String toString()>();
label:
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompCommand: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompCommand valueOf(java.lang.String)>(v);
label:
return v;
label:
v := @caughtexception;
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.DecoderException;
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[])>("Cannot to parse command \u0001");
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.DecoderException: void <init>(java.lang.String)>(v);
throw v;
catch java.lang.IllegalArgumentException from label to label with label;
}
private org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompSubframeDecoder$State readHeaders(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf, org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompHeaders)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompSubframeDecoder v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompSubframeDecoder$HeaderParser 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.stomp.StompSubframeDecoder$State v, v;
long v, v;
byte v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.AsciiString v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompHeaders v;
boolean v, v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompSubframeDecoder;
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.stomp.StompHeaders;
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompSubframeDecoder: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompSubframeDecoder$HeaderParser headerParser>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompSubframeDecoder$HeaderParser: boolean parseHeader(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompHeaders,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf)>(v, v);
if v != 0 goto label;
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompHeaders: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.AsciiString CONTENT_LENGTH>;
v = interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompHeaders: boolean contains(java.lang.Object)>(v);
if v == 0 goto label;
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompSubframeDecoder: long getContentLength(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompHeaders)>(v);
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompSubframeDecoder: long contentLength> = v;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompSubframeDecoder: long contentLength>;
v = v cmp 0L;
if v != 0 goto label;
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompSubframeDecoder$State: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompSubframeDecoder$State FINALIZE_FRAME_READ>;
return v;
label:
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompSubframeDecoder$State: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompSubframeDecoder$State READ_CONTENT>;
return v;
}
private static long getContentLength(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompHeaders)
{
byte v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.AsciiString v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.DecoderException v;
long v;
java.lang.String v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompHeaders v;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompHeaders;
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompHeaders: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.AsciiString CONTENT_LENGTH>;
v = interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompHeaders: long getLong(java.lang.Object,long)>(v, 0L);
v = v cmp 0L;
if v >= 0 goto label;
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.DecoderException;
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompHeaders: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.AsciiString CONTENT_LENGTH>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.AsciiString)>(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[])>("\u must be non-negative");
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.DecoderException: void <init>(java.lang.String)>(v);
throw v;
label:
return v;
}
private static void skipNullCharacter(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf)
{
java.lang.IllegalStateException v;
byte v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf v;
java.lang.String 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: byte readByte()>();
if v == 0 goto label;
v = new java.lang.IllegalStateException;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (byte)>(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[])>("unexpected byte in buffer \u while expecting NULL byte");
specialinvoke v.<java.lang.IllegalStateException: void <init>(java.lang.String)>(v);
throw v;
label:
return;
}
private static void skipControlCharacters(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf)
{
byte v;
int v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf v;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf;
label:
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: byte readByte()>();
if v == 13 goto label;
if v == 10 goto label;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: int readerIndex()>();
v = v - 1;
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;
}
private void resetDecoder()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompSubframeDecoder$State v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompSubframeDecoder v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompSubframeDecoder;
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompSubframeDecoder$State: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompSubframeDecoder$State SKIP_CONTROL_CHARACTERS>;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompSubframeDecoder: void checkpoint(java.lang.Object)>(v);
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompSubframeDecoder: long contentLength> = -1L;
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompSubframeDecoder: int alreadyReadChunkSize> = 0;
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompSubframeDecoder: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.LastStompContentSubframe lastContent> = null;
return;
}
}