public class com.datastax.oss.protocol.internal.FrameCodec<B>
minor version: 0
major version: 59
flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
this_class: com.datastax.oss.protocol.internal.FrameCodec
super_class: java.lang.Object
{
public static final int ;
descriptor: I
flags: (0x0019) ACC_PUBLIC, ACC_STATIC, ACC_FINAL
ConstantValue: 9
private final com.datastax.oss.protocol.internal.PrimitiveCodec<B> primitiveCodec;
descriptor: Lcom/datastax/oss/protocol/internal/PrimitiveCodec;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Lcom/datastax/oss/protocol/internal/PrimitiveCodec<TB;>;
private final com.datastax.oss.protocol.internal.Compressor<B> compressor;
descriptor: Lcom/datastax/oss/protocol/internal/Compressor;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Lcom/datastax/oss/protocol/internal/Compressor<TB;>;
private final com.datastax.oss.protocol.internal.util.IntIntMap<com.datastax.oss.protocol.internal.Message$Codec> encoders;
descriptor: Lcom/datastax/oss/protocol/internal/util/IntIntMap;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Lcom/datastax/oss/protocol/internal/util/IntIntMap<Lcom/datastax/oss/protocol/internal/Message$Codec;>;
private final com.datastax.oss.protocol.internal.util.IntIntMap<com.datastax.oss.protocol.internal.Message$Codec> decoders;
descriptor: Lcom/datastax/oss/protocol/internal/util/IntIntMap;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Lcom/datastax/oss/protocol/internal/util/IntIntMap<Lcom/datastax/oss/protocol/internal/Message$Codec;>;
public static <B> com.datastax.oss.protocol.internal.FrameCodec<B> defaultClient(com.datastax.oss.protocol.internal.PrimitiveCodec<B>, com.datastax.oss.protocol.internal.Compressor<B>);
descriptor: (Lcom/datastax/oss/protocol/internal/PrimitiveCodec;Lcom/datastax/oss/protocol/internal/Compressor;)Lcom/datastax/oss/protocol/internal/FrameCodec;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=9, locals=2, args_size=2
start local 0 start local 1 0: new com.datastax.oss.protocol.internal.FrameCodec
dup
1: aload 0
2: aload 1
iconst_3
anewarray com.datastax.oss.protocol.internal.FrameCodec$CodecGroup
dup
iconst_0
3: new com.datastax.oss.protocol.internal.ProtocolV3ClientCodecs
dup
invokespecial com.datastax.oss.protocol.internal.ProtocolV3ClientCodecs.<init>:()V
aastore
dup
iconst_1
4: new com.datastax.oss.protocol.internal.ProtocolV4ClientCodecs
dup
invokespecial com.datastax.oss.protocol.internal.ProtocolV4ClientCodecs.<init>:()V
aastore
dup
iconst_2
5: new com.datastax.oss.protocol.internal.ProtocolV5ClientCodecs
dup
invokespecial com.datastax.oss.protocol.internal.ProtocolV5ClientCodecs.<init>:()V
6: aastore
invokespecial com.datastax.oss.protocol.internal.FrameCodec.<init>:(Lcom/datastax/oss/protocol/internal/PrimitiveCodec;Lcom/datastax/oss/protocol/internal/Compressor;[Lcom/datastax/oss/protocol/internal/FrameCodec$CodecGroup;)V
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 7 0 primitiveCodec Lcom/datastax/oss/protocol/internal/PrimitiveCodec<TB;>;
0 7 1 compressor Lcom/datastax/oss/protocol/internal/Compressor<TB;>;
Signature: <B:Ljava/lang/Object;>(Lcom/datastax/oss/protocol/internal/PrimitiveCodec<TB;>;Lcom/datastax/oss/protocol/internal/Compressor<TB;>;)Lcom/datastax/oss/protocol/internal/FrameCodec<TB;>;
MethodParameters:
Name Flags
primitiveCodec
compressor
public static <B> com.datastax.oss.protocol.internal.FrameCodec<B> defaultServer(com.datastax.oss.protocol.internal.PrimitiveCodec<B>, com.datastax.oss.protocol.internal.Compressor<B>);
descriptor: (Lcom/datastax/oss/protocol/internal/PrimitiveCodec;Lcom/datastax/oss/protocol/internal/Compressor;)Lcom/datastax/oss/protocol/internal/FrameCodec;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=9, locals=2, args_size=2
start local 0 start local 1 0: new com.datastax.oss.protocol.internal.FrameCodec
dup
1: aload 0
2: aload 1
iconst_3
anewarray com.datastax.oss.protocol.internal.FrameCodec$CodecGroup
dup
iconst_0
3: new com.datastax.oss.protocol.internal.ProtocolV3ServerCodecs
dup
invokespecial com.datastax.oss.protocol.internal.ProtocolV3ServerCodecs.<init>:()V
aastore
dup
iconst_1
4: new com.datastax.oss.protocol.internal.ProtocolV4ServerCodecs
dup
invokespecial com.datastax.oss.protocol.internal.ProtocolV4ServerCodecs.<init>:()V
aastore
dup
iconst_2
5: new com.datastax.oss.protocol.internal.ProtocolV5ServerCodecs
dup
invokespecial com.datastax.oss.protocol.internal.ProtocolV5ServerCodecs.<init>:()V
6: aastore
invokespecial com.datastax.oss.protocol.internal.FrameCodec.<init>:(Lcom/datastax/oss/protocol/internal/PrimitiveCodec;Lcom/datastax/oss/protocol/internal/Compressor;[Lcom/datastax/oss/protocol/internal/FrameCodec$CodecGroup;)V
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 7 0 primitiveCodec Lcom/datastax/oss/protocol/internal/PrimitiveCodec<TB;>;
0 7 1 compressor Lcom/datastax/oss/protocol/internal/Compressor<TB;>;
Signature: <B:Ljava/lang/Object;>(Lcom/datastax/oss/protocol/internal/PrimitiveCodec<TB;>;Lcom/datastax/oss/protocol/internal/Compressor<TB;>;)Lcom/datastax/oss/protocol/internal/FrameCodec<TB;>;
MethodParameters:
Name Flags
primitiveCodec
compressor
public void <init>(com.datastax.oss.protocol.internal.PrimitiveCodec<B>, com.datastax.oss.protocol.internal.Compressor<B>, com.datastax.oss.protocol.internal.FrameCodec$CodecGroup[]);
descriptor: (Lcom/datastax/oss/protocol/internal/PrimitiveCodec;Lcom/datastax/oss/protocol/internal/Compressor;[Lcom/datastax/oss/protocol/internal/FrameCodec$CodecGroup;)V
flags: (0x0081) ACC_PUBLIC, ACC_VARARGS
Code:
stack=5, locals=11, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
invokespecial java.lang.Object.<init>:()V
1: aload 1
ifnull 2
iconst_1
goto 3
StackMap locals: com.datastax.oss.protocol.internal.FrameCodec com.datastax.oss.protocol.internal.PrimitiveCodec com.datastax.oss.protocol.internal.Compressor com.datastax.oss.protocol.internal.FrameCodec$CodecGroup[]
StackMap stack:
2: iconst_0
StackMap locals:
StackMap stack: int
3: ldc "primitiveCodec can't be null"
iconst_0
anewarray java.lang.Object
invokestatic com.datastax.oss.protocol.internal.ProtocolErrors.check:(ZLjava/lang/String;[Ljava/lang/Object;)V
4: aload 2
ifnull 5
iconst_1
goto 6
StackMap locals:
StackMap stack:
5: iconst_0
StackMap locals:
StackMap stack: int
6: ldc "compressor can't be null, use Compressor.none()"
iconst_0
anewarray java.lang.Object
invokestatic com.datastax.oss.protocol.internal.ProtocolErrors.check:(ZLjava/lang/String;[Ljava/lang/Object;)V
7: aload 0
aload 1
putfield com.datastax.oss.protocol.internal.FrameCodec.primitiveCodec:Lcom/datastax/oss/protocol/internal/PrimitiveCodec;
8: aload 0
aload 2
putfield com.datastax.oss.protocol.internal.FrameCodec.compressor:Lcom/datastax/oss/protocol/internal/Compressor;
9: invokestatic com.datastax.oss.protocol.internal.util.IntIntMap.builder:()Lcom/datastax/oss/protocol/internal/util/IntIntMap$Builder;
astore 4
start local 4 10: invokestatic com.datastax.oss.protocol.internal.util.IntIntMap.builder:()Lcom/datastax/oss/protocol/internal/util/IntIntMap$Builder;
astore 5
start local 5 11: new com.datastax.oss.protocol.internal.FrameCodec$1
dup
aload 0
aload 4
aload 5
invokespecial com.datastax.oss.protocol.internal.FrameCodec$1.<init>:(Lcom/datastax/oss/protocol/internal/FrameCodec;Lcom/datastax/oss/protocol/internal/util/IntIntMap$Builder;Lcom/datastax/oss/protocol/internal/util/IntIntMap$Builder;)V
12: astore 6
start local 6 13: aload 3
dup
astore 10
arraylength
istore 9
iconst_0
istore 8
goto 17
StackMap locals: com.datastax.oss.protocol.internal.FrameCodec com.datastax.oss.protocol.internal.PrimitiveCodec com.datastax.oss.protocol.internal.Compressor com.datastax.oss.protocol.internal.FrameCodec$CodecGroup[] com.datastax.oss.protocol.internal.util.IntIntMap$Builder com.datastax.oss.protocol.internal.util.IntIntMap$Builder com.datastax.oss.protocol.internal.FrameCodec$CodecGroup$Registry top int int com.datastax.oss.protocol.internal.FrameCodec$CodecGroup[]
StackMap stack:
14: aload 10
iload 8
aaload
astore 7
start local 7 15: aload 7
aload 6
invokeinterface com.datastax.oss.protocol.internal.FrameCodec$CodecGroup.registerCodecs:(Lcom/datastax/oss/protocol/internal/FrameCodec$CodecGroup$Registry;)V
end local 7 16: iinc 8 1
StackMap locals:
StackMap stack:
17: iload 8
iload 9
if_icmplt 14
18: aload 0
aload 4
invokevirtual com.datastax.oss.protocol.internal.util.IntIntMap$Builder.build:()Lcom/datastax/oss/protocol/internal/util/IntIntMap;
putfield com.datastax.oss.protocol.internal.FrameCodec.encoders:Lcom/datastax/oss/protocol/internal/util/IntIntMap;
19: aload 0
aload 5
invokevirtual com.datastax.oss.protocol.internal.util.IntIntMap$Builder.build:()Lcom/datastax/oss/protocol/internal/util/IntIntMap;
putfield com.datastax.oss.protocol.internal.FrameCodec.decoders:Lcom/datastax/oss/protocol/internal/util/IntIntMap;
20: return
end local 6 end local 5 end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 21 0 this Lcom/datastax/oss/protocol/internal/FrameCodec<TB;>;
0 21 1 primitiveCodec Lcom/datastax/oss/protocol/internal/PrimitiveCodec<TB;>;
0 21 2 compressor Lcom/datastax/oss/protocol/internal/Compressor<TB;>;
0 21 3 codecGroups [Lcom/datastax/oss/protocol/internal/FrameCodec$CodecGroup;
10 21 4 encodersBuilder Lcom/datastax/oss/protocol/internal/util/IntIntMap$Builder<Lcom/datastax/oss/protocol/internal/Message$Codec;>;
11 21 5 decodersBuilder Lcom/datastax/oss/protocol/internal/util/IntIntMap$Builder<Lcom/datastax/oss/protocol/internal/Message$Codec;>;
13 21 6 registry Lcom/datastax/oss/protocol/internal/FrameCodec$CodecGroup$Registry;
15 16 7 codecGroup Lcom/datastax/oss/protocol/internal/FrameCodec$CodecGroup;
Signature: (Lcom/datastax/oss/protocol/internal/PrimitiveCodec<TB;>;Lcom/datastax/oss/protocol/internal/Compressor<TB;>;[Lcom/datastax/oss/protocol/internal/FrameCodec$CodecGroup;)V
MethodParameters:
Name Flags
primitiveCodec
compressor
codecGroups
public B encode(com.datastax.oss.protocol.internal.Frame);
descriptor: (Lcom/datastax/oss/protocol/internal/Frame;)Ljava/lang/Object;
flags: (0x0001) ACC_PUBLIC
Code:
stack=6, locals=11, args_size=2
start local 0 start local 1 0: aload 1
getfield com.datastax.oss.protocol.internal.Frame.protocolVersion:I
istore 2
start local 2 1: iload 2
iconst_4
if_icmpge 2
aload 1
getfield com.datastax.oss.protocol.internal.Frame.customPayload:Ljava/util/Map;
invokeinterface java.util.Map.isEmpty:()Z
ifne 2
iconst_0
goto 3
StackMap locals: int
StackMap stack:
2: iconst_1
3: StackMap locals:
StackMap stack: int
ldc "Custom payload is not supported in protocol v%d"
iconst_1
anewarray java.lang.Object
dup
iconst_0
4: iload 2
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
aastore
5: invokestatic com.datastax.oss.protocol.internal.ProtocolErrors.check:(ZLjava/lang/String;[Ljava/lang/Object;)V
6: iload 2
iconst_4
if_icmpge 7
aload 1
getfield com.datastax.oss.protocol.internal.Frame.warnings:Ljava/util/List;
invokeinterface java.util.List.isEmpty:()Z
ifne 7
iconst_0
goto 8
StackMap locals:
StackMap stack:
7: iconst_1
8: StackMap locals:
StackMap stack: int
ldc "Warnings are not supported in protocol v%d"
iconst_1
anewarray java.lang.Object
dup
iconst_0
9: iload 2
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
aastore
10: invokestatic com.datastax.oss.protocol.internal.ProtocolErrors.check:(ZLjava/lang/String;[Ljava/lang/Object;)V
11: aload 0
aload 1
invokevirtual com.datastax.oss.protocol.internal.FrameCodec.getMessageEncoder:(Lcom/datastax/oss/protocol/internal/Frame;)Lcom/datastax/oss/protocol/internal/Message$Codec;
astore 3
start local 3 12: aload 0
aload 1
invokevirtual com.datastax.oss.protocol.internal.FrameCodec.encodedHeaderSize:(Lcom/datastax/oss/protocol/internal/Frame;)I
istore 4
start local 4 13: aload 0
aload 1
invokevirtual com.datastax.oss.protocol.internal.FrameCodec.encodedBodySize:(Lcom/datastax/oss/protocol/internal/Frame;)I
istore 5
start local 5 14: aload 0
aload 1
invokevirtual com.datastax.oss.protocol.internal.FrameCodec.computeFlags:(Lcom/datastax/oss/protocol/internal/Frame;)I
istore 6
start local 6 15: iload 6
iconst_1
invokestatic com.datastax.oss.protocol.internal.util.Flags.contains:(II)Z
ifne 19
16: aload 0
getfield com.datastax.oss.protocol.internal.FrameCodec.primitiveCodec:Lcom/datastax/oss/protocol/internal/PrimitiveCodec;
iload 4
iload 5
iadd
invokeinterface com.datastax.oss.protocol.internal.PrimitiveCodec.allocate:(I)Ljava/lang/Object;
astore 7
start local 7 17: aload 0
aload 1
iload 5
iload 6
aload 3
aload 7
invokevirtual com.datastax.oss.protocol.internal.FrameCodec.encodeInto:(Lcom/datastax/oss/protocol/internal/Frame;IILcom/datastax/oss/protocol/internal/Message$Codec;Ljava/lang/Object;)V
18: aload 7
areturn
end local 7 19: StackMap locals: com.datastax.oss.protocol.internal.FrameCodec com.datastax.oss.protocol.internal.Frame int com.datastax.oss.protocol.internal.Message$Codec int int int
StackMap stack:
aload 0
getfield com.datastax.oss.protocol.internal.FrameCodec.primitiveCodec:Lcom/datastax/oss/protocol/internal/PrimitiveCodec;
iload 5
invokeinterface com.datastax.oss.protocol.internal.PrimitiveCodec.allocate:(I)Ljava/lang/Object;
astore 7
start local 7 20: aload 0
aload 1
aload 3
aload 7
invokevirtual com.datastax.oss.protocol.internal.FrameCodec.encodeBodyInto:(Lcom/datastax/oss/protocol/internal/Frame;Lcom/datastax/oss/protocol/internal/Message$Codec;Ljava/lang/Object;)V
21: aload 0
getfield com.datastax.oss.protocol.internal.FrameCodec.compressor:Lcom/datastax/oss/protocol/internal/Compressor;
aload 7
invokeinterface com.datastax.oss.protocol.internal.Compressor.compress:(Ljava/lang/Object;)Ljava/lang/Object;
astore 8
start local 8 22: aload 0
getfield com.datastax.oss.protocol.internal.FrameCodec.primitiveCodec:Lcom/datastax/oss/protocol/internal/PrimitiveCodec;
aload 7
invokeinterface com.datastax.oss.protocol.internal.PrimitiveCodec.release:(Ljava/lang/Object;)V
23: aload 0
getfield com.datastax.oss.protocol.internal.FrameCodec.primitiveCodec:Lcom/datastax/oss/protocol/internal/PrimitiveCodec;
aload 8
invokeinterface com.datastax.oss.protocol.internal.PrimitiveCodec.sizeOf:(Ljava/lang/Object;)I
istore 9
start local 9 24: aload 0
getfield com.datastax.oss.protocol.internal.FrameCodec.primitiveCodec:Lcom/datastax/oss/protocol/internal/PrimitiveCodec;
iload 4
invokeinterface com.datastax.oss.protocol.internal.PrimitiveCodec.allocate:(I)Ljava/lang/Object;
astore 10
start local 10 25: aload 0
aload 1
iload 6
iload 9
aload 10
invokevirtual com.datastax.oss.protocol.internal.FrameCodec.encodeHeaderInto:(Lcom/datastax/oss/protocol/internal/Frame;IILjava/lang/Object;)V
26: aload 0
getfield com.datastax.oss.protocol.internal.FrameCodec.primitiveCodec:Lcom/datastax/oss/protocol/internal/PrimitiveCodec;
aload 10
aload 8
invokeinterface com.datastax.oss.protocol.internal.PrimitiveCodec.concat:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
areturn
end local 10 end local 9 end local 8 end local 7 end local 6 end local 5 end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 27 0 this Lcom/datastax/oss/protocol/internal/FrameCodec<TB;>;
0 27 1 frame Lcom/datastax/oss/protocol/internal/Frame;
1 27 2 protocolVersion I
12 27 3 messageEncoder Lcom/datastax/oss/protocol/internal/Message$Codec;
13 27 4 headerSize I
14 27 5 bodySize I
15 27 6 flags I
17 19 7 dest TB;
20 27 7 uncompressedBody TB;
22 27 8 compressedBody TB;
24 27 9 compressedBodySize I
25 27 10 header TB;
Signature: (Lcom/datastax/oss/protocol/internal/Frame;)TB;
MethodParameters:
Name Flags
frame
public void encodeInto(com.datastax.oss.protocol.internal.Frame, int, );
descriptor: (Lcom/datastax/oss/protocol/internal/Frame;ILjava/lang/Object;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=6, locals=6, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
aload 1
invokevirtual com.datastax.oss.protocol.internal.FrameCodec.computeFlags:(Lcom/datastax/oss/protocol/internal/Frame;)I
istore 4
start local 4 1: aload 0
aload 1
invokevirtual com.datastax.oss.protocol.internal.FrameCodec.getMessageEncoder:(Lcom/datastax/oss/protocol/internal/Frame;)Lcom/datastax/oss/protocol/internal/Message$Codec;
astore 5
start local 5 2: aload 0
aload 1
iload 2
iload 4
aload 5
aload 3
invokevirtual com.datastax.oss.protocol.internal.FrameCodec.encodeInto:(Lcom/datastax/oss/protocol/internal/Frame;IILcom/datastax/oss/protocol/internal/Message$Codec;Ljava/lang/Object;)V
3: return
end local 5 end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lcom/datastax/oss/protocol/internal/FrameCodec<TB;>;
0 4 1 frame Lcom/datastax/oss/protocol/internal/Frame;
0 4 2 bodySize I
0 4 3 dest TB;
1 4 4 flags I
2 4 5 encoder Lcom/datastax/oss/protocol/internal/Message$Codec;
Signature: (Lcom/datastax/oss/protocol/internal/Frame;ITB;)V
MethodParameters:
Name Flags
frame
bodySize
dest
private com.datastax.oss.protocol.internal.Message$Codec getMessageEncoder(com.datastax.oss.protocol.internal.Frame);
descriptor: (Lcom/datastax/oss/protocol/internal/Frame;)Lcom/datastax/oss/protocol/internal/Message$Codec;
flags: (0x0002) ACC_PRIVATE
Code:
stack=6, locals=3, args_size=2
start local 0 start local 1 0: aload 0
getfield com.datastax.oss.protocol.internal.FrameCodec.encoders:Lcom/datastax/oss/protocol/internal/util/IntIntMap;
aload 1
getfield com.datastax.oss.protocol.internal.Frame.protocolVersion:I
aload 1
getfield com.datastax.oss.protocol.internal.Frame.message:Lcom/datastax/oss/protocol/internal/Message;
getfield com.datastax.oss.protocol.internal.Message.opcode:I
invokevirtual com.datastax.oss.protocol.internal.util.IntIntMap.get:(II)Ljava/lang/Object;
checkcast com.datastax.oss.protocol.internal.Message$Codec
astore 2
start local 2 1: aload 2
ifnull 2
iconst_1
goto 3
StackMap locals: com.datastax.oss.protocol.internal.Message$Codec
StackMap stack:
2: iconst_0
3: StackMap locals:
StackMap stack: int
ldc "Unsupported opcode %s in protocol v%d"
iconst_2
anewarray java.lang.Object
dup
iconst_0
4: aload 1
getfield com.datastax.oss.protocol.internal.Frame.message:Lcom/datastax/oss/protocol/internal/Message;
getfield com.datastax.oss.protocol.internal.Message.opcode:I
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
aastore
dup
iconst_1
5: aload 1
getfield com.datastax.oss.protocol.internal.Frame.protocolVersion:I
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
aastore
6: invokestatic com.datastax.oss.protocol.internal.ProtocolErrors.check:(ZLjava/lang/String;[Ljava/lang/Object;)V
7: aload 2
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 8 0 this Lcom/datastax/oss/protocol/internal/FrameCodec<TB;>;
0 8 1 frame Lcom/datastax/oss/protocol/internal/Frame;
1 8 2 encoder Lcom/datastax/oss/protocol/internal/Message$Codec;
MethodParameters:
Name Flags
frame
private int computeFlags(com.datastax.oss.protocol.internal.Frame);
descriptor: (Lcom/datastax/oss/protocol/internal/Frame;)I
flags: (0x0002) ACC_PRIVATE
Code:
stack=2, locals=3, args_size=2
start local 0 start local 1 0: iconst_0
istore 2
start local 2 1: aload 0
getfield com.datastax.oss.protocol.internal.FrameCodec.compressor:Lcom/datastax/oss/protocol/internal/Compressor;
instanceof com.datastax.oss.protocol.internal.NoopCompressor
ifne 5
2: aload 1
getfield com.datastax.oss.protocol.internal.Frame.message:Lcom/datastax/oss/protocol/internal/Message;
getfield com.datastax.oss.protocol.internal.Message.opcode:I
iconst_1
if_icmpeq 5
3: aload 1
getfield com.datastax.oss.protocol.internal.Frame.message:Lcom/datastax/oss/protocol/internal/Message;
getfield com.datastax.oss.protocol.internal.Message.opcode:I
iconst_5
if_icmpeq 5
4: iload 2
iconst_1
invokestatic com.datastax.oss.protocol.internal.util.Flags.add:(II)I
istore 2
5: StackMap locals: int
StackMap stack:
aload 1
getfield com.datastax.oss.protocol.internal.Frame.tracing:Z
ifne 6
aload 1
getfield com.datastax.oss.protocol.internal.Frame.tracingId:Ljava/util/UUID;
ifnull 7
6: StackMap locals:
StackMap stack:
iload 2
iconst_2
invokestatic com.datastax.oss.protocol.internal.util.Flags.add:(II)I
istore 2
7: StackMap locals:
StackMap stack:
aload 1
getfield com.datastax.oss.protocol.internal.Frame.customPayload:Ljava/util/Map;
invokeinterface java.util.Map.isEmpty:()Z
ifne 9
8: iload 2
iconst_4
invokestatic com.datastax.oss.protocol.internal.util.Flags.add:(II)I
istore 2
9: StackMap locals:
StackMap stack:
aload 1
getfield com.datastax.oss.protocol.internal.Frame.warnings:Ljava/util/List;
invokeinterface java.util.List.isEmpty:()Z
ifne 11
10: iload 2
bipush 8
invokestatic com.datastax.oss.protocol.internal.util.Flags.add:(II)I
istore 2
11: StackMap locals:
StackMap stack:
aload 1
getfield com.datastax.oss.protocol.internal.Frame.protocolVersion:I
iconst_5
if_icmpne 13
12: iload 2
bipush 16
invokestatic com.datastax.oss.protocol.internal.util.Flags.add:(II)I
istore 2
13: StackMap locals:
StackMap stack:
iload 2
ireturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 14 0 this Lcom/datastax/oss/protocol/internal/FrameCodec<TB;>;
0 14 1 frame Lcom/datastax/oss/protocol/internal/Frame;
1 14 2 flags I
MethodParameters:
Name Flags
frame
private void encodeInto(com.datastax.oss.protocol.internal.Frame, int, int, com.datastax.oss.protocol.internal.Message$Codec, );
descriptor: (Lcom/datastax/oss/protocol/internal/Frame;IILcom/datastax/oss/protocol/internal/Message$Codec;Ljava/lang/Object;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=5, locals=6, args_size=6
start local 0 start local 1 start local 2 start local 3 start local 4 start local 5 0: aload 0
aload 1
iload 3
iload 2
aload 5
invokevirtual com.datastax.oss.protocol.internal.FrameCodec.encodeHeaderInto:(Lcom/datastax/oss/protocol/internal/Frame;IILjava/lang/Object;)V
1: aload 0
aload 1
aload 4
aload 5
invokevirtual com.datastax.oss.protocol.internal.FrameCodec.encodeBodyInto:(Lcom/datastax/oss/protocol/internal/Frame;Lcom/datastax/oss/protocol/internal/Message$Codec;Ljava/lang/Object;)V
2: return
end local 5 end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lcom/datastax/oss/protocol/internal/FrameCodec<TB;>;
0 3 1 frame Lcom/datastax/oss/protocol/internal/Frame;
0 3 2 bodySize I
0 3 3 flags I
0 3 4 messageEncoder Lcom/datastax/oss/protocol/internal/Message$Codec;
0 3 5 dest TB;
Signature: (Lcom/datastax/oss/protocol/internal/Frame;IILcom/datastax/oss/protocol/internal/Message$Codec;TB;)V
MethodParameters:
Name Flags
frame
bodySize
flags
messageEncoder
dest
private void encodeHeaderInto(com.datastax.oss.protocol.internal.Frame, int, int, );
descriptor: (Lcom/datastax/oss/protocol/internal/Frame;IILjava/lang/Object;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=3, locals=6, args_size=5
start local 0 start local 1 start local 2 start local 3 start local 4 0: iload 3
ifge 2
1: aload 0
aload 1
invokevirtual com.datastax.oss.protocol.internal.FrameCodec.encodedBodySize:(Lcom/datastax/oss/protocol/internal/Frame;)I
istore 3
2: StackMap locals:
StackMap stack:
aload 1
getfield com.datastax.oss.protocol.internal.Frame.protocolVersion:I
istore 5
start local 5 3: aload 1
getfield com.datastax.oss.protocol.internal.Frame.message:Lcom/datastax/oss/protocol/internal/Message;
getfield com.datastax.oss.protocol.internal.Message.isResponse:Z
ifeq 5
4: iload 5
sipush 128
ior
istore 5
5: StackMap locals: int
StackMap stack:
aload 0
getfield com.datastax.oss.protocol.internal.FrameCodec.primitiveCodec:Lcom/datastax/oss/protocol/internal/PrimitiveCodec;
iload 5
i2b
aload 4
invokeinterface com.datastax.oss.protocol.internal.PrimitiveCodec.writeByte:(BLjava/lang/Object;)V
6: aload 0
getfield com.datastax.oss.protocol.internal.FrameCodec.primitiveCodec:Lcom/datastax/oss/protocol/internal/PrimitiveCodec;
iload 2
i2b
aload 4
invokeinterface com.datastax.oss.protocol.internal.PrimitiveCodec.writeByte:(BLjava/lang/Object;)V
7: aload 0
getfield com.datastax.oss.protocol.internal.FrameCodec.primitiveCodec:Lcom/datastax/oss/protocol/internal/PrimitiveCodec;
8: aload 1
getfield com.datastax.oss.protocol.internal.Frame.streamId:I
ldc 65535
iand
9: aload 4
10: invokeinterface com.datastax.oss.protocol.internal.PrimitiveCodec.writeUnsignedShort:(ILjava/lang/Object;)V
11: aload 0
getfield com.datastax.oss.protocol.internal.FrameCodec.primitiveCodec:Lcom/datastax/oss/protocol/internal/PrimitiveCodec;
aload 1
getfield com.datastax.oss.protocol.internal.Frame.message:Lcom/datastax/oss/protocol/internal/Message;
getfield com.datastax.oss.protocol.internal.Message.opcode:I
i2b
aload 4
invokeinterface com.datastax.oss.protocol.internal.PrimitiveCodec.writeByte:(BLjava/lang/Object;)V
12: aload 0
getfield com.datastax.oss.protocol.internal.FrameCodec.primitiveCodec:Lcom/datastax/oss/protocol/internal/PrimitiveCodec;
iload 3
aload 4
invokeinterface com.datastax.oss.protocol.internal.PrimitiveCodec.writeInt:(ILjava/lang/Object;)V
13: return
end local 5 end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 14 0 this Lcom/datastax/oss/protocol/internal/FrameCodec<TB;>;
0 14 1 frame Lcom/datastax/oss/protocol/internal/Frame;
0 14 2 flags I
0 14 3 bodySize I
0 14 4 dest TB;
3 14 5 versionAndDirection I
Signature: (Lcom/datastax/oss/protocol/internal/Frame;IITB;)V
MethodParameters:
Name Flags
frame
flags
bodySize
dest
private void encodeBodyInto(com.datastax.oss.protocol.internal.Frame, com.datastax.oss.protocol.internal.Message$Codec, );
descriptor: (Lcom/datastax/oss/protocol/internal/Frame;Lcom/datastax/oss/protocol/internal/Message$Codec;Ljava/lang/Object;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=4, locals=4, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
aload 1
getfield com.datastax.oss.protocol.internal.Frame.tracingId:Ljava/util/UUID;
aload 3
invokevirtual com.datastax.oss.protocol.internal.FrameCodec.encodeTracingId:(Ljava/util/UUID;Ljava/lang/Object;)V
1: aload 0
aload 1
getfield com.datastax.oss.protocol.internal.Frame.customPayload:Ljava/util/Map;
aload 3
invokevirtual com.datastax.oss.protocol.internal.FrameCodec.encodeCustomPayload:(Ljava/util/Map;Ljava/lang/Object;)V
2: aload 0
aload 1
getfield com.datastax.oss.protocol.internal.Frame.warnings:Ljava/util/List;
aload 3
invokevirtual com.datastax.oss.protocol.internal.FrameCodec.encodeWarnings:(Ljava/util/List;Ljava/lang/Object;)V
3: aload 2
aload 3
aload 1
getfield com.datastax.oss.protocol.internal.Frame.message:Lcom/datastax/oss/protocol/internal/Message;
aload 0
getfield com.datastax.oss.protocol.internal.FrameCodec.primitiveCodec:Lcom/datastax/oss/protocol/internal/PrimitiveCodec;
invokevirtual com.datastax.oss.protocol.internal.Message$Codec.encode:(Ljava/lang/Object;Lcom/datastax/oss/protocol/internal/Message;Lcom/datastax/oss/protocol/internal/PrimitiveCodec;)V
4: return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lcom/datastax/oss/protocol/internal/FrameCodec<TB;>;
0 5 1 frame Lcom/datastax/oss/protocol/internal/Frame;
0 5 2 messageEncoder Lcom/datastax/oss/protocol/internal/Message$Codec;
0 5 3 dest TB;
Signature: (Lcom/datastax/oss/protocol/internal/Frame;Lcom/datastax/oss/protocol/internal/Message$Codec;TB;)V
MethodParameters:
Name Flags
frame
messageEncoder
dest
private void encodeTracingId(java.util.UUID, );
descriptor: (Ljava/util/UUID;Ljava/lang/Object;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=3, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 1
ifnull 2
1: aload 0
getfield com.datastax.oss.protocol.internal.FrameCodec.primitiveCodec:Lcom/datastax/oss/protocol/internal/PrimitiveCodec;
aload 1
aload 2
invokeinterface com.datastax.oss.protocol.internal.PrimitiveCodec.writeUuid:(Ljava/util/UUID;Ljava/lang/Object;)V
2: StackMap locals:
StackMap stack:
return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lcom/datastax/oss/protocol/internal/FrameCodec<TB;>;
0 3 1 tracingId Ljava/util/UUID;
0 3 2 dest TB;
Signature: (Ljava/util/UUID;TB;)V
MethodParameters:
Name Flags
tracingId
dest
private void encodeCustomPayload(java.util.Map<java.lang.String, java.nio.ByteBuffer>, );
descriptor: (Ljava/util/Map;Ljava/lang/Object;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=3, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 1
invokeinterface java.util.Map.isEmpty:()Z
ifne 2
1: aload 0
getfield com.datastax.oss.protocol.internal.FrameCodec.primitiveCodec:Lcom/datastax/oss/protocol/internal/PrimitiveCodec;
aload 1
aload 2
invokeinterface com.datastax.oss.protocol.internal.PrimitiveCodec.writeBytesMap:(Ljava/util/Map;Ljava/lang/Object;)V
2: StackMap locals:
StackMap stack:
return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lcom/datastax/oss/protocol/internal/FrameCodec<TB;>;
0 3 1 customPayload Ljava/util/Map<Ljava/lang/String;Ljava/nio/ByteBuffer;>;
0 3 2 dest TB;
Signature: (Ljava/util/Map<Ljava/lang/String;Ljava/nio/ByteBuffer;>;TB;)V
MethodParameters:
Name Flags
customPayload
dest
private void encodeWarnings(java.util.List<java.lang.String>, );
descriptor: (Ljava/util/List;Ljava/lang/Object;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=3, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 1
invokeinterface java.util.List.isEmpty:()Z
ifne 2
1: aload 0
getfield com.datastax.oss.protocol.internal.FrameCodec.primitiveCodec:Lcom/datastax/oss/protocol/internal/PrimitiveCodec;
aload 1
aload 2
invokeinterface com.datastax.oss.protocol.internal.PrimitiveCodec.writeStringList:(Ljava/util/List;Ljava/lang/Object;)V
2: StackMap locals:
StackMap stack:
return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lcom/datastax/oss/protocol/internal/FrameCodec<TB;>;
0 3 1 warnings Ljava/util/List<Ljava/lang/String;>;
0 3 2 dest TB;
Signature: (Ljava/util/List<Ljava/lang/String;>;TB;)V
MethodParameters:
Name Flags
warnings
dest
public int (com.datastax.oss.protocol.internal.Frame);
descriptor: (Lcom/datastax/oss/protocol/internal/Frame;)I
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=2, args_size=2
start local 0 start local 1 0: bipush 9
ireturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lcom/datastax/oss/protocol/internal/FrameCodec<TB;>;
0 1 1 frame Lcom/datastax/oss/protocol/internal/Frame;
MethodParameters:
Name Flags
frame
public int encodedBodySize(com.datastax.oss.protocol.internal.Frame);
descriptor: (Lcom/datastax/oss/protocol/internal/Frame;)I
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=4, args_size=2
start local 0 start local 1 0: iconst_0
istore 2
start local 2 1: aload 1
getfield com.datastax.oss.protocol.internal.Frame.tracingId:Ljava/util/UUID;
ifnull 3
2: iinc 2 16
3: StackMap locals: int
StackMap stack:
aload 1
getfield com.datastax.oss.protocol.internal.Frame.customPayload:Ljava/util/Map;
invokeinterface java.util.Map.isEmpty:()Z
ifne 5
4: iload 2
aload 1
getfield com.datastax.oss.protocol.internal.Frame.customPayload:Ljava/util/Map;
invokestatic com.datastax.oss.protocol.internal.PrimitiveSizes.sizeOfBytesMap:(Ljava/util/Map;)I
iadd
istore 2
5: StackMap locals:
StackMap stack:
aload 1
getfield com.datastax.oss.protocol.internal.Frame.warnings:Ljava/util/List;
invokeinterface java.util.List.isEmpty:()Z
ifne 7
6: iload 2
aload 1
getfield com.datastax.oss.protocol.internal.Frame.warnings:Ljava/util/List;
invokestatic com.datastax.oss.protocol.internal.PrimitiveSizes.sizeOfStringList:(Ljava/util/List;)I
iadd
istore 2
7: StackMap locals:
StackMap stack:
aload 0
aload 1
invokevirtual com.datastax.oss.protocol.internal.FrameCodec.getMessageEncoder:(Lcom/datastax/oss/protocol/internal/Frame;)Lcom/datastax/oss/protocol/internal/Message$Codec;
astore 3
start local 3 8: iload 2
aload 3
aload 1
getfield com.datastax.oss.protocol.internal.Frame.message:Lcom/datastax/oss/protocol/internal/Message;
invokevirtual com.datastax.oss.protocol.internal.Message$Codec.encodedSize:(Lcom/datastax/oss/protocol/internal/Message;)I
iadd
ireturn
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 9 0 this Lcom/datastax/oss/protocol/internal/FrameCodec<TB;>;
0 9 1 frame Lcom/datastax/oss/protocol/internal/Frame;
1 9 2 size I
8 9 3 encoder Lcom/datastax/oss/protocol/internal/Message$Codec;
MethodParameters:
Name Flags
frame
public int decodeBodySize();
descriptor: (Ljava/lang/Object;)I
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield com.datastax.oss.protocol.internal.FrameCodec.primitiveCodec:Lcom/datastax/oss/protocol/internal/PrimitiveCodec;
aload 1
iconst_5
invokeinterface com.datastax.oss.protocol.internal.PrimitiveCodec.readInt:(Ljava/lang/Object;I)I
ireturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lcom/datastax/oss/protocol/internal/FrameCodec<TB;>;
0 1 1 source TB;
Signature: (TB;)I
MethodParameters:
Name Flags
source
public com.datastax.oss.protocol.internal.Frame decode(B);
descriptor: (Ljava/lang/Object;)Lcom/datastax/oss/protocol/internal/Frame;
flags: (0x0001) ACC_PUBLIC
Code:
stack=12, locals=19, args_size=2
start local 0 start local 1 0: aload 0
getfield com.datastax.oss.protocol.internal.FrameCodec.primitiveCodec:Lcom/datastax/oss/protocol/internal/PrimitiveCodec;
aload 1
invokeinterface com.datastax.oss.protocol.internal.PrimitiveCodec.readByte:(Ljava/lang/Object;)B
istore 2
start local 2 1: iload 2
sipush 128
iand
sipush 128
if_icmpne 2
iconst_1
goto 3
StackMap locals: int
StackMap stack:
2: iconst_0
StackMap locals:
StackMap stack: int
3: istore 3
start local 3 4: iload 2
bipush 127
iand
istore 4
start local 4 5: aload 0
getfield com.datastax.oss.protocol.internal.FrameCodec.primitiveCodec:Lcom/datastax/oss/protocol/internal/PrimitiveCodec;
aload 1
invokeinterface com.datastax.oss.protocol.internal.PrimitiveCodec.readByte:(Ljava/lang/Object;)B
istore 5
start local 5 6: iload 5
bipush 16
invokestatic com.datastax.oss.protocol.internal.util.Flags.contains:(II)Z
istore 6
start local 6 7: aload 0
aload 1
invokevirtual com.datastax.oss.protocol.internal.FrameCodec.readStreamId:(Ljava/lang/Object;)I
istore 7
start local 7 8: aload 0
getfield com.datastax.oss.protocol.internal.FrameCodec.primitiveCodec:Lcom/datastax/oss/protocol/internal/PrimitiveCodec;
aload 1
invokeinterface com.datastax.oss.protocol.internal.PrimitiveCodec.readByte:(Ljava/lang/Object;)B
istore 8
start local 8 9: aload 0
getfield com.datastax.oss.protocol.internal.FrameCodec.primitiveCodec:Lcom/datastax/oss/protocol/internal/PrimitiveCodec;
aload 1
invokeinterface com.datastax.oss.protocol.internal.PrimitiveCodec.readInt:(Ljava/lang/Object;)I
istore 9
start local 9 10: iconst_0
istore 10
start local 10 11: iload 5
iconst_1
invokestatic com.datastax.oss.protocol.internal.util.Flags.contains:(II)Z
ifeq 16
12: aload 0
getfield com.datastax.oss.protocol.internal.FrameCodec.compressor:Lcom/datastax/oss/protocol/internal/Compressor;
aload 1
invokeinterface com.datastax.oss.protocol.internal.Compressor.decompress:(Ljava/lang/Object;)Ljava/lang/Object;
astore 11
start local 11 13: aload 11
aload 1
if_acmpeq 16
14: iconst_1
istore 10
15: aload 11
astore 1
end local 11 16: StackMap locals: com.datastax.oss.protocol.internal.FrameCodec java.lang.Object int int int int int int int int int
StackMap stack:
iload 10
ifeq 21
17: bipush 9
aload 0
getfield com.datastax.oss.protocol.internal.FrameCodec.primitiveCodec:Lcom/datastax/oss/protocol/internal/PrimitiveCodec;
aload 1
invokeinterface com.datastax.oss.protocol.internal.PrimitiveCodec.sizeOf:(Ljava/lang/Object;)I
iadd
istore 11
start local 11 18: bipush 9
iload 9
iadd
19: istore 12
start local 12 20: goto 23
end local 12 end local 11 21: StackMap locals:
StackMap stack:
bipush 9
iload 9
iadd
istore 11
start local 11 22: iconst_m1
istore 12
start local 12 23: StackMap locals: int int
StackMap stack:
iload 5
iconst_2
invokestatic com.datastax.oss.protocol.internal.util.Flags.contains:(II)Z
istore 13
start local 13 24: iload 3
ifeq 25
iload 13
ifeq 25
aload 0
getfield com.datastax.oss.protocol.internal.FrameCodec.primitiveCodec:Lcom/datastax/oss/protocol/internal/PrimitiveCodec;
aload 1
invokeinterface com.datastax.oss.protocol.internal.PrimitiveCodec.readUuid:(Ljava/lang/Object;)Ljava/util/UUID;
goto 26
StackMap locals: int
StackMap stack:
25: aconst_null
StackMap locals:
StackMap stack: java.util.UUID
26: astore 14
start local 14 27: iload 5
iconst_4
invokestatic com.datastax.oss.protocol.internal.util.Flags.contains:(II)Z
ifeq 29
28: aload 0
getfield com.datastax.oss.protocol.internal.FrameCodec.primitiveCodec:Lcom/datastax/oss/protocol/internal/PrimitiveCodec;
aload 1
invokeinterface com.datastax.oss.protocol.internal.PrimitiveCodec.readBytesMap:(Ljava/lang/Object;)Ljava/util/Map;
goto 30
29: StackMap locals: java.util.UUID
StackMap stack:
invokestatic java.util.Collections.emptyMap:()Ljava/util/Map;
30: StackMap locals:
StackMap stack: java.util.Map
astore 15
start local 15 31: iload 3
ifeq 33
iload 5
bipush 8
invokestatic com.datastax.oss.protocol.internal.util.Flags.contains:(II)Z
ifeq 33
32: aload 0
getfield com.datastax.oss.protocol.internal.FrameCodec.primitiveCodec:Lcom/datastax/oss/protocol/internal/PrimitiveCodec;
aload 1
invokeinterface com.datastax.oss.protocol.internal.PrimitiveCodec.readStringList:(Ljava/lang/Object;)Ljava/util/List;
goto 34
33: StackMap locals: java.util.Map
StackMap stack:
invokestatic java.util.Collections.emptyList:()Ljava/util/List;
34: StackMap locals:
StackMap stack: java.util.List
astore 16
start local 16 35: aload 0
getfield com.datastax.oss.protocol.internal.FrameCodec.decoders:Lcom/datastax/oss/protocol/internal/util/IntIntMap;
iload 4
iload 8
invokevirtual com.datastax.oss.protocol.internal.util.IntIntMap.get:(II)Ljava/lang/Object;
checkcast com.datastax.oss.protocol.internal.Message$Codec
astore 17
start local 17 36: aload 17
ifnull 37
iconst_1
goto 38
StackMap locals: java.util.List com.datastax.oss.protocol.internal.Message$Codec
StackMap stack:
37: iconst_0
StackMap locals:
StackMap stack: int
38: ldc "Unsupported request opcode: %s in protocol %d"
iconst_2
anewarray java.lang.Object
dup
iconst_0
iload 8
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
aastore
dup
iconst_1
iload 4
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
aastore
39: invokestatic com.datastax.oss.protocol.internal.ProtocolErrors.check:(ZLjava/lang/String;[Ljava/lang/Object;)V
40: aload 17
aload 1
aload 0
getfield com.datastax.oss.protocol.internal.FrameCodec.primitiveCodec:Lcom/datastax/oss/protocol/internal/PrimitiveCodec;
invokevirtual com.datastax.oss.protocol.internal.Message$Codec.decode:(Ljava/lang/Object;Lcom/datastax/oss/protocol/internal/PrimitiveCodec;)Lcom/datastax/oss/protocol/internal/Message;
astore 18
start local 18 41: iload 10
ifeq 43
42: aload 0
getfield com.datastax.oss.protocol.internal.FrameCodec.primitiveCodec:Lcom/datastax/oss/protocol/internal/PrimitiveCodec;
aload 1
invokeinterface com.datastax.oss.protocol.internal.PrimitiveCodec.release:(Ljava/lang/Object;)V
43: StackMap locals: com.datastax.oss.protocol.internal.Message
StackMap stack:
new com.datastax.oss.protocol.internal.Frame
dup
44: iload 4
45: iload 6
46: iload 7
47: iload 13
48: aload 14
49: iload 11
50: iload 12
51: aload 15
52: aload 16
53: aload 18
54: invokespecial com.datastax.oss.protocol.internal.Frame.<init>:(IZIZLjava/util/UUID;IILjava/util/Map;Ljava/util/List;Lcom/datastax/oss/protocol/internal/Message;)V
areturn
end local 18 end local 17 end local 16 end local 15 end local 14 end local 13 end local 12 end local 11 end local 10 end local 9 end local 8 end local 7 end local 6 end local 5 end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 55 0 this Lcom/datastax/oss/protocol/internal/FrameCodec<TB;>;
0 55 1 source TB;
1 55 2 directionAndVersion I
4 55 3 isResponse Z
5 55 4 protocolVersion I
6 55 5 flags I
7 55 6 beta Z
8 55 7 streamId I
9 55 8 opcode I
10 55 9 length I
11 55 10 decompressed Z
13 16 11 newSource TB;
18 21 11 frameSize I
22 55 11 frameSize I
20 21 12 compressedFrameSize I
23 55 12 compressedFrameSize I
24 55 13 isTracing Z
27 55 14 tracingId Ljava/util/UUID;
31 55 15 customPayload Ljava/util/Map<Ljava/lang/String;Ljava/nio/ByteBuffer;>;
35 55 16 warnings Ljava/util/List<Ljava/lang/String;>;
36 55 17 decoder Lcom/datastax/oss/protocol/internal/Message$Codec;
41 55 18 response Lcom/datastax/oss/protocol/internal/Message;
Signature: (TB;)Lcom/datastax/oss/protocol/internal/Frame;
MethodParameters:
Name Flags
source
private int readStreamId();
descriptor: (Ljava/lang/Object;)I
flags: (0x0002) ACC_PRIVATE
Code:
stack=2, locals=3, args_size=2
start local 0 start local 1 0: aload 0
getfield com.datastax.oss.protocol.internal.FrameCodec.primitiveCodec:Lcom/datastax/oss/protocol/internal/PrimitiveCodec;
aload 1
invokeinterface com.datastax.oss.protocol.internal.PrimitiveCodec.readUnsignedShort:(Ljava/lang/Object;)I
istore 2
start local 2 1: iload 2
i2s
ireturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lcom/datastax/oss/protocol/internal/FrameCodec<TB;>;
0 2 1 source TB;
1 2 2 id I
Signature: (TB;)I
MethodParameters:
Name Flags
source
}
Signature: <B:Ljava/lang/Object;>Ljava/lang/Object;
SourceFile: "FrameCodec.java"
NestMembers:
com.datastax.oss.protocol.internal.FrameCodec$1 com.datastax.oss.protocol.internal.FrameCodec$CodecGroup com.datastax.oss.protocol.internal.FrameCodec$CodecGroup$Registry
InnerClasses:
com.datastax.oss.protocol.internal.FrameCodec$1
public abstract CodecGroup = com.datastax.oss.protocol.internal.FrameCodec$CodecGroup of com.datastax.oss.protocol.internal.FrameCodec
public abstract Registry = com.datastax.oss.protocol.internal.FrameCodec$CodecGroup$Registry of com.datastax.oss.protocol.internal.FrameCodec$CodecGroup
public abstract Codec = com.datastax.oss.protocol.internal.Message$Codec of com.datastax.oss.protocol.internal.Message
public Builder = com.datastax.oss.protocol.internal.util.IntIntMap$Builder of com.datastax.oss.protocol.internal.util.IntIntMap