public class org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompSubframeAggregator extends org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.MessageAggregator
{
public void <init>(int)
{
int v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompSubframeAggregator v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompSubframeAggregator;
v := @parameter: int;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.MessageAggregator: void <init>(int)>(v);
return;
}
protected boolean isStartMessage(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompSubframe) throws java.lang.Exception
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompSubframe v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompSubframeAggregator v;
boolean v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompSubframeAggregator;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompSubframe;
v = v instanceof org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompHeadersSubframe;
return v;
}
protected boolean isContentMessage(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompSubframe) throws java.lang.Exception
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompSubframe v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompSubframeAggregator v;
boolean v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompSubframeAggregator;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompSubframe;
v = v instanceof org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompContentSubframe;
return v;
}
protected boolean isLastContentMessage(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompContentSubframe) throws java.lang.Exception
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompContentSubframe v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompSubframeAggregator v;
boolean v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompSubframeAggregator;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompContentSubframe;
v = v instanceof org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.LastStompContentSubframe;
return v;
}
protected boolean isAggregated(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompSubframe) throws java.lang.Exception
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompSubframe v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompSubframeAggregator v;
boolean v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompSubframeAggregator;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompSubframe;
v = v instanceof org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompFrame;
return v;
}
protected boolean isContentLengthInvalid(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompHeadersSubframe, int)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompSubframeAggregator v;
long v, 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.StompHeadersSubframe v;
int v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompHeaders v;
boolean v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompSubframeAggregator;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompHeadersSubframe;
v := @parameter: int;
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 = <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, -1L);
v = staticinvoke <java.lang.Math: long min(long,long)>(2147483647L, v);
if v <= v goto label;
v = 1;
goto label;
label:
v = 0;
label:
return v;
}
protected java.lang.Object newContinueResponse(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompHeadersSubframe, int, org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPipeline)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPipeline v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompSubframeAggregator v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompHeadersSubframe v;
int v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompSubframeAggregator;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompHeadersSubframe;
v := @parameter: int;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPipeline;
return null;
}
protected boolean closeAfterContinueResponse(java.lang.Object) throws java.lang.Exception
{
java.lang.UnsupportedOperationException v;
java.lang.Object v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompSubframeAggregator v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompSubframeAggregator;
v := @parameter: java.lang.Object;
v = new java.lang.UnsupportedOperationException;
specialinvoke v.<java.lang.UnsupportedOperationException: void <init>()>();
throw v;
}
protected boolean ignoreContentAfterContinueResponse(java.lang.Object) throws java.lang.Exception
{
java.lang.UnsupportedOperationException v;
java.lang.Object v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompSubframeAggregator v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompSubframeAggregator;
v := @parameter: java.lang.Object;
v = new java.lang.UnsupportedOperationException;
specialinvoke v.<java.lang.UnsupportedOperationException: void <init>()>();
throw v;
}
protected org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompFrame beginAggregation(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompHeadersSubframe, org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf) throws java.lang.Exception
{
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.DefaultStompFrame v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompSubframeAggregator v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompHeadersSubframe 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.StompHeaders v, v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompSubframeAggregator;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompHeadersSubframe;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf;
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.DefaultStompFrame;
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.StompCommand command()>();
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.DefaultStompFrame: void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompCommand,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf)>(v, v);
v = interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompFrame: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.stomp.StompHeaders headers()>();
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()>();
interfaceinvoke 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.handler.codec.Headers set(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.Headers)>(v);
return v;
}
}