public final class org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.redis.RedisBulkStringAggregator extends org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.MessageAggregator
{
public void <init>()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.redis.RedisBulkStringAggregator v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.redis.RedisBulkStringAggregator;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.MessageAggregator: void <init>(int)>(536870912);
return;
}
protected boolean isStartMessage(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.redis.RedisMessage) throws java.lang.Exception
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.redis.RedisMessage v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.redis.RedisBulkStringAggregator v;
boolean v, v, v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.redis.RedisBulkStringAggregator;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.redis.RedisMessage;
v = v instanceof org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.redis.BulkStringHeaderRedisMessage;
if v == 0 goto label;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.redis.RedisBulkStringAggregator: boolean isAggregated(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.redis.RedisMessage)>(v);
if v != 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
return v;
}
protected boolean isContentMessage(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.redis.RedisMessage) throws java.lang.Exception
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.redis.RedisMessage v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.redis.RedisBulkStringAggregator v;
boolean v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.redis.RedisBulkStringAggregator;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.redis.RedisMessage;
v = v instanceof org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.redis.BulkStringRedisContent;
return v;
}
protected boolean isLastContentMessage(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.redis.BulkStringRedisContent) throws java.lang.Exception
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.redis.BulkStringRedisContent v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.redis.RedisBulkStringAggregator v;
boolean v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.redis.RedisBulkStringAggregator;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.redis.BulkStringRedisContent;
v = v instanceof org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.redis.LastBulkStringRedisContent;
return v;
}
protected boolean isAggregated(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.redis.RedisMessage) throws java.lang.Exception
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.redis.RedisMessage v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.redis.RedisBulkStringAggregator v;
boolean v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.redis.RedisBulkStringAggregator;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.redis.RedisMessage;
v = v instanceof org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.redis.FullBulkStringRedisMessage;
return v;
}
protected boolean isContentLengthInvalid(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.redis.BulkStringHeaderRedisMessage, int) throws java.lang.Exception
{
int v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.redis.RedisBulkStringAggregator v;
boolean v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.redis.BulkStringHeaderRedisMessage v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.redis.RedisBulkStringAggregator;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.redis.BulkStringHeaderRedisMessage;
v := @parameter: int;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.redis.BulkStringHeaderRedisMessage: int bulkStringLength()>();
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.redis.BulkStringHeaderRedisMessage, int, org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPipeline) throws java.lang.Exception
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPipeline v;
int v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.redis.RedisBulkStringAggregator v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.redis.BulkStringHeaderRedisMessage v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.redis.RedisBulkStringAggregator;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.redis.BulkStringHeaderRedisMessage;
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.redis.RedisBulkStringAggregator v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.redis.RedisBulkStringAggregator;
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.redis.RedisBulkStringAggregator v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.redis.RedisBulkStringAggregator;
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.redis.FullBulkStringRedisMessage beginAggregation(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.redis.BulkStringHeaderRedisMessage, 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.redis.FullBulkStringRedisMessage 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.redis.RedisBulkStringAggregator v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.redis.BulkStringHeaderRedisMessage v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.redis.RedisBulkStringAggregator;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.redis.BulkStringHeaderRedisMessage;
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.redis.FullBulkStringRedisMessage;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.redis.FullBulkStringRedisMessage: void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf)>(v);
return v;
}
}