https://cassandra.apache.org: The Apache Cassandra Project develops a highly scalable second-generation distributed database, bringing together Dynamo's fully distributed design and Bigtable's ColumnFamily-based data model.
  • Andres de la Peña
  • Avinash Lakshman
  • Aleksey Yeschenko
  • Aaron Morton
  • Ariel Weisberg
  • Blake Eggleston
  • Benedict Elliott Smith
  • Benjamin Lerer
  • Branimir Lambov
  • Brandon Williams
  • Carl Yeksigian
  • David Brosiusd
  • Dikang Gu
  • Eric Evans
  • Gary Dusbabek
  • Chris Goffinet
  • Alex Petrov
  • Laine Jaakko Olavi
  • T Jake Luciani
  • Jason Brown
  • Jonathan Ellis
  • Jake Farrell
  • Jeff Jirsa
  • Joel Knighton
  • Josh McKenzie
  • Johan Oskarsson
  • Jun Rao
  • Jay Zhuang
  • Sankalp Kohli
  • Marcus Eriksson
  • Michael Semb Wever
  • Mikhail Stepura
  • Michael Shuler
  • Paulo Motta
  • Prashant Malik
  • Robert Stupp
  • Peter Schuller
  • Sam Tunnicliffe
  • Sylvain Lebresne
  • Stefania Alborghetti
  • Tyler Hobbs
  • Vijay Parthasarathy
  • Pavel Yaskevich
  • Yuki Morishita
  • Nate McCall 
