public abstract class org.apache.cassandra.db.ReadResponse
minor version: 0
major version: 59
flags: flags: (0x0421) ACC_PUBLIC, ACC_SUPER, ACC_ABSTRACT
this_class: org.apache.cassandra.db.ReadResponse
super_class: java.lang.Object
{
public static final org.apache.cassandra.io.IVersionedSerializer<org.apache.cassandra.db.ReadResponse> serializer;
descriptor: Lorg/apache/cassandra/io/IVersionedSerializer;
flags: (0x0019) ACC_PUBLIC, ACC_STATIC, ACC_FINAL
Signature: Lorg/apache/cassandra/io/IVersionedSerializer<Lorg/apache/cassandra/db/ReadResponse;>;
public static final org.apache.cassandra.io.IVersionedSerializer<org.apache.cassandra.db.ReadResponse> legacyRangeSliceReplySerializer;
descriptor: Lorg/apache/cassandra/io/IVersionedSerializer;
flags: (0x0019) ACC_PUBLIC, ACC_STATIC, ACC_FINAL
Signature: Lorg/apache/cassandra/io/IVersionedSerializer<Lorg/apache/cassandra/db/ReadResponse;>;
public static final org.apache.cassandra.io.IVersionedSerializer<org.apache.cassandra.db.ReadResponse> rangeSliceSerializer;
descriptor: Lorg/apache/cassandra/io/IVersionedSerializer;
flags: (0x0019) ACC_PUBLIC, ACC_STATIC, ACC_FINAL
Signature: Lorg/apache/cassandra/io/IVersionedSerializer<Lorg/apache/cassandra/db/ReadResponse;>;
private final org.apache.cassandra.db.ReadCommand command;
descriptor: Lorg/apache/cassandra/db/ReadCommand;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
static void <clinit>();
descriptor: ()V
flags: (0x0008) ACC_STATIC
Code:
stack=2, locals=0, args_size=0
0: new org.apache.cassandra.db.ReadResponse$Serializer
dup
invokespecial org.apache.cassandra.db.ReadResponse$Serializer.<init>:()V
putstatic org.apache.cassandra.db.ReadResponse.serializer:Lorg/apache/cassandra/io/IVersionedSerializer;
1: new org.apache.cassandra.db.ReadResponse$LegacyRangeSliceReplySerializer
dup
invokespecial org.apache.cassandra.db.ReadResponse$LegacyRangeSliceReplySerializer.<init>:()V
putstatic org.apache.cassandra.db.ReadResponse.legacyRangeSliceReplySerializer:Lorg/apache/cassandra/io/IVersionedSerializer;
2: new org.apache.cassandra.db.ReadResponse$1
dup
invokespecial org.apache.cassandra.db.ReadResponse$1.<init>:()V
putstatic org.apache.cassandra.db.ReadResponse.rangeSliceSerializer:Lorg/apache/cassandra/io/IVersionedSerializer;
3: return
LocalVariableTable:
Start End Slot Name Signature
protected void <init>(org.apache.cassandra.db.ReadCommand);
descriptor: (Lorg/apache/cassandra/db/ReadCommand;)V
flags: (0x0004) ACC_PROTECTED
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
invokespecial java.lang.Object.<init>:()V
1: aload 0
aload 1
putfield org.apache.cassandra.db.ReadResponse.command:Lorg/apache/cassandra/db/ReadCommand;
2: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lorg/apache/cassandra/db/ReadResponse;
0 3 1 command Lorg/apache/cassandra/db/ReadCommand;
MethodParameters:
Name Flags
command
public static org.apache.cassandra.db.ReadResponse createDataResponse(org.apache.cassandra.db.partitions.UnfilteredPartitionIterator, org.apache.cassandra.db.ReadCommand);
descriptor: (Lorg/apache/cassandra/db/partitions/UnfilteredPartitionIterator;Lorg/apache/cassandra/db/ReadCommand;)Lorg/apache/cassandra/db/ReadResponse;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=4, locals=2, args_size=2
start local 0 start local 1 0: new org.apache.cassandra.db.ReadResponse$LocalDataResponse
dup
aload 0
aload 1
invokespecial org.apache.cassandra.db.ReadResponse$LocalDataResponse.<init>:(Lorg/apache/cassandra/db/partitions/UnfilteredPartitionIterator;Lorg/apache/cassandra/db/ReadCommand;)V
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 data Lorg/apache/cassandra/db/partitions/UnfilteredPartitionIterator;
0 1 1 command Lorg/apache/cassandra/db/ReadCommand;
MethodParameters:
Name Flags
data
command
public static org.apache.cassandra.db.ReadResponse createRemoteDataResponse(org.apache.cassandra.db.partitions.UnfilteredPartitionIterator, org.apache.cassandra.db.ReadCommand);
descriptor: (Lorg/apache/cassandra/db/partitions/UnfilteredPartitionIterator;Lorg/apache/cassandra/db/ReadCommand;)Lorg/apache/cassandra/db/ReadResponse;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=4, locals=2, args_size=2
start local 0 start local 1 0: new org.apache.cassandra.db.ReadResponse$RemoteDataResponse
dup
aload 0
aload 1
invokevirtual org.apache.cassandra.db.ReadCommand.columnFilter:()Lorg/apache/cassandra/db/filter/ColumnFilter;
invokestatic org.apache.cassandra.db.ReadResponse$LocalDataResponse.build:(Lorg/apache/cassandra/db/partitions/UnfilteredPartitionIterator;Lorg/apache/cassandra/db/filter/ColumnFilter;)Ljava/nio/ByteBuffer;
invokespecial org.apache.cassandra.db.ReadResponse$RemoteDataResponse.<init>:(Ljava/nio/ByteBuffer;)V
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 data Lorg/apache/cassandra/db/partitions/UnfilteredPartitionIterator;
0 1 1 command Lorg/apache/cassandra/db/ReadCommand;
RuntimeInvisibleAnnotations:
com.google.common.annotations.VisibleForTesting()
RuntimeInvisibleTypeAnnotations:
METHOD_RETURN
com.google.common.annotations.VisibleForTesting()
MethodParameters:
Name Flags
data
command
public static org.apache.cassandra.db.ReadResponse createDigestResponse(org.apache.cassandra.db.partitions.UnfilteredPartitionIterator, org.apache.cassandra.db.ReadCommand);
descriptor: (Lorg/apache/cassandra/db/partitions/UnfilteredPartitionIterator;Lorg/apache/cassandra/db/ReadCommand;)Lorg/apache/cassandra/db/ReadResponse;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=4, locals=2, args_size=2
start local 0 start local 1 0: new org.apache.cassandra.db.ReadResponse$DigestResponse
dup
aload 0
aload 1
invokestatic org.apache.cassandra.db.ReadResponse.makeDigest:(Lorg/apache/cassandra/db/partitions/UnfilteredPartitionIterator;Lorg/apache/cassandra/db/ReadCommand;)Ljava/nio/ByteBuffer;
invokespecial org.apache.cassandra.db.ReadResponse$DigestResponse.<init>:(Ljava/nio/ByteBuffer;)V
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 data Lorg/apache/cassandra/db/partitions/UnfilteredPartitionIterator;
0 1 1 command Lorg/apache/cassandra/db/ReadCommand;
MethodParameters:
Name Flags
data
command
public abstract org.apache.cassandra.db.partitions.UnfilteredPartitionIterator makeIterator(org.apache.cassandra.db.ReadCommand);
descriptor: (Lorg/apache/cassandra/db/ReadCommand;)Lorg/apache/cassandra/db/partitions/UnfilteredPartitionIterator;
flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
MethodParameters:
Name Flags
command
public abstract java.nio.ByteBuffer digest(org.apache.cassandra.db.ReadCommand);
descriptor: (Lorg/apache/cassandra/db/ReadCommand;)Ljava/nio/ByteBuffer;
flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
MethodParameters:
Name Flags
command
public abstract boolean isDigestResponse();
descriptor: ()Z
flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
public java.lang.String toDebugString(org.apache.cassandra.db.ReadCommand, org.apache.cassandra.db.DecoratedKey);
descriptor: (Lorg/apache/cassandra/db/ReadCommand;Lorg/apache/cassandra/db/DecoratedKey;)Ljava/lang/String;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=9, args_size=3
start local 0 start local 1 start local 2 0: aload 0
invokevirtual org.apache.cassandra.db.ReadResponse.isDigestResponse:()Z
ifeq 2
1: new java.lang.StringBuilder
dup
ldc "Digest:0x"
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 0
aload 1
invokevirtual org.apache.cassandra.db.ReadResponse.digest:(Lorg/apache/cassandra/db/ReadCommand;)Ljava/nio/ByteBuffer;
invokestatic org.apache.cassandra.utils.ByteBufferUtil.bytesToHex:(Ljava/nio/ByteBuffer;)Ljava/lang/String;
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
areturn
2: StackMap locals:
StackMap stack:
aconst_null
astore 3
aconst_null
astore 4
3: aload 0
aload 1
invokevirtual org.apache.cassandra.db.ReadResponse.makeIterator:(Lorg/apache/cassandra/db/ReadCommand;)Lorg/apache/cassandra/db/partitions/UnfilteredPartitionIterator;
astore 5
start local 5 4: goto 18
5: StackMap locals: java.lang.Throwable java.lang.Throwable org.apache.cassandra.db.partitions.UnfilteredPartitionIterator
StackMap stack:
aconst_null
astore 6
aconst_null
astore 7
6: aload 5
invokeinterface org.apache.cassandra.db.partitions.UnfilteredPartitionIterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.db.rows.UnfilteredRowIterator
astore 8
start local 8 7: aload 8
invokeinterface org.apache.cassandra.db.rows.UnfilteredRowIterator.partitionKey:()Lorg/apache/cassandra/db/DecoratedKey;
aload 2
invokevirtual org.apache.cassandra.db.DecoratedKey.equals:(Ljava/lang/Object;)Z
ifeq 12
8: aload 0
aload 8
aload 1
invokevirtual org.apache.cassandra.db.ReadCommand.metadata:()Lorg/apache/cassandra/config/CFMetaData;
invokevirtual org.apache.cassandra.db.ReadResponse.toDebugString:(Lorg/apache/cassandra/db/rows/UnfilteredRowIterator;Lorg/apache/cassandra/config/CFMetaData;)Ljava/lang/String;
9: aload 8
ifnull 10
aload 8
invokeinterface org.apache.cassandra.db.rows.UnfilteredRowIterator.close:()V
10: StackMap locals: org.apache.cassandra.db.ReadResponse org.apache.cassandra.db.ReadCommand org.apache.cassandra.db.DecoratedKey java.lang.Throwable java.lang.Throwable org.apache.cassandra.db.partitions.UnfilteredPartitionIterator java.lang.Throwable java.lang.Throwable org.apache.cassandra.db.rows.UnfilteredRowIterator
StackMap stack: java.lang.String
aload 5
ifnull 11
aload 5
invokeinterface org.apache.cassandra.db.partitions.UnfilteredPartitionIterator.close:()V
11: StackMap locals:
StackMap stack: java.lang.String
areturn
12: StackMap locals:
StackMap stack:
aload 8
ifnull 18
aload 8
invokeinterface org.apache.cassandra.db.rows.UnfilteredRowIterator.close:()V
goto 18
StackMap locals:
StackMap stack: java.lang.Throwable
13: astore 6
aload 8
ifnull 14
aload 8
invokeinterface org.apache.cassandra.db.rows.UnfilteredRowIterator.close:()V
end local 8 StackMap locals:
StackMap stack:
14: aload 6
athrow
StackMap locals:
StackMap stack: java.lang.Throwable
15: astore 7
aload 6
ifnonnull 16
aload 7
astore 6
goto 17
StackMap locals:
StackMap stack:
16: aload 6
aload 7
if_acmpeq 17
aload 6
aload 7
invokevirtual java.lang.Throwable.addSuppressed:(Ljava/lang/Throwable;)V
StackMap locals:
StackMap stack:
17: aload 6
athrow
18: StackMap locals:
StackMap stack:
aload 5
invokeinterface org.apache.cassandra.db.partitions.UnfilteredPartitionIterator.hasNext:()Z
ifne 5
19: aload 5
ifnull 25
aload 5
invokeinterface org.apache.cassandra.db.partitions.UnfilteredPartitionIterator.close:()V
goto 25
StackMap locals:
StackMap stack: java.lang.Throwable
20: astore 3
aload 5
ifnull 21
aload 5
invokeinterface org.apache.cassandra.db.partitions.UnfilteredPartitionIterator.close:()V
end local 5 StackMap locals:
StackMap stack:
21: aload 3
athrow
StackMap locals:
StackMap stack: java.lang.Throwable
22: astore 4
aload 3
ifnonnull 23
aload 4
astore 3
goto 24
StackMap locals:
StackMap stack:
23: aload 3
aload 4
if_acmpeq 24
aload 3
aload 4
invokevirtual java.lang.Throwable.addSuppressed:(Ljava/lang/Throwable;)V
StackMap locals:
StackMap stack:
24: aload 3
athrow
25: StackMap locals:
StackMap stack:
new java.lang.StringBuilder
dup
ldc "<key "
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 2
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/Object;)Ljava/lang/StringBuilder;
ldc " not found>"
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 26 0 this Lorg/apache/cassandra/db/ReadResponse;
0 26 1 command Lorg/apache/cassandra/db/ReadCommand;
0 26 2 key Lorg/apache/cassandra/db/DecoratedKey;
4 21 5 iter Lorg/apache/cassandra/db/partitions/UnfilteredPartitionIterator;
7 14 8 partition Lorg/apache/cassandra/db/rows/UnfilteredRowIterator;
Exception table:
from to target type
7 9 13 any
6 10 15 any
12 15 15 any
4 10 20 any
12 19 20 any
3 11 22 any
12 22 22 any
MethodParameters:
Name Flags
command
key
private java.lang.String toDebugString(org.apache.cassandra.db.rows.UnfilteredRowIterator, org.apache.cassandra.config.CFMetaData);
descriptor: (Lorg/apache/cassandra/db/rows/UnfilteredRowIterator;Lorg/apache/cassandra/config/CFMetaData;)Ljava/lang/String;
flags: (0x0002) ACC_PRIVATE
Code:
stack=7, locals=4, args_size=3
start local 0 start local 1 start local 2 0: new java.lang.StringBuilder
dup
invokespecial java.lang.StringBuilder.<init>:()V
astore 3
start local 3 1: aload 3
ldc "[%s.%s] key=%s partition_deletion=%s columns=%s"
iconst_5
anewarray java.lang.Object
dup
iconst_0
2: aload 2
getfield org.apache.cassandra.config.CFMetaData.ksName:Ljava/lang/String;
aastore
dup
iconst_1
3: aload 2
getfield org.apache.cassandra.config.CFMetaData.cfName:Ljava/lang/String;
aastore
dup
iconst_2
4: aload 2
invokevirtual org.apache.cassandra.config.CFMetaData.getKeyValidator:()Lorg/apache/cassandra/db/marshal/AbstractType;
aload 1
invokeinterface org.apache.cassandra.db.rows.UnfilteredRowIterator.partitionKey:()Lorg/apache/cassandra/db/DecoratedKey;
invokevirtual org.apache.cassandra.db.DecoratedKey.getKey:()Ljava/nio/ByteBuffer;
invokevirtual org.apache.cassandra.db.marshal.AbstractType.getString:(Ljava/nio/ByteBuffer;)Ljava/lang/String;
aastore
dup
iconst_3
5: aload 1
invokeinterface org.apache.cassandra.db.rows.UnfilteredRowIterator.partitionLevelDeletion:()Lorg/apache/cassandra/db/DeletionTime;
aastore
dup
iconst_4
6: aload 1
invokeinterface org.apache.cassandra.db.rows.UnfilteredRowIterator.columns:()Lorg/apache/cassandra/db/PartitionColumns;
aastore
7: invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
pop
8: aload 1
invokeinterface org.apache.cassandra.db.rows.UnfilteredRowIterator.staticRow:()Lorg/apache/cassandra/db/rows/Row;
getstatic org.apache.cassandra.db.rows.Rows.EMPTY_STATIC_ROW:Lorg/apache/cassandra/db/rows/Row;
if_acmpeq 12
9: aload 3
ldc "\n "
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
aload 1
invokeinterface org.apache.cassandra.db.rows.UnfilteredRowIterator.staticRow:()Lorg/apache/cassandra/db/rows/Row;
aload 2
iconst_1
invokeinterface org.apache.cassandra.db.rows.Row.toString:(Lorg/apache/cassandra/config/CFMetaData;Z)Ljava/lang/String;
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
pop
10: goto 12
11: StackMap locals: java.lang.StringBuilder
StackMap stack:
aload 3
ldc "\n "
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
aload 1
invokeinterface org.apache.cassandra.db.rows.UnfilteredRowIterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.db.rows.Unfiltered
aload 2
iconst_1
invokeinterface org.apache.cassandra.db.rows.Unfiltered.toString:(Lorg/apache/cassandra/config/CFMetaData;Z)Ljava/lang/String;
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
pop
12: StackMap locals:
StackMap stack:
aload 1
invokeinterface org.apache.cassandra.db.rows.UnfilteredRowIterator.hasNext:()Z
ifne 11
13: aload 3
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
areturn
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 14 0 this Lorg/apache/cassandra/db/ReadResponse;
0 14 1 partition Lorg/apache/cassandra/db/rows/UnfilteredRowIterator;
0 14 2 metadata Lorg/apache/cassandra/config/CFMetaData;
1 14 3 sb Ljava/lang/StringBuilder;
MethodParameters:
Name Flags
partition
metadata
protected static java.nio.ByteBuffer makeDigest(org.apache.cassandra.db.partitions.UnfilteredPartitionIterator, org.apache.cassandra.db.ReadCommand);
descriptor: (Lorg/apache/cassandra/db/partitions/UnfilteredPartitionIterator;Lorg/apache/cassandra/db/ReadCommand;)Ljava/nio/ByteBuffer;
flags: (0x000c) ACC_PROTECTED, ACC_STATIC
Code:
stack=4, locals=3, args_size=2
start local 0 start local 1 0: invokestatic org.apache.cassandra.utils.FBUtilities.threadLocalMD5Digest:()Ljava/security/MessageDigest;
astore 2
start local 2 1: aload 1
aload 0
aload 2
aload 1
invokevirtual org.apache.cassandra.db.ReadCommand.digestVersion:()I
invokestatic org.apache.cassandra.db.partitions.UnfilteredPartitionIterators.digest:(Lorg/apache/cassandra/db/ReadCommand;Lorg/apache/cassandra/db/partitions/UnfilteredPartitionIterator;Ljava/security/MessageDigest;I)V
2: aload 2
invokevirtual java.security.MessageDigest.digest:()[B
invokestatic java.nio.ByteBuffer.wrap:([B)Ljava/nio/ByteBuffer;
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 iterator Lorg/apache/cassandra/db/partitions/UnfilteredPartitionIterator;
0 3 1 command Lorg/apache/cassandra/db/ReadCommand;
1 3 2 digest Ljava/security/MessageDigest;
MethodParameters:
Name Flags
iterator
command
}
SourceFile: "ReadResponse.java"
NestMembers:
org.apache.cassandra.db.ReadResponse$1 org.apache.cassandra.db.ReadResponse$DataResponse org.apache.cassandra.db.ReadResponse$DigestResponse org.apache.cassandra.db.ReadResponse$LegacyRangeSliceReplySerializer org.apache.cassandra.db.ReadResponse$LegacyRemoteDataResponse org.apache.cassandra.db.ReadResponse$LegacyRemoteDataResponse$1 org.apache.cassandra.db.ReadResponse$LocalDataResponse org.apache.cassandra.db.ReadResponse$RemoteDataResponse org.apache.cassandra.db.ReadResponse$Serializer
InnerClasses:
org.apache.cassandra.db.ReadResponse$1
abstract DataResponse = org.apache.cassandra.db.ReadResponse$DataResponse of org.apache.cassandra.db.ReadResponse
private DigestResponse = org.apache.cassandra.db.ReadResponse$DigestResponse of org.apache.cassandra.db.ReadResponse
private LegacyRangeSliceReplySerializer = org.apache.cassandra.db.ReadResponse$LegacyRangeSliceReplySerializer of org.apache.cassandra.db.ReadResponse
LegacyRemoteDataResponse = org.apache.cassandra.db.ReadResponse$LegacyRemoteDataResponse of org.apache.cassandra.db.ReadResponse
private LocalDataResponse = org.apache.cassandra.db.ReadResponse$LocalDataResponse of org.apache.cassandra.db.ReadResponse
private RemoteDataResponse = org.apache.cassandra.db.ReadResponse$RemoteDataResponse of org.apache.cassandra.db.ReadResponse
private Serializer = org.apache.cassandra.db.ReadResponse$Serializer of org.apache.cassandra.db.ReadResponse