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.CompressedSegment extends org.apache.cassandra.db.commitlog.FileDirectSegment
  minor version: 0
  major version: 59
  flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
  this_class: org.apache.cassandra.db.commitlog.CompressedSegment
  super_class: org.apache.cassandra.db.commitlog.FileDirectSegment
{
  static final int COMPRESSED_MARKER_SIZE;
    descriptor: I
    flags: (0x0018) ACC_STATIC, ACC_FINAL
    ConstantValue: 12

  final org.apache.cassandra.io.compress.ICompressor compressor;
    descriptor: Lorg/apache/cassandra/io/compress/ICompressor;
    flags: (0x0010) ACC_FINAL

  static final boolean $assertionsDisabled;
    descriptor: Z
    flags: (0x1018) ACC_STATIC, ACC_FINAL, ACC_SYNTHETIC

  static void <clinit>();
    descriptor: ()V
    flags: (0x0008) ACC_STATIC
    Code:
      stack=1, locals=0, args_size=0
         0: .line 36
            ldc Lorg/apache/cassandra/db/commitlog/CompressedSegment;
            invokevirtual java.lang.Class.desiredAssertionStatus:()Z
            ifne 1
            iconst_1
            goto 2
      StackMap locals:
      StackMap stack:
         1: iconst_0
      StackMap locals:
      StackMap stack: int
         2: putstatic org.apache.cassandra.db.commitlog.CompressedSegment.$assertionsDisabled:Z
         3: .line 38
            return
      LocalVariableTable:
        Start  End  Slot  Name  Signature

  void <init>(org.apache.cassandra.db.commitlog.CommitLog, org.apache.cassandra.db.commitlog.AbstractCommitLogSegmentManager);
    descriptor: (Lorg/apache/cassandra/db/commitlog/CommitLog;Lorg/apache/cassandra/db/commitlog/AbstractCommitLogSegmentManager;)V
    flags: (0x0000) 
    Code:
      stack=3, locals=3, args_size=3
        start local 0 // org.apache.cassandra.db.commitlog.CompressedSegment this
        start local 1 // org.apache.cassandra.db.commitlog.CommitLog commitLog
        start local 2 // org.apache.cassandra.db.commitlog.AbstractCommitLogSegmentManager manager
         0: .line 46
            aload 0 /* this */
            aload 1 /* commitLog */
            aload 2 /* manager */
            invokespecial org.apache.cassandra.db.commitlog.FileDirectSegment.<init>:(Lorg/apache/cassandra/db/commitlog/CommitLog;Lorg/apache/cassandra/db/commitlog/AbstractCommitLogSegmentManager;)V
         1: .line 47
            aload 0 /* this */
            aload 1 /* commitLog */
            getfield org.apache.cassandra.db.commitlog.CommitLog.configuration:Lorg/apache/cassandra/db/commitlog/CommitLog$Configuration;
            invokevirtual org.apache.cassandra.db.commitlog.CommitLog$Configuration.getCompressor:()Lorg/apache/cassandra/io/compress/ICompressor;
            putfield org.apache.cassandra.db.commitlog.CompressedSegment.compressor:Lorg/apache/cassandra/io/compress/ICompressor;
         2: .line 48
            aload 2 /* manager */
            invokevirtual org.apache.cassandra.db.commitlog.AbstractCommitLogSegmentManager.getBufferPool:()Lorg/apache/cassandra/db/commitlog/SimpleCachedBufferPool;
            aload 0 /* this */
            getfield org.apache.cassandra.db.commitlog.CompressedSegment.compressor:Lorg/apache/cassandra/io/compress/ICompressor;
            invokeinterface org.apache.cassandra.io.compress.ICompressor.preferredBufferType:()Lorg/apache/cassandra/io/compress/BufferType;
            invokevirtual org.apache.cassandra.db.commitlog.SimpleCachedBufferPool.setPreferredReusableBufferType:(Lorg/apache/cassandra/io/compress/BufferType;)V
         3: .line 49
            return
        end local 2 // org.apache.cassandra.db.commitlog.AbstractCommitLogSegmentManager manager
        end local 1 // org.apache.cassandra.db.commitlog.CommitLog commitLog
        end local 0 // org.apache.cassandra.db.commitlog.CompressedSegment this
      LocalVariableTable:
        Start  End  Slot       Name  Signature
            0    4     0       this  Lorg/apache/cassandra/db/commitlog/CompressedSegment;
            0    4     1  commitLog  Lorg/apache/cassandra/db/commitlog/CommitLog;
            0    4     2    manager  Lorg/apache/cassandra/db/commitlog/AbstractCommitLogSegmentManager;
    MethodParameters:
           Name  Flags
      commitLog  
      manager    

  java.nio.ByteBuffer createBuffer(org.apache.cassandra.db.commitlog.CommitLog);
    descriptor: (Lorg/apache/cassandra/db/commitlog/CommitLog;)Ljava/nio/ByteBuffer;
    flags: (0x0000) 
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // org.apache.cassandra.db.commitlog.CompressedSegment this
        start local 1 // org.apache.cassandra.db.commitlog.CommitLog commitLog
         0: .line 53
            aload 0 /* this */
            getfield org.apache.cassandra.db.commitlog.CompressedSegment.manager:Lorg/apache/cassandra/db/commitlog/AbstractCommitLogSegmentManager;
            invokevirtual org.apache.cassandra.db.commitlog.AbstractCommitLogSegmentManager.getBufferPool:()Lorg/apache/cassandra/db/commitlog/SimpleCachedBufferPool;
            aload 1 /* commitLog */
            getfield org.apache.cassandra.db.commitlog.CommitLog.configuration:Lorg/apache/cassandra/db/commitlog/CommitLog$Configuration;
            invokevirtual org.apache.cassandra.db.commitlog.CommitLog$Configuration.getCompressor:()Lorg/apache/cassandra/io/compress/ICompressor;
            invokeinterface org.apache.cassandra.io.compress.ICompressor.preferredBufferType:()Lorg/apache/cassandra/io/compress/BufferType;
            invokevirtual org.apache.cassandra.db.commitlog.SimpleCachedBufferPool.createBuffer:(Lorg/apache/cassandra/io/compress/BufferType;)Ljava/nio/ByteBuffer;
            areturn
        end local 1 // org.apache.cassandra.db.commitlog.CommitLog commitLog
        end local 0 // org.apache.cassandra.db.commitlog.CompressedSegment this
      LocalVariableTable:
        Start  End  Slot       Name  Signature
            0    1     0       this  Lorg/apache/cassandra/db/commitlog/CompressedSegment;
            0    1     1  commitLog  Lorg/apache/cassandra/db/commitlog/CommitLog;
    MethodParameters:
           Name  Flags
      commitLog  

  void write(int, int);
    descriptor: (II)V
    flags: (0x0000) 
    Code:
      stack=7, locals=8, args_size=3
        start local 0 // org.apache.cassandra.db.commitlog.CompressedSegment this
        start local 1 // int startMarker
        start local 2 // int nextMarker
         0: .line 59
            iload 1 /* startMarker */
            bipush 8
            iadd
            istore 3 /* contentStart */
        start local 3 // int contentStart
         1: .line 60
            iload 2 /* nextMarker */
            iload 3 /* contentStart */
            isub
            istore 4 /* length */
        start local 4 // int length
         2: .line 62
            getstatic org.apache.cassandra.db.commitlog.CompressedSegment.$assertionsDisabled:Z
            ifne 4
            iload 4 /* length */
            ifgt 4
            iload 4 /* length */
            ifne 3
            aload 0 /* this */
            invokevirtual org.apache.cassandra.db.commitlog.CompressedSegment.isStillAllocating:()Z
            ifeq 4
      StackMap locals: int int
      StackMap stack:
         3: new java.lang.AssertionError
            dup
            invokespecial java.lang.AssertionError.<init>:()V
            athrow
         4: .line 66
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield org.apache.cassandra.db.commitlog.CompressedSegment.compressor:Lorg/apache/cassandra/io/compress/ICompressor;
            iload 4 /* length */
            invokeinterface org.apache.cassandra.io.compress.ICompressor.initialCompressedBufferLength:(I)I
            bipush 12
            iadd
            istore 5 /* neededBufferSize */
        start local 5 // int neededBufferSize
         5: .line 67
            aload 0 /* this */
            getfield org.apache.cassandra.db.commitlog.CompressedSegment.manager:Lorg/apache/cassandra/db/commitlog/AbstractCommitLogSegmentManager;
            invokevirtual org.apache.cassandra.db.commitlog.AbstractCommitLogSegmentManager.getBufferPool:()Lorg/apache/cassandra/db/commitlog/SimpleCachedBufferPool;
            iload 5 /* neededBufferSize */
            invokevirtual org.apache.cassandra.db.commitlog.SimpleCachedBufferPool.getThreadLocalReusableBuffer:(I)Ljava/nio/ByteBuffer;
            astore 6 /* compressedBuffer */
        start local 6 // java.nio.ByteBuffer compressedBuffer
         6: .line 69
            aload 0 /* this */
            getfield org.apache.cassandra.db.commitlog.CompressedSegment.buffer:Ljava/nio/ByteBuffer;
            invokevirtual java.nio.ByteBuffer.duplicate:()Ljava/nio/ByteBuffer;
            astore 7 /* inputBuffer */
        start local 7 // java.nio.ByteBuffer inputBuffer
         7: .line 70
            aload 7 /* inputBuffer */
            iload 3 /* contentStart */
            iload 4 /* length */
            iadd
            invokevirtual java.nio.ByteBuffer.limit:(I)Ljava/nio/Buffer;
            iload 3 /* contentStart */
            invokevirtual java.nio.Buffer.position:(I)Ljava/nio/Buffer;
            pop
         8: .line 71
            aload 6 /* compressedBuffer */
            aload 6 /* compressedBuffer */
            invokevirtual java.nio.ByteBuffer.capacity:()I
            invokevirtual java.nio.ByteBuffer.limit:(I)Ljava/nio/Buffer;
            bipush 12
            invokevirtual java.nio.Buffer.position:(I)Ljava/nio/Buffer;
            pop
         9: .line 72
            aload 0 /* this */
            getfield org.apache.cassandra.db.commitlog.CompressedSegment.compressor:Lorg/apache/cassandra/io/compress/ICompressor;
            aload 7 /* inputBuffer */
            aload 6 /* compressedBuffer */
            invokeinterface org.apache.cassandra.io.compress.ICompressor.compress:(Ljava/nio/ByteBuffer;Ljava/nio/ByteBuffer;)V
        10: .line 74
            aload 6 /* compressedBuffer */
            invokevirtual java.nio.ByteBuffer.flip:()Ljava/nio/Buffer;
            pop
        11: .line 75
            aload 6 /* compressedBuffer */
            bipush 8
            iload 4 /* length */
            invokevirtual java.nio.ByteBuffer.putInt:(II)Ljava/nio/ByteBuffer;
            pop
        12: .line 79
            aload 0 /* this */
            getfield org.apache.cassandra.db.commitlog.CompressedSegment.id:J
            aload 6 /* compressedBuffer */
            iconst_0
            aload 0 /* this */
            getfield org.apache.cassandra.db.commitlog.CompressedSegment.channel:Ljava/nio/channels/FileChannel;
            invokevirtual java.nio.channels.FileChannel.position:()J
            l2i
            aload 0 /* this */
            getfield org.apache.cassandra.db.commitlog.CompressedSegment.channel:Ljava/nio/channels/FileChannel;
            invokevirtual java.nio.channels.FileChannel.position:()J
            l2i
            aload 6 /* compressedBuffer */
            invokevirtual java.nio.ByteBuffer.remaining:()I
            iadd
            invokestatic org.apache.cassandra.db.commitlog.CompressedSegment.writeSyncMarker:(JLjava/nio/ByteBuffer;III)V
        13: .line 80
            aload 0 /* this */
            getfield org.apache.cassandra.db.commitlog.CompressedSegment.manager:Lorg/apache/cassandra/db/commitlog/AbstractCommitLogSegmentManager;
            aload 6 /* compressedBuffer */
            invokevirtual java.nio.ByteBuffer.limit:()I
            i2l
            invokevirtual org.apache.cassandra.db.commitlog.AbstractCommitLogSegmentManager.addSize:(J)V
        14: .line 81
            aload 0 /* this */
            getfield org.apache.cassandra.db.commitlog.CompressedSegment.channel:Ljava/nio/channels/FileChannel;
            aload 6 /* compressedBuffer */
            invokevirtual java.nio.channels.FileChannel.write:(Ljava/nio/ByteBuffer;)I
            pop
        15: .line 82
            getstatic org.apache.cassandra.db.commitlog.CompressedSegment.$assertionsDisabled:Z
            ifne 16
            aload 0 /* this */
            getfield org.apache.cassandra.db.commitlog.CompressedSegment.channel:Ljava/nio/channels/FileChannel;
            invokevirtual java.nio.channels.FileChannel.position:()J
            aload 0 /* this */
            getfield org.apache.cassandra.db.commitlog.CompressedSegment.lastWrittenPos:J
            lsub
            aload 6 /* compressedBuffer */
            invokevirtual java.nio.ByteBuffer.limit:()I
            i2l
            lcmp
            ifeq 16
            new java.lang.AssertionError
            dup
            invokespecial java.lang.AssertionError.<init>:()V
            athrow
        16: .line 83
      StackMap locals: int java.nio.ByteBuffer java.nio.ByteBuffer
      StackMap stack:
            aload 0 /* this */
            aload 0 /* this */
            getfield org.apache.cassandra.db.commitlog.CompressedSegment.channel:Ljava/nio/channels/FileChannel;
            invokevirtual java.nio.channels.FileChannel.position:()J
            putfield org.apache.cassandra.db.commitlog.CompressedSegment.lastWrittenPos:J
        end local 7 // java.nio.ByteBuffer inputBuffer
        end local 6 // java.nio.ByteBuffer compressedBuffer
        end local 5 // int neededBufferSize
        17: .line 84
            goto 20
        18: .line 85
      StackMap locals: org.apache.cassandra.db.commitlog.CompressedSegment int int int int
      StackMap stack: java.lang.Exception
            astore 5 /* e */
        start local 5 // java.lang.Exception e
        19: .line 87
            new org.apache.cassandra.io.FSWriteError
            dup
            aload 5 /* e */
            aload 0 /* this */
            invokevirtual org.apache.cassandra.db.commitlog.CompressedSegment.getPath:()Ljava/lang/String;
            invokespecial org.apache.cassandra.io.FSWriteError.<init>:(Ljava/lang/Throwable;Ljava/lang/String;)V
            athrow
        end local 5 // java.lang.Exception e
        20: .line 89
      StackMap locals:
      StackMap stack:
            return
        end local 4 // int length
        end local 3 // int contentStart
        end local 2 // int nextMarker
        end local 1 // int startMarker
        end local 0 // org.apache.cassandra.db.commitlog.CompressedSegment this
      LocalVariableTable:
        Start  End  Slot              Name  Signature
            0   21     0              this  Lorg/apache/cassandra/db/commitlog/CompressedSegment;
            0   21     1       startMarker  I
            0   21     2        nextMarker  I
            1   21     3      contentStart  I
            2   21     4            length  I
            5   17     5  neededBufferSize  I
            6   17     6  compressedBuffer  Ljava/nio/ByteBuffer;
            7   17     7       inputBuffer  Ljava/nio/ByteBuffer;
           19   20     5                 e  Ljava/lang/Exception;
      Exception table:
        from    to  target  type
           4    17      18  Class java.lang.Exception
    MethodParameters:
             Name  Flags
      startMarker  
      nextMarker   

  public long onDiskSize();
    descriptor: ()J
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // org.apache.cassandra.db.commitlog.CompressedSegment this
         0: .line 94
            aload 0 /* this */
            getfield org.apache.cassandra.db.commitlog.CompressedSegment.lastWrittenPos:J
            lreturn
        end local 0 // org.apache.cassandra.db.commitlog.CompressedSegment this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lorg/apache/cassandra/db/commitlog/CompressedSegment;
}
SourceFile: "CompressedSegment.java"
InnerClasses:
  public final Configuration = org.apache.cassandra.db.commitlog.CommitLog$Configuration of org.apache.cassandra.db.commitlog.CommitLog