public class org.apache.cassandra.db.commitlog.CommitLogSegmentReader implements java.lang.Iterable<org.apache.cassandra.db.commitlog.CommitLogSegmentReader$SyncSegment>
  minor version: 0
  major version: 59
  flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
  this_class: org.apache.cassandra.db.commitlog.CommitLogSegmentReader
  super_class: java.lang.Object
{
  private final org.apache.cassandra.db.commitlog.CommitLogReadHandler handler;
    descriptor: Lorg/apache/cassandra/db/commitlog/CommitLogReadHandler;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  private final org.apache.cassandra.db.commitlog.CommitLogDescriptor descriptor;
    descriptor: Lorg/apache/cassandra/db/commitlog/CommitLogDescriptor;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  private final org.apache.cassandra.io.util.RandomAccessReader reader;
    descriptor: Lorg/apache/cassandra/io/util/RandomAccessReader;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  private final org.apache.cassandra.db.commitlog.CommitLogSegmentReader$Segmenter segmenter;
    descriptor: Lorg/apache/cassandra/db/commitlog/CommitLogSegmentReader$Segmenter;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  private final boolean tolerateTruncation;
    descriptor: Z
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  protected int end;
    descriptor: I
    flags: (0x0004) ACC_PROTECTED

  protected void <init>(org.apache.cassandra.db.commitlog.CommitLogReadHandler, org.apache.cassandra.db.commitlog.CommitLogDescriptor, org.apache.cassandra.io.util.RandomAccessReader, boolean);
    descriptor: (Lorg/apache/cassandra/db/commitlog/CommitLogReadHandler;Lorg/apache/cassandra/db/commitlog/CommitLogDescriptor;Lorg/apache/cassandra/io/util/RandomAccessReader;Z)V
    flags: (0x0004) ACC_PROTECTED
    Code:
      stack=5, locals=5, args_size=5
        start local 0 // org.apache.cassandra.db.commitlog.CommitLogSegmentReader this
        start local 1 // org.apache.cassandra.db.commitlog.CommitLogReadHandler handler
        start local 2 // org.apache.cassandra.db.commitlog.CommitLogDescriptor descriptor
        start local 3 // org.apache.cassandra.io.util.RandomAccessReader reader
        start local 4 // boolean tolerateTruncation
         0: .line 60
            aload 0 /* this */
            invokespecial java.lang.Object.<init>:()V
         1: .line 65
            aload 0 /* this */
            aload 1 /* handler */
            putfield org.apache.cassandra.db.commitlog.CommitLogSegmentReader.handler:Lorg/apache/cassandra/db/commitlog/CommitLogReadHandler;
         2: .line 66
            aload 0 /* this */
            aload 2 /* descriptor */
            putfield org.apache.cassandra.db.commitlog.CommitLogSegmentReader.descriptor:Lorg/apache/cassandra/db/commitlog/CommitLogDescriptor;
         3: .line 67
            aload 0 /* this */
            aload 3 /* reader */
            putfield org.apache.cassandra.db.commitlog.CommitLogSegmentReader.reader:Lorg/apache/cassandra/io/util/RandomAccessReader;
         4: .line 68
            aload 0 /* this */
            iload 4 /* tolerateTruncation */
            putfield org.apache.cassandra.db.commitlog.CommitLogSegmentReader.tolerateTruncation:Z
         5: .line 70
            aload 0 /* this */
            aload 3 /* reader */
            invokevirtual org.apache.cassandra.io.util.RandomAccessReader.getFilePointer:()J
            l2i
            putfield org.apache.cassandra.db.commitlog.CommitLogSegmentReader.end:I
         6: .line 71
            aload 2 /* descriptor */
            invokevirtual org.apache.cassandra.db.commitlog.CommitLogDescriptor.getEncryptionContext:()Lorg/apache/cassandra/security/EncryptionContext;
            invokevirtual org.apache.cassandra.security.EncryptionContext.isEnabled:()Z
            ifeq 8
         7: .line 72
            aload 0 /* this */
            new org.apache.cassandra.db.commitlog.CommitLogSegmentReader$EncryptedSegmenter
            dup
            aload 2 /* descriptor */
            aload 3 /* reader */
            invokespecial org.apache.cassandra.db.commitlog.CommitLogSegmentReader$EncryptedSegmenter.<init>:(Lorg/apache/cassandra/db/commitlog/CommitLogDescriptor;Lorg/apache/cassandra/io/util/RandomAccessReader;)V
            putfield org.apache.cassandra.db.commitlog.CommitLogSegmentReader.segmenter:Lorg/apache/cassandra/db/commitlog/CommitLogSegmentReader$Segmenter;
            goto 11
         8: .line 73
      StackMap locals: org.apache.cassandra.db.commitlog.CommitLogSegmentReader org.apache.cassandra.db.commitlog.CommitLogReadHandler org.apache.cassandra.db.commitlog.CommitLogDescriptor org.apache.cassandra.io.util.RandomAccessReader int
      StackMap stack:
            aload 2 /* descriptor */
            getfield org.apache.cassandra.db.commitlog.CommitLogDescriptor.compression:Lorg/apache/cassandra/config/ParameterizedClass;
            ifnull 10
         9: .line 74
            aload 0 /* this */
            new org.apache.cassandra.db.commitlog.CommitLogSegmentReader$CompressedSegmenter
            dup
            aload 2 /* descriptor */
            aload 3 /* reader */
            invokespecial org.apache.cassandra.db.commitlog.CommitLogSegmentReader$CompressedSegmenter.<init>:(Lorg/apache/cassandra/db/commitlog/CommitLogDescriptor;Lorg/apache/cassandra/io/util/RandomAccessReader;)V
            putfield org.apache.cassandra.db.commitlog.CommitLogSegmentReader.segmenter:Lorg/apache/cassandra/db/commitlog/CommitLogSegmentReader$Segmenter;
            goto 11
        10: .line 76
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            new org.apache.cassandra.db.commitlog.CommitLogSegmentReader$NoOpSegmenter
            dup
            aload 3 /* reader */
            invokespecial org.apache.cassandra.db.commitlog.CommitLogSegmentReader$NoOpSegmenter.<init>:(Lorg/apache/cassandra/io/util/RandomAccessReader;)V
            putfield org.apache.cassandra.db.commitlog.CommitLogSegmentReader.segmenter:Lorg/apache/cassandra/db/commitlog/CommitLogSegmentReader$Segmenter;
        11: .line 77
      StackMap locals:
      StackMap stack:
            return
        end local 4 // boolean tolerateTruncation
        end local 3 // org.apache.cassandra.io.util.RandomAccessReader reader
        end local 2 // org.apache.cassandra.db.commitlog.CommitLogDescriptor descriptor
        end local 1 // org.apache.cassandra.db.commitlog.CommitLogReadHandler handler
        end local 0 // org.apache.cassandra.db.commitlog.CommitLogSegmentReader this
      LocalVariableTable:
        Start  End  Slot                Name  Signature
            0   12     0                this  Lorg/apache/cassandra/db/commitlog/CommitLogSegmentReader;
            0   12     1             handler  Lorg/apache/cassandra/db/commitlog/CommitLogReadHandler;
            0   12     2          descriptor  Lorg/apache/cassandra/db/commitlog/CommitLogDescriptor;
            0   12     3              reader  Lorg/apache/cassandra/io/util/RandomAccessReader;
            0   12     4  tolerateTruncation  Z
    MethodParameters:
                    Name  Flags
      handler             
      descriptor          
      reader              
      tolerateTruncation  

  public java.util.Iterator<org.apache.cassandra.db.commitlog.CommitLogSegmentReader$SyncSegment> iterator();
    descriptor: ()Ljava/util/Iterator;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=1, args_size=1
        start local 0 // org.apache.cassandra.db.commitlog.CommitLogSegmentReader this
         0: .line 81
            new org.apache.cassandra.db.commitlog.CommitLogSegmentReader$SegmentIterator
            dup
            aload 0 /* this */
            invokespecial org.apache.cassandra.db.commitlog.CommitLogSegmentReader$SegmentIterator.<init>:(Lorg/apache/cassandra/db/commitlog/CommitLogSegmentReader;)V
            areturn
        end local 0 // org.apache.cassandra.db.commitlog.CommitLogSegmentReader this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lorg/apache/cassandra/db/commitlog/CommitLogSegmentReader;
    Signature: ()Ljava/util/Iterator<Lorg/apache/cassandra/db/commitlog/CommitLogSegmentReader$SyncSegment;>;

  private int readSyncMarker(org.apache.cassandra.db.commitlog.CommitLogDescriptor, int, org.apache.cassandra.io.util.RandomAccessReader);
    descriptor: (Lorg/apache/cassandra/db/commitlog/CommitLogDescriptor;ILorg/apache/cassandra/io/util/RandomAccessReader;)I
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=6, locals=9, args_size=4
        start local 0 // org.apache.cassandra.db.commitlog.CommitLogSegmentReader this
        start local 1 // org.apache.cassandra.db.commitlog.CommitLogDescriptor descriptor
        start local 2 // int offset
        start local 3 // org.apache.cassandra.io.util.RandomAccessReader reader
         0: .line 142
            iload 2 /* offset */
            i2l
            aload 3 /* reader */
            invokevirtual org.apache.cassandra.io.util.RandomAccessReader.length:()J
            ldc 8
            lsub
            lcmp
            ifle 2
         1: .line 145
            iconst_m1
            ireturn
         2: .line 147
      StackMap locals:
      StackMap stack:
            aload 3 /* reader */
            iload 2 /* offset */
            i2l
            invokevirtual org.apache.cassandra.io.util.RandomAccessReader.seek:(J)V
         3: .line 148
            new java.util.zip.CRC32
            dup
            invokespecial java.util.zip.CRC32.<init>:()V
            astore 4 /* crc */
        start local 4 // java.util.zip.CRC32 crc
         4: .line 149
            aload 4 /* crc */
            aload 1 /* descriptor */
            getfield org.apache.cassandra.db.commitlog.CommitLogDescriptor.id:J
            ldc 4294967295
            land
            l2i
            invokestatic org.apache.cassandra.utils.FBUtilities.updateChecksumInt:(Ljava/util/zip/Checksum;I)V
         5: .line 150
            aload 4 /* crc */
            aload 1 /* descriptor */
            getfield org.apache.cassandra.db.commitlog.CommitLogDescriptor.id:J
            bipush 32
            lushr
            l2i
            invokestatic org.apache.cassandra.utils.FBUtilities.updateChecksumInt:(Ljava/util/zip/Checksum;I)V
         6: .line 151
            aload 4 /* crc */
            aload 3 /* reader */
            invokevirtual org.apache.cassandra.io.util.RandomAccessReader.getPosition:()J
            l2i
            invokestatic org.apache.cassandra.utils.FBUtilities.updateChecksumInt:(Ljava/util/zip/Checksum;I)V
         7: .line 152
            aload 3 /* reader */
            invokevirtual org.apache.cassandra.io.util.RandomAccessReader.readInt:()I
            istore 5 /* end */
        start local 5 // int end
         8: .line 153
            aload 3 /* reader */
            invokevirtual org.apache.cassandra.io.util.RandomAccessReader.readInt:()I
            i2l
            ldc 4294967295
            land
            lstore 6 /* filecrc */
        start local 6 // long filecrc
         9: .line 154
            aload 4 /* crc */
            invokevirtual java.util.zip.CRC32.getValue:()J
            lload 6 /* filecrc */
            lcmp
            ifeq 16
        10: .line 156
            iload 5 /* end */
            ifne 11
            lload 6 /* filecrc */
            lconst_0
            lcmp
            ifeq 15
        11: .line 158
      StackMap locals: java.util.zip.CRC32 int long
      StackMap stack:
            ldc "Encountered bad header at position %d of commit log %s, with invalid CRC. The end of segment marker should be zero."
            iconst_2
            anewarray java.lang.Object
            dup
            iconst_0
        12: .line 159
            iload 2 /* offset */
            invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
            aastore
            dup
            iconst_1
            aload 3 /* reader */
            invokevirtual org.apache.cassandra.io.util.RandomAccessReader.getPath:()Ljava/lang/String;
            aastore
        13: .line 158
            invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
            astore 8 /* msg */
        start local 8 // java.lang.String msg
        14: .line 160
            new org.apache.cassandra.db.commitlog.CommitLogSegmentReader$SegmentReadException
            dup
            aload 8 /* msg */
            iconst_1
            invokespecial org.apache.cassandra.db.commitlog.CommitLogSegmentReader$SegmentReadException.<init>:(Ljava/lang/String;Z)V
            athrow
        end local 8 // java.lang.String msg
        15: .line 162
      StackMap locals:
      StackMap stack:
            iconst_m1
            ireturn
        16: .line 164
      StackMap locals:
      StackMap stack:
            iload 5 /* end */
            iload 2 /* offset */
            if_icmplt 17
            iload 5 /* end */
            i2l
            aload 3 /* reader */
            invokevirtual org.apache.cassandra.io.util.RandomAccessReader.length:()J
            lcmp
            ifle 19
        17: .line 166
      StackMap locals:
      StackMap stack:
            ldc "Encountered bad header at position %d of commit log %s, with bad position but valid CRC"
            iconst_2
            anewarray java.lang.Object
            dup
            iconst_0
            iload 2 /* offset */
            invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
            aastore
            dup
            iconst_1
            aload 3 /* reader */
            invokevirtual org.apache.cassandra.io.util.RandomAccessReader.getPath:()Ljava/lang/String;
            aastore
            invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
            astore 8 /* msg */
        start local 8 // java.lang.String msg
        18: .line 167
            new org.apache.cassandra.db.commitlog.CommitLogSegmentReader$SegmentReadException
            dup
            aload 8 /* msg */
            iconst_0
            invokespecial org.apache.cassandra.db.commitlog.CommitLogSegmentReader$SegmentReadException.<init>:(Ljava/lang/String;Z)V
            athrow
        end local 8 // java.lang.String msg
        19: .line 169
      StackMap locals:
      StackMap stack:
            iload 5 /* end */
            ireturn
        end local 6 // long filecrc
        end local 5 // int end
        end local 4 // java.util.zip.CRC32 crc
        end local 3 // org.apache.cassandra.io.util.RandomAccessReader reader
        end local 2 // int offset
        end local 1 // org.apache.cassandra.db.commitlog.CommitLogDescriptor descriptor
        end local 0 // org.apache.cassandra.db.commitlog.CommitLogSegmentReader this
      LocalVariableTable:
        Start  End  Slot        Name  Signature
            0   20     0        this  Lorg/apache/cassandra/db/commitlog/CommitLogSegmentReader;
            0   20     1  descriptor  Lorg/apache/cassandra/db/commitlog/CommitLogDescriptor;
            0   20     2      offset  I
            0   20     3      reader  Lorg/apache/cassandra/io/util/RandomAccessReader;
            4   20     4         crc  Ljava/util/zip/CRC32;
            8   20     5         end  I
            9   20     6     filecrc  J
           14   15     8         msg  Ljava/lang/String;
           18   19     8         msg  Ljava/lang/String;
    Exceptions:
      throws java.io.IOException
    MethodParameters:
            Name  Flags
      descriptor  
      offset      
      reader      
}
Signature: Ljava/lang/Object;Ljava/lang/Iterable<Lorg/apache/cassandra/db/commitlog/CommitLogSegmentReader$SyncSegment;>;
SourceFile: "CommitLogSegmentReader.java"
NestMembers:
  org.apache.cassandra.db.commitlog.CommitLogSegmentReader$CompressedSegmenter  org.apache.cassandra.db.commitlog.CommitLogSegmentReader$EncryptedSegmenter  org.apache.cassandra.db.commitlog.CommitLogSegmentReader$NoOpSegmenter  org.apache.cassandra.db.commitlog.CommitLogSegmentReader$SegmentIterator  org.apache.cassandra.db.commitlog.CommitLogSegmentReader$SegmentReadException  org.apache.cassandra.db.commitlog.CommitLogSegmentReader$Segmenter  org.apache.cassandra.db.commitlog.CommitLogSegmentReader$SyncSegment
