public class io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder extends io.netty.channel.ChannelInboundHandlerAdapter
minor version: 0
major version: 59
flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
this_class: io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder
super_class: io.netty.channel.ChannelInboundHandlerAdapter
{
private final java.util.Deque<io.reactiverse.pgclient.impl.CommandBase<?>> inflight;
descriptor: Ljava/util/Deque;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Ljava/util/Deque<Lio/reactiverse/pgclient/impl/CommandBase<*>;>;
private final io.netty.buffer.ByteBufAllocator alloc;
descriptor: Lio/netty/buffer/ByteBufAllocator;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private io.vertx.core.Handler<? super io.reactiverse.pgclient.impl.CommandResponse<?>> commandResponseHandler;
descriptor: Lio/vertx/core/Handler;
flags: (0x0002) ACC_PRIVATE
Signature: Lio/vertx/core/Handler<-Lio/reactiverse/pgclient/impl/CommandResponse<*>;>;
private io.vertx.core.Handler<io.reactiverse.pgclient.impl.codec.decoder.NoticeResponse> noticeHandler;
descriptor: Lio/vertx/core/Handler;
flags: (0x0002) ACC_PRIVATE
Signature: Lio/vertx/core/Handler<Lio/reactiverse/pgclient/impl/codec/decoder/NoticeResponse;>;
private io.netty.buffer.ByteBuf in;
descriptor: Lio/netty/buffer/ByteBuf;
flags: (0x0002) ACC_PRIVATE
private static final byte I;
descriptor: B
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
ConstantValue: 73
private static final byte T;
descriptor: B
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
ConstantValue: 84
private io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder$CommandCompleteProcessor processor;
descriptor: Lio/reactiverse/pgclient/impl/codec/decoder/MessageDecoder$CommandCompleteProcessor;
flags: (0x0002) ACC_PRIVATE
public void <init>(java.util.Deque<io.reactiverse.pgclient.impl.CommandBase<?>>, io.netty.buffer.ByteBufAllocator);
descriptor: (Ljava/util/Deque;Lio/netty/buffer/ByteBufAllocator;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
invokespecial io.netty.channel.ChannelInboundHandlerAdapter.<init>:()V
1: aload 0
new io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder$CommandCompleteProcessor
dup
invokespecial io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder$CommandCompleteProcessor.<init>:()V
putfield io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder.processor:Lio/reactiverse/pgclient/impl/codec/decoder/MessageDecoder$CommandCompleteProcessor;
2: aload 0
aload 1
putfield io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder.inflight:Ljava/util/Deque;
3: aload 0
aload 2
putfield io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder.alloc:Lio/netty/buffer/ByteBufAllocator;
4: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lio/reactiverse/pgclient/impl/codec/decoder/MessageDecoder;
0 5 1 inflight Ljava/util/Deque<Lio/reactiverse/pgclient/impl/CommandBase<*>;>;
0 5 2 alloc Lio/netty/buffer/ByteBufAllocator;
Signature: (Ljava/util/Deque<Lio/reactiverse/pgclient/impl/CommandBase<*>;>;Lio/netty/buffer/ByteBufAllocator;)V
MethodParameters:
Name Flags
inflight
alloc
public void run(io.reactiverse.pgclient.impl.CommandBase<?>);
descriptor: (Lio/reactiverse/pgclient/impl/CommandBase;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 1
aload 0
getfield io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder.commandResponseHandler:Lio/vertx/core/Handler;
putfield io.reactiverse.pgclient.impl.CommandBase.completionHandler:Lio/vertx/core/Handler;
1: aload 1
aload 0
getfield io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder.noticeHandler:Lio/vertx/core/Handler;
putfield io.reactiverse.pgclient.impl.CommandBase.noticeHandler:Lio/vertx/core/Handler;
2: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/reactiverse/pgclient/impl/codec/decoder/MessageDecoder;
0 3 1 cmd Lio/reactiverse/pgclient/impl/CommandBase<*>;
Signature: (Lio/reactiverse/pgclient/impl/CommandBase<*>;)V
MethodParameters:
Name Flags
cmd
public void handlerAdded(io.netty.channel.ChannelHandlerContext);
descriptor: (Lio/netty/channel/ChannelHandlerContext;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
dup
invokevirtual java.lang.Object.getClass:()Ljava/lang/Class;
pop
invokedynamic handle(Lio/netty/channel/ChannelHandlerContext;)Lio/vertx/core/Handler;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)V
io/netty/channel/ChannelHandlerContext.fireChannelRead(Ljava/lang/Object;)Lio/netty/channel/ChannelHandlerContext; (9 itf)
(Lio/reactiverse/pgclient/impl/CommandResponse;)V
putfield io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder.commandResponseHandler:Lio/vertx/core/Handler;
1: aload 0
aload 1
dup
invokevirtual java.lang.Object.getClass:()Ljava/lang/Class;
pop
invokedynamic handle(Lio/netty/channel/ChannelHandlerContext;)Lio/vertx/core/Handler;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)V
io/netty/channel/ChannelHandlerContext.fireChannelRead(Ljava/lang/Object;)Lio/netty/channel/ChannelHandlerContext; (9 itf)
(Lio/reactiverse/pgclient/impl/codec/decoder/NoticeResponse;)V
putfield io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder.noticeHandler:Lio/vertx/core/Handler;
2: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/reactiverse/pgclient/impl/codec/decoder/MessageDecoder;
0 3 1 ctx Lio/netty/channel/ChannelHandlerContext;
Exceptions:
throws java.lang.Exception
MethodParameters:
Name Flags
ctx
public void channelRead(io.netty.channel.ChannelHandlerContext, java.lang.Object);
descriptor: (Lio/netty/channel/ChannelHandlerContext;Ljava/lang/Object;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=11, args_size=3
start local 0 start local 1 start local 2 0: aload 2
checkcast io.netty.buffer.ByteBuf
astore 3
start local 3 1: aload 0
getfield io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder.in:Lio/netty/buffer/ByteBuf;
ifnonnull 4
2: aload 0
aload 3
putfield io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder.in:Lio/netty/buffer/ByteBuf;
3: goto 11
4: StackMap locals: io.netty.buffer.ByteBuf
StackMap stack:
aload 0
getfield io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder.in:Lio/netty/buffer/ByteBuf;
instanceof io.netty.buffer.CompositeByteBuf
ifeq 7
5: aload 0
getfield io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder.in:Lio/netty/buffer/ByteBuf;
checkcast io.netty.buffer.CompositeByteBuf
astore 4
start local 4 6: goto 10
end local 4 7: StackMap locals:
StackMap stack:
aload 0
getfield io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder.alloc:Lio/netty/buffer/ByteBufAllocator;
invokeinterface io.netty.buffer.ByteBufAllocator.compositeBuffer:()Lio/netty/buffer/CompositeByteBuf;
astore 4
start local 4 8: aload 4
iconst_1
aload 0
getfield io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder.in:Lio/netty/buffer/ByteBuf;
invokevirtual io.netty.buffer.CompositeByteBuf.addComponent:(ZLio/netty/buffer/ByteBuf;)Lio/netty/buffer/CompositeByteBuf;
pop
9: aload 0
aload 4
putfield io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder.in:Lio/netty/buffer/ByteBuf;
10: StackMap locals: io.netty.buffer.CompositeByteBuf
StackMap stack:
aload 4
iconst_1
aload 3
invokevirtual io.netty.buffer.CompositeByteBuf.addComponent:(ZLio/netty/buffer/ByteBuf;)Lio/netty/buffer/CompositeByteBuf;
pop
end local 4 11: StackMap locals:
StackMap stack:
aload 0
getfield io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder.in:Lio/netty/buffer/ByteBuf;
invokevirtual io.netty.buffer.ByteBuf.readableBytes:()I
istore 4
start local 4 12: iload 4
iconst_5
if_icmpge 14
13: goto 38
14: StackMap locals: int
StackMap stack:
aload 0
getfield io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder.in:Lio/netty/buffer/ByteBuf;
invokevirtual io.netty.buffer.ByteBuf.readerIndex:()I
istore 5
start local 5 15: aload 0
getfield io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder.in:Lio/netty/buffer/ByteBuf;
iload 5
iconst_1
iadd
invokevirtual io.netty.buffer.ByteBuf.getInt:(I)I
istore 6
start local 6 16: iload 6
iconst_1
iadd
iload 4
if_icmple 18
17: goto 38
18: StackMap locals: int int
StackMap stack:
aload 0
getfield io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder.in:Lio/netty/buffer/ByteBuf;
iload 5
invokevirtual io.netty.buffer.ByteBuf.getByte:(I)B
istore 7
start local 7 19: iload 5
iload 6
iadd
iconst_1
iadd
istore 8
start local 8 20: aload 0
getfield io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder.in:Lio/netty/buffer/ByteBuf;
invokevirtual io.netty.buffer.ByteBuf.writerIndex:()I
istore 9
start local 9 21: aload 0
getfield io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder.in:Lio/netty/buffer/ByteBuf;
iload 5
iconst_5
iadd
iload 8
invokevirtual io.netty.buffer.ByteBuf.setIndex:(II)Lio/netty/buffer/ByteBuf;
pop
22: iload 7
lookupswitch { // 4
50: 29
67: 27
68: 25
90: 23
default: 31
}
23: StackMap locals: int int int
StackMap stack:
aload 0
aload 0
getfield io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder.in:Lio/netty/buffer/ByteBuf;
invokevirtual io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder.decodeReadyForQuery:(Lio/netty/buffer/ByteBuf;)V
24: goto 36
25: StackMap locals:
StackMap stack:
aload 0
aload 0
getfield io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder.in:Lio/netty/buffer/ByteBuf;
invokevirtual io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder.decodeDataRow:(Lio/netty/buffer/ByteBuf;)V
26: goto 36
27: StackMap locals:
StackMap stack:
aload 0
aload 0
getfield io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder.in:Lio/netty/buffer/ByteBuf;
invokevirtual io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder.decodeCommandComplete:(Lio/netty/buffer/ByteBuf;)V
28: goto 36
29: StackMap locals:
StackMap stack:
aload 0
invokevirtual io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder.decodeBindComplete:()V
30: goto 36
31: StackMap locals:
StackMap stack:
aload 0
aload 1
iload 7
aload 0
getfield io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder.in:Lio/netty/buffer/ByteBuf;
invokevirtual io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder.decodeMessage:(Lio/netty/channel/ChannelHandlerContext;BLio/netty/buffer/ByteBuf;)V
32: goto 36
StackMap locals:
StackMap stack: java.lang.Throwable
33: astore 10
34: aload 0
getfield io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder.in:Lio/netty/buffer/ByteBuf;
iload 8
iload 9
invokevirtual io.netty.buffer.ByteBuf.setIndex:(II)Lio/netty/buffer/ByteBuf;
pop
35: aload 10
athrow
36: StackMap locals:
StackMap stack:
aload 0
getfield io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder.in:Lio/netty/buffer/ByteBuf;
iload 8
iload 9
invokevirtual io.netty.buffer.ByteBuf.setIndex:(II)Lio/netty/buffer/ByteBuf;
pop
end local 9 end local 8 end local 7 end local 6 end local 5 end local 4 37: goto 11
38: StackMap locals: io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder io.netty.channel.ChannelHandlerContext java.lang.Object io.netty.buffer.ByteBuf
StackMap stack:
aload 0
getfield io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder.in:Lio/netty/buffer/ByteBuf;
ifnull 41
aload 0
getfield io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder.in:Lio/netty/buffer/ByteBuf;
invokevirtual io.netty.buffer.ByteBuf.isReadable:()Z
ifne 41
39: aload 0
getfield io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder.in:Lio/netty/buffer/ByteBuf;
invokevirtual io.netty.buffer.ByteBuf.release:()Z
pop
40: aload 0
aconst_null
putfield io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder.in:Lio/netty/buffer/ByteBuf;
41: StackMap locals:
StackMap stack:
return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 42 0 this Lio/reactiverse/pgclient/impl/codec/decoder/MessageDecoder;
0 42 1 ctx Lio/netty/channel/ChannelHandlerContext;
0 42 2 msg Ljava/lang/Object;
1 42 3 buff Lio/netty/buffer/ByteBuf;
6 7 4 composite Lio/netty/buffer/CompositeByteBuf;
8 11 4 composite Lio/netty/buffer/CompositeByteBuf;
12 37 4 available I
15 37 5 beginIdx I
16 37 6 length I
19 37 7 id B
20 37 8 endIdx I
21 37 9 writerIndex I
Exception table:
from to target type
21 33 33 any
MethodParameters:
Name Flags
ctx
msg
private void decodeMessage(io.netty.channel.ChannelHandlerContext, byte, io.netty.buffer.ByteBuf);
descriptor: (Lio/netty/channel/ChannelHandlerContext;BLio/netty/buffer/ByteBuf;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=3, locals=4, args_size=4
start local 0 start local 1 start local 2 start local 3 0: iload 2
lookupswitch { // 13
49: 11
51: 13
65: 25
69: 3
73: 9
75: 23
78: 5
82: 7
83: 21
84: 1
110: 15
115: 17
116: 19
default: 27
}
1: StackMap locals:
StackMap stack:
aload 0
aload 3
invokevirtual io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder.decodeRowDescription:(Lio/netty/buffer/ByteBuf;)V
2: goto 28
3: StackMap locals:
StackMap stack:
aload 0
aload 3
invokevirtual io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder.decodeError:(Lio/netty/buffer/ByteBuf;)V
4: goto 28
5: StackMap locals:
StackMap stack:
aload 0
aload 3
invokevirtual io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder.decodeNotice:(Lio/netty/buffer/ByteBuf;)V
6: goto 28
7: StackMap locals:
StackMap stack:
aload 0
aload 3
invokevirtual io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder.decodeAuthentication:(Lio/netty/buffer/ByteBuf;)V
8: goto 28
9: StackMap locals:
StackMap stack:
aload 0
invokevirtual io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder.decodeEmptyQueryResponse:()V
10: goto 28
11: StackMap locals:
StackMap stack:
aload 0
invokevirtual io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder.decodeParseComplete:()V
12: goto 28
13: StackMap locals:
StackMap stack:
aload 0
invokevirtual io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder.decodeCloseComplete:()V
14: goto 28
15: StackMap locals:
StackMap stack:
aload 0
invokevirtual io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder.decodeNoData:()V
16: goto 28
17: StackMap locals:
StackMap stack:
aload 0
invokevirtual io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder.decodePortalSuspended:()V
18: goto 28
19: StackMap locals:
StackMap stack:
aload 0
aload 3
invokevirtual io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder.decodeParameterDescription:(Lio/netty/buffer/ByteBuf;)V
20: goto 28
21: StackMap locals:
StackMap stack:
aload 0
aload 3
invokevirtual io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder.decodeParameterStatus:(Lio/netty/buffer/ByteBuf;)V
22: goto 28
23: StackMap locals:
StackMap stack:
aload 0
aload 3
invokevirtual io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder.decodeBackendKeyData:(Lio/netty/buffer/ByteBuf;)V
24: goto 28
25: StackMap locals:
StackMap stack:
aload 0
aload 1
aload 3
invokevirtual io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder.decodeNotificationResponse:(Lio/netty/channel/ChannelHandlerContext;Lio/netty/buffer/ByteBuf;)V
26: goto 28
27: StackMap locals:
StackMap stack:
new java.lang.UnsupportedOperationException
dup
invokespecial java.lang.UnsupportedOperationException.<init>:()V
athrow
28: StackMap locals:
StackMap stack:
return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 29 0 this Lio/reactiverse/pgclient/impl/codec/decoder/MessageDecoder;
0 29 1 ctx Lio/netty/channel/ChannelHandlerContext;
0 29 2 id B
0 29 3 in Lio/netty/buffer/ByteBuf;
MethodParameters:
Name Flags
ctx
id
in
private void decodePortalSuspended();
descriptor: ()V
flags: (0x0002) ACC_PRIVATE
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder.inflight:Ljava/util/Deque;
invokeinterface java.util.Deque.peek:()Ljava/lang/Object;
checkcast io.reactiverse.pgclient.impl.CommandBase
invokevirtual io.reactiverse.pgclient.impl.CommandBase.handlePortalSuspended:()V
1: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/reactiverse/pgclient/impl/codec/decoder/MessageDecoder;
private void decodeCommandComplete(io.netty.buffer.ByteBuf);
descriptor: (Lio/netty/buffer/ByteBuf;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=2, locals=3, args_size=2
start local 0 start local 1 0: aload 0
getfield io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder.processor:Lio/reactiverse/pgclient/impl/codec/decoder/MessageDecoder$CommandCompleteProcessor;
aload 1
invokevirtual io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder$CommandCompleteProcessor.parse:(Lio/netty/buffer/ByteBuf;)I
istore 2
start local 2 1: aload 0
getfield io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder.inflight:Ljava/util/Deque;
invokeinterface java.util.Deque.peek:()Ljava/lang/Object;
checkcast io.reactiverse.pgclient.impl.CommandBase
iload 2
invokevirtual io.reactiverse.pgclient.impl.CommandBase.handleCommandComplete:(I)V
2: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/reactiverse/pgclient/impl/codec/decoder/MessageDecoder;
0 3 1 in Lio/netty/buffer/ByteBuf;
1 3 2 updated I
MethodParameters:
Name Flags
in
private void decodeDataRow(io.netty.buffer.ByteBuf);
descriptor: (Lio/netty/buffer/ByteBuf;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=3, locals=4, args_size=2
start local 0 start local 1 0: aload 0
getfield io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder.inflight:Ljava/util/Deque;
invokeinterface java.util.Deque.peek:()Ljava/lang/Object;
checkcast io.reactiverse.pgclient.impl.QueryCommandBase
astore 2
start local 2 1: aload 1
invokevirtual io.netty.buffer.ByteBuf.readUnsignedShort:()I
istore 3
start local 3 2: aload 2
getfield io.reactiverse.pgclient.impl.QueryCommandBase.decoder:Lio/reactiverse/pgclient/impl/RowResultDecoder;
iload 3
aload 1
invokevirtual io.reactiverse.pgclient.impl.RowResultDecoder.decodeRow:(ILio/netty/buffer/ByteBuf;)V
3: return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lio/reactiverse/pgclient/impl/codec/decoder/MessageDecoder;
0 4 1 in Lio/netty/buffer/ByteBuf;
1 4 2 cmd Lio/reactiverse/pgclient/impl/QueryCommandBase<*>;
2 4 3 len I
MethodParameters:
Name Flags
in
private void decodeRowDescription(io.netty.buffer.ByteBuf);
descriptor: (Lio/netty/buffer/ByteBuf;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=9, locals=12, args_size=2
start local 0 start local 1 0: aload 1
invokevirtual io.netty.buffer.ByteBuf.readUnsignedShort:()I
anewarray io.reactiverse.pgclient.impl.codec.ColumnDesc
astore 2
start local 2 1: iconst_0
istore 3
start local 3 2: goto 21
3: StackMap locals: io.reactiverse.pgclient.impl.codec.ColumnDesc[] int
StackMap stack:
aload 1
invokestatic io.reactiverse.pgclient.impl.codec.util.Util.readCStringUTF8:(Lio/netty/buffer/ByteBuf;)Ljava/lang/String;
astore 4
start local 4 4: aload 1
invokevirtual io.netty.buffer.ByteBuf.readInt:()I
istore 5
start local 5 5: aload 1
invokevirtual io.netty.buffer.ByteBuf.readShort:()S
istore 6
start local 6 6: aload 1
invokevirtual io.netty.buffer.ByteBuf.readInt:()I
istore 7
start local 7 7: aload 1
invokevirtual io.netty.buffer.ByteBuf.readShort:()S
istore 8
start local 8 8: aload 1
invokevirtual io.netty.buffer.ByteBuf.readInt:()I
istore 9
start local 9 9: aload 1
invokevirtual io.netty.buffer.ByteBuf.readUnsignedShort:()I
istore 10
start local 10 10: new io.reactiverse.pgclient.impl.codec.ColumnDesc
dup
11: aload 4
12: iload 5
13: iload 6
14: iload 7
invokestatic io.reactiverse.pgclient.impl.codec.DataType.valueOf:(I)Lio/reactiverse/pgclient/impl/codec/DataType;
15: iload 8
16: iload 9
17: iload 10
invokestatic io.reactiverse.pgclient.impl.codec.DataFormat.valueOf:(I)Lio/reactiverse/pgclient/impl/codec/DataFormat;
18: invokespecial io.reactiverse.pgclient.impl.codec.ColumnDesc.<init>:(Ljava/lang/String;ISLio/reactiverse/pgclient/impl/codec/DataType;SILio/reactiverse/pgclient/impl/codec/DataFormat;)V
astore 11
start local 11 19: aload 2
iload 3
aload 11
aastore
end local 11 end local 10 end local 9 end local 8 end local 7 end local 6 end local 5 end local 4 20: iinc 3 1
StackMap locals:
StackMap stack:
21: iload 3
aload 2
arraylength
if_icmplt 3
end local 3 22: new io.reactiverse.pgclient.impl.codec.decoder.RowDescription
dup
aload 2
invokespecial io.reactiverse.pgclient.impl.codec.decoder.RowDescription.<init>:([Lio/reactiverse/pgclient/impl/codec/ColumnDesc;)V
astore 3
start local 3 23: aload 0
getfield io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder.inflight:Ljava/util/Deque;
invokeinterface java.util.Deque.peek:()Ljava/lang/Object;
checkcast io.reactiverse.pgclient.impl.CommandBase
aload 3
invokevirtual io.reactiverse.pgclient.impl.CommandBase.handleRowDescription:(Lio/reactiverse/pgclient/impl/codec/decoder/RowDescription;)V
24: return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 25 0 this Lio/reactiverse/pgclient/impl/codec/decoder/MessageDecoder;
0 25 1 in Lio/netty/buffer/ByteBuf;
1 25 2 columns [Lio/reactiverse/pgclient/impl/codec/ColumnDesc;
2 22 3 c I
4 20 4 fieldName Ljava/lang/String;
5 20 5 tableOID I
6 20 6 columnAttributeNumber S
7 20 7 typeOID I
8 20 8 typeSize S
9 20 9 typeModifier I
10 20 10 textOrBinary I
19 20 11 column Lio/reactiverse/pgclient/impl/codec/ColumnDesc;
23 25 3 rowDesc Lio/reactiverse/pgclient/impl/codec/decoder/RowDescription;
MethodParameters:
Name Flags
in
private void decodeReadyForQuery(io.netty.buffer.ByteBuf);
descriptor: (Lio/netty/buffer/ByteBuf;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=2, locals=4, args_size=2
start local 0 start local 1 0: aload 1
invokevirtual io.netty.buffer.ByteBuf.readByte:()B
istore 2
start local 2 1: iload 2
bipush 73
if_icmpne 4
2: getstatic io.reactiverse.pgclient.impl.codec.TxStatus.IDLE:Lio/reactiverse/pgclient/impl/codec/TxStatus;
astore 3
start local 3 3: goto 8
end local 3 StackMap locals: int
StackMap stack:
4: iload 2
bipush 84
if_icmpne 7
5: getstatic io.reactiverse.pgclient.impl.codec.TxStatus.ACTIVE:Lio/reactiverse/pgclient/impl/codec/TxStatus;
astore 3
start local 3 6: goto 8
end local 3 7: StackMap locals:
StackMap stack:
getstatic io.reactiverse.pgclient.impl.codec.TxStatus.FAILED:Lio/reactiverse/pgclient/impl/codec/TxStatus;
astore 3
start local 3 8: StackMap locals: io.reactiverse.pgclient.impl.codec.TxStatus
StackMap stack:
aload 0
getfield io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder.inflight:Ljava/util/Deque;
invokeinterface java.util.Deque.peek:()Ljava/lang/Object;
checkcast io.reactiverse.pgclient.impl.CommandBase
aload 3
invokevirtual io.reactiverse.pgclient.impl.CommandBase.handleReadyForQuery:(Lio/reactiverse/pgclient/impl/codec/TxStatus;)V
9: return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 10 0 this Lio/reactiverse/pgclient/impl/codec/decoder/MessageDecoder;
0 10 1 in Lio/netty/buffer/ByteBuf;
1 10 2 id B
3 4 3 txStatus Lio/reactiverse/pgclient/impl/codec/TxStatus;
6 7 3 txStatus Lio/reactiverse/pgclient/impl/codec/TxStatus;
8 10 3 txStatus Lio/reactiverse/pgclient/impl/codec/TxStatus;
MethodParameters:
Name Flags
in
private void decodeError(io.netty.buffer.ByteBuf);
descriptor: (Lio/netty/buffer/ByteBuf;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=3, locals=3, args_size=2
start local 0 start local 1 0: new io.reactiverse.pgclient.impl.codec.decoder.ErrorResponse
dup
invokespecial io.reactiverse.pgclient.impl.codec.decoder.ErrorResponse.<init>:()V
astore 2
start local 2 1: aload 0
aload 2
aload 1
invokevirtual io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder.decodeErrorOrNotice:(Lio/reactiverse/pgclient/impl/codec/decoder/Response;Lio/netty/buffer/ByteBuf;)V
2: aload 0
getfield io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder.inflight:Ljava/util/Deque;
invokeinterface java.util.Deque.peek:()Ljava/lang/Object;
checkcast io.reactiverse.pgclient.impl.CommandBase
aload 2
invokevirtual io.reactiverse.pgclient.impl.CommandBase.handleErrorResponse:(Lio/reactiverse/pgclient/impl/codec/decoder/ErrorResponse;)V
3: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lio/reactiverse/pgclient/impl/codec/decoder/MessageDecoder;
0 4 1 in Lio/netty/buffer/ByteBuf;
1 4 2 response Lio/reactiverse/pgclient/impl/codec/decoder/ErrorResponse;
MethodParameters:
Name Flags
in
private void decodeNotice(io.netty.buffer.ByteBuf);
descriptor: (Lio/netty/buffer/ByteBuf;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=3, locals=3, args_size=2
start local 0 start local 1 0: new io.reactiverse.pgclient.impl.codec.decoder.NoticeResponse
dup
invokespecial io.reactiverse.pgclient.impl.codec.decoder.NoticeResponse.<init>:()V
astore 2
start local 2 1: aload 0
aload 2
aload 1
invokevirtual io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder.decodeErrorOrNotice:(Lio/reactiverse/pgclient/impl/codec/decoder/Response;Lio/netty/buffer/ByteBuf;)V
2: aload 0
getfield io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder.inflight:Ljava/util/Deque;
invokeinterface java.util.Deque.peek:()Ljava/lang/Object;
checkcast io.reactiverse.pgclient.impl.CommandBase
aload 2
invokevirtual io.reactiverse.pgclient.impl.CommandBase.handleNoticeResponse:(Lio/reactiverse/pgclient/impl/codec/decoder/NoticeResponse;)V
3: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lio/reactiverse/pgclient/impl/codec/decoder/MessageDecoder;
0 4 1 in Lio/netty/buffer/ByteBuf;
1 4 2 response Lio/reactiverse/pgclient/impl/codec/decoder/NoticeResponse;
MethodParameters:
Name Flags
in
private void decodeErrorOrNotice(io.reactiverse.pgclient.impl.codec.decoder.Response, io.netty.buffer.ByteBuf);
descriptor: (Lio/reactiverse/pgclient/impl/codec/decoder/Response;Lio/netty/buffer/ByteBuf;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=2, locals=4, args_size=3
start local 0 start local 1 start local 2 0: goto 37
start local 3 1: StackMap locals: int
StackMap stack:
iload 3
lookupswitch { // 17
67: 4
68: 8
70: 20
72: 10
76: 22
77: 6
80: 16
82: 24
83: 2
87: 18
99: 30
100: 32
110: 34
112: 12
113: 14
115: 26
116: 28
default: 36
}
2: StackMap locals:
StackMap stack:
aload 1
aload 2
invokestatic io.reactiverse.pgclient.impl.codec.util.Util.readCStringUTF8:(Lio/netty/buffer/ByteBuf;)Ljava/lang/String;
invokevirtual io.reactiverse.pgclient.impl.codec.decoder.Response.setSeverity:(Ljava/lang/String;)V
3: goto 37
4: StackMap locals:
StackMap stack:
aload 1
aload 2
invokestatic io.reactiverse.pgclient.impl.codec.util.Util.readCStringUTF8:(Lio/netty/buffer/ByteBuf;)Ljava/lang/String;
invokevirtual io.reactiverse.pgclient.impl.codec.decoder.Response.setCode:(Ljava/lang/String;)V
5: goto 37
6: StackMap locals:
StackMap stack:
aload 1
aload 2
invokestatic io.reactiverse.pgclient.impl.codec.util.Util.readCStringUTF8:(Lio/netty/buffer/ByteBuf;)Ljava/lang/String;
invokevirtual io.reactiverse.pgclient.impl.codec.decoder.Response.setMessage:(Ljava/lang/String;)V
7: goto 37
8: StackMap locals:
StackMap stack:
aload 1
aload 2
invokestatic io.reactiverse.pgclient.impl.codec.util.Util.readCStringUTF8:(Lio/netty/buffer/ByteBuf;)Ljava/lang/String;
invokevirtual io.reactiverse.pgclient.impl.codec.decoder.Response.setDetail:(Ljava/lang/String;)V
9: goto 37
10: StackMap locals:
StackMap stack:
aload 1
aload 2
invokestatic io.reactiverse.pgclient.impl.codec.util.Util.readCStringUTF8:(Lio/netty/buffer/ByteBuf;)Ljava/lang/String;
invokevirtual io.reactiverse.pgclient.impl.codec.decoder.Response.setHint:(Ljava/lang/String;)V
11: goto 37
12: StackMap locals:
StackMap stack:
aload 1
aload 2
invokestatic io.reactiverse.pgclient.impl.codec.util.Util.readCStringUTF8:(Lio/netty/buffer/ByteBuf;)Ljava/lang/String;
invokevirtual io.reactiverse.pgclient.impl.codec.decoder.Response.setInternalPosition:(Ljava/lang/String;)V
13: goto 37
14: StackMap locals:
StackMap stack:
aload 1
aload 2
invokestatic io.reactiverse.pgclient.impl.codec.util.Util.readCStringUTF8:(Lio/netty/buffer/ByteBuf;)Ljava/lang/String;
invokevirtual io.reactiverse.pgclient.impl.codec.decoder.Response.setInternalQuery:(Ljava/lang/String;)V
15: goto 37
16: StackMap locals:
StackMap stack:
aload 1
aload 2
invokestatic io.reactiverse.pgclient.impl.codec.util.Util.readCStringUTF8:(Lio/netty/buffer/ByteBuf;)Ljava/lang/String;
invokevirtual io.reactiverse.pgclient.impl.codec.decoder.Response.setPosition:(Ljava/lang/String;)V
17: goto 37
18: StackMap locals:
StackMap stack:
aload 1
aload 2
invokestatic io.reactiverse.pgclient.impl.codec.util.Util.readCStringUTF8:(Lio/netty/buffer/ByteBuf;)Ljava/lang/String;
invokevirtual io.reactiverse.pgclient.impl.codec.decoder.Response.setWhere:(Ljava/lang/String;)V
19: goto 37
20: StackMap locals:
StackMap stack:
aload 1
aload 2
invokestatic io.reactiverse.pgclient.impl.codec.util.Util.readCStringUTF8:(Lio/netty/buffer/ByteBuf;)Ljava/lang/String;
invokevirtual io.reactiverse.pgclient.impl.codec.decoder.Response.setFile:(Ljava/lang/String;)V
21: goto 37
22: StackMap locals:
StackMap stack:
aload 1
aload 2
invokestatic io.reactiverse.pgclient.impl.codec.util.Util.readCStringUTF8:(Lio/netty/buffer/ByteBuf;)Ljava/lang/String;
invokevirtual io.reactiverse.pgclient.impl.codec.decoder.Response.setLine:(Ljava/lang/String;)V
23: goto 37
24: StackMap locals:
StackMap stack:
aload 1
aload 2
invokestatic io.reactiverse.pgclient.impl.codec.util.Util.readCStringUTF8:(Lio/netty/buffer/ByteBuf;)Ljava/lang/String;
invokevirtual io.reactiverse.pgclient.impl.codec.decoder.Response.setRoutine:(Ljava/lang/String;)V
25: goto 37
26: StackMap locals:
StackMap stack:
aload 1
aload 2
invokestatic io.reactiverse.pgclient.impl.codec.util.Util.readCStringUTF8:(Lio/netty/buffer/ByteBuf;)Ljava/lang/String;
invokevirtual io.reactiverse.pgclient.impl.codec.decoder.Response.setSchema:(Ljava/lang/String;)V
27: goto 37
28: StackMap locals:
StackMap stack:
aload 1
aload 2
invokestatic io.reactiverse.pgclient.impl.codec.util.Util.readCStringUTF8:(Lio/netty/buffer/ByteBuf;)Ljava/lang/String;
invokevirtual io.reactiverse.pgclient.impl.codec.decoder.Response.setTable:(Ljava/lang/String;)V
29: goto 37
30: StackMap locals:
StackMap stack:
aload 1
aload 2
invokestatic io.reactiverse.pgclient.impl.codec.util.Util.readCStringUTF8:(Lio/netty/buffer/ByteBuf;)Ljava/lang/String;
invokevirtual io.reactiverse.pgclient.impl.codec.decoder.Response.setColumn:(Ljava/lang/String;)V
31: goto 37
32: StackMap locals:
StackMap stack:
aload 1
aload 2
invokestatic io.reactiverse.pgclient.impl.codec.util.Util.readCStringUTF8:(Lio/netty/buffer/ByteBuf;)Ljava/lang/String;
invokevirtual io.reactiverse.pgclient.impl.codec.decoder.Response.setDataType:(Ljava/lang/String;)V
33: goto 37
34: StackMap locals:
StackMap stack:
aload 1
aload 2
invokestatic io.reactiverse.pgclient.impl.codec.util.Util.readCStringUTF8:(Lio/netty/buffer/ByteBuf;)Ljava/lang/String;
invokevirtual io.reactiverse.pgclient.impl.codec.decoder.Response.setConstraint:(Ljava/lang/String;)V
35: goto 37
36: StackMap locals:
StackMap stack:
aload 2
invokestatic io.reactiverse.pgclient.impl.codec.util.Util.readCStringUTF8:(Lio/netty/buffer/ByteBuf;)Ljava/lang/String;
pop
end local 3 37: StackMap locals:
StackMap stack:
aload 2
invokevirtual io.netty.buffer.ByteBuf.readByte:()B
dup
istore 3
start local 3 38: ifne 1
39: return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 40 0 this Lio/reactiverse/pgclient/impl/codec/decoder/MessageDecoder;
0 40 1 response Lio/reactiverse/pgclient/impl/codec/decoder/Response;
0 40 2 in Lio/netty/buffer/ByteBuf;
1 37 3 type B
38 40 3 type B
MethodParameters:
Name Flags
response
in
private void decodeAuthentication(io.netty.buffer.ByteBuf);
descriptor: (Lio/netty/buffer/ByteBuf;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=5, locals=4, args_size=2
start local 0 start local 1 0: aload 1
invokevirtual io.netty.buffer.ByteBuf.readInt:()I
istore 2
start local 2 1: iload 2
tableswitch { // 0 - 9
0: 2
1: 10
2: 10
3: 8
4: 10
5: 4
6: 10
7: 10
8: 10
9: 10
default: 10
}
2: StackMap locals: int
StackMap stack:
aload 0
getfield io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder.inflight:Ljava/util/Deque;
invokeinterface java.util.Deque.peek:()Ljava/lang/Object;
checkcast io.reactiverse.pgclient.impl.CommandBase
invokevirtual io.reactiverse.pgclient.impl.CommandBase.handleAuthenticationOk:()V
3: goto 11
4: StackMap locals:
StackMap stack:
iconst_4
newarray 8
astore 3
start local 3 5: aload 1
aload 3
invokevirtual io.netty.buffer.ByteBuf.readBytes:([B)Lio/netty/buffer/ByteBuf;
pop
6: aload 0
getfield io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder.inflight:Ljava/util/Deque;
invokeinterface java.util.Deque.peek:()Ljava/lang/Object;
checkcast io.reactiverse.pgclient.impl.CommandBase
aload 3
invokevirtual io.reactiverse.pgclient.impl.CommandBase.handleAuthenticationMD5Password:([B)V
end local 3 7: goto 11
8: StackMap locals:
StackMap stack:
aload 0
getfield io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder.inflight:Ljava/util/Deque;
invokeinterface java.util.Deque.peek:()Ljava/lang/Object;
checkcast io.reactiverse.pgclient.impl.CommandBase
invokevirtual io.reactiverse.pgclient.impl.CommandBase.handleAuthenticationClearTextPassword:()V
9: goto 11
10: StackMap locals:
StackMap stack:
new java.lang.UnsupportedOperationException
dup
new java.lang.StringBuilder
dup
ldc "Authentication type "
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
iload 2
invokevirtual java.lang.StringBuilder.append:(I)Ljava/lang/StringBuilder;
ldc " is not supported in the client"
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokespecial java.lang.UnsupportedOperationException.<init>:(Ljava/lang/String;)V
athrow
11: StackMap locals:
StackMap stack:
return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 12 0 this Lio/reactiverse/pgclient/impl/codec/decoder/MessageDecoder;
0 12 1 in Lio/netty/buffer/ByteBuf;
1 12 2 type I
5 7 3 salt [B
MethodParameters:
Name Flags
in
private void decodeParseComplete();
descriptor: ()V
flags: (0x0002) ACC_PRIVATE
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder.inflight:Ljava/util/Deque;
invokeinterface java.util.Deque.peek:()Ljava/lang/Object;
checkcast io.reactiverse.pgclient.impl.CommandBase
invokevirtual io.reactiverse.pgclient.impl.CommandBase.handleParseComplete:()V
1: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/reactiverse/pgclient/impl/codec/decoder/MessageDecoder;
private void decodeBindComplete();
descriptor: ()V
flags: (0x0002) ACC_PRIVATE
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder.inflight:Ljava/util/Deque;
invokeinterface java.util.Deque.peek:()Ljava/lang/Object;
checkcast io.reactiverse.pgclient.impl.CommandBase
invokevirtual io.reactiverse.pgclient.impl.CommandBase.handleBindComplete:()V
1: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/reactiverse/pgclient/impl/codec/decoder/MessageDecoder;
private void decodeCloseComplete();
descriptor: ()V
flags: (0x0002) ACC_PRIVATE
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder.inflight:Ljava/util/Deque;
invokeinterface java.util.Deque.peek:()Ljava/lang/Object;
checkcast io.reactiverse.pgclient.impl.CommandBase
invokevirtual io.reactiverse.pgclient.impl.CommandBase.handleCloseComplete:()V
1: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/reactiverse/pgclient/impl/codec/decoder/MessageDecoder;
private void decodeNoData();
descriptor: ()V
flags: (0x0002) ACC_PRIVATE
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder.inflight:Ljava/util/Deque;
invokeinterface java.util.Deque.peek:()Ljava/lang/Object;
checkcast io.reactiverse.pgclient.impl.CommandBase
invokevirtual io.reactiverse.pgclient.impl.CommandBase.handleNoData:()V
1: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/reactiverse/pgclient/impl/codec/decoder/MessageDecoder;
private void decodeParameterDescription(io.netty.buffer.ByteBuf);
descriptor: (Lio/netty/buffer/ByteBuf;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=4, locals=4, args_size=2
start local 0 start local 1 0: aload 1
invokevirtual io.netty.buffer.ByteBuf.readUnsignedShort:()I
anewarray io.reactiverse.pgclient.impl.codec.DataType
astore 2
start local 2 1: iconst_0
istore 3
start local 3 2: goto 5
3: StackMap locals: io.reactiverse.pgclient.impl.codec.DataType[] int
StackMap stack:
aload 2
iload 3
aload 1
invokevirtual io.netty.buffer.ByteBuf.readInt:()I
invokestatic io.reactiverse.pgclient.impl.codec.DataType.valueOf:(I)Lio/reactiverse/pgclient/impl/codec/DataType;
aastore
4: iinc 3 1
StackMap locals:
StackMap stack:
5: iload 3
aload 2
arraylength
if_icmplt 3
end local 3 6: aload 0
getfield io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder.inflight:Ljava/util/Deque;
invokeinterface java.util.Deque.peek:()Ljava/lang/Object;
checkcast io.reactiverse.pgclient.impl.CommandBase
new io.reactiverse.pgclient.impl.codec.decoder.ParameterDescription
dup
aload 2
invokespecial io.reactiverse.pgclient.impl.codec.decoder.ParameterDescription.<init>:([Lio/reactiverse/pgclient/impl/codec/DataType;)V
invokevirtual io.reactiverse.pgclient.impl.CommandBase.handleParameterDescription:(Lio/reactiverse/pgclient/impl/codec/decoder/ParameterDescription;)V
7: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 8 0 this Lio/reactiverse/pgclient/impl/codec/decoder/MessageDecoder;
0 8 1 in Lio/netty/buffer/ByteBuf;
1 8 2 paramDataTypes [Lio/reactiverse/pgclient/impl/codec/DataType;
2 6 3 c I
MethodParameters:
Name Flags
in
private void decodeParameterStatus(io.netty.buffer.ByteBuf);
descriptor: (Lio/netty/buffer/ByteBuf;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=3, locals=4, args_size=2
start local 0 start local 1 0: aload 1
invokestatic io.reactiverse.pgclient.impl.codec.util.Util.readCStringUTF8:(Lio/netty/buffer/ByteBuf;)Ljava/lang/String;
astore 2
start local 2 1: aload 1
invokestatic io.reactiverse.pgclient.impl.codec.util.Util.readCStringUTF8:(Lio/netty/buffer/ByteBuf;)Ljava/lang/String;
astore 3
start local 3 2: aload 0
getfield io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder.inflight:Ljava/util/Deque;
invokeinterface java.util.Deque.peek:()Ljava/lang/Object;
checkcast io.reactiverse.pgclient.impl.CommandBase
aload 2
aload 3
invokevirtual io.reactiverse.pgclient.impl.CommandBase.handleParameterStatus:(Ljava/lang/String;Ljava/lang/String;)V
3: return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lio/reactiverse/pgclient/impl/codec/decoder/MessageDecoder;
0 4 1 in Lio/netty/buffer/ByteBuf;
1 4 2 key Ljava/lang/String;
2 4 3 value Ljava/lang/String;
MethodParameters:
Name Flags
in
private void decodeEmptyQueryResponse();
descriptor: ()V
flags: (0x0002) ACC_PRIVATE
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder.inflight:Ljava/util/Deque;
invokeinterface java.util.Deque.peek:()Ljava/lang/Object;
checkcast io.reactiverse.pgclient.impl.CommandBase
invokevirtual io.reactiverse.pgclient.impl.CommandBase.handleEmptyQueryResponse:()V
1: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/reactiverse/pgclient/impl/codec/decoder/MessageDecoder;
private void decodeBackendKeyData(io.netty.buffer.ByteBuf);
descriptor: (Lio/netty/buffer/ByteBuf;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=3, locals=4, args_size=2
start local 0 start local 1 0: aload 1
invokevirtual io.netty.buffer.ByteBuf.readInt:()I
istore 2
start local 2 1: aload 1
invokevirtual io.netty.buffer.ByteBuf.readInt:()I
istore 3
start local 3 2: aload 0
getfield io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder.inflight:Ljava/util/Deque;
invokeinterface java.util.Deque.peek:()Ljava/lang/Object;
checkcast io.reactiverse.pgclient.impl.CommandBase
iload 2
iload 3
invokevirtual io.reactiverse.pgclient.impl.CommandBase.handleBackendKeyData:(II)V
3: return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lio/reactiverse/pgclient/impl/codec/decoder/MessageDecoder;
0 4 1 in Lio/netty/buffer/ByteBuf;
1 4 2 processId I
2 4 3 secretKey I
MethodParameters:
Name Flags
in
private void decodeNotificationResponse(io.netty.channel.ChannelHandlerContext, io.netty.buffer.ByteBuf);
descriptor: (Lio/netty/channel/ChannelHandlerContext;Lio/netty/buffer/ByteBuf;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=6, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 1
new io.reactiverse.pgclient.impl.codec.decoder.NotificationResponse
dup
aload 2
invokevirtual io.netty.buffer.ByteBuf.readInt:()I
aload 2
invokestatic io.reactiverse.pgclient.impl.codec.util.Util.readCStringUTF8:(Lio/netty/buffer/ByteBuf;)Ljava/lang/String;
aload 2
invokestatic io.reactiverse.pgclient.impl.codec.util.Util.readCStringUTF8:(Lio/netty/buffer/ByteBuf;)Ljava/lang/String;
invokespecial io.reactiverse.pgclient.impl.codec.decoder.NotificationResponse.<init>:(ILjava/lang/String;Ljava/lang/String;)V
invokeinterface io.netty.channel.ChannelHandlerContext.fireChannelRead:(Ljava/lang/Object;)Lio/netty/channel/ChannelHandlerContext;
pop
1: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/reactiverse/pgclient/impl/codec/decoder/MessageDecoder;
0 2 1 ctx Lio/netty/channel/ChannelHandlerContext;
0 2 2 in Lio/netty/buffer/ByteBuf;
MethodParameters:
Name Flags
ctx
in
}
SourceFile: "MessageDecoder.java"
NestMembers:
io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder$CommandCompleteProcessor
InnerClasses:
CommandCompleteProcessor = io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder$CommandCompleteProcessor of io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder
public final Lookup = java.lang.invoke.MethodHandles$Lookup of java.lang.invoke.MethodHandles