public final class io.netty.handler.codec.redis.RedisArrayAggregator extends io.netty.handler.codec.MessageToMessageDecoder<io.netty.handler.codec.redis.RedisMessage>
minor version: 0
major version: 59
flags: flags: (0x0031) ACC_PUBLIC, ACC_FINAL, ACC_SUPER
this_class: io.netty.handler.codec.redis.RedisArrayAggregator
super_class: io.netty.handler.codec.MessageToMessageDecoder
{
private final java.util.Deque<io.netty.handler.codec.redis.RedisArrayAggregator$AggregateState> depths;
descriptor: Ljava/util/Deque;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Ljava/util/Deque<Lio/netty/handler/codec/redis/RedisArrayAggregator$AggregateState;>;
public void <init>();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=1, args_size=1
start local 0 0: aload 0
invokespecial io.netty.handler.codec.MessageToMessageDecoder.<init>:()V
1: aload 0
new java.util.ArrayDeque
dup
iconst_4
invokespecial java.util.ArrayDeque.<init>:(I)V
putfield io.netty.handler.codec.redis.RedisArrayAggregator.depths:Ljava/util/Deque;
2: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/netty/handler/codec/redis/RedisArrayAggregator;
protected void decode(io.netty.channel.ChannelHandlerContext, io.netty.handler.codec.redis.RedisMessage, java.util.List<java.lang.Object>);
descriptor: (Lio/netty/channel/ChannelHandlerContext;Lio/netty/handler/codec/redis/RedisMessage;Ljava/util/List;)V
flags: (0x0004) ACC_PROTECTED
Code:
stack=3, locals=5, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 2
instanceof io.netty.handler.codec.redis.ArrayHeaderRedisMessage
ifeq 4
1: aload 0
aload 2
checkcast io.netty.handler.codec.redis.ArrayHeaderRedisMessage
invokevirtual io.netty.handler.codec.redis.RedisArrayAggregator.decodeRedisArrayHeader:(Lio/netty/handler/codec/redis/ArrayHeaderRedisMessage;)Lio/netty/handler/codec/redis/RedisMessage;
astore 2
2: aload 2
ifnonnull 13
3: return
4: StackMap locals:
StackMap stack:
aload 2
invokestatic io.netty.util.ReferenceCountUtil.retain:(Ljava/lang/Object;)Ljava/lang/Object;
pop
5: goto 13
6: StackMap locals:
StackMap stack:
aload 0
getfield io.netty.handler.codec.redis.RedisArrayAggregator.depths:Ljava/util/Deque;
invokeinterface java.util.Deque.peek:()Ljava/lang/Object;
checkcast io.netty.handler.codec.redis.RedisArrayAggregator$AggregateState
astore 4
start local 4 7: aload 4
getfield io.netty.handler.codec.redis.RedisArrayAggregator$AggregateState.children:Ljava/util/List;
aload 2
invokeinterface java.util.List.add:(Ljava/lang/Object;)Z
pop
8: aload 4
getfield io.netty.handler.codec.redis.RedisArrayAggregator$AggregateState.children:Ljava/util/List;
invokeinterface java.util.List.size:()I
aload 4
getfield io.netty.handler.codec.redis.RedisArrayAggregator$AggregateState.length:I
if_icmpne 12
9: new io.netty.handler.codec.redis.ArrayRedisMessage
dup
aload 4
getfield io.netty.handler.codec.redis.RedisArrayAggregator$AggregateState.children:Ljava/util/List;
invokespecial io.netty.handler.codec.redis.ArrayRedisMessage.<init>:(Ljava/util/List;)V
astore 2
10: aload 0
getfield io.netty.handler.codec.redis.RedisArrayAggregator.depths:Ljava/util/Deque;
invokeinterface java.util.Deque.pop:()Ljava/lang/Object;
pop
11: goto 13
12: StackMap locals: io.netty.handler.codec.redis.RedisArrayAggregator$AggregateState
StackMap stack:
return
end local 4 13: StackMap locals:
StackMap stack:
aload 0
getfield io.netty.handler.codec.redis.RedisArrayAggregator.depths:Ljava/util/Deque;
invokeinterface java.util.Deque.isEmpty:()Z
ifeq 6
14: aload 3
aload 2
invokeinterface java.util.List.add:(Ljava/lang/Object;)Z
pop
15: return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 16 0 this Lio/netty/handler/codec/redis/RedisArrayAggregator;
0 16 1 ctx Lio/netty/channel/ChannelHandlerContext;
0 16 2 msg Lio/netty/handler/codec/redis/RedisMessage;
0 16 3 out Ljava/util/List<Ljava/lang/Object;>;
7 13 4 current Lio/netty/handler/codec/redis/RedisArrayAggregator$AggregateState;
Exceptions:
throws java.lang.Exception
Signature: (Lio/netty/channel/ChannelHandlerContext;Lio/netty/handler/codec/redis/RedisMessage;Ljava/util/List<Ljava/lang/Object;>;)V
MethodParameters:
Name Flags
ctx
msg
out
private io.netty.handler.codec.redis.RedisMessage decodeRedisArrayHeader(io.netty.handler.codec.redis.ArrayHeaderRedisMessage);
descriptor: (Lio/netty/handler/codec/redis/ArrayHeaderRedisMessage;)Lio/netty/handler/codec/redis/RedisMessage;
flags: (0x0002) ACC_PRIVATE
Code:
stack=5, locals=2, args_size=2
start local 0 start local 1 0: aload 1
invokevirtual io.netty.handler.codec.redis.ArrayHeaderRedisMessage.isNull:()Z
ifeq 2
1: getstatic io.netty.handler.codec.redis.ArrayRedisMessage.NULL_INSTANCE:Lio/netty/handler/codec/redis/ArrayRedisMessage;
areturn
2: StackMap locals:
StackMap stack:
aload 1
invokevirtual io.netty.handler.codec.redis.ArrayHeaderRedisMessage.length:()J
lconst_0
lcmp
ifne 4
3: getstatic io.netty.handler.codec.redis.ArrayRedisMessage.EMPTY_INSTANCE:Lio/netty/handler/codec/redis/ArrayRedisMessage;
areturn
4: StackMap locals:
StackMap stack:
aload 1
invokevirtual io.netty.handler.codec.redis.ArrayHeaderRedisMessage.length:()J
lconst_0
lcmp
ifle 9
5: aload 1
invokevirtual io.netty.handler.codec.redis.ArrayHeaderRedisMessage.length:()J
ldc 2147483647
lcmp
ifle 7
6: new io.netty.handler.codec.CodecException
dup
ldc "this codec doesn't support longer length than 2147483647"
invokespecial io.netty.handler.codec.CodecException.<init>:(Ljava/lang/String;)V
athrow
7: StackMap locals:
StackMap stack:
aload 0
getfield io.netty.handler.codec.redis.RedisArrayAggregator.depths:Ljava/util/Deque;
new io.netty.handler.codec.redis.RedisArrayAggregator$AggregateState
dup
aload 1
invokevirtual io.netty.handler.codec.redis.ArrayHeaderRedisMessage.length:()J
l2i
invokespecial io.netty.handler.codec.redis.RedisArrayAggregator$AggregateState.<init>:(I)V
invokeinterface java.util.Deque.push:(Ljava/lang/Object;)V
8: aconst_null
areturn
9: StackMap locals:
StackMap stack:
new io.netty.handler.codec.CodecException
dup
new java.lang.StringBuilder
dup
ldc "bad length: "
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 1
invokevirtual io.netty.handler.codec.redis.ArrayHeaderRedisMessage.length:()J
invokevirtual java.lang.StringBuilder.append:(J)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokespecial io.netty.handler.codec.CodecException.<init>:(Ljava/lang/String;)V
athrow
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 10 0 this Lio/netty/handler/codec/redis/RedisArrayAggregator;
0 10 1 header Lio/netty/handler/codec/redis/ArrayHeaderRedisMessage;
MethodParameters:
Name Flags
header
protected void decode(io.netty.channel.ChannelHandlerContext, java.lang.Object, java.util.List);
descriptor: (Lio/netty/channel/ChannelHandlerContext;Ljava/lang/Object;Ljava/util/List;)V
flags: (0x1044) ACC_PROTECTED, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=4, locals=4, args_size=4
0: aload 0
aload 1
aload 2
checkcast io.netty.handler.codec.redis.RedisMessage
aload 3
invokevirtual io.netty.handler.codec.redis.RedisArrayAggregator.decode:(Lio/netty/channel/ChannelHandlerContext;Lio/netty/handler/codec/redis/RedisMessage;Ljava/util/List;)V
return
LocalVariableTable:
Start End Slot Name Signature
Exceptions:
throws java.lang.Exception
}
Signature: Lio/netty/handler/codec/MessageToMessageDecoder<Lio/netty/handler/codec/redis/RedisMessage;>;
SourceFile: "RedisArrayAggregator.java"
NestMembers:
io.netty.handler.codec.redis.RedisArrayAggregator$AggregateState
InnerClasses:
private final AggregateState = io.netty.handler.codec.redis.RedisArrayAggregator$AggregateState of io.netty.handler.codec.redis.RedisArrayAggregator