InnerClasses:
  CompressedSegmenter = org.apache.cassandra.db.commitlog.CommitLogSegmentReader$CompressedSegmenter of org.apache.cassandra.db.commitlog.CommitLogSegmentReader
  EncryptedSegmenter = org.apache.cassandra.db.commitlog.CommitLogSegmentReader$EncryptedSegmenter of org.apache.cassandra.db.commitlog.CommitLogSegmentReader
  NoOpSegmenter = org.apache.cassandra.db.commitlog.CommitLogSegmentReader$NoOpSegmenter of org.apache.cassandra.db.commitlog.CommitLogSegmentReader
  protected SegmentIterator = org.apache.cassandra.db.commitlog.CommitLogSegmentReader$SegmentIterator of org.apache.cassandra.db.commitlog.CommitLogSegmentReader
  public SegmentReadException = org.apache.cassandra.db.commitlog.CommitLogSegmentReader$SegmentReadException of org.apache.cassandra.db.commitlog.CommitLogSegmentReader
  abstract Segmenter = org.apache.cassandra.db.commitlog.CommitLogSegmentReader$Segmenter of org.apache.cassandra.db.commitlog.CommitLogSegmentReader
  public SyncSegment = org.apache.cassandra.db.commitlog.CommitLogSegmentReader$SyncSegment of org.apache.cassandra.db.commitlog.CommitLogSegmentReader