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.transport.FrameCompressor$SnappyCompressor implements org.apache.cassandra.transport.FrameCompressor
  minor version: 0
  major version: 59
  flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
  this_class: org.apache.cassandra.transport.FrameCompressor$SnappyCompressor
  super_class: java.lang.Object
{
  public static final org.apache.cassandra.transport.FrameCompressor$SnappyCompressor instance;
    descriptor: Lorg/apache/cassandra/transport/FrameCompressor$SnappyCompressor;
    flags: (0x0019) ACC_PUBLIC, ACC_STATIC, ACC_FINAL

  static void <clinit>();
    descriptor: ()V
    flags: (0x0008) ACC_STATIC
    Code:
      stack=2, locals=2, args_size=0
         0: .line 47
            new org.apache.cassandra.transport.FrameCompressor$SnappyCompressor
            dup
            invokespecial org.apache.cassandra.transport.FrameCompressor$SnappyCompressor.<init>:()V
            astore 0 /* i */
        start local 0 // org.apache.cassandra.transport.FrameCompressor$SnappyCompressor i
         1: .line 48
            goto 8
        end local 0 // org.apache.cassandra.transport.FrameCompressor$SnappyCompressor i
         2: .line 49
      StackMap locals:
      StackMap stack: java.lang.Exception
            astore 1 /* e */
        start local 1 // java.lang.Exception e
         3: .line 51
            aload 1 /* e */
            invokestatic org.apache.cassandra.utils.JVMStabilityInspector.inspectThrowable:(Ljava/lang/Throwable;)V
         4: .line 52
            aconst_null
            astore 0 /* i */
        end local 1 // java.lang.Exception e
        start local 0 // org.apache.cassandra.transport.FrameCompressor$SnappyCompressor i
         5: goto 8
        end local 0 // org.apache.cassandra.transport.FrameCompressor$SnappyCompressor i
         6: .line 54
      StackMap locals:
      StackMap stack: java.lang.Error
            pop
         7: .line 56
            aconst_null
            astore 0 /* i */
        start local 0 // org.apache.cassandra.transport.FrameCompressor$SnappyCompressor i
         8: .line 58
      StackMap locals: org.apache.cassandra.transport.FrameCompressor$SnappyCompressor
      StackMap stack:
            aload 0 /* i */
            putstatic org.apache.cassandra.transport.FrameCompressor$SnappyCompressor.instance:Lorg/apache/cassandra/transport/FrameCompressor$SnappyCompressor;
        end local 0 // org.apache.cassandra.transport.FrameCompressor$SnappyCompressor i
         9: .line 59
            return
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            1    2     0     i  Lorg/apache/cassandra/transport/FrameCompressor$SnappyCompressor;
            5    6     0     i  Lorg/apache/cassandra/transport/FrameCompressor$SnappyCompressor;
            8    9     0     i  Lorg/apache/cassandra/transport/FrameCompressor$SnappyCompressor;
            3    5     1     e  Ljava/lang/Exception;
      Exception table:
        from    to  target  type
           0     1       2  Class java.lang.Exception
           0     1       6  Class java.lang.NoClassDefFoundError
           0     1       6  Class org.xerial.snappy.SnappyError
           0     1       6  Class java.lang.UnsatisfiedLinkError

  private void <init>();
    descriptor: ()V
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // org.apache.cassandra.transport.FrameCompressor$SnappyCompressor this
         0: .line 61
            aload 0 /* this */
            invokespecial java.lang.Object.<init>:()V
         1: .line 65
            invokestatic org.xerial.snappy.Snappy.getNativeLibraryVersion:()Ljava/lang/String;
            pop
         2: .line 66
            return
        end local 0 // org.apache.cassandra.transport.FrameCompressor$SnappyCompressor this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    3     0  this  Lorg/apache/cassandra/transport/FrameCompressor$SnappyCompressor;

  public org.apache.cassandra.transport.Frame compress(org.apache.cassandra.transport.Frame);
    descriptor: (Lorg/apache/cassandra/transport/Frame;)Lorg/apache/cassandra/transport/Frame;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=5, locals=6, args_size=2
        start local 0 // org.apache.cassandra.transport.FrameCompressor$SnappyCompressor this
        start local 1 // org.apache.cassandra.transport.Frame frame
         0: .line 70
            aload 1 /* frame */
            getfield org.apache.cassandra.transport.Frame.body:Lio/netty/buffer/ByteBuf;
            invokestatic org.apache.cassandra.transport.CBUtil.readRawBytes:(Lio/netty/buffer/ByteBuf;)[B
            astore 2 /* input */
        start local 2 // byte[] input
         1: .line 71
            getstatic org.apache.cassandra.transport.CBUtil.allocator:Lio/netty/buffer/ByteBufAllocator;
            aload 2 /* input */
            arraylength
            invokestatic org.xerial.snappy.Snappy.maxCompressedLength:(I)I
            invokeinterface io.netty.buffer.ByteBufAllocator.heapBuffer:(I)Lio/netty/buffer/ByteBuf;
            astore 3 /* output */
        start local 3 // io.netty.buffer.ByteBuf output
         2: .line 75
            aload 2 /* input */
            iconst_0
            aload 2 /* input */
            arraylength
            aload 3 /* output */
            invokevirtual io.netty.buffer.ByteBuf.array:()[B
            aload 3 /* output */
            invokevirtual io.netty.buffer.ByteBuf.arrayOffset:()I
            invokestatic org.xerial.snappy.Snappy.compress:([BII[BI)I
            istore 4 /* written */
        start local 4 // int written
         3: .line 76
            aload 3 /* output */
            iload 4 /* written */
            invokevirtual io.netty.buffer.ByteBuf.writerIndex:(I)Lio/netty/buffer/ByteBuf;
            pop
        end local 4 // int written
         4: .line 77
            goto 11
         5: .line 78
      StackMap locals: org.apache.cassandra.transport.FrameCompressor$SnappyCompressor org.apache.cassandra.transport.Frame byte[] io.netty.buffer.ByteBuf
      StackMap stack: java.lang.Throwable
            astore 4 /* e */
        start local 4 // java.lang.Throwable e
         6: .line 80
            aload 3 /* output */
            invokevirtual io.netty.buffer.ByteBuf.release:()Z
            pop
         7: .line 81
            aload 4 /* e */
            athrow
        end local 4 // java.lang.Throwable e
         8: .line 84
      StackMap locals:
      StackMap stack: java.lang.Throwable
            astore 5
         9: .line 86
            aload 1 /* frame */
            invokevirtual org.apache.cassandra.transport.Frame.release:()Z
            pop
        10: .line 87
            aload 5
            athrow
        11: .line 86
      StackMap locals:
      StackMap stack:
            aload 1 /* frame */
            invokevirtual org.apache.cassandra.transport.Frame.release:()Z
            pop
        12: .line 89
            aload 1 /* frame */
            aload 3 /* output */
            invokevirtual org.apache.cassandra.transport.Frame.with:(Lio/netty/buffer/ByteBuf;)Lorg/apache/cassandra/transport/Frame;
            areturn
        end local 3 // io.netty.buffer.ByteBuf output
        end local 2 // byte[] input
        end local 1 // org.apache.cassandra.transport.Frame frame
        end local 0 // org.apache.cassandra.transport.FrameCompressor$SnappyCompressor this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0   13     0     this  Lorg/apache/cassandra/transport/FrameCompressor$SnappyCompressor;
            0   13     1    frame  Lorg/apache/cassandra/transport/Frame;
            1   13     2    input  [B
            2   13     3   output  Lio/netty/buffer/ByteBuf;
            3    4     4  written  I
            6    8     4        e  Ljava/lang/Throwable;
      Exception table:
        from    to  target  type
           2     4       5  Class java.lang.Throwable
           2     8       8  any
    Exceptions:
      throws java.io.IOException
    MethodParameters:
       Name  Flags
      frame  

  public org.apache.cassandra.transport.Frame decompress(org.apache.cassandra.transport.Frame);
    descriptor: (Lorg/apache/cassandra/transport/Frame;)Lorg/apache/cassandra/transport/Frame;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=5, locals=6, args_size=2
        start local 0 // org.apache.cassandra.transport.FrameCompressor$SnappyCompressor this
        start local 1 // org.apache.cassandra.transport.Frame frame
         0: .line 94
            aload 1 /* frame */
            getfield org.apache.cassandra.transport.Frame.body:Lio/netty/buffer/ByteBuf;
            invokestatic org.apache.cassandra.transport.CBUtil.readRawBytes:(Lio/netty/buffer/ByteBuf;)[B
            astore 2 /* input */
        start local 2 // byte[] input
         1: .line 96
            aload 2 /* input */
            iconst_0
            aload 2 /* input */
            arraylength
            invokestatic org.xerial.snappy.Snappy.isValidCompressedBuffer:([BII)Z
            ifne 3
         2: .line 97
            new org.apache.cassandra.transport.ProtocolException
            dup
            ldc "Provided frame does not appear to be Snappy compressed"
            invokespecial org.apache.cassandra.transport.ProtocolException.<init>:(Ljava/lang/String;)V
            athrow
         3: .line 99
      StackMap locals: byte[]
      StackMap stack:
            getstatic org.apache.cassandra.transport.CBUtil.allocator:Lio/netty/buffer/ByteBufAllocator;
            aload 2 /* input */
            invokestatic org.xerial.snappy.Snappy.uncompressedLength:([B)I
            invokeinterface io.netty.buffer.ByteBufAllocator.heapBuffer:(I)Lio/netty/buffer/ByteBuf;
            astore 3 /* output */
        start local 3 // io.netty.buffer.ByteBuf output
         4: .line 103
            aload 2 /* input */
            iconst_0
            aload 2 /* input */
            arraylength
            aload 3 /* output */
            invokevirtual io.netty.buffer.ByteBuf.array:()[B
            aload 3 /* output */
            invokevirtual io.netty.buffer.ByteBuf.arrayOffset:()I
            invokestatic org.xerial.snappy.Snappy.uncompress:([BII[BI)I
            istore 4 /* size */
        start local 4 // int size
         5: .line 104
            aload 3 /* output */
            iload 4 /* size */
            invokevirtual io.netty.buffer.ByteBuf.writerIndex:(I)Lio/netty/buffer/ByteBuf;
            pop
        end local 4 // int size
         6: .line 105
            goto 13
         7: .line 106
      StackMap locals: org.apache.cassandra.transport.FrameCompressor$SnappyCompressor org.apache.cassandra.transport.Frame byte[] io.netty.buffer.ByteBuf
      StackMap stack: java.lang.Throwable
            astore 4 /* e */
        start local 4 // java.lang.Throwable e
         8: .line 108
            aload 3 /* output */
            invokevirtual io.netty.buffer.ByteBuf.release:()Z
            pop
         9: .line 109
            aload 4 /* e */
            athrow
        end local 4 // java.lang.Throwable e
        10: .line 112
      StackMap locals:
      StackMap stack: java.lang.Throwable
            astore 5
        11: .line 114
            aload 1 /* frame */
            invokevirtual org.apache.cassandra.transport.Frame.release:()Z
            pop
        12: .line 115
            aload 5
            athrow
        13: .line 114
      StackMap locals:
      StackMap stack:
            aload 1 /* frame */
            invokevirtual org.apache.cassandra.transport.Frame.release:()Z
            pop
        14: .line 117
            aload 1 /* frame */
            aload 3 /* output */
            invokevirtual org.apache.cassandra.transport.Frame.with:(Lio/netty/buffer/ByteBuf;)Lorg/apache/cassandra/transport/Frame;
            areturn
        end local 3 // io.netty.buffer.ByteBuf output
        end local 2 // byte[] input
        end local 1 // org.apache.cassandra.transport.Frame frame
        end local 0 // org.apache.cassandra.transport.FrameCompressor$SnappyCompressor this
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0   15     0    this  Lorg/apache/cassandra/transport/FrameCompressor$SnappyCompressor;
            0   15     1   frame  Lorg/apache/cassandra/transport/Frame;
            1   15     2   input  [B
            4   15     3  output  Lio/netty/buffer/ByteBuf;
            5    6     4    size  I
            8   10     4       e  Ljava/lang/Throwable;
      Exception table:
        from    to  target  type
           4     6       7  Class java.lang.Throwable
           4    10      10  any
    Exceptions:
      throws java.io.IOException
    MethodParameters:
       Name  Flags
      frame  
}
SourceFile: "FrameCompressor.java"
NestHost: org.apache.cassandra.transport.FrameCompressor
InnerClasses:
  public SnappyCompressor = org.apache.cassandra.transport.FrameCompressor$SnappyCompressor of org.apache.cassandra.transport.FrameCompressor