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.io.compress.LZ4Compressor implements org.apache.cassandra.io.compress.ICompressor
  minor version: 0
  major version: 59
  flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
  this_class: org.apache.cassandra.io.compress.LZ4Compressor
  super_class: java.lang.Object
{
  private static final org.slf4j.Logger logger;
    descriptor: Lorg/slf4j/Logger;
    flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL

  public static final java.lang.String LZ4_FAST_COMPRESSOR;
    descriptor: Ljava/lang/String;
    flags: (0x0019) ACC_PUBLIC, ACC_STATIC, ACC_FINAL
    ConstantValue: "fast"

  public static final java.lang.String LZ4_HIGH_COMPRESSOR;
    descriptor: Ljava/lang/String;
    flags: (0x0019) ACC_PUBLIC, ACC_STATIC, ACC_FINAL
    ConstantValue: "high"

  private static final java.util.Set<java.lang.String> VALID_COMPRESSOR_TYPES;
    descriptor: Ljava/util/Set;
    flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
    Signature: Ljava/util/Set<Ljava/lang/String;>;

  private static final int DEFAULT_HIGH_COMPRESSION_LEVEL;
    descriptor: I
    flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
    ConstantValue: 9

  private static final java.lang.String DEFAULT_LZ4_COMPRESSOR_TYPE;
    descriptor: Ljava/lang/String;
    flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
    ConstantValue: "fast"

  public static final java.lang.String LZ4_HIGH_COMPRESSION_LEVEL;
    descriptor: Ljava/lang/String;
    flags: (0x0019) ACC_PUBLIC, ACC_STATIC, ACC_FINAL
    ConstantValue: "lz4_high_compressor_level"

  public static final java.lang.String LZ4_COMPRESSOR_TYPE;
    descriptor: Ljava/lang/String;
    flags: (0x0019) ACC_PUBLIC, ACC_STATIC, ACC_FINAL
    ConstantValue: "lz4_compressor_type"

  private static final int INTEGER_BYTES;
    descriptor: I
    flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
    ConstantValue: 4

  private static final java.util.concurrent.ConcurrentHashMap<org.apache.cassandra.utils.Pair<java.lang.String, java.lang.Integer>, org.apache.cassandra.io.compress.LZ4Compressor> instances;
    descriptor: Ljava/util/concurrent/ConcurrentHashMap;
    flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
    Signature: Ljava/util/concurrent/ConcurrentHashMap<Lorg/apache/cassandra/utils/Pair<Ljava/lang/String;Ljava/lang/Integer;>;Lorg/apache/cassandra/io/compress/LZ4Compressor;>;

  private final net.jpountz.lz4.LZ4Compressor compressor;
    descriptor: Lnet/jpountz/lz4/LZ4Compressor;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  private final net.jpountz.lz4.LZ4FastDecompressor decompressor;
    descriptor: Lnet/jpountz/lz4/LZ4FastDecompressor;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  final java.lang.String compressorType;
    descriptor: Ljava/lang/String;
    flags: (0x0010) ACC_FINAL
    RuntimeInvisibleAnnotations: 
      com.google.common.annotations.VisibleForTesting()

  final java.lang.Integer compressionLevel;
    descriptor: Ljava/lang/Integer;
    flags: (0x0010) ACC_FINAL
    RuntimeInvisibleAnnotations: 
      com.google.common.annotations.VisibleForTesting()

  static void <clinit>();
    descriptor: ()V
    flags: (0x0008) ACC_STATIC
    Code:
      stack=6, locals=0, args_size=0
         0: .line 39
            ldc Lorg/apache/cassandra/io/compress/LZ4Compressor;
            invokestatic org.slf4j.LoggerFactory.getLogger:(Ljava/lang/Class;)Lorg/slf4j/Logger;
            putstatic org.apache.cassandra.io.compress.LZ4Compressor.logger:Lorg/slf4j/Logger;
         1: .line 43
            new java.util.HashSet
            dup
            iconst_2
            anewarray java.lang.String
            dup
            iconst_0
            ldc "fast"
            aastore
            dup
            iconst_1
            ldc "high"
            aastore
            invokestatic java.util.Arrays.asList:([Ljava/lang/Object;)Ljava/util/List;
            invokespecial java.util.HashSet.<init>:(Ljava/util/Collection;)V
            putstatic org.apache.cassandra.io.compress.LZ4Compressor.VALID_COMPRESSOR_TYPES:Ljava/util/Set;
         2: .line 53
            new java.util.concurrent.ConcurrentHashMap
            dup
            invokespecial java.util.concurrent.ConcurrentHashMap.<init>:()V
            putstatic org.apache.cassandra.io.compress.LZ4Compressor.instances:Ljava/util/concurrent/ConcurrentHashMap;
            return
      LocalVariableTable:
        Start  End  Slot  Name  Signature

  public static org.apache.cassandra.io.compress.LZ4Compressor create(java.util.Map<java.lang.String, java.lang.String>);
    descriptor: (Ljava/util/Map;)Lorg/apache/cassandra/io/compress/LZ4Compressor;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=6, locals=6, args_size=1
        start local 0 // java.util.Map args
         0: .line 57
            aload 0 /* args */
            ldc "lz4_compressor_type"
            invokeinterface java.util.Map.get:(Ljava/lang/Object;)Ljava/lang/Object;
            checkcast java.lang.String
            invokestatic org.apache.cassandra.io.compress.LZ4Compressor.validateCompressorType:(Ljava/lang/String;)Ljava/lang/String;
            astore 1 /* compressorType */
        start local 1 // java.lang.String compressorType
         1: .line 58
            aload 0 /* args */
            ldc "lz4_high_compressor_level"
            invokeinterface java.util.Map.get:(Ljava/lang/Object;)Ljava/lang/Object;
            checkcast java.lang.String
            invokestatic org.apache.cassandra.io.compress.LZ4Compressor.validateCompressionLevel:(Ljava/lang/String;)Ljava/lang/Integer;
            astore 2 /* compressionLevel */
        start local 2 // java.lang.Integer compressionLevel
         2: .line 60
            aload 1 /* compressorType */
            aload 2 /* compressionLevel */
            invokestatic org.apache.cassandra.utils.Pair.create:(Ljava/lang/Object;Ljava/lang/Object;)Lorg/apache/cassandra/utils/Pair;
            astore 3 /* compressorTypeAndLevel */
        start local 3 // org.apache.cassandra.utils.Pair compressorTypeAndLevel
         3: .line 61
            getstatic org.apache.cassandra.io.compress.LZ4Compressor.instances:Ljava/util/concurrent/ConcurrentHashMap;
            aload 3 /* compressorTypeAndLevel */
            invokevirtual java.util.concurrent.ConcurrentHashMap.get:(Ljava/lang/Object;)Ljava/lang/Object;
            checkcast org.apache.cassandra.io.compress.LZ4Compressor
            astore 4 /* instance */
        start local 4 // org.apache.cassandra.io.compress.LZ4Compressor instance
         4: .line 62
            aload 4 /* instance */
            ifnonnull 11
         5: .line 64
            aload 1 /* compressorType */
            ldc "fast"
            invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
            ifeq 7
            aload 0 /* args */
            ldc "lz4_high_compressor_level"
            invokeinterface java.util.Map.get:(Ljava/lang/Object;)Ljava/lang/Object;
            ifnull 7
         6: .line 65
            getstatic org.apache.cassandra.io.compress.LZ4Compressor.logger:Lorg/slf4j/Logger;
            ldc "'{}' parameter is ignored when '{}' is '{}'"
            iconst_3
            anewarray java.lang.Object
            dup
            iconst_0
            ldc "lz4_high_compressor_level"
            aastore
            dup
            iconst_1
            ldc "lz4_compressor_type"
            aastore
            dup
            iconst_2
            ldc "fast"
            aastore
            invokeinterface org.slf4j.Logger.warn:(Ljava/lang/String;[Ljava/lang/Object;)V
         7: .line 66
      StackMap locals: java.util.Map java.lang.String java.lang.Integer org.apache.cassandra.utils.Pair org.apache.cassandra.io.compress.LZ4Compressor
      StackMap stack:
            new org.apache.cassandra.io.compress.LZ4Compressor
            dup
            aload 1 /* compressorType */
            aload 2 /* compressionLevel */
            invokespecial org.apache.cassandra.io.compress.LZ4Compressor.<init>:(Ljava/lang/String;Ljava/lang/Integer;)V
            astore 4 /* instance */
         8: .line 67
            getstatic org.apache.cassandra.io.compress.LZ4Compressor.instances:Ljava/util/concurrent/ConcurrentHashMap;
            aload 3 /* compressorTypeAndLevel */
            aload 4 /* instance */
            invokevirtual java.util.concurrent.ConcurrentHashMap.putIfAbsent:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
            checkcast org.apache.cassandra.io.compress.LZ4Compressor
            astore 5 /* instanceFromMap */
        start local 5 // org.apache.cassandra.io.compress.LZ4Compressor instanceFromMap
         9: .line 68
            aload 5 /* instanceFromMap */
            ifnull 11
        10: .line 69
            aload 5 /* instanceFromMap */
            astore 4 /* instance */
        end local 5 // org.apache.cassandra.io.compress.LZ4Compressor instanceFromMap
        11: .line 71
      StackMap locals:
      StackMap stack:
            aload 4 /* instance */
            areturn
        end local 4 // org.apache.cassandra.io.compress.LZ4Compressor instance
        end local 3 // org.apache.cassandra.utils.Pair compressorTypeAndLevel
        end local 2 // java.lang.Integer compressionLevel
        end local 1 // java.lang.String compressorType
        end local 0 // java.util.Map args
      LocalVariableTable:
        Start  End  Slot                    Name  Signature
            0   12     0                    args  Ljava/util/Map<Ljava/lang/String;Ljava/lang/String;>;
            1   12     1          compressorType  Ljava/lang/String;
            2   12     2        compressionLevel  Ljava/lang/Integer;
            3   12     3  compressorTypeAndLevel  Lorg/apache/cassandra/utils/Pair<Ljava/lang/String;Ljava/lang/Integer;>;
            4   12     4                instance  Lorg/apache/cassandra/io/compress/LZ4Compressor;
            9   11     5         instanceFromMap  Lorg/apache/cassandra/io/compress/LZ4Compressor;
    Exceptions:
      throws org.apache.cassandra.exceptions.ConfigurationException
    Signature: (Ljava/util/Map<Ljava/lang/String;Ljava/lang/String;>;)Lorg/apache/cassandra/io/compress/LZ4Compressor;
    MethodParameters:
      Name  Flags
      args  

  private void <init>(java.lang.String, java.lang.Integer);
    descriptor: (Ljava/lang/String;Ljava/lang/Integer;)V
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=3, locals=5, args_size=3
        start local 0 // org.apache.cassandra.io.compress.LZ4Compressor this
        start local 1 // java.lang.String type
        start local 2 // java.lang.Integer compressionLevel
         0: .line 81
            aload 0 /* this */
            invokespecial java.lang.Object.<init>:()V
         1: .line 83
            aload 0 /* this */
            aload 1 /* type */
            putfield org.apache.cassandra.io.compress.LZ4Compressor.compressorType:Ljava/lang/String;
         2: .line 84
            aload 0 /* this */
            aload 2 /* compressionLevel */
            putfield org.apache.cassandra.io.compress.LZ4Compressor.compressionLevel:Ljava/lang/Integer;
         3: .line 85
            invokestatic net.jpountz.lz4.LZ4Factory.fastestInstance:()Lnet/jpountz/lz4/LZ4Factory;
            astore 3 /* lz4Factory */
        start local 3 // net.jpountz.lz4.LZ4Factory lz4Factory
         4: .line 86
            aload 1 /* type */
            dup
            astore 4
            invokevirtual java.lang.String.hashCode:()I
            lookupswitch { // 2
              3135580: 5
              3202466: 6
              default: 9
          }
      StackMap locals: org.apache.cassandra.io.compress.LZ4Compressor java.lang.String java.lang.Integer net.jpountz.lz4.LZ4Factory java.lang.String
      StackMap stack:
         5: aload 4
            ldc "fast"
            invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
            ifne 9
            goto 9
      StackMap locals:
      StackMap stack:
         6: aload 4
            ldc "high"
            invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
            ifne 7
            goto 9
         7: .line 90
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            aload 3 /* lz4Factory */
            aload 2 /* compressionLevel */
            invokevirtual java.lang.Integer.intValue:()I
            invokevirtual net.jpountz.lz4.LZ4Factory.highCompressor:(I)Lnet/jpountz/lz4/LZ4Compressor;
            putfield org.apache.cassandra.io.compress.LZ4Compressor.compressor:Lnet/jpountz/lz4/LZ4Compressor;
         8: .line 91
            goto 10
         9: .line 96
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            aload 3 /* lz4Factory */
            invokevirtual net.jpountz.lz4.LZ4Factory.fastCompressor:()Lnet/jpountz/lz4/LZ4Compressor;
            putfield org.apache.cassandra.io.compress.LZ4Compressor.compressor:Lnet/jpountz/lz4/LZ4Compressor;
        10: .line 100
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            aload 3 /* lz4Factory */
            invokevirtual net.jpountz.lz4.LZ4Factory.fastDecompressor:()Lnet/jpountz/lz4/LZ4FastDecompressor;
            putfield org.apache.cassandra.io.compress.LZ4Compressor.decompressor:Lnet/jpountz/lz4/LZ4FastDecompressor;
        11: .line 101
            return
        end local 3 // net.jpountz.lz4.LZ4Factory lz4Factory
        end local 2 // java.lang.Integer compressionLevel
        end local 1 // java.lang.String type
        end local 0 // org.apache.cassandra.io.compress.LZ4Compressor this
      LocalVariableTable:
        Start  End  Slot              Name  Signature
            0   12     0              this  Lorg/apache/cassandra/io/compress/LZ4Compressor;
            0   12     1              type  Ljava/lang/String;
            0   12     2  compressionLevel  Ljava/lang/Integer;
            4   12     3        lz4Factory  Lnet/jpountz/lz4/LZ4Factory;
    MethodParameters:
                  Name  Flags
      type              
      compressionLevel  

  public int initialCompressedBufferLength(int);
    descriptor: (I)I
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=2, args_size=2
        start local 0 // org.apache.cassandra.io.compress.LZ4Compressor this
        start local 1 // int chunkLength
         0: .line 105
            iconst_4
            aload 0 /* this */
            getfield org.apache.cassandra.io.compress.LZ4Compressor.compressor:Lnet/jpountz/lz4/LZ4Compressor;
            iload 1 /* chunkLength */
            invokevirtual net.jpountz.lz4.LZ4Compressor.maxCompressedLength:(I)I
            iadd
            ireturn
        end local 1 // int chunkLength
        end local 0 // org.apache.cassandra.io.compress.LZ4Compressor this
      LocalVariableTable:
        Start  End  Slot         Name  Signature
            0    1     0         this  Lorg/apache/cassandra/io/compress/LZ4Compressor;
            0    1     1  chunkLength  I
    MethodParameters:
             Name  Flags
      chunkLength  

  public void compress(java.nio.ByteBuffer, java.nio.ByteBuffer);
    descriptor: (Ljava/nio/ByteBuffer;Ljava/nio/ByteBuffer;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=5, args_size=3
        start local 0 // org.apache.cassandra.io.compress.LZ4Compressor this
        start local 1 // java.nio.ByteBuffer input
        start local 2 // java.nio.ByteBuffer output
         0: .line 110
            aload 1 /* input */
            invokevirtual java.nio.ByteBuffer.remaining:()I
            istore 3 /* len */
        start local 3 // int len
         1: .line 111
            aload 2 /* output */
            iload 3 /* len */
            i2b
            invokevirtual java.nio.ByteBuffer.put:(B)Ljava/nio/ByteBuffer;
            pop
         2: .line 112
            aload 2 /* output */
            iload 3 /* len */
            bipush 8
            iushr
            i2b
            invokevirtual java.nio.ByteBuffer.put:(B)Ljava/nio/ByteBuffer;
            pop
         3: .line 113
            aload 2 /* output */
            iload 3 /* len */
            bipush 16
            iushr
            i2b
            invokevirtual java.nio.ByteBuffer.put:(B)Ljava/nio/ByteBuffer;
            pop
         4: .line 114
            aload 2 /* output */
            iload 3 /* len */
            bipush 24
            iushr
            i2b
            invokevirtual java.nio.ByteBuffer.put:(B)Ljava/nio/ByteBuffer;
            pop
         5: .line 118
            aload 0 /* this */
            getfield org.apache.cassandra.io.compress.LZ4Compressor.compressor:Lnet/jpountz/lz4/LZ4Compressor;
            aload 1 /* input */
            aload 2 /* output */
            invokevirtual net.jpountz.lz4.LZ4Compressor.compress:(Ljava/nio/ByteBuffer;Ljava/nio/ByteBuffer;)V
         6: .line 119
            goto 9
         7: .line 120
      StackMap locals: org.apache.cassandra.io.compress.LZ4Compressor java.nio.ByteBuffer java.nio.ByteBuffer int
      StackMap stack: net.jpountz.lz4.LZ4Exception
            astore 4 /* e */
        start local 4 // net.jpountz.lz4.LZ4Exception e
         8: .line 122
            new java.io.IOException
            dup
            aload 4 /* e */
            invokespecial java.io.IOException.<init>:(Ljava/lang/Throwable;)V
            athrow
        end local 4 // net.jpountz.lz4.LZ4Exception e
         9: .line 124
      StackMap locals:
      StackMap stack:
            return
        end local 3 // int len
        end local 2 // java.nio.ByteBuffer output
        end local 1 // java.nio.ByteBuffer input
        end local 0 // org.apache.cassandra.io.compress.LZ4Compressor this
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0   10     0    this  Lorg/apache/cassandra/io/compress/LZ4Compressor;
            0   10     1   input  Ljava/nio/ByteBuffer;
            0   10     2  output  Ljava/nio/ByteBuffer;
            1   10     3     len  I
            8    9     4       e  Lnet/jpountz/lz4/LZ4Exception;
      Exception table:
        from    to  target  type
           5     6       7  Class net.jpountz.lz4.LZ4Exception
    Exceptions:
      throws java.io.IOException
    MethodParameters:
        Name  Flags
      input   
      output  

  public int uncompress(byte[], int, int, byte[], int);
    descriptor: ([BII[BI)I
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=6, locals=9, args_size=6
        start local 0 // org.apache.cassandra.io.compress.LZ4Compressor this
        start local 1 // byte[] input
        start local 2 // int inputOffset
        start local 3 // int inputLength
        start local 4 // byte[] output
        start local 5 // int outputOffset
         0: .line 129
            aload 1 /* input */
            iload 2 /* inputOffset */
            baload
            sipush 255
            iand
         1: .line 130
            aload 1 /* input */
            iload 2 /* inputOffset */
            iconst_1
            iadd
            baload
            sipush 255
            iand
            bipush 8
            ishl
         2: .line 129
            ior
         3: .line 131
            aload 1 /* input */
            iload 2 /* inputOffset */
            iconst_2
            iadd
            baload
            sipush 255
            iand
            bipush 16
            ishl
         4: .line 129
            ior
         5: .line 132
            aload 1 /* input */
            iload 2 /* inputOffset */
            iconst_3
            iadd
            baload
            sipush 255
            iand
            bipush 24
            ishl
         6: .line 129
            ior
         7: .line 128
            istore 6 /* decompressedLength */
        start local 6 // int decompressedLength
         8: .line 137
            aload 0 /* this */
            getfield org.apache.cassandra.io.compress.LZ4Compressor.decompressor:Lnet/jpountz/lz4/LZ4FastDecompressor;
            aload 1 /* input */
            iload 2 /* inputOffset */
            iconst_4
            iadd
         9: .line 138
            aload 4 /* output */
            iload 5 /* outputOffset */
            iload 6 /* decompressedLength */
        10: .line 137
            invokevirtual net.jpountz.lz4.LZ4FastDecompressor.decompress:([BI[BII)I
            istore 7 /* compressedLength */
        start local 7 // int compressedLength
        11: .line 139
            goto 14
        end local 7 // int compressedLength
        12: .line 140
      StackMap locals: org.apache.cassandra.io.compress.LZ4Compressor byte[] int int byte[] int int
      StackMap stack: net.jpountz.lz4.LZ4Exception
            astore 8 /* e */
        start local 8 // net.jpountz.lz4.LZ4Exception e
        13: .line 142
            new java.io.IOException
            dup
            aload 8 /* e */
            invokespecial java.io.IOException.<init>:(Ljava/lang/Throwable;)V
            athrow
        end local 8 // net.jpountz.lz4.LZ4Exception e
        start local 7 // int compressedLength
        14: .line 145
      StackMap locals: int
      StackMap stack:
            iload 7 /* compressedLength */
            iload 3 /* inputLength */
            iconst_4
            isub
            if_icmpeq 16
        15: .line 147
            new java.io.IOException
            dup
            ldc "Compressed lengths mismatch"
            invokespecial java.io.IOException.<init>:(Ljava/lang/String;)V
            athrow
        16: .line 150
      StackMap locals:
      StackMap stack:
            iload 6 /* decompressedLength */
            ireturn
        end local 7 // int compressedLength
        end local 6 // int decompressedLength
        end local 5 // int outputOffset
        end local 4 // byte[] output
        end local 3 // int inputLength
        end local 2 // int inputOffset
        end local 1 // byte[] input
        end local 0 // org.apache.cassandra.io.compress.LZ4Compressor this
      LocalVariableTable:
        Start  End  Slot                Name  Signature
            0   17     0                this  Lorg/apache/cassandra/io/compress/LZ4Compressor;
            0   17     1               input  [B
            0   17     2         inputOffset  I
            0   17     3         inputLength  I
            0   17     4              output  [B
            0   17     5        outputOffset  I
            8   17     6  decompressedLength  I
           11   12     7    compressedLength  I
           14   17     7    compressedLength  I
           13   14     8                   e  Lnet/jpountz/lz4/LZ4Exception;
      Exception table:
        from    to  target  type
           8    11      12  Class net.jpountz.lz4.LZ4Exception
    Exceptions:
      throws java.io.IOException
    MethodParameters:
              Name  Flags
      input         
      inputOffset   
      inputLength   
      output        
      outputOffset  

  public void uncompress(java.nio.ByteBuffer, java.nio.ByteBuffer);
    descriptor: (Ljava/nio/ByteBuffer;Ljava/nio/ByteBuffer;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=6, locals=5, args_size=3
        start local 0 // org.apache.cassandra.io.compress.LZ4Compressor this
        start local 1 // java.nio.ByteBuffer input
        start local 2 // java.nio.ByteBuffer output
         0: .line 155
            aload 1 /* input */
            invokevirtual java.nio.ByteBuffer.get:()B
            sipush 255
            iand
         1: .line 156
            aload 1 /* input */
            invokevirtual java.nio.ByteBuffer.get:()B
            sipush 255
            iand
            bipush 8
            ishl
         2: .line 155
            ior
         3: .line 157
            aload 1 /* input */
            invokevirtual java.nio.ByteBuffer.get:()B
            sipush 255
            iand
            bipush 16
            ishl
         4: .line 155
            ior
         5: .line 158
            aload 1 /* input */
            invokevirtual java.nio.ByteBuffer.get:()B
            sipush 255
            iand
            bipush 24
            ishl
         6: .line 155
            ior
            istore 3 /* decompressedLength */
        start local 3 // int decompressedLength
         7: .line 162
            aload 0 /* this */
            getfield org.apache.cassandra.io.compress.LZ4Compressor.decompressor:Lnet/jpountz/lz4/LZ4FastDecompressor;
            aload 1 /* input */
            aload 1 /* input */
            invokevirtual java.nio.ByteBuffer.position:()I
            aload 2 /* output */
            aload 2 /* output */
            invokevirtual java.nio.ByteBuffer.position:()I
            iload 3 /* decompressedLength */
            invokevirtual net.jpountz.lz4.LZ4FastDecompressor.decompress:(Ljava/nio/ByteBuffer;ILjava/nio/ByteBuffer;II)I
            istore 4 /* compressedLength */
        start local 4 // int compressedLength
         8: .line 163
            aload 1 /* input */
            aload 1 /* input */
            invokevirtual java.nio.ByteBuffer.position:()I
            iload 4 /* compressedLength */
            iadd
            invokevirtual java.nio.ByteBuffer.position:(I)Ljava/nio/Buffer;
            pop
         9: .line 164
            aload 2 /* output */
            aload 2 /* output */
            invokevirtual java.nio.ByteBuffer.position:()I
            iload 3 /* decompressedLength */
            iadd
            invokevirtual java.nio.ByteBuffer.position:(I)Ljava/nio/Buffer;
            pop
        end local 4 // int compressedLength
        10: .line 165
            goto 13
        11: .line 166
      StackMap locals: org.apache.cassandra.io.compress.LZ4Compressor java.nio.ByteBuffer java.nio.ByteBuffer int
      StackMap stack: net.jpountz.lz4.LZ4Exception
            astore 4 /* e */
        start local 4 // net.jpountz.lz4.LZ4Exception e
        12: .line 168
            new java.io.IOException
            dup
            aload 4 /* e */
            invokespecial java.io.IOException.<init>:(Ljava/lang/Throwable;)V
            athrow
        end local 4 // net.jpountz.lz4.LZ4Exception e
        13: .line 171
      StackMap locals:
      StackMap stack:
            aload 1 /* input */
            invokevirtual java.nio.ByteBuffer.remaining:()I
            ifle 15
        14: .line 173
            new java.io.IOException
            dup
            new java.lang.StringBuilder
            dup
            ldc "Compressed lengths mismatch - "
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
            aload 1 /* input */
            invokevirtual java.nio.ByteBuffer.remaining:()I
            invokevirtual java.lang.StringBuilder.append:(I)Ljava/lang/StringBuilder;
            ldc " bytes remain"
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
            invokespecial java.io.IOException.<init>:(Ljava/lang/String;)V
            athrow
        15: .line 175
      StackMap locals:
      StackMap stack:
            return
        end local 3 // int decompressedLength
        end local 2 // java.nio.ByteBuffer output
        end local 1 // java.nio.ByteBuffer input
        end local 0 // org.apache.cassandra.io.compress.LZ4Compressor this
      LocalVariableTable:
        Start  End  Slot                Name  Signature
            0   16     0                this  Lorg/apache/cassandra/io/compress/LZ4Compressor;
            0   16     1               input  Ljava/nio/ByteBuffer;
            0   16     2              output  Ljava/nio/ByteBuffer;
            7   16     3  decompressedLength  I
            8   10     4    compressedLength  I
           12   13     4                   e  Lnet/jpountz/lz4/LZ4Exception;
      Exception table:
        from    to  target  type
           7    10      11  Class net.jpountz.lz4.LZ4Exception
    Exceptions:
      throws java.io.IOException
    MethodParameters:
        Name  Flags
      input   
      output  

  public java.util.Set<java.lang.String> supportedOptions();
    descriptor: ()Ljava/util/Set;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=6, locals=1, args_size=1
        start local 0 // org.apache.cassandra.io.compress.LZ4Compressor this
         0: .line 179
            new java.util.HashSet
            dup
            iconst_2
            anewarray java.lang.String
            dup
            iconst_0
            ldc "lz4_high_compressor_level"
            aastore
            dup
            iconst_1
            ldc "lz4_compressor_type"
            aastore
            invokestatic java.util.Arrays.asList:([Ljava/lang/Object;)Ljava/util/List;
            invokespecial java.util.HashSet.<init>:(Ljava/util/Collection;)V
            areturn
        end local 0 // org.apache.cassandra.io.compress.LZ4Compressor this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lorg/apache/cassandra/io/compress/LZ4Compressor;
    Signature: ()Ljava/util/Set<Ljava/lang/String;>;

  public static java.lang.String validateCompressorType(java.lang.String);
    descriptor: (Ljava/lang/String;)Ljava/lang/String;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=7, locals=1, args_size=1
        start local 0 // java.lang.String compressorType
         0: .line 184
            aload 0 /* compressorType */
            ifnonnull 2
         1: .line 185
            ldc "fast"
            areturn
         2: .line 187
      StackMap locals:
      StackMap stack:
            getstatic org.apache.cassandra.io.compress.LZ4Compressor.VALID_COMPRESSOR_TYPES:Ljava/util/Set;
            aload 0 /* compressorType */
            invokeinterface java.util.Set.contains:(Ljava/lang/Object;)Z
            ifne 7
         3: .line 189
            new org.apache.cassandra.exceptions.ConfigurationException
            dup
            ldc "Invalid compressor type '%s' specified for LZ4 parameter '%s'. Valid options are %s."
            iconst_3
            anewarray java.lang.Object
            dup
            iconst_0
         4: .line 190
            aload 0 /* compressorType */
            aastore
            dup
            iconst_1
            ldc "lz4_compressor_type"
            aastore
            dup
            iconst_2
         5: .line 191
            getstatic org.apache.cassandra.io.compress.LZ4Compressor.VALID_COMPRESSOR_TYPES:Ljava/util/Set;
            invokevirtual java.lang.Object.toString:()Ljava/lang/String;
            aastore
         6: .line 189
            invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
            invokespecial org.apache.cassandra.exceptions.ConfigurationException.<init>:(Ljava/lang/String;)V
            athrow
         7: .line 195
      StackMap locals:
      StackMap stack:
            aload 0 /* compressorType */
            areturn
        end local 0 // java.lang.String compressorType
      LocalVariableTable:
        Start  End  Slot            Name  Signature
            0    8     0  compressorType  Ljava/lang/String;
    Exceptions:
      throws org.apache.cassandra.exceptions.ConfigurationException
    MethodParameters:
                Name  Flags
      compressorType  

  public static java.lang.Integer validateCompressionLevel(java.lang.String);
    descriptor: (Ljava/lang/String;)Ljava/lang/Integer;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=5, locals=3, args_size=1
        start local 0 // java.lang.String compressionLevel
         0: .line 201
            aload 0 /* compressionLevel */
            ifnonnull 2
         1: .line 202
            bipush 9
            invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
            areturn
         2: .line 204
      StackMap locals:
      StackMap stack:
            new org.apache.cassandra.exceptions.ConfigurationException
            dup
            new java.lang.StringBuilder
            dup
            ldc "Invalid value ["
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
            aload 0 /* compressionLevel */
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            ldc "] for parameter '"
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
         3: .line 205
            ldc "lz4_high_compressor_level"
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            ldc "'. Value must be between 1 and 17."
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
         4: .line 204
            invokespecial org.apache.cassandra.exceptions.ConfigurationException.<init>:(Ljava/lang/String;)V
            astore 1 /* ex */
        start local 1 // org.apache.cassandra.exceptions.ConfigurationException ex
         5: .line 210
            aload 0 /* compressionLevel */
            invokestatic java.lang.Integer.valueOf:(Ljava/lang/String;)Ljava/lang/Integer;
            astore 2 /* level */
        start local 2 // java.lang.Integer level
         6: .line 211
            goto 9
        end local 2 // java.lang.Integer level
         7: .line 212
      StackMap locals: java.lang.String org.apache.cassandra.exceptions.ConfigurationException
      StackMap stack: java.lang.NumberFormatException
            pop
         8: .line 214
            aload 1 /* ex */
            athrow
        start local 2 // java.lang.Integer level
         9: .line 217
      StackMap locals: java.lang.Integer
      StackMap stack:
            aload 2 /* level */
            invokevirtual java.lang.Integer.intValue:()I
            iconst_1
            if_icmplt 10
            aload 2 /* level */
            invokevirtual java.lang.Integer.intValue:()I
            bipush 17
            if_icmple 11
        10: .line 219
      StackMap locals:
      StackMap stack:
            aload 1 /* ex */
            athrow
        11: .line 222
      StackMap locals:
      StackMap stack:
            aload 2 /* level */
            areturn
        end local 2 // java.lang.Integer level
        end local 1 // org.apache.cassandra.exceptions.ConfigurationException ex
        end local 0 // java.lang.String compressionLevel
      LocalVariableTable:
        Start  End  Slot              Name  Signature
            0   12     0  compressionLevel  Ljava/lang/String;
            5   12     1                ex  Lorg/apache/cassandra/exceptions/ConfigurationException;
            6    7     2             level  Ljava/lang/Integer;
            9   12     2             level  Ljava/lang/Integer;
      Exception table:
        from    to  target  type
           5     6       7  Class java.lang.NumberFormatException
    Exceptions:
      throws org.apache.cassandra.exceptions.ConfigurationException
    MethodParameters:
                  Name  Flags
      compressionLevel  

  public org.apache.cassandra.io.compress.BufferType preferredBufferType();
    descriptor: ()Lorg/apache/cassandra/io/compress/BufferType;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // org.apache.cassandra.io.compress.LZ4Compressor this
         0: .line 227
            getstatic org.apache.cassandra.io.compress.BufferType.OFF_HEAP:Lorg/apache/cassandra/io/compress/BufferType;
            areturn
        end local 0 // org.apache.cassandra.io.compress.LZ4Compressor this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lorg/apache/cassandra/io/compress/LZ4Compressor;

  public boolean supports(org.apache.cassandra.io.compress.BufferType);
    descriptor: (Lorg/apache/cassandra/io/compress/BufferType;)Z
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=1, locals=2, args_size=2
        start local 0 // org.apache.cassandra.io.compress.LZ4Compressor this
        start local 1 // org.apache.cassandra.io.compress.BufferType bufferType
         0: .line 232
            iconst_1
            ireturn
        end local 1 // org.apache.cassandra.io.compress.BufferType bufferType
        end local 0 // org.apache.cassandra.io.compress.LZ4Compressor this
      LocalVariableTable:
        Start  End  Slot        Name  Signature
            0    1     0        this  Lorg/apache/cassandra/io/compress/LZ4Compressor;
            0    1     1  bufferType  Lorg/apache/cassandra/io/compress/BufferType;
    MethodParameters:
            Name  Flags
      bufferType  
}
SourceFile: "LZ4Compressor.java"