org.apache.cassandra/cassandra-all/3.11.5 : org/apache/cassandra/io/util/SimpleChunkReader.class

SimpleChunkReader

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.

The Apache Software License, Version 2.0

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

class org.apache.cassandra.io.util.SimpleChunkReader extends org.apache.cassandra.io.util.AbstractReaderFileProxy implements org.apache.cassandra.io.util.ChunkReader
  minor version: 0
  major version: 59
  flags: flags: (0x0020) ACC_SUPER
  this_class: org.apache.cassandra.io.util.SimpleChunkReader
  super_class: org.apache.cassandra.io.util.AbstractReaderFileProxy
{
  private final int bufferSize;
    descriptor: I
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  private final org.apache.cassandra.io.compress.BufferType bufferType;
    descriptor: Lorg/apache/cassandra/io/compress/BufferType;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  void <init>(org.apache.cassandra.io.util.ChannelProxy, long, org.apache.cassandra.io.compress.BufferType, int);
    descriptor: (Lorg/apache/cassandra/io/util/ChannelProxy;JLorg/apache/cassandra/io/compress/BufferType;I)V
    flags: (0x0000) 
    Code:
      stack=4, locals=6, args_size=5
        start local 0 // org.apache.cassandra.io.util.SimpleChunkReader this
        start local 1 // org.apache.cassandra.io.util.ChannelProxy channel
        start local 2 // long fileLength
        start local 4 // org.apache.cassandra.io.compress.BufferType bufferType
        start local 5 // int bufferSize
         0: .line 32
            aload 0 /* this */
            aload 1 /* channel */
            lload 2 /* fileLength */
            invokespecial org.apache.cassandra.io.util.AbstractReaderFileProxy.<init>:(Lorg/apache/cassandra/io/util/ChannelProxy;J)V
         1: .line 33
            aload 0 /* this */
            iload 5 /* bufferSize */
            putfield org.apache.cassandra.io.util.SimpleChunkReader.bufferSize:I
         2: .line 34
            aload 0 /* this */
            aload 4 /* bufferType */
            putfield org.apache.cassandra.io.util.SimpleChunkReader.bufferType:Lorg/apache/cassandra/io/compress/BufferType;
         3: .line 35
            return
        end local 5 // int bufferSize
        end local 4 // org.apache.cassandra.io.compress.BufferType bufferType
        end local 2 // long fileLength
        end local 1 // org.apache.cassandra.io.util.ChannelProxy channel
        end local 0 // org.apache.cassandra.io.util.SimpleChunkReader this
      LocalVariableTable:
        Start  End  Slot        Name  Signature
            0    4     0        this  Lorg/apache/cassandra/io/util/SimpleChunkReader;
            0    4     1     channel  Lorg/apache/cassandra/io/util/ChannelProxy;
            0    4     2  fileLength  J
            0    4     4  bufferType  Lorg/apache/cassandra/io/compress/BufferType;
            0    4     5  bufferSize  I
    MethodParameters:
            Name  Flags
      channel     
      fileLength  
      bufferType  
      bufferSize  

  public void readChunk(long, java.nio.ByteBuffer);
    descriptor: (JLjava/nio/ByteBuffer;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=4, locals=4, args_size=3
        start local 0 // org.apache.cassandra.io.util.SimpleChunkReader this
        start local 1 // long position
        start local 3 // java.nio.ByteBuffer buffer
         0: .line 40
            aload 3 /* buffer */
            invokevirtual java.nio.ByteBuffer.clear:()Ljava/nio/Buffer;
            pop
         1: .line 41
            aload 0 /* this */
            getfield org.apache.cassandra.io.util.SimpleChunkReader.channel:Lorg/apache/cassandra/io/util/ChannelProxy;
            aload 3 /* buffer */
            lload 1 /* position */
            invokevirtual org.apache.cassandra.io.util.ChannelProxy.read:(Ljava/nio/ByteBuffer;J)I
            pop
         2: .line 42
            aload 3 /* buffer */
            invokevirtual java.nio.ByteBuffer.flip:()Ljava/nio/Buffer;
            pop
         3: .line 43
            return
        end local 3 // java.nio.ByteBuffer buffer
        end local 1 // long position
        end local 0 // org.apache.cassandra.io.util.SimpleChunkReader this
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0    4     0      this  Lorg/apache/cassandra/io/util/SimpleChunkReader;
            0    4     1  position  J
            0    4     3    buffer  Ljava/nio/ByteBuffer;
    MethodParameters:
          Name  Flags
      position  
      buffer    

  public int chunkSize();
    descriptor: ()I
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // org.apache.cassandra.io.util.SimpleChunkReader this
         0: .line 48
            aload 0 /* this */
            getfield org.apache.cassandra.io.util.SimpleChunkReader.bufferSize:I
            ireturn
        end local 0 // org.apache.cassandra.io.util.SimpleChunkReader this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lorg/apache/cassandra/io/util/SimpleChunkReader;

  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.util.SimpleChunkReader this
         0: .line 54
            aload 0 /* this */
            getfield org.apache.cassandra.io.util.SimpleChunkReader.bufferType:Lorg/apache/cassandra/io/compress/BufferType;
            areturn
        end local 0 // org.apache.cassandra.io.util.SimpleChunkReader this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lorg/apache/cassandra/io/util/SimpleChunkReader;

  public org.apache.cassandra.io.util.Rebufferer instantiateRebufferer();
    descriptor: ()Lorg/apache/cassandra/io/util/Rebufferer;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=1, args_size=1
        start local 0 // org.apache.cassandra.io.util.SimpleChunkReader this
         0: .line 60
            new org.apache.cassandra.io.util.BufferManagingRebufferer$Unaligned
            dup
            aload 0 /* this */
            invokespecial org.apache.cassandra.io.util.BufferManagingRebufferer$Unaligned.<init>:(Lorg/apache/cassandra/io/util/ChunkReader;)V
            areturn
        end local 0 // org.apache.cassandra.io.util.SimpleChunkReader this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lorg/apache/cassandra/io/util/SimpleChunkReader;

  public java.lang.String toString();
    descriptor: ()Ljava/lang/String;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=6, locals=1, args_size=1
        start local 0 // org.apache.cassandra.io.util.SimpleChunkReader this
         0: .line 66
            ldc "%s(%s - chunk length %d, data length %d)"
            iconst_4
            anewarray java.lang.Object
            dup
            iconst_0
         1: .line 67
            aload 0 /* this */
            invokevirtual java.lang.Object.getClass:()Ljava/lang/Class;
            invokevirtual java.lang.Class.getSimpleName:()Ljava/lang/String;
            aastore
            dup
            iconst_1
         2: .line 68
            aload 0 /* this */
            getfield org.apache.cassandra.io.util.SimpleChunkReader.channel:Lorg/apache/cassandra/io/util/ChannelProxy;
            invokevirtual org.apache.cassandra.io.util.ChannelProxy.filePath:()Ljava/lang/String;
            aastore
            dup
            iconst_2
         3: .line 69
            aload 0 /* this */
            getfield org.apache.cassandra.io.util.SimpleChunkReader.bufferSize:I
            invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
            aastore
            dup
            iconst_3
         4: .line 70
            aload 0 /* this */
            invokevirtual org.apache.cassandra.io.util.SimpleChunkReader.fileLength:()J
            invokestatic java.lang.Long.valueOf:(J)Ljava/lang/Long;
            aastore
         5: .line 66
            invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
            areturn
        end local 0 // org.apache.cassandra.io.util.SimpleChunkReader this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    6     0  this  Lorg/apache/cassandra/io/util/SimpleChunkReader;
}
SourceFile: "SimpleChunkReader.java"
InnerClasses:
  public Unaligned = org.apache.cassandra.io.util.BufferManagingRebufferer$Unaligned of org.apache.cassandra.io.util.BufferManagingRebufferer

/

org.apache.cassandra/ cassandra-all/ 3.11.5/ org/apache/cassandra/io/util/SimpleChunkReader.class