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
{
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=13, 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: aload 1
getfield com.datastax.oss.protocol.internal.Frame.message:Lcom/datastax/oss/protocol/internal/Message;
astore 3
start local 3 2: iload 2
iconst_4
if_icmpge 3
aload 1
getfield com.datastax.oss.protocol.internal.Frame.customPayload:Ljava/util/Map;
invokeinterface java.util.Map.isEmpty:()Z
ifne 3
iconst_0
goto 4
StackMap locals: int com.datastax.oss.protocol.internal.Message
StackMap stack:
3: iconst_1
4: StackMap locals:
StackMap stack: int
ldc "Custom payload is not supported in protocol v%d"
iconst_1
anewarray java.lang.Object
dup
iconst_0
5: iload 2
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: iload 2
iconst_4
if_icmpge 8
aload 1
getfield com.datastax.oss.protocol.internal.Frame.warnings:Ljava/util/List;
invokeinterface java.util.List.isEmpty:()Z
ifne 8
iconst_0
goto 9
StackMap locals:
StackMap stack:
8: iconst_1
9: StackMap locals:
StackMap stack: int
ldc "Warnings are not supported in protocol v%d"
iconst_1
anewarray java.lang.Object
dup
iconst_0
10: iload 2
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
aastore
11: invokestatic com.datastax.oss.protocol.internal.ProtocolErrors.check:(ZLjava/lang/String;[Ljava/lang/Object;)V
12: aload 3
getfield com.datastax.oss.protocol.internal.Message.opcode:I
istore 4
start local 4 13: aload 0
getfield com.datastax.oss.protocol.internal.FrameCodec.encoders:Lcom/datastax/oss/protocol/internal/util/IntIntMap;
iload 2
iload 4
invokevirtual com.datastax.oss.protocol.internal.util.IntIntMap.get:(II)Ljava/lang/Object;
checkcast com.datastax.oss.protocol.internal.Message$Codec
astore 5
start local 5 14: aload 5
ifnull 15
iconst_1
goto 16
StackMap locals: int com.datastax.oss.protocol.internal.Message$Codec
StackMap stack:
15: iconst_0
StackMap locals:
StackMap stack: int
16: ldc "Unsupported opcode %s in protocol v%d"
iconst_2
anewarray java.lang.Object
dup
iconst_0
iload 4
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
aastore
dup
iconst_1
iload 2
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
aastore
17: invokestatic com.datastax.oss.protocol.internal.ProtocolErrors.check:(ZLjava/lang/String;[Ljava/lang/Object;)V
18: iconst_0
istore 6
start local 6 19: aload 0
getfield com.datastax.oss.protocol.internal.FrameCodec.compressor:Lcom/datastax/oss/protocol/internal/Compressor;
instanceof com.datastax.oss.protocol.internal.NoopCompressor
ifne 21
iload 4
iconst_1
if_icmpeq 21
20: iload 6
iconst_1
invokestatic com.datastax.oss.protocol.internal.util.Flags.add:(II)I
istore 6
21: StackMap locals: int
StackMap stack:
aload 1
getfield com.datastax.oss.protocol.internal.Frame.tracing:Z
ifne 22
aload 1
getfield com.datastax.oss.protocol.internal.Frame.tracingId:Ljava/util/UUID;
ifnull 23
22: StackMap locals:
StackMap stack:
iload 6
iconst_2
invokestatic com.datastax.oss.protocol.internal.util.Flags.add:(II)I
istore 6
23: StackMap locals:
StackMap stack:
aload 1
getfield com.datastax.oss.protocol.internal.Frame.customPayload:Ljava/util/Map;
invokeinterface java.util.Map.isEmpty:()Z
ifne 25
24: iload 6
iconst_4
invokestatic com.datastax.oss.protocol.internal.util.Flags.add:(II)I
istore 6
25: StackMap locals:
StackMap stack:
aload 1
getfield com.datastax.oss.protocol.internal.Frame.warnings:Ljava/util/List;
invokeinterface java.util.List.isEmpty:()Z
ifne 27
26: iload 6
bipush 8
invokestatic com.datastax.oss.protocol.internal.util.Flags.add:(II)I
istore 6
27: StackMap locals:
StackMap stack:
iload 2
iconst_5
if_icmpne 29
28: iload 6
bipush 16
invokestatic com.datastax.oss.protocol.internal.util.Flags.add:(II)I
istore 6
29: StackMap locals:
StackMap stack:
invokestatic com.datastax.oss.protocol.internal.FrameCodec.headerEncodedSize:()I
istore 7
start local 7 30: iload 6
iconst_1
invokestatic com.datastax.oss.protocol.internal.util.Flags.contains:(II)Z
ifne 45
31: aload 5
aload 3
invokevirtual com.datastax.oss.protocol.internal.Message$Codec.encodedSize:(Lcom/datastax/oss/protocol/internal/Message;)I
istore 8
start local 8 32: aload 1
getfield com.datastax.oss.protocol.internal.Frame.tracingId:Ljava/util/UUID;
ifnull 34
33: iinc 8 16
34: StackMap locals: int int
StackMap stack:
aload 1
getfield com.datastax.oss.protocol.internal.Frame.customPayload:Ljava/util/Map;
invokeinterface java.util.Map.isEmpty:()Z
ifne 36
35: iload 8
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 8
36: StackMap locals:
StackMap stack:
aload 1
getfield com.datastax.oss.protocol.internal.Frame.warnings:Ljava/util/List;
invokeinterface java.util.List.isEmpty:()Z
ifne 38
37: iload 8
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 8
38: StackMap locals:
StackMap stack:
aload 0
getfield com.datastax.oss.protocol.internal.FrameCodec.primitiveCodec:Lcom/datastax/oss/protocol/internal/PrimitiveCodec;
iload 7
iload 8
iadd
invokeinterface com.datastax.oss.protocol.internal.PrimitiveCodec.allocate:(I)Ljava/lang/Object;
astore 9
start local 9 39: aload 0
aload 1
iload 6
iload 8
aload 9
invokevirtual com.datastax.oss.protocol.internal.FrameCodec.encodeHeader:(Lcom/datastax/oss/protocol/internal/Frame;IILjava/lang/Object;)V
40: aload 0
aload 1
getfield com.datastax.oss.protocol.internal.Frame.tracingId:Ljava/util/UUID;
aload 9
invokevirtual com.datastax.oss.protocol.internal.FrameCodec.encodeTracingId:(Ljava/util/UUID;Ljava/lang/Object;)V
41: aload 0
aload 1
getfield com.datastax.oss.protocol.internal.Frame.customPayload:Ljava/util/Map;
aload 9
invokevirtual com.datastax.oss.protocol.internal.FrameCodec.encodeCustomPayload:(Ljava/util/Map;Ljava/lang/Object;)V
42: aload 0
aload 1
getfield com.datastax.oss.protocol.internal.Frame.warnings:Ljava/util/List;
aload 9
invokevirtual com.datastax.oss.protocol.internal.FrameCodec.encodeWarnings:(Ljava/util/List;Ljava/lang/Object;)V
43: aload 5
aload 9
aload 3
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
44: aload 9
areturn
end local 9 end local 8 45: StackMap locals:
StackMap stack:
aload 5
aload 3
invokevirtual com.datastax.oss.protocol.internal.Message$Codec.encodedSize:(Lcom/datastax/oss/protocol/internal/Message;)I
istore 8
start local 8 46: aload 1
getfield com.datastax.oss.protocol.internal.Frame.tracingId:Ljava/util/UUID;
ifnull 48
47: iinc 8 16
48: 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 50
49: iload 8
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 8
50: StackMap locals:
StackMap stack:
aload 1
getfield com.datastax.oss.protocol.internal.Frame.warnings:Ljava/util/List;
invokeinterface java.util.List.isEmpty:()Z
ifne 52
51: iload 8
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 8
52: StackMap locals:
StackMap stack:
aload 0
getfield com.datastax.oss.protocol.internal.FrameCodec.primitiveCodec:Lcom/datastax/oss/protocol/internal/PrimitiveCodec;
iload 8
invokeinterface com.datastax.oss.protocol.internal.PrimitiveCodec.allocate:(I)Ljava/lang/Object;
astore 9
start local 9 53: aload 0
aload 1
getfield com.datastax.oss.protocol.internal.Frame.tracingId:Ljava/util/UUID;
aload 9
invokevirtual com.datastax.oss.protocol.internal.FrameCodec.encodeTracingId:(Ljava/util/UUID;Ljava/lang/Object;)V
54: aload 0
aload 1
getfield com.datastax.oss.protocol.internal.Frame.customPayload:Ljava/util/Map;
aload 9
invokevirtual com.datastax.oss.protocol.internal.FrameCodec.encodeCustomPayload:(Ljava/util/Map;Ljava/lang/Object;)V
55: aload 0
aload 1
getfield com.datastax.oss.protocol.internal.Frame.warnings:Ljava/util/List;
aload 9
invokevirtual com.datastax.oss.protocol.internal.FrameCodec.encodeWarnings:(Ljava/util/List;Ljava/lang/Object;)V
56: aload 5
aload 9
aload 3
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
57: aload 0
getfield com.datastax.oss.protocol.internal.FrameCodec.compressor:Lcom/datastax/oss/protocol/internal/Compressor;
aload 9
invokeinterface com.datastax.oss.protocol.internal.Compressor.compress:(Ljava/lang/Object;)Ljava/lang/Object;
astore 10
start local 10 58: aload 0
getfield com.datastax.oss.protocol.internal.FrameCodec.primitiveCodec:Lcom/datastax/oss/protocol/internal/PrimitiveCodec;
aload 9
invokeinterface com.datastax.oss.protocol.internal.PrimitiveCodec.release:(Ljava/lang/Object;)V
59: aload 0
getfield com.datastax.oss.protocol.internal.FrameCodec.primitiveCodec:Lcom/datastax/oss/protocol/internal/PrimitiveCodec;
aload 10
invokeinterface com.datastax.oss.protocol.internal.PrimitiveCodec.sizeOf:(Ljava/lang/Object;)I
istore 11
start local 11 60: aload 0
getfield com.datastax.oss.protocol.internal.FrameCodec.primitiveCodec:Lcom/datastax/oss/protocol/internal/PrimitiveCodec;
iload 7
invokeinterface com.datastax.oss.protocol.internal.PrimitiveCodec.allocate:(I)Ljava/lang/Object;
astore 12
start local 12 61: aload 0
aload 1
iload 6
iload 11
aload 12
invokevirtual com.datastax.oss.protocol.internal.FrameCodec.encodeHeader:(Lcom/datastax/oss/protocol/internal/Frame;IILjava/lang/Object;)V
62: aload 0
getfield com.datastax.oss.protocol.internal.FrameCodec.primitiveCodec:Lcom/datastax/oss/protocol/internal/PrimitiveCodec;
aload 12
aload 10
invokeinterface com.datastax.oss.protocol.internal.PrimitiveCodec.concat:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
areturn
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 63 0 this Lcom/datastax/oss/protocol/internal/FrameCodec<TB;>;
0 63 1 frame Lcom/datastax/oss/protocol/internal/Frame;
1 63 2 protocolVersion I
2 63 3 request Lcom/datastax/oss/protocol/internal/Message;
13 63 4 opcode I
14 63 5 encoder Lcom/datastax/oss/protocol/internal/Message$Codec;
19 63 6 flags I
30 63 7 headerSize I
32 45 8 messageSize I
39 45 9 dest TB;
46 63 8 uncompressedMessageSize I
53 63 9 uncompressedMessage TB;
58 63 10 compressedMessage TB;
60 63 11 messageSize I
61 63 12 header TB;
Signature: (Lcom/datastax/oss/protocol/internal/Frame;)TB;
MethodParameters:
Name Flags
frame
public static int ();
descriptor: ()I
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=1, locals=0, args_size=0
0: bipush 9
ireturn
LocalVariableTable:
Start End Slot Name Signature
private void encodeHeader(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: aload 1
getfield com.datastax.oss.protocol.internal.Frame.protocolVersion:I
istore 5
start local 5 1: 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 3
2: iload 5
sipush 128
ior
istore 5
3: 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
4: 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
5: aload 0
getfield com.datastax.oss.protocol.internal.FrameCodec.primitiveCodec:Lcom/datastax/oss/protocol/internal/PrimitiveCodec;
6: aload 1
getfield com.datastax.oss.protocol.internal.Frame.streamId:I
ldc 65535
iand
7: aload 4
8: invokeinterface com.datastax.oss.protocol.internal.PrimitiveCodec.writeUnsignedShort:(ILjava/lang/Object;)V
9: 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
10: 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
11: 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 12 0 this Lcom/datastax/oss/protocol/internal/FrameCodec<TB;>;
0 12 1 frame Lcom/datastax/oss/protocol/internal/Frame;
0 12 2 flags I
0 12 3 messageSize I
0 12 4 dest TB;
1 12 5 versionAndDirection I
Signature: (Lcom/datastax/oss/protocol/internal/Frame;IITB;)V
MethodParameters:
Name Flags
frame
flags
messageSize
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 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=20, 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: 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
istore 10
start local 10 11: iload 9
iload 10
if_icmpne 12
iconst_1
goto 13
StackMap locals: com.datastax.oss.protocol.internal.FrameCodec java.lang.Object int int int int int int int int int
StackMap stack:
12: iconst_0
13: StackMap locals:
StackMap stack: int
ldc "Declared length in header (%d) does not match actual length (%d)"
iconst_2
anewarray java.lang.Object
dup
iconst_0
14: iload 9
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
aastore
dup
iconst_1
15: iload 10
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
aastore
16: invokestatic com.datastax.oss.protocol.internal.ProtocolErrors.check:(ZLjava/lang/String;[Ljava/lang/Object;)V
17: iconst_0
istore 11
start local 11 18: iload 5
iconst_1
invokestatic com.datastax.oss.protocol.internal.util.Flags.contains:(II)Z
ifeq 23
19: 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 12
start local 12 20: aload 12
aload 1
if_acmpeq 23
21: iconst_1
istore 11
22: aload 12
astore 1
end local 12 23: StackMap locals: int
StackMap stack:
iload 11
ifeq 27
24: invokestatic com.datastax.oss.protocol.internal.FrameCodec.headerEncodedSize:()I
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 12
start local 12 25: invokestatic com.datastax.oss.protocol.internal.FrameCodec.headerEncodedSize:()I
iload 9
iadd
istore 13
start local 13 26: goto 29
end local 13 end local 12 27: StackMap locals:
StackMap stack:
invokestatic com.datastax.oss.protocol.internal.FrameCodec.headerEncodedSize:()I
iload 9
iadd
istore 12
start local 12 28: iconst_m1
istore 13
start local 13 29: StackMap locals: int int
StackMap stack:
iload 5
iconst_2
invokestatic com.datastax.oss.protocol.internal.util.Flags.contains:(II)Z
istore 14
start local 14 30: iload 3
ifeq 31
iload 14
ifeq 31
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 32
StackMap locals: int
StackMap stack:
31: aconst_null
StackMap locals:
StackMap stack: java.util.UUID
32: astore 15
start local 15 33: iload 5
iconst_4
invokestatic com.datastax.oss.protocol.internal.util.Flags.contains:(II)Z
ifeq 35
34: 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 36
35: StackMap locals: java.util.UUID
StackMap stack:
invokestatic java.util.Collections.emptyMap:()Ljava/util/Map;
36: StackMap locals:
StackMap stack: java.util.Map
astore 16
start local 16 37: iload 3
ifeq 39
iload 5
bipush 8
invokestatic com.datastax.oss.protocol.internal.util.Flags.contains:(II)Z
ifeq 39
38: 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 40
39: StackMap locals: java.util.Map
StackMap stack:
invokestatic java.util.Collections.emptyList:()Ljava/util/List;
40: StackMap locals:
StackMap stack: java.util.List
astore 17
start local 17 41: 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 18
start local 18 42: aload 18
ifnull 43
iconst_1
goto 44
StackMap locals: java.util.List com.datastax.oss.protocol.internal.Message$Codec
StackMap stack:
43: iconst_0
StackMap locals:
StackMap stack: int
44: 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
45: invokestatic com.datastax.oss.protocol.internal.ProtocolErrors.check:(ZLjava/lang/String;[Ljava/lang/Object;)V
46: aload 18
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 19
start local 19 47: iload 11
ifeq 49
48: 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
49: StackMap locals: com.datastax.oss.protocol.internal.Message
StackMap stack:
new com.datastax.oss.protocol.internal.Frame
dup
50: iload 4
51: iload 6
52: iload 7
53: iload 14
54: aload 15
55: iload 12
56: iload 13
57: aload 16
58: aload 17
59: aload 19
60: 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 19 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 61 0 this Lcom/datastax/oss/protocol/internal/FrameCodec<TB;>;
0 61 1 source TB;
1 61 2 directionAndVersion I
4 61 3 isResponse Z
5 61 4 protocolVersion I
6 61 5 flags I
7 61 6 beta Z
8 61 7 streamId I
9 61 8 opcode I
10 61 9 length I
11 61 10 actualLength I
18 61 11 decompressed Z
20 23 12 newSource TB;
25 27 12 frameSize I
28 61 12 frameSize I
26 27 13 compressedFrameSize I
29 61 13 compressedFrameSize I
30 61 14 isTracing Z
33 61 15 tracingId Ljava/util/UUID;
37 61 16 customPayload Ljava/util/Map<Ljava/lang/String;Ljava/nio/ByteBuffer;>;
41 61 17 warnings Ljava/util/List<Ljava/lang/String;>;
42 61 18 decoder Lcom/datastax/oss/protocol/internal/Message$Codec;
47 61 19 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