public class org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.FixedLengthFrameDecoder extends org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.ByteToMessageDecoder
{
private final int frameLength;
public void <init>(int)
{
int v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.FixedLengthFrameDecoder v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.FixedLengthFrameDecoder;
v := @parameter: int;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.ByteToMessageDecoder: void <init>()>();
staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.ObjectUtil: int checkPositive(int,java.lang.String)>(v, "frameLength");
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.FixedLengthFrameDecoder: int frameLength> = v;
return;
}
protected final 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
{
java.util.List v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.FixedLengthFrameDecoder v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf v;
java.lang.Object v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.FixedLengthFrameDecoder;
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 = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.FixedLengthFrameDecoder: java.lang.Object 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)>(v, v);
if v == null goto label;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
label:
return;
}
protected java.lang.Object 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) throws java.lang.Exception
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.FixedLengthFrameDecoder v;
int v, v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.FixedLengthFrameDecoder;
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 = 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.FixedLengthFrameDecoder: int frameLength>;
if v >= v goto label;
return null;
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.FixedLengthFrameDecoder: int frameLength>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf readRetainedSlice(int)>(v);
return v;
}
}