public class org.apache.cassandra.db.commitlog.CommitLogReader
minor version: 0
major version: 59
flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
this_class: org.apache.cassandra.db.commitlog.CommitLogReader
super_class: java.lang.Object
{
private static final org.slf4j.Logger logger;
descriptor: Lorg/slf4j/Logger;
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
private static final int LEGACY_END_OF_SEGMENT_MARKER;
descriptor: I
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
ConstantValue: 0
public static final int ALL_MUTATIONS;
descriptor: I
flags: (0x0019) ACC_PUBLIC, ACC_STATIC, ACC_FINAL
ConstantValue: -1
RuntimeInvisibleAnnotations:
com.google.common.annotations.VisibleForTesting()
private final java.util.zip.CRC32 checksum;
descriptor: Ljava/util/zip/CRC32;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final java.util.Map<java.util.UUID, java.util.concurrent.atomic.AtomicInteger> invalidMutations;
descriptor: Ljava/util/Map;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Ljava/util/Map<Ljava/util/UUID;Ljava/util/concurrent/atomic/AtomicInteger;>;
private byte[] buffer;
descriptor: [B
flags: (0x0002) ACC_PRIVATE
static void <clinit>();
descriptor: ()V
flags: (0x0008) ACC_STATIC
Code:
stack=1, locals=0, args_size=0
0: ldc Lorg/apache/cassandra/db/commitlog/CommitLogReader;
invokestatic org.slf4j.LoggerFactory.getLogger:(Ljava/lang/Class;)Lorg/slf4j/Logger;
putstatic org.apache.cassandra.db.commitlog.CommitLogReader.logger:Lorg/slf4j/Logger;
1: return
LocalVariableTable:
Start End Slot Name Signature
public void <init>();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=1, args_size=1
start local 0 0: aload 0
invokespecial java.lang.Object.<init>:()V
1: aload 0
new java.util.zip.CRC32
dup
invokespecial java.util.zip.CRC32.<init>:()V
putfield org.apache.cassandra.db.commitlog.CommitLogReader.checksum:Ljava/util/zip/CRC32;
2: aload 0
new java.util.HashMap
dup
invokespecial java.util.HashMap.<init>:()V
putfield org.apache.cassandra.db.commitlog.CommitLogReader.invalidMutations:Ljava/util/Map;
3: aload 0
sipush 4096
newarray 8
putfield org.apache.cassandra.db.commitlog.CommitLogReader.buffer:[B
4: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lorg/apache/cassandra/db/commitlog/CommitLogReader;
public java.util.Set<java.util.Map$Entry<java.util.UUID, java.util.concurrent.atomic.AtomicInteger>> getInvalidMutations();
descriptor: ()Ljava/util/Set;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.db.commitlog.CommitLogReader.invalidMutations:Ljava/util/Map;
invokeinterface java.util.Map.entrySet:()Ljava/util/Set;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/db/commitlog/CommitLogReader;
Signature: ()Ljava/util/Set<Ljava/util/Map$Entry<Ljava/util/UUID;Ljava/util/concurrent/atomic/AtomicInteger;>;>;
public void readAllFiles(org.apache.cassandra.db.commitlog.CommitLogReadHandler, java.io.File[]);
descriptor: (Lorg/apache/cassandra/db/commitlog/CommitLogReadHandler;[Ljava/io/File;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
aload 1
aload 2
getstatic org.apache.cassandra.db.commitlog.CommitLogPosition.NONE:Lorg/apache/cassandra/db/commitlog/CommitLogPosition;
invokevirtual org.apache.cassandra.db.commitlog.CommitLogReader.readAllFiles:(Lorg/apache/cassandra/db/commitlog/CommitLogReadHandler;[Ljava/io/File;Lorg/apache/cassandra/db/commitlog/CommitLogPosition;)V
1: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/apache/cassandra/db/commitlog/CommitLogReader;
0 2 1 handler Lorg/apache/cassandra/db/commitlog/CommitLogReadHandler;
0 2 2 files [Ljava/io/File;
Exceptions:
throws java.io.IOException
MethodParameters:
Name Flags
handler
files
private static boolean shouldSkip(java.io.File);
descriptor: (Ljava/io/File;)Z
flags: (0x000a) ACC_PRIVATE, ACC_STATIC
Code:
stack=4, locals=8, args_size=1
start local 0 0: aload 0
invokevirtual java.io.File.getName:()Ljava/lang/String;
invokestatic org.apache.cassandra.db.commitlog.CommitLogDescriptor.fromFileName:(Ljava/lang/String;)Lorg/apache/cassandra/db/commitlog/CommitLogDescriptor;
astore 1
start local 1 1: aload 1
getfield org.apache.cassandra.db.commitlog.CommitLogDescriptor.version:I
iconst_4
if_icmpge 3
2: iconst_0
ireturn
3: StackMap locals: org.apache.cassandra.db.commitlog.CommitLogDescriptor
StackMap stack:
aconst_null
astore 2
aconst_null
astore 3
4: aload 0
invokestatic org.apache.cassandra.io.util.RandomAccessReader.open:(Ljava/io/File;)Lorg/apache/cassandra/io/util/RandomAccessReader;
astore 4
start local 4 5: aload 4
invokestatic org.apache.cassandra.config.DatabaseDescriptor.getEncryptionContext:()Lorg/apache/cassandra/security/EncryptionContext;
invokestatic org.apache.cassandra.db.commitlog.CommitLogDescriptor.readHeader:(Ljava/io/DataInput;Lorg/apache/cassandra/security/EncryptionContext;)Lorg/apache/cassandra/db/commitlog/CommitLogDescriptor;
pop
6: aload 4
invokevirtual org.apache.cassandra.io.util.RandomAccessReader.readInt:()I
istore 5
start local 5 7: aload 4
invokevirtual org.apache.cassandra.io.util.RandomAccessReader.readInt:()I
i2l
ldc 4294967295
land
lstore 6
start local 6 8: iload 5
ifne 9
lload 6
lconst_0
lcmp
ifne 9
iconst_1
goto 10
StackMap locals: java.io.File org.apache.cassandra.db.commitlog.CommitLogDescriptor java.lang.Throwable java.lang.Throwable org.apache.cassandra.io.util.RandomAccessReader int long
StackMap stack:
9: iconst_0
10: StackMap locals:
StackMap stack: int
aload 4
ifnull 11
aload 4
invokevirtual org.apache.cassandra.io.util.RandomAccessReader.close:()V
11: StackMap locals:
StackMap stack: int
ireturn
end local 6 end local 5 StackMap locals: java.io.File org.apache.cassandra.db.commitlog.CommitLogDescriptor java.lang.Throwable java.lang.Throwable org.apache.cassandra.io.util.RandomAccessReader
StackMap stack: java.lang.Throwable
12: astore 2
13: aload 4
ifnull 14
aload 4
invokevirtual org.apache.cassandra.io.util.RandomAccessReader.close:()V
end local 4 StackMap locals:
StackMap stack:
14: aload 2
athrow
StackMap locals:
StackMap stack: java.lang.Throwable
15: astore 3
aload 2
ifnonnull 16
aload 3
astore 2
goto 17
StackMap locals:
StackMap stack:
16: aload 2
aload 3
if_acmpeq 17
aload 2
aload 3
invokevirtual java.lang.Throwable.addSuppressed:(Ljava/lang/Throwable;)V
StackMap locals:
StackMap stack:
17: aload 2
athrow
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 18 0 file Ljava/io/File;
1 18 1 desc Lorg/apache/cassandra/db/commitlog/CommitLogDescriptor;
5 14 4 reader Lorg/apache/cassandra/io/util/RandomAccessReader;
7 12 5 end I
8 12 6 filecrc J
Exception table:
from to target type
5 10 12 any
4 11 15 any
12 15 15 any
Exceptions:
throws java.io.IOException, org.apache.cassandra.exceptions.ConfigurationException
MethodParameters:
Name Flags
file
private static java.util.List<java.io.File> filterCommitLogFiles(java.io.File[]);
descriptor: ([Ljava/io/File;)Ljava/util/List;
flags: (0x000a) ACC_PRIVATE, ACC_STATIC
Code:
stack=3, locals=6, args_size=1
start local 0 0: new java.util.ArrayList
dup
aload 0
arraylength
invokespecial java.util.ArrayList.<init>:(I)V
astore 1
start local 1 1: aload 0
dup
astore 5
arraylength
istore 4
iconst_0
istore 3
goto 11
StackMap locals: java.io.File[] java.util.List top int int java.io.File[]
StackMap stack:
2: aload 5
iload 3
aaload
astore 2
start local 2 3: aload 2
invokestatic org.apache.cassandra.db.commitlog.CommitLogReader.shouldSkip:(Ljava/io/File;)Z
ifeq 6
4: getstatic org.apache.cassandra.db.commitlog.CommitLogReader.logger:Lorg/slf4j/Logger;
ldc "Skipping playback of empty log: {}"
aload 2
invokevirtual java.io.File.getName:()Ljava/lang/String;
invokeinterface org.slf4j.Logger.info:(Ljava/lang/String;Ljava/lang/Object;)V
5: goto 10
6: StackMap locals: java.io.File[] java.util.List java.io.File int int java.io.File[]
StackMap stack:
aload 1
aload 2
invokeinterface java.util.List.add:(Ljava/lang/Object;)Z
pop
7: goto 10
8: StackMap locals:
StackMap stack: java.lang.Exception
pop
9: aload 1
aload 2
invokeinterface java.util.List.add:(Ljava/lang/Object;)Z
pop
end local 2 10: StackMap locals: java.io.File[] java.util.List top int int java.io.File[]
StackMap stack:
iinc 3 1
StackMap locals:
StackMap stack:
11: iload 3
iload 4
if_icmplt 2
12: aload 1
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 13 0 toFilter [Ljava/io/File;
1 13 1 filtered Ljava/util/List<Ljava/io/File;>;
3 10 2 file Ljava/io/File;
Exception table:
from to target type
3 7 8 Class java.lang.Exception
Signature: ([Ljava/io/File;)Ljava/util/List<Ljava/io/File;>;
MethodParameters:
Name Flags
toFilter
public void readAllFiles(org.apache.cassandra.db.commitlog.CommitLogReadHandler, java.io.File[], org.apache.cassandra.db.commitlog.CommitLogPosition);
descriptor: (Lorg/apache/cassandra/db/commitlog/CommitLogReadHandler;[Ljava/io/File;Lorg/apache/cassandra/db/commitlog/CommitLogPosition;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=7, locals=8, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 2
invokestatic org.apache.cassandra.db.commitlog.CommitLogReader.filterCommitLogFiles:([Ljava/io/File;)Ljava/util/List;
astore 4
start local 4 1: iconst_0
istore 5
start local 5 2: aload 4
invokeinterface java.util.List.iterator:()Ljava/util/Iterator;
astore 7
goto 8
StackMap locals: org.apache.cassandra.db.commitlog.CommitLogReader org.apache.cassandra.db.commitlog.CommitLogReadHandler java.io.File[] org.apache.cassandra.db.commitlog.CommitLogPosition java.util.List int top java.util.Iterator
StackMap stack:
3: aload 7
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast java.io.File
astore 6
start local 6 4: iinc 5 1
5: aload 0
aload 1
aload 6
aload 3
iconst_m1
iload 5
aload 4
invokeinterface java.util.List.size:()I
if_icmpne 6
iconst_1
goto 7
StackMap locals: org.apache.cassandra.db.commitlog.CommitLogReader org.apache.cassandra.db.commitlog.CommitLogReadHandler java.io.File[] org.apache.cassandra.db.commitlog.CommitLogPosition java.util.List int java.io.File java.util.Iterator
StackMap stack: org.apache.cassandra.db.commitlog.CommitLogReader org.apache.cassandra.db.commitlog.CommitLogReadHandler java.io.File org.apache.cassandra.db.commitlog.CommitLogPosition int
6: iconst_0
StackMap locals: org.apache.cassandra.db.commitlog.CommitLogReader org.apache.cassandra.db.commitlog.CommitLogReadHandler java.io.File[] org.apache.cassandra.db.commitlog.CommitLogPosition java.util.List int java.io.File java.util.Iterator
StackMap stack: org.apache.cassandra.db.commitlog.CommitLogReader org.apache.cassandra.db.commitlog.CommitLogReadHandler java.io.File org.apache.cassandra.db.commitlog.CommitLogPosition int int
7: invokevirtual org.apache.cassandra.db.commitlog.CommitLogReader.readCommitLogSegment:(Lorg/apache/cassandra/db/commitlog/CommitLogReadHandler;Ljava/io/File;Lorg/apache/cassandra/db/commitlog/CommitLogPosition;IZ)V
end local 6 8: StackMap locals: org.apache.cassandra.db.commitlog.CommitLogReader org.apache.cassandra.db.commitlog.CommitLogReadHandler java.io.File[] org.apache.cassandra.db.commitlog.CommitLogPosition java.util.List int top java.util.Iterator
StackMap stack:
aload 7
invokeinterface java.util.Iterator.hasNext:()Z
ifne 3
9: 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 10 0 this Lorg/apache/cassandra/db/commitlog/CommitLogReader;
0 10 1 handler Lorg/apache/cassandra/db/commitlog/CommitLogReadHandler;
0 10 2 files [Ljava/io/File;
0 10 3 minPosition Lorg/apache/cassandra/db/commitlog/CommitLogPosition;
1 10 4 filteredLogs Ljava/util/List<Ljava/io/File;>;
2 10 5 i I
4 8 6 file Ljava/io/File;
Exceptions:
throws java.io.IOException
MethodParameters:
Name Flags
handler
files
minPosition
public void readCommitLogSegment(org.apache.cassandra.db.commitlog.CommitLogReadHandler, java.io.File, boolean);
descriptor: (Lorg/apache/cassandra/db/commitlog/CommitLogReadHandler;Ljava/io/File;Z)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=6, locals=4, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
aload 1
aload 2
getstatic org.apache.cassandra.db.commitlog.CommitLogPosition.NONE:Lorg/apache/cassandra/db/commitlog/CommitLogPosition;
iconst_m1
iload 3
invokevirtual org.apache.cassandra.db.commitlog.CommitLogReader.readCommitLogSegment:(Lorg/apache/cassandra/db/commitlog/CommitLogReadHandler;Ljava/io/File;Lorg/apache/cassandra/db/commitlog/CommitLogPosition;IZ)V
1: return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/apache/cassandra/db/commitlog/CommitLogReader;
0 2 1 handler Lorg/apache/cassandra/db/commitlog/CommitLogReadHandler;
0 2 2 file Ljava/io/File;
0 2 3 tolerateTruncation Z
Exceptions:
throws java.io.IOException
MethodParameters:
Name Flags
handler
file
tolerateTruncation
public void readCommitLogSegment(org.apache.cassandra.db.commitlog.CommitLogReadHandler, java.io.File, int, boolean);
descriptor: (Lorg/apache/cassandra/db/commitlog/CommitLogReadHandler;Ljava/io/File;IZ)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=6, locals=5, args_size=5
start local 0 start local 1 start local 2 start local 3 start local 4 0: aload 0
aload 1
aload 2
getstatic org.apache.cassandra.db.commitlog.CommitLogPosition.NONE:Lorg/apache/cassandra/db/commitlog/CommitLogPosition;
iload 3
iload 4
invokevirtual org.apache.cassandra.db.commitlog.CommitLogReader.readCommitLogSegment:(Lorg/apache/cassandra/db/commitlog/CommitLogReadHandler;Ljava/io/File;Lorg/apache/cassandra/db/commitlog/CommitLogPosition;IZ)V
1: return
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/apache/cassandra/db/commitlog/CommitLogReader;
0 2 1 handler Lorg/apache/cassandra/db/commitlog/CommitLogReadHandler;
0 2 2 file Ljava/io/File;
0 2 3 mutationLimit I
0 2 4 tolerateTruncation Z
Exceptions:
throws java.io.IOException
RuntimeInvisibleAnnotations:
com.google.common.annotations.VisibleForTesting()
MethodParameters:
Name Flags
handler
file
mutationLimit
tolerateTruncation
public void readCommitLogSegment(org.apache.cassandra.db.commitlog.CommitLogReadHandler, java.io.File, org.apache.cassandra.db.commitlog.CommitLogPosition, int, boolean);
descriptor: (Lorg/apache/cassandra/db/commitlog/CommitLogReadHandler;Ljava/io/File;Lorg/apache/cassandra/db/commitlog/CommitLogPosition;IZ)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=9, locals=16, args_size=6
start local 0 start local 1 start local 2 start local 3 start local 4 start local 5 0: aload 2
invokevirtual java.io.File.getName:()Ljava/lang/String;
invokestatic org.apache.cassandra.db.commitlog.CommitLogDescriptor.fromFileName:(Ljava/lang/String;)Lorg/apache/cassandra/db/commitlog/CommitLogDescriptor;
astore 6
start local 6 1: aconst_null
astore 7
aconst_null
astore 8
2: aload 2
invokestatic org.apache.cassandra.io.util.RandomAccessReader.open:(Ljava/io/File;)Lorg/apache/cassandra/io/util/RandomAccessReader;
astore 9
start local 9 3: aload 6
getfield org.apache.cassandra.db.commitlog.CommitLogDescriptor.version:I
iconst_4
if_icmpge 12
4: aload 0
aload 2
aload 6
aload 3
invokevirtual org.apache.cassandra.db.commitlog.CommitLogReader.shouldSkipSegmentId:(Ljava/io/File;Lorg/apache/cassandra/db/commitlog/CommitLogDescriptor;Lorg/apache/cassandra/db/commitlog/CommitLogPosition;)Z
ifne 10
5: aload 3
getfield org.apache.cassandra.db.commitlog.CommitLogPosition.segmentId:J
aload 6
getfield org.apache.cassandra.db.commitlog.CommitLogDescriptor.id:J
lcmp
ifne 7
6: aload 9
aload 3
getfield org.apache.cassandra.db.commitlog.CommitLogPosition.position:I
i2l
invokevirtual org.apache.cassandra.io.util.RandomAccessReader.seek:(J)V
7: StackMap locals: org.apache.cassandra.db.commitlog.CommitLogReader org.apache.cassandra.db.commitlog.CommitLogReadHandler java.io.File org.apache.cassandra.db.commitlog.CommitLogPosition int int org.apache.cassandra.db.commitlog.CommitLogDescriptor java.lang.Throwable java.lang.Throwable org.apache.cassandra.io.util.RandomAccessReader
StackMap stack:
new org.apache.cassandra.db.commitlog.CommitLogReader$ReadStatusTracker
dup
iload 4
iload 5
invokespecial org.apache.cassandra.db.commitlog.CommitLogReader$ReadStatusTracker.<init>:(IZ)V
astore 10
start local 10 8: aload 10
aload 6
invokevirtual org.apache.cassandra.db.commitlog.CommitLogDescriptor.fileName:()Ljava/lang/String;
putfield org.apache.cassandra.db.commitlog.CommitLogReader$ReadStatusTracker.errorContext:Ljava/lang/String;
9: aload 0
aload 1
aload 9
aload 3
aload 9
invokevirtual org.apache.cassandra.io.util.RandomAccessReader.length:()J
l2i
aload 10
aload 6
invokevirtual org.apache.cassandra.db.commitlog.CommitLogReader.readSection:(Lorg/apache/cassandra/db/commitlog/CommitLogReadHandler;Lorg/apache/cassandra/io/util/FileDataInput;Lorg/apache/cassandra/db/commitlog/CommitLogPosition;ILorg/apache/cassandra/db/commitlog/CommitLogReader$ReadStatusTracker;Lorg/apache/cassandra/db/commitlog/CommitLogDescriptor;)V
end local 10 10: StackMap locals:
StackMap stack:
aload 9
ifnull 11
aload 9
invokevirtual org.apache.cassandra.io.util.RandomAccessReader.close:()V
11: StackMap locals:
StackMap stack:
return
12: StackMap locals:
StackMap stack:
aload 6
getfield org.apache.cassandra.db.commitlog.CommitLogDescriptor.id:J
lstore 10
start local 10 13: aload 9
invokestatic org.apache.cassandra.config.DatabaseDescriptor.getEncryptionContext:()Lorg/apache/cassandra/security/EncryptionContext;
invokestatic org.apache.cassandra.db.commitlog.CommitLogDescriptor.readHeader:(Ljava/io/DataInput;Lorg/apache/cassandra/security/EncryptionContext;)Lorg/apache/cassandra/db/commitlog/CommitLogDescriptor;
astore 6
14: goto 17
15: StackMap locals: org.apache.cassandra.db.commitlog.CommitLogReader org.apache.cassandra.db.commitlog.CommitLogReadHandler java.io.File org.apache.cassandra.db.commitlog.CommitLogPosition int int org.apache.cassandra.db.commitlog.CommitLogDescriptor java.lang.Throwable java.lang.Throwable org.apache.cassandra.io.util.RandomAccessReader long
StackMap stack: java.lang.Exception
pop
16: aconst_null
astore 6
17: StackMap locals:
StackMap stack:
aload 6
ifnonnull 25
18: aload 1
new org.apache.cassandra.db.commitlog.CommitLogReadHandler$CommitLogReadException
dup
19: ldc "Could not read commit log descriptor in file %s"
iconst_1
anewarray java.lang.Object
dup
iconst_0
aload 2
aastore
invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
20: getstatic org.apache.cassandra.db.commitlog.CommitLogReadHandler$CommitLogReadErrorReason.UNRECOVERABLE_DESCRIPTOR_ERROR:Lorg/apache/cassandra/db/commitlog/CommitLogReadHandler$CommitLogReadErrorReason;
21: iload 5
invokespecial org.apache.cassandra.db.commitlog.CommitLogReadHandler$CommitLogReadException.<init>:(Ljava/lang/String;Lorg/apache/cassandra/db/commitlog/CommitLogReadHandler$CommitLogReadErrorReason;Z)V
22: invokeinterface org.apache.cassandra.db.commitlog.CommitLogReadHandler.handleUnrecoverableError:(Lorg/apache/cassandra/db/commitlog/CommitLogReadHandler$CommitLogReadException;)V
23: aload 9
ifnull 24
aload 9
invokevirtual org.apache.cassandra.io.util.RandomAccessReader.close:()V
24: StackMap locals:
StackMap stack:
return
25: StackMap locals:
StackMap stack:
lload 10
aload 6
getfield org.apache.cassandra.db.commitlog.CommitLogDescriptor.id:J
lcmp
ifeq 35
26: aload 1
new org.apache.cassandra.db.commitlog.CommitLogReadHandler$CommitLogReadException
dup
27: ldc "Segment id mismatch (filename %d, descriptor %d) in file %s"
iconst_3
anewarray java.lang.Object
dup
iconst_0
lload 10
invokestatic java.lang.Long.valueOf:(J)Ljava/lang/Long;
aastore
dup
iconst_1
aload 6
getfield org.apache.cassandra.db.commitlog.CommitLogDescriptor.id:J
invokestatic java.lang.Long.valueOf:(J)Ljava/lang/Long;
aastore
dup
iconst_2
aload 2
aastore
28: invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
29: getstatic org.apache.cassandra.db.commitlog.CommitLogReadHandler$CommitLogReadErrorReason.RECOVERABLE_DESCRIPTOR_ERROR:Lorg/apache/cassandra/db/commitlog/CommitLogReadHandler$CommitLogReadErrorReason;
30: iconst_0
invokespecial org.apache.cassandra.db.commitlog.CommitLogReadHandler$CommitLogReadException.<init>:(Ljava/lang/String;Lorg/apache/cassandra/db/commitlog/CommitLogReadHandler$CommitLogReadErrorReason;Z)V
31: invokeinterface org.apache.cassandra.db.commitlog.CommitLogReadHandler.shouldSkipSegmentOnError:(Lorg/apache/cassandra/db/commitlog/CommitLogReadHandler$CommitLogReadException;)Z
32: ifeq 35
33: aload 9
ifnull 34
aload 9
invokevirtual org.apache.cassandra.io.util.RandomAccessReader.close:()V
34: StackMap locals:
StackMap stack:
return
35: StackMap locals:
StackMap stack:
aload 0
aload 2
aload 6
aload 3
invokevirtual org.apache.cassandra.db.commitlog.CommitLogReader.shouldSkipSegmentId:(Ljava/io/File;Lorg/apache/cassandra/db/commitlog/CommitLogDescriptor;Lorg/apache/cassandra/db/commitlog/CommitLogPosition;)Z
ifeq 38
36: aload 9
ifnull 37
aload 9
invokevirtual org.apache.cassandra.io.util.RandomAccessReader.close:()V
37: StackMap locals:
StackMap stack:
return
38: StackMap locals:
StackMap stack:
new org.apache.cassandra.db.commitlog.CommitLogSegmentReader
dup
aload 1
aload 6
aload 9
iload 5
invokespecial org.apache.cassandra.db.commitlog.CommitLogSegmentReader.<init>:(Lorg/apache/cassandra/db/commitlog/CommitLogReadHandler;Lorg/apache/cassandra/db/commitlog/CommitLogDescriptor;Lorg/apache/cassandra/io/util/RandomAccessReader;Z)V
astore 12
start local 12 39: goto 48
end local 12 40: StackMap locals:
StackMap stack: java.lang.Exception
astore 13
start local 13 41: aload 1
new org.apache.cassandra.db.commitlog.CommitLogReadHandler$CommitLogReadException
dup
42: ldc "Unable to create segment reader for commit log file: %s"
iconst_1
anewarray java.lang.Object
dup
iconst_0
aload 13
aastore
invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
43: getstatic org.apache.cassandra.db.commitlog.CommitLogReadHandler$CommitLogReadErrorReason.UNRECOVERABLE_UNKNOWN_ERROR:Lorg/apache/cassandra/db/commitlog/CommitLogReadHandler$CommitLogReadErrorReason;
44: iload 5
invokespecial org.apache.cassandra.db.commitlog.CommitLogReadHandler$CommitLogReadException.<init>:(Ljava/lang/String;Lorg/apache/cassandra/db/commitlog/CommitLogReadHandler$CommitLogReadErrorReason;Z)V
45: invokeinterface org.apache.cassandra.db.commitlog.CommitLogReadHandler.handleUnrecoverableError:(Lorg/apache/cassandra/db/commitlog/CommitLogReadHandler$CommitLogReadException;)V
46: aload 9
ifnull 47
aload 9
invokevirtual org.apache.cassandra.io.util.RandomAccessReader.close:()V
47: StackMap locals: org.apache.cassandra.db.commitlog.CommitLogReader org.apache.cassandra.db.commitlog.CommitLogReadHandler java.io.File org.apache.cassandra.db.commitlog.CommitLogPosition int int org.apache.cassandra.db.commitlog.CommitLogDescriptor java.lang.Throwable java.lang.Throwable org.apache.cassandra.io.util.RandomAccessReader long top java.lang.Exception
StackMap stack:
return
end local 13 start local 12 48: StackMap locals: org.apache.cassandra.db.commitlog.CommitLogReader org.apache.cassandra.db.commitlog.CommitLogReadHandler java.io.File org.apache.cassandra.db.commitlog.CommitLogPosition int int org.apache.cassandra.db.commitlog.CommitLogDescriptor java.lang.Throwable java.lang.Throwable org.apache.cassandra.io.util.RandomAccessReader long org.apache.cassandra.db.commitlog.CommitLogSegmentReader
StackMap stack:
new org.apache.cassandra.db.commitlog.CommitLogReader$ReadStatusTracker
dup
iload 4
iload 5
invokespecial org.apache.cassandra.db.commitlog.CommitLogReader$ReadStatusTracker.<init>:(IZ)V
astore 13
start local 13 49: aload 12
invokevirtual org.apache.cassandra.db.commitlog.CommitLogSegmentReader.iterator:()Ljava/util/Iterator;
astore 15
goto 58
StackMap locals: org.apache.cassandra.db.commitlog.CommitLogReader org.apache.cassandra.db.commitlog.CommitLogReadHandler java.io.File org.apache.cassandra.db.commitlog.CommitLogPosition int int org.apache.cassandra.db.commitlog.CommitLogDescriptor java.lang.Throwable java.lang.Throwable org.apache.cassandra.io.util.RandomAccessReader long org.apache.cassandra.db.commitlog.CommitLogSegmentReader org.apache.cassandra.db.commitlog.CommitLogReader$ReadStatusTracker top java.util.Iterator
StackMap stack:
50: aload 15
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.db.commitlog.CommitLogSegmentReader$SyncSegment
astore 14
start local 14 51: aload 13
iload 5
aload 14
getfield org.apache.cassandra.db.commitlog.CommitLogSegmentReader$SyncSegment.toleratesErrorsInSection:Z
iand
putfield org.apache.cassandra.db.commitlog.CommitLogReader$ReadStatusTracker.tolerateErrorsInSection:Z
52: aload 6
getfield org.apache.cassandra.db.commitlog.CommitLogDescriptor.id:J
aload 3
getfield org.apache.cassandra.db.commitlog.CommitLogPosition.segmentId:J
lcmp
ifne 54
aload 14
getfield org.apache.cassandra.db.commitlog.CommitLogSegmentReader$SyncSegment.endPosition:I
aload 3
getfield org.apache.cassandra.db.commitlog.CommitLogPosition.position:I
if_icmpge 54
53: goto 58
54: StackMap locals: org.apache.cassandra.db.commitlog.CommitLogReader org.apache.cassandra.db.commitlog.CommitLogReadHandler java.io.File org.apache.cassandra.db.commitlog.CommitLogPosition int int org.apache.cassandra.db.commitlog.CommitLogDescriptor java.lang.Throwable java.lang.Throwable org.apache.cassandra.io.util.RandomAccessReader long org.apache.cassandra.db.commitlog.CommitLogSegmentReader org.apache.cassandra.db.commitlog.CommitLogReader$ReadStatusTracker org.apache.cassandra.db.commitlog.CommitLogSegmentReader$SyncSegment java.util.Iterator
StackMap stack:
aload 13
ldc "Next section at %d in %s"
iconst_2
anewarray java.lang.Object
dup
iconst_0
aload 14
getfield org.apache.cassandra.db.commitlog.CommitLogSegmentReader$SyncSegment.fileStartPosition:I
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
aastore
dup
iconst_1
aload 6
invokevirtual org.apache.cassandra.db.commitlog.CommitLogDescriptor.fileName:()Ljava/lang/String;
aastore
invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
putfield org.apache.cassandra.db.commitlog.CommitLogReader$ReadStatusTracker.errorContext:Ljava/lang/String;
55: aload 0
aload 1
aload 14
getfield org.apache.cassandra.db.commitlog.CommitLogSegmentReader$SyncSegment.input:Lorg/apache/cassandra/io/util/FileDataInput;
aload 3
aload 14
getfield org.apache.cassandra.db.commitlog.CommitLogSegmentReader$SyncSegment.endPosition:I
aload 13
aload 6
invokevirtual org.apache.cassandra.db.commitlog.CommitLogReader.readSection:(Lorg/apache/cassandra/db/commitlog/CommitLogReadHandler;Lorg/apache/cassandra/io/util/FileDataInput;Lorg/apache/cassandra/db/commitlog/CommitLogPosition;ILorg/apache/cassandra/db/commitlog/CommitLogReader$ReadStatusTracker;Lorg/apache/cassandra/db/commitlog/CommitLogDescriptor;)V
56: aload 13
invokevirtual org.apache.cassandra.db.commitlog.CommitLogReader$ReadStatusTracker.shouldContinue:()Z
ifne 58
57: goto 64
end local 14 58: StackMap locals: org.apache.cassandra.db.commitlog.CommitLogReader org.apache.cassandra.db.commitlog.CommitLogReadHandler java.io.File org.apache.cassandra.db.commitlog.CommitLogPosition int int org.apache.cassandra.db.commitlog.CommitLogDescriptor java.lang.Throwable java.lang.Throwable org.apache.cassandra.io.util.RandomAccessReader long org.apache.cassandra.db.commitlog.CommitLogSegmentReader org.apache.cassandra.db.commitlog.CommitLogReader$ReadStatusTracker top java.util.Iterator
StackMap stack:
aload 15
invokeinterface java.util.Iterator.hasNext:()Z
ifne 50
end local 13 59: goto 64
60: StackMap locals: org.apache.cassandra.db.commitlog.CommitLogReader org.apache.cassandra.db.commitlog.CommitLogReadHandler java.io.File org.apache.cassandra.db.commitlog.CommitLogPosition int int org.apache.cassandra.db.commitlog.CommitLogDescriptor java.lang.Throwable java.lang.Throwable org.apache.cassandra.io.util.RandomAccessReader long org.apache.cassandra.db.commitlog.CommitLogSegmentReader
StackMap stack: java.lang.RuntimeException
astore 13
start local 13 61: aload 13
invokevirtual java.lang.RuntimeException.getCause:()Ljava/lang/Throwable;
instanceof java.io.IOException
ifeq 63
62: aload 13
invokevirtual java.lang.RuntimeException.getCause:()Ljava/lang/Throwable;
checkcast java.io.IOException
athrow
63: StackMap locals: java.lang.RuntimeException
StackMap stack:
aload 13
athrow
end local 13 64: StackMap locals:
StackMap stack:
getstatic org.apache.cassandra.db.commitlog.CommitLogReader.logger:Lorg/slf4j/Logger;
ldc "Finished reading {}"
aload 2
invokeinterface org.slf4j.Logger.debug:(Ljava/lang/String;Ljava/lang/Object;)V
end local 12 end local 10 65: aload 9
ifnull 71
aload 9
invokevirtual org.apache.cassandra.io.util.RandomAccessReader.close:()V
goto 71
StackMap locals: org.apache.cassandra.db.commitlog.CommitLogReader org.apache.cassandra.db.commitlog.CommitLogReadHandler java.io.File org.apache.cassandra.db.commitlog.CommitLogPosition int int org.apache.cassandra.db.commitlog.CommitLogDescriptor java.lang.Throwable java.lang.Throwable org.apache.cassandra.io.util.RandomAccessReader
StackMap stack: java.lang.Throwable
66: astore 7
aload 9
ifnull 67
aload 9
invokevirtual org.apache.cassandra.io.util.RandomAccessReader.close:()V
end local 9 StackMap locals:
StackMap stack:
67: aload 7
athrow
StackMap locals:
StackMap stack: java.lang.Throwable
68: astore 8
aload 7
ifnonnull 69
aload 8
astore 7
goto 70
StackMap locals:
StackMap stack:
69: aload 7
aload 8
if_acmpeq 70
aload 7
aload 8
invokevirtual java.lang.Throwable.addSuppressed:(Ljava/lang/Throwable;)V
StackMap locals:
StackMap stack:
70: aload 7
athrow
71: StackMap locals:
StackMap stack:
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 72 0 this Lorg/apache/cassandra/db/commitlog/CommitLogReader;
0 72 1 handler Lorg/apache/cassandra/db/commitlog/CommitLogReadHandler;
0 72 2 file Ljava/io/File;
0 72 3 minPosition Lorg/apache/cassandra/db/commitlog/CommitLogPosition;
0 72 4 mutationLimit I
0 72 5 tolerateTruncation Z
1 72 6 desc Lorg/apache/cassandra/db/commitlog/CommitLogDescriptor;
3 67 9 reader Lorg/apache/cassandra/io/util/RandomAccessReader;
8 10 10 statusTracker Lorg/apache/cassandra/db/commitlog/CommitLogReader$ReadStatusTracker;
13 65 10 segmentIdFromFilename J
39 40 12 segmentReader Lorg/apache/cassandra/db/commitlog/CommitLogSegmentReader;
48 65 12 segmentReader Lorg/apache/cassandra/db/commitlog/CommitLogSegmentReader;
41 48 13 e Ljava/lang/Exception;
49 59 13 statusTracker Lorg/apache/cassandra/db/commitlog/CommitLogReader$ReadStatusTracker;
51 58 14 syncSegment Lorg/apache/cassandra/db/commitlog/CommitLogSegmentReader$SyncSegment;
61 64 13 re Ljava/lang/RuntimeException;
Exception table:
from to target type
13 14 15 Class java.lang.Exception
38 39 40 Class java.lang.Exception
48 59 60 Class java.lang.RuntimeException
3 10 66 any
12 23 66 any
25 33 66 any
35 36 66 any
38 46 66 any
48 65 66 any
2 11 68 any
12 24 68 any
25 34 68 any
35 37 68 any
38 47 68 any
48 68 68 any
Exceptions:
throws java.io.IOException
MethodParameters:
Name Flags
handler
file
minPosition
mutationLimit
tolerateTruncation
private boolean shouldSkipSegmentId(java.io.File, org.apache.cassandra.db.commitlog.CommitLogDescriptor, org.apache.cassandra.db.commitlog.CommitLogPosition);
descriptor: (Ljava/io/File;Lorg/apache/cassandra/db/commitlog/CommitLogDescriptor;Lorg/apache/cassandra/db/commitlog/CommitLogPosition;)Z
flags: (0x0002) ACC_PRIVATE
Code:
stack=6, locals=4, args_size=4
start local 0 start local 1 start local 2 start local 3 0: getstatic org.apache.cassandra.db.commitlog.CommitLogReader.logger:Lorg/slf4j/Logger;
ldc "Reading {} (CL version {}, messaging version {}, compression {})"
iconst_4
anewarray java.lang.Object
dup
iconst_0
1: aload 1
invokevirtual java.io.File.getPath:()Ljava/lang/String;
aastore
dup
iconst_1
2: aload 2
getfield org.apache.cassandra.db.commitlog.CommitLogDescriptor.version:I
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
aastore
dup
iconst_2
3: aload 2
invokevirtual org.apache.cassandra.db.commitlog.CommitLogDescriptor.getMessagingVersion:()I
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
aastore
dup
iconst_3
4: aload 2
getfield org.apache.cassandra.db.commitlog.CommitLogDescriptor.compression:Lorg/apache/cassandra/config/ParameterizedClass;
aastore
5: invokeinterface org.slf4j.Logger.debug:(Ljava/lang/String;[Ljava/lang/Object;)V
6: aload 3
getfield org.apache.cassandra.db.commitlog.CommitLogPosition.segmentId:J
aload 2
getfield org.apache.cassandra.db.commitlog.CommitLogDescriptor.id:J
lcmp
ifle 9
7: getstatic org.apache.cassandra.db.commitlog.CommitLogReader.logger:Lorg/slf4j/Logger;
ldc "Skipping read of fully-flushed {}"
aload 1
invokeinterface org.slf4j.Logger.trace:(Ljava/lang/String;Ljava/lang/Object;)V
8: iconst_1
ireturn
9: StackMap locals:
StackMap stack:
iconst_0
ireturn
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 10 0 this Lorg/apache/cassandra/db/commitlog/CommitLogReader;
0 10 1 file Ljava/io/File;
0 10 2 desc Lorg/apache/cassandra/db/commitlog/CommitLogDescriptor;
0 10 3 minPosition Lorg/apache/cassandra/db/commitlog/CommitLogPosition;
MethodParameters:
Name Flags
file
desc
minPosition
private void readSection(org.apache.cassandra.db.commitlog.CommitLogReadHandler, org.apache.cassandra.io.util.FileDataInput, org.apache.cassandra.db.commitlog.CommitLogPosition, int, org.apache.cassandra.db.commitlog.CommitLogReader$ReadStatusTracker, org.apache.cassandra.db.commitlog.CommitLogDescriptor);
descriptor: (Lorg/apache/cassandra/db/commitlog/CommitLogReadHandler;Lorg/apache/cassandra/io/util/FileDataInput;Lorg/apache/cassandra/db/commitlog/CommitLogPosition;ILorg/apache/cassandra/db/commitlog/CommitLogReader$ReadStatusTracker;Lorg/apache/cassandra/db/commitlog/CommitLogDescriptor;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=9, locals=14, args_size=7
start local 0 start local 1 start local 2 start local 3 start local 4 start local 5 start local 6 0: aload 6
getfield org.apache.cassandra.db.commitlog.CommitLogDescriptor.id:J
aload 3
getfield org.apache.cassandra.db.commitlog.CommitLogPosition.segmentId:J
lcmp
ifne 64
aload 2
invokeinterface org.apache.cassandra.io.util.FileDataInput.getFilePointer:()J
aload 3
getfield org.apache.cassandra.db.commitlog.CommitLogPosition.position:I
i2l
lcmp
ifge 64
1: aload 2
aload 3
getfield org.apache.cassandra.db.commitlog.CommitLogPosition.position:I
i2l
invokeinterface org.apache.cassandra.io.util.FileDataInput.seek:(J)V
2: goto 64
3: StackMap locals:
StackMap stack:
aload 2
invokeinterface org.apache.cassandra.io.util.FileDataInput.getFilePointer:()J
lstore 7
start local 7 4: getstatic org.apache.cassandra.db.commitlog.CommitLogReader.logger:Lorg/slf4j/Logger;
invokeinterface org.slf4j.Logger.isTraceEnabled:()Z
ifeq 6
5: getstatic org.apache.cassandra.db.commitlog.CommitLogReader.logger:Lorg/slf4j/Logger;
ldc "Reading mutation at {}"
lload 7
invokestatic java.lang.Long.valueOf:(J)Ljava/lang/Long;
invokeinterface org.slf4j.Logger.trace:(Ljava/lang/String;Ljava/lang/Object;)V
6: StackMap locals: long
StackMap stack:
iload 4
i2l
aload 2
invokeinterface org.apache.cassandra.io.util.FileDataInput.getFilePointer:()J
lsub
ldc 4
lcmp
ifge 10
7: getstatic org.apache.cassandra.db.commitlog.CommitLogReader.logger:Lorg/slf4j/Logger;
ldc "Not enough bytes left for another mutation in this CommitLog segment, continuing"
invokeinterface org.slf4j.Logger.trace:(Ljava/lang/String;)V
8: aload 5
invokevirtual org.apache.cassandra.db.commitlog.CommitLogReader$ReadStatusTracker.requestTermination:()V
9: return
10: StackMap locals:
StackMap stack:
aload 2
invokeinterface org.apache.cassandra.io.util.FileDataInput.readInt:()I
istore 11
start local 11 11: iload 11
ifne 15
12: getstatic org.apache.cassandra.db.commitlog.CommitLogReader.logger:Lorg/slf4j/Logger;
ldc "Encountered end of segment marker at {}"
aload 2
invokeinterface org.apache.cassandra.io.util.FileDataInput.getFilePointer:()J
invokestatic java.lang.Long.valueOf:(J)Ljava/lang/Long;
invokeinterface org.slf4j.Logger.trace:(Ljava/lang/String;Ljava/lang/Object;)V
13: aload 5
invokevirtual org.apache.cassandra.db.commitlog.CommitLogReader$ReadStatusTracker.requestTermination:()V
14: return
15: StackMap locals: org.apache.cassandra.db.commitlog.CommitLogReader org.apache.cassandra.db.commitlog.CommitLogReadHandler org.apache.cassandra.io.util.FileDataInput org.apache.cassandra.db.commitlog.CommitLogPosition int org.apache.cassandra.db.commitlog.CommitLogReader$ReadStatusTracker org.apache.cassandra.db.commitlog.CommitLogDescriptor long top top int
StackMap stack:
iload 11
bipush 10
if_icmpge 24
16: aload 1
new org.apache.cassandra.db.commitlog.CommitLogReadHandler$CommitLogReadException
dup
17: ldc "Invalid mutation size %d at %d in %s"
iconst_3
anewarray java.lang.Object
dup
iconst_0
iload 11
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
aastore
dup
iconst_1
lload 7
invokestatic java.lang.Long.valueOf:(J)Ljava/lang/Long;
aastore
dup
iconst_2
aload 5
getfield org.apache.cassandra.db.commitlog.CommitLogReader$ReadStatusTracker.errorContext:Ljava/lang/String;
aastore
invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
18: getstatic org.apache.cassandra.db.commitlog.CommitLogReadHandler$CommitLogReadErrorReason.MUTATION_ERROR:Lorg/apache/cassandra/db/commitlog/CommitLogReadHandler$CommitLogReadErrorReason;
19: aload 5
getfield org.apache.cassandra.db.commitlog.CommitLogReader$ReadStatusTracker.tolerateErrorsInSection:Z
invokespecial org.apache.cassandra.db.commitlog.CommitLogReadHandler$CommitLogReadException.<init>:(Ljava/lang/String;Lorg/apache/cassandra/db/commitlog/CommitLogReadHandler$CommitLogReadErrorReason;Z)V
20: invokeinterface org.apache.cassandra.db.commitlog.CommitLogReadHandler.shouldSkipSegmentOnError:(Lorg/apache/cassandra/db/commitlog/CommitLogReadHandler$CommitLogReadException;)Z
21: ifeq 23
22: aload 5
invokevirtual org.apache.cassandra.db.commitlog.CommitLogReader$ReadStatusTracker.requestTermination:()V
23: StackMap locals:
StackMap stack:
return
24: StackMap locals:
StackMap stack:
aload 2
aload 6
getfield org.apache.cassandra.db.commitlog.CommitLogDescriptor.version:I
invokestatic org.apache.cassandra.db.commitlog.CommitLogReader$CommitLogFormat.calculateClaimedChecksum:(Lorg/apache/cassandra/io/util/FileDataInput;I)J
lstore 12
start local 12 25: aload 0
getfield org.apache.cassandra.db.commitlog.CommitLogReader.checksum:Ljava/util/zip/CRC32;
invokevirtual java.util.zip.CRC32.reset:()V
26: aload 0
getfield org.apache.cassandra.db.commitlog.CommitLogReader.checksum:Ljava/util/zip/CRC32;
iload 11
aload 6
getfield org.apache.cassandra.db.commitlog.CommitLogDescriptor.version:I
invokestatic org.apache.cassandra.db.commitlog.CommitLogReader$CommitLogFormat.updateChecksum:(Ljava/util/zip/CRC32;II)V
27: aload 0
getfield org.apache.cassandra.db.commitlog.CommitLogReader.checksum:Ljava/util/zip/CRC32;
invokevirtual java.util.zip.CRC32.getValue:()J
lload 12
lcmp
ifeq 36
28: aload 1
new org.apache.cassandra.db.commitlog.CommitLogReadHandler$CommitLogReadException
dup
29: ldc "Mutation size checksum failure at %d in %s"
iconst_2
anewarray java.lang.Object
dup
iconst_0
lload 7
invokestatic java.lang.Long.valueOf:(J)Ljava/lang/Long;
aastore
dup
iconst_1
aload 5
getfield org.apache.cassandra.db.commitlog.CommitLogReader$ReadStatusTracker.errorContext:Ljava/lang/String;
aastore
invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
30: getstatic org.apache.cassandra.db.commitlog.CommitLogReadHandler$CommitLogReadErrorReason.MUTATION_ERROR:Lorg/apache/cassandra/db/commitlog/CommitLogReadHandler$CommitLogReadErrorReason;
31: aload 5
getfield org.apache.cassandra.db.commitlog.CommitLogReader$ReadStatusTracker.tolerateErrorsInSection:Z
invokespecial org.apache.cassandra.db.commitlog.CommitLogReadHandler$CommitLogReadException.<init>:(Ljava/lang/String;Lorg/apache/cassandra/db/commitlog/CommitLogReadHandler$CommitLogReadErrorReason;Z)V
32: invokeinterface org.apache.cassandra.db.commitlog.CommitLogReadHandler.shouldSkipSegmentOnError:(Lorg/apache/cassandra/db/commitlog/CommitLogReadHandler$CommitLogReadException;)Z
33: ifeq 35
34: aload 5
invokevirtual org.apache.cassandra.db.commitlog.CommitLogReader$ReadStatusTracker.requestTermination:()V
35: StackMap locals: long
StackMap stack:
return
36: StackMap locals:
StackMap stack:
iload 11
aload 0
getfield org.apache.cassandra.db.commitlog.CommitLogReader.buffer:[B
arraylength
if_icmple 38
37: aload 0
ldc 1.2
iload 11
i2d
dmul
d2i
newarray 8
putfield org.apache.cassandra.db.commitlog.CommitLogReader.buffer:[B
38: StackMap locals:
StackMap stack:
aload 2
aload 0
getfield org.apache.cassandra.db.commitlog.CommitLogReader.buffer:[B
iconst_0
iload 11
invokeinterface org.apache.cassandra.io.util.FileDataInput.readFully:([BII)V
39: aload 2
aload 6
getfield org.apache.cassandra.db.commitlog.CommitLogDescriptor.version:I
invokestatic org.apache.cassandra.db.commitlog.CommitLogReader$CommitLogFormat.calculateClaimedCRC32:(Lorg/apache/cassandra/io/util/FileDataInput;I)J
lstore 9
end local 12 start local 9 40: goto 50
end local 11 end local 9 41: StackMap locals: org.apache.cassandra.db.commitlog.CommitLogReader org.apache.cassandra.db.commitlog.CommitLogReadHandler org.apache.cassandra.io.util.FileDataInput org.apache.cassandra.db.commitlog.CommitLogPosition int org.apache.cassandra.db.commitlog.CommitLogReader$ReadStatusTracker org.apache.cassandra.db.commitlog.CommitLogDescriptor long
StackMap stack: java.io.EOFException
pop
42: aload 1
new org.apache.cassandra.db.commitlog.CommitLogReadHandler$CommitLogReadException
dup
43: ldc "Unexpected end of segment at %d in %s"
iconst_2
anewarray java.lang.Object
dup
iconst_0
lload 7
invokestatic java.lang.Long.valueOf:(J)Ljava/lang/Long;
aastore
dup
iconst_1
aload 5
getfield org.apache.cassandra.db.commitlog.CommitLogReader$ReadStatusTracker.errorContext:Ljava/lang/String;
aastore
invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
44: getstatic org.apache.cassandra.db.commitlog.CommitLogReadHandler$CommitLogReadErrorReason.EOF:Lorg/apache/cassandra/db/commitlog/CommitLogReadHandler$CommitLogReadErrorReason;
45: aload 5
getfield org.apache.cassandra.db.commitlog.CommitLogReader$ReadStatusTracker.tolerateErrorsInSection:Z
invokespecial org.apache.cassandra.db.commitlog.CommitLogReadHandler$CommitLogReadException.<init>:(Ljava/lang/String;Lorg/apache/cassandra/db/commitlog/CommitLogReadHandler$CommitLogReadErrorReason;Z)V
46: invokeinterface org.apache.cassandra.db.commitlog.CommitLogReadHandler.shouldSkipSegmentOnError:(Lorg/apache/cassandra/db/commitlog/CommitLogReadHandler$CommitLogReadException;)Z
47: ifeq 49
48: aload 5
invokevirtual org.apache.cassandra.db.commitlog.CommitLogReader$ReadStatusTracker.requestTermination:()V
49: StackMap locals:
StackMap stack:
return
start local 9 start local 11 50: StackMap locals: long int
StackMap stack:
aload 0
getfield org.apache.cassandra.db.commitlog.CommitLogReader.checksum:Ljava/util/zip/CRC32;
aload 0
getfield org.apache.cassandra.db.commitlog.CommitLogReader.buffer:[B
iconst_0
iload 11
invokevirtual java.util.zip.CRC32.update:([BII)V
51: lload 9
aload 0
getfield org.apache.cassandra.db.commitlog.CommitLogReader.checksum:Ljava/util/zip/CRC32;
invokevirtual java.util.zip.CRC32.getValue:()J
lcmp
ifeq 60
52: aload 1
new org.apache.cassandra.db.commitlog.CommitLogReadHandler$CommitLogReadException
dup
53: ldc "Mutation checksum failure at %d in %s"
iconst_2
anewarray java.lang.Object
dup
iconst_0
lload 7
invokestatic java.lang.Long.valueOf:(J)Ljava/lang/Long;
aastore
dup
iconst_1
aload 5
getfield org.apache.cassandra.db.commitlog.CommitLogReader$ReadStatusTracker.errorContext:Ljava/lang/String;
aastore
invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
54: getstatic org.apache.cassandra.db.commitlog.CommitLogReadHandler$CommitLogReadErrorReason.MUTATION_ERROR:Lorg/apache/cassandra/db/commitlog/CommitLogReadHandler$CommitLogReadErrorReason;
55: aload 5
getfield org.apache.cassandra.db.commitlog.CommitLogReader$ReadStatusTracker.tolerateErrorsInSection:Z
invokespecial org.apache.cassandra.db.commitlog.CommitLogReadHandler$CommitLogReadException.<init>:(Ljava/lang/String;Lorg/apache/cassandra/db/commitlog/CommitLogReadHandler$CommitLogReadErrorReason;Z)V
56: invokeinterface org.apache.cassandra.db.commitlog.CommitLogReadHandler.shouldSkipSegmentOnError:(Lorg/apache/cassandra/db/commitlog/CommitLogReadHandler$CommitLogReadException;)Z
57: ifeq 64
58: aload 5
invokevirtual org.apache.cassandra.db.commitlog.CommitLogReader$ReadStatusTracker.requestTermination:()V
59: goto 64
60: StackMap locals:
StackMap stack:
aload 2
invokeinterface org.apache.cassandra.io.util.FileDataInput.getFilePointer:()J
lstore 12
start local 12 61: aload 0
aload 1
aload 0
getfield org.apache.cassandra.db.commitlog.CommitLogReader.buffer:[B
iload 11
aload 3
lload 12
l2i
aload 6
invokevirtual org.apache.cassandra.db.commitlog.CommitLogReader.readMutation:(Lorg/apache/cassandra/db/commitlog/CommitLogReadHandler;[BILorg/apache/cassandra/db/commitlog/CommitLogPosition;ILorg/apache/cassandra/db/commitlog/CommitLogDescriptor;)V
62: lload 12
aload 3
getfield org.apache.cassandra.db.commitlog.CommitLogPosition.position:I
i2l
lcmp
iflt 64
63: aload 5
invokevirtual org.apache.cassandra.db.commitlog.CommitLogReader$ReadStatusTracker.addProcessedMutation:()V
end local 12 end local 11 end local 9 end local 7 64: StackMap locals:
StackMap stack:
aload 5
invokevirtual org.apache.cassandra.db.commitlog.CommitLogReader$ReadStatusTracker.shouldContinue:()Z
ifeq 65
aload 2
invokeinterface org.apache.cassandra.io.util.FileDataInput.getFilePointer:()J
iload 4
i2l
lcmp
ifge 65
aload 2
invokeinterface org.apache.cassandra.io.util.FileDataInput.isEOF:()Z
ifeq 3
65: StackMap locals:
StackMap stack:
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 66 0 this Lorg/apache/cassandra/db/commitlog/CommitLogReader;
0 66 1 handler Lorg/apache/cassandra/db/commitlog/CommitLogReadHandler;
0 66 2 reader Lorg/apache/cassandra/io/util/FileDataInput;
0 66 3 minPosition Lorg/apache/cassandra/db/commitlog/CommitLogPosition;
0 66 4 end I
0 66 5 statusTracker Lorg/apache/cassandra/db/commitlog/CommitLogReader$ReadStatusTracker;
0 66 6 desc Lorg/apache/cassandra/db/commitlog/CommitLogDescriptor;
4 64 7 mutationStart J
40 41 9 claimedCRC32 J
50 64 9 claimedCRC32 J
11 41 11 serializedSize I
50 64 11 serializedSize I
25 40 12 claimedSizeChecksum J
61 64 12 mutationPosition J
Exception table:
from to target type
6 9 41 Class java.io.EOFException
10 14 41 Class java.io.EOFException
15 23 41 Class java.io.EOFException
24 35 41 Class java.io.EOFException
36 40 41 Class java.io.EOFException
Exceptions:
throws java.io.IOException
MethodParameters:
Name Flags
handler
reader
minPosition
end
statusTracker
desc
protected void readMutation(org.apache.cassandra.db.commitlog.CommitLogReadHandler, byte[], int, org.apache.cassandra.db.commitlog.CommitLogPosition, int, org.apache.cassandra.db.commitlog.CommitLogDescriptor);
descriptor: (Lorg/apache/cassandra/db/commitlog/CommitLogReadHandler;[BILorg/apache/cassandra/db/commitlog/CommitLogPosition;ILorg/apache/cassandra/db/commitlog/CommitLogDescriptor;)V
flags: (0x0004) ACC_PROTECTED
Code:
stack=8, locals=14, args_size=7
start local 0 start local 1 start local 2 start local 3 start local 4 start local 5 start local 6 0: iload 5
aload 4
getfield org.apache.cassandra.db.commitlog.CommitLogPosition.position:I
if_icmple 1
iconst_1
goto 2
StackMap locals:
StackMap stack:
1: iconst_0
StackMap locals:
StackMap stack: int
2: istore 7
start local 7 3: aconst_null
astore 9
aconst_null
astore 10
4: new org.apache.cassandra.io.util.DataInputBuffer
dup
aload 2
iconst_0
iload 3
invokespecial org.apache.cassandra.io.util.DataInputBuffer.<init>:([BII)V
astore 11
start local 11 5: getstatic org.apache.cassandra.db.Mutation.serializer:Lorg/apache/cassandra/db/Mutation$MutationSerializer;
aload 11
6: aload 6
invokevirtual org.apache.cassandra.db.commitlog.CommitLogDescriptor.getMessagingVersion:()I
7: getstatic org.apache.cassandra.db.rows.SerializationHelper$Flag.LOCAL:Lorg/apache/cassandra/db/rows/SerializationHelper$Flag;
8: invokevirtual org.apache.cassandra.db.Mutation$MutationSerializer.deserialize:(Lorg/apache/cassandra/io/util/DataInputPlus;ILorg/apache/cassandra/db/rows/SerializationHelper$Flag;)Lorg/apache/cassandra/db/Mutation;
astore 8
start local 8 9: aload 8
invokevirtual org.apache.cassandra.db.Mutation.getPartitionUpdates:()Ljava/util/Collection;
invokeinterface java.util.Collection.iterator:()Ljava/util/Iterator;
astore 13
goto 12
StackMap locals: org.apache.cassandra.db.commitlog.CommitLogReader org.apache.cassandra.db.commitlog.CommitLogReadHandler byte[] int org.apache.cassandra.db.commitlog.CommitLogPosition int org.apache.cassandra.db.commitlog.CommitLogDescriptor int org.apache.cassandra.db.Mutation java.lang.Throwable java.lang.Throwable org.apache.cassandra.io.util.RebufferingInputStream top java.util.Iterator
StackMap stack:
10: aload 13
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.db.partitions.PartitionUpdate
astore 12
start local 12 11: aload 12
invokevirtual org.apache.cassandra.db.partitions.PartitionUpdate.validate:()V
end local 12 12: StackMap locals:
StackMap stack:
aload 13
invokeinterface java.util.Iterator.hasNext:()Z
ifne 10
13: aload 11
ifnull 49
aload 11
invokevirtual org.apache.cassandra.io.util.RebufferingInputStream.close:()V
goto 49
end local 8 StackMap locals: org.apache.cassandra.db.commitlog.CommitLogReader org.apache.cassandra.db.commitlog.CommitLogReadHandler byte[] int org.apache.cassandra.db.commitlog.CommitLogPosition int org.apache.cassandra.db.commitlog.CommitLogDescriptor int top java.lang.Throwable java.lang.Throwable org.apache.cassandra.io.util.RebufferingInputStream
StackMap stack: java.lang.Throwable
14: astore 9
aload 11
ifnull 15
aload 11
invokevirtual org.apache.cassandra.io.util.RebufferingInputStream.close:()V
end local 11 StackMap locals:
StackMap stack:
15: aload 9
athrow
StackMap locals:
StackMap stack: java.lang.Throwable
16: astore 10
aload 9
ifnonnull 17
aload 10
astore 9
goto 18
StackMap locals:
StackMap stack:
17: aload 9
aload 10
if_acmpeq 18
aload 9
aload 10
invokevirtual java.lang.Throwable.addSuppressed:(Ljava/lang/Throwable;)V
StackMap locals:
StackMap stack:
18: aload 9
athrow
19: StackMap locals: org.apache.cassandra.db.commitlog.CommitLogReader org.apache.cassandra.db.commitlog.CommitLogReadHandler byte[] int org.apache.cassandra.db.commitlog.CommitLogPosition int org.apache.cassandra.db.commitlog.CommitLogDescriptor int
StackMap stack: org.apache.cassandra.db.UnknownColumnFamilyException
astore 9
start local 9 20: aload 9
getfield org.apache.cassandra.db.UnknownColumnFamilyException.cfId:Ljava/util/UUID;
ifnonnull 22
21: return
22: StackMap locals: org.apache.cassandra.db.commitlog.CommitLogReader org.apache.cassandra.db.commitlog.CommitLogReadHandler byte[] int org.apache.cassandra.db.commitlog.CommitLogPosition int org.apache.cassandra.db.commitlog.CommitLogDescriptor int top org.apache.cassandra.db.UnknownColumnFamilyException
StackMap stack:
aload 0
getfield org.apache.cassandra.db.commitlog.CommitLogReader.invalidMutations:Ljava/util/Map;
aload 9
getfield org.apache.cassandra.db.UnknownColumnFamilyException.cfId:Ljava/util/UUID;
invokeinterface java.util.Map.get:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast java.util.concurrent.atomic.AtomicInteger
astore 10
start local 10 23: aload 10
ifnonnull 27
24: new java.util.concurrent.atomic.AtomicInteger
dup
iconst_1
invokespecial java.util.concurrent.atomic.AtomicInteger.<init>:(I)V
astore 10
25: aload 0
getfield org.apache.cassandra.db.commitlog.CommitLogReader.invalidMutations:Ljava/util/Map;
aload 9
getfield org.apache.cassandra.db.UnknownColumnFamilyException.cfId:Ljava/util/UUID;
aload 10
invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
pop
26: goto 28
27: StackMap locals: java.util.concurrent.atomic.AtomicInteger
StackMap stack:
aload 10
invokevirtual java.util.concurrent.atomic.AtomicInteger.incrementAndGet:()I
pop
28: StackMap locals:
StackMap stack:
return
end local 10 end local 9 29: StackMap locals: org.apache.cassandra.db.commitlog.CommitLogReader org.apache.cassandra.db.commitlog.CommitLogReadHandler byte[] int org.apache.cassandra.db.commitlog.CommitLogPosition int org.apache.cassandra.db.commitlog.CommitLogDescriptor int
StackMap stack: java.lang.Throwable
astore 9
start local 9 30: aload 9
invokestatic org.apache.cassandra.utils.JVMStabilityInspector.inspectThrowable:(Ljava/lang/Throwable;)V
31: ldc "mutation"
ldc "dat"
invokestatic java.io.File.createTempFile:(Ljava/lang/String;Ljava/lang/String;)Ljava/io/File;
astore 10
start local 10 32: aconst_null
astore 11
aconst_null
astore 12
33: new java.io.DataOutputStream
dup
new java.io.FileOutputStream
dup
aload 10
invokespecial java.io.FileOutputStream.<init>:(Ljava/io/File;)V
invokespecial java.io.DataOutputStream.<init>:(Ljava/io/OutputStream;)V
astore 13
start local 13 34: aload 13
aload 2
iconst_0
iload 3
invokevirtual java.io.DataOutputStream.write:([BII)V
35: aload 13
ifnull 41
aload 13
invokevirtual java.io.DataOutputStream.close:()V
goto 41
StackMap locals: org.apache.cassandra.db.commitlog.CommitLogReader org.apache.cassandra.db.commitlog.CommitLogReadHandler byte[] int org.apache.cassandra.db.commitlog.CommitLogPosition int org.apache.cassandra.db.commitlog.CommitLogDescriptor int top java.lang.Throwable java.io.File java.lang.Throwable java.lang.Throwable java.io.DataOutputStream
StackMap stack: java.lang.Throwable
36: astore 11
aload 13
ifnull 37
aload 13
invokevirtual java.io.DataOutputStream.close:()V
end local 13 StackMap locals:
StackMap stack:
37: aload 11
athrow
StackMap locals:
StackMap stack: java.lang.Throwable
38: astore 12
aload 11
ifnonnull 39
aload 12
astore 11
goto 40
StackMap locals:
StackMap stack:
39: aload 11
aload 12
if_acmpeq 40
aload 11
aload 12
invokevirtual java.lang.Throwable.addSuppressed:(Ljava/lang/Throwable;)V
StackMap locals:
StackMap stack:
40: aload 11
athrow
41: StackMap locals:
StackMap stack:
aload 1
new org.apache.cassandra.db.commitlog.CommitLogReadHandler$CommitLogReadException
dup
42: ldc "Unexpected error deserializing mutation; saved to %s. This may be caused by replaying a mutation against a table with the same name but incompatible schema. Exception follows: %s"
iconst_2
anewarray java.lang.Object
dup
iconst_0
43: aload 10
invokevirtual java.io.File.getAbsolutePath:()Ljava/lang/String;
aastore
dup
iconst_1
aload 9
aastore
44: invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
45: getstatic org.apache.cassandra.db.commitlog.CommitLogReadHandler$CommitLogReadErrorReason.MUTATION_ERROR:Lorg/apache/cassandra/db/commitlog/CommitLogReadHandler$CommitLogReadErrorReason;
46: iconst_0
invokespecial org.apache.cassandra.db.commitlog.CommitLogReadHandler$CommitLogReadException.<init>:(Ljava/lang/String;Lorg/apache/cassandra/db/commitlog/CommitLogReadHandler$CommitLogReadErrorReason;Z)V
47: invokeinterface org.apache.cassandra.db.commitlog.CommitLogReadHandler.handleUnrecoverableError:(Lorg/apache/cassandra/db/commitlog/CommitLogReadHandler$CommitLogReadException;)V
48: return
end local 10 end local 9 start local 8 49: StackMap locals: org.apache.cassandra.db.commitlog.CommitLogReader org.apache.cassandra.db.commitlog.CommitLogReadHandler byte[] int org.apache.cassandra.db.commitlog.CommitLogPosition int org.apache.cassandra.db.commitlog.CommitLogDescriptor int org.apache.cassandra.db.Mutation
StackMap stack:
getstatic org.apache.cassandra.db.commitlog.CommitLogReader.logger:Lorg/slf4j/Logger;
invokeinterface org.slf4j.Logger.isTraceEnabled:()Z
ifeq 53
50: getstatic org.apache.cassandra.db.commitlog.CommitLogReader.logger:Lorg/slf4j/Logger;
ldc "Read mutation for {}.{}: {}"
iconst_3
anewarray java.lang.Object
dup
iconst_0
aload 8
invokevirtual org.apache.cassandra.db.Mutation.getKeyspaceName:()Ljava/lang/String;
aastore
dup
iconst_1
aload 8
invokevirtual org.apache.cassandra.db.Mutation.key:()Lorg/apache/cassandra/db/DecoratedKey;
aastore
dup
iconst_2
51: new java.lang.StringBuilder
dup
ldc "{"
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 8
invokevirtual org.apache.cassandra.db.Mutation.getPartitionUpdates:()Ljava/util/Collection;
invokeinterface java.util.Collection.iterator:()Ljava/util/Iterator;
ldc ", "
invokestatic org.apache.commons.lang3.StringUtils.join:(Ljava/util/Iterator;Ljava/lang/String;)Ljava/lang/String;
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
ldc "}"
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
aastore
52: invokeinterface org.slf4j.Logger.trace:(Ljava/lang/String;[Ljava/lang/Object;)V
53: StackMap locals:
StackMap stack:
iload 7
ifeq 55
54: aload 1
aload 8
iload 3
iload 5
aload 6
invokeinterface org.apache.cassandra.db.commitlog.CommitLogReadHandler.handleMutation:(Lorg/apache/cassandra/db/Mutation;IILorg/apache/cassandra/db/commitlog/CommitLogDescriptor;)V
55: StackMap locals:
StackMap stack:
return
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 56 0 this Lorg/apache/cassandra/db/commitlog/CommitLogReader;
0 56 1 handler Lorg/apache/cassandra/db/commitlog/CommitLogReadHandler;
0 56 2 inputBuffer [B
0 56 3 size I
0 56 4 minPosition Lorg/apache/cassandra/db/commitlog/CommitLogPosition;
0 56 5 entryLocation I
0 56 6 desc Lorg/apache/cassandra/db/commitlog/CommitLogDescriptor;
3 56 7 shouldReplay Z
9 14 8 mutation Lorg/apache/cassandra/db/Mutation;
49 56 8 mutation Lorg/apache/cassandra/db/Mutation;
5 15 11 bufIn Lorg/apache/cassandra/io/util/RebufferingInputStream;
11 12 12 upd Lorg/apache/cassandra/db/partitions/PartitionUpdate;
20 29 9 ex Lorg/apache/cassandra/db/UnknownColumnFamilyException;
23 29 10 i Ljava/util/concurrent/atomic/AtomicInteger;
30 49 9 t Ljava/lang/Throwable;
32 49 10 f Ljava/io/File;
34 37 13 out Ljava/io/DataOutputStream;
Exception table:
from to target type
5 13 14 any
4 16 16 any
3 19 19 Class org.apache.cassandra.db.UnknownColumnFamilyException
3 19 29 Class java.lang.Throwable
34 35 36 any
33 38 38 any
Exceptions:
throws java.io.IOException
RuntimeInvisibleAnnotations:
com.google.common.annotations.VisibleForTesting()
MethodParameters:
Name Flags
handler
inputBuffer
size
minPosition
entryLocation final
desc final
}
SourceFile: "CommitLogReader.java"
NestMembers:
org.apache.cassandra.db.commitlog.CommitLogReader$CommitLogFormat org.apache.cassandra.db.commitlog.CommitLogReader$ReadStatusTracker
InnerClasses:
public abstract Entry = java.util.Map$Entry of java.util.Map
public MutationSerializer = org.apache.cassandra.db.Mutation$MutationSerializer of org.apache.cassandra.db.Mutation
public final CommitLogReadErrorReason = org.apache.cassandra.db.commitlog.CommitLogReadHandler$CommitLogReadErrorReason of org.apache.cassandra.db.commitlog.CommitLogReadHandler
public CommitLogReadException = org.apache.cassandra.db.commitlog.CommitLogReadHandler$CommitLogReadException of org.apache.cassandra.db.commitlog.CommitLogReadHandler
private CommitLogFormat = org.apache.cassandra.db.commitlog.CommitLogReader$CommitLogFormat of org.apache.cassandra.db.commitlog.CommitLogReader
private ReadStatusTracker = org.apache.cassandra.db.commitlog.CommitLogReader$ReadStatusTracker of org.apache.cassandra.db.commitlog.CommitLogReader
public SyncSegment = org.apache.cassandra.db.commitlog.CommitLogSegmentReader$SyncSegment of org.apache.cassandra.db.commitlog.CommitLogSegmentReader
public final Flag = org.apache.cassandra.db.rows.SerializationHelper$Flag of org.apache.cassandra.db.rows.SerializationHelper