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 
class org.apache.cassandra.db.ReadResponse$Serializer implements org.apache.cassandra.io.IVersionedSerializer<org.apache.cassandra.db.ReadResponse>
  minor version: 0
  major version: 59
  flags: flags: (0x0020) ACC_SUPER
  this_class: org.apache.cassandra.db.ReadResponse$Serializer
  super_class: java.lang.Object
{
  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 352
            ldc Lorg/apache/cassandra/db/ReadResponse;
            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.ReadResponse$Serializer.$assertionsDisabled:Z
            return
      LocalVariableTable:
        Start  End  Slot  Name  Signature

  private void <init>();
    descriptor: ()V
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // org.apache.cassandra.db.ReadResponse$Serializer this
         0: .line 352
            aload 0 /* this */
            invokespecial java.lang.Object.<init>:()V
            return
        end local 0 // org.apache.cassandra.db.ReadResponse$Serializer this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lorg/apache/cassandra/db/ReadResponse$Serializer;

  public void serialize(org.apache.cassandra.db.ReadResponse, org.apache.cassandra.io.util.DataOutputPlus, int);
    descriptor: (Lorg/apache/cassandra/db/ReadResponse;Lorg/apache/cassandra/io/util/DataOutputPlus;I)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=4, locals=12, args_size=4
        start local 0 // org.apache.cassandra.db.ReadResponse$Serializer this
        start local 1 // org.apache.cassandra.db.ReadResponse response
        start local 2 // org.apache.cassandra.io.util.DataOutputPlus out
        start local 3 // int version
         0: .line 356
            aload 1 /* response */
            instanceof org.apache.cassandra.db.ReadResponse$DigestResponse
            istore 4 /* isDigest */
        start local 4 // boolean isDigest
         1: .line 357
            iload 4 /* isDigest */
            ifeq 2
            aload 1 /* response */
            checkcast org.apache.cassandra.db.ReadResponse$DigestResponse
            getfield org.apache.cassandra.db.ReadResponse$DigestResponse.digest:Ljava/nio/ByteBuffer;
            goto 3
      StackMap locals: int
      StackMap stack:
         2: getstatic org.apache.cassandra.utils.ByteBufferUtil.EMPTY_BYTE_BUFFER:Ljava/nio/ByteBuffer;
      StackMap locals:
      StackMap stack: java.nio.ByteBuffer
         3: astore 5 /* digest */
        start local 5 // java.nio.ByteBuffer digest
         4: .line 358
            iload 3 /* version */
            bipush 10
            if_icmpge 31
         5: .line 360
            aload 2 /* out */
            aload 5 /* digest */
            invokevirtual java.nio.ByteBuffer.remaining:()I
            invokeinterface org.apache.cassandra.io.util.DataOutputPlus.writeInt:(I)V
         6: .line 361
            aload 2 /* out */
            aload 5 /* digest */
            invokeinterface org.apache.cassandra.io.util.DataOutputPlus.write:(Ljava/nio/ByteBuffer;)V
         7: .line 362
            aload 2 /* out */
            iload 4 /* isDigest */
            invokeinterface org.apache.cassandra.io.util.DataOutputPlus.writeBoolean:(Z)V
         8: .line 363
            iload 4 /* isDigest */
            ifne 30
         9: .line 365
            getstatic org.apache.cassandra.db.ReadResponse$Serializer.$assertionsDisabled:Z
            ifne 10
            aload 1 /* response */
            getfield org.apache.cassandra.db.ReadResponse.command:Lorg/apache/cassandra/db/ReadCommand;
            ifnonnull 10
            new java.lang.AssertionError
            dup
            invokespecial java.lang.AssertionError.<init>:()V
            athrow
        10: .line 366
      StackMap locals: java.nio.ByteBuffer
      StackMap stack:
            aconst_null
            astore 6
            aconst_null
            astore 7
        11: aload 1 /* response */
            aload 1 /* response */
            getfield org.apache.cassandra.db.ReadResponse.command:Lorg/apache/cassandra/db/ReadCommand;
            invokevirtual org.apache.cassandra.db.ReadResponse.makeIterator:(Lorg/apache/cassandra/db/ReadCommand;)Lorg/apache/cassandra/db/partitions/UnfilteredPartitionIterator;
            astore 8 /* iter */
        start local 8 // org.apache.cassandra.db.partitions.UnfilteredPartitionIterator iter
        12: .line 368
            getstatic org.apache.cassandra.db.ReadResponse$Serializer.$assertionsDisabled:Z
            ifne 13
            aload 8 /* iter */
            invokeinterface org.apache.cassandra.db.partitions.UnfilteredPartitionIterator.hasNext:()Z
            ifne 13
            new java.lang.AssertionError
            dup
            invokespecial java.lang.AssertionError.<init>:()V
            athrow
        13: .line 369
      StackMap locals: java.lang.Throwable java.lang.Throwable org.apache.cassandra.db.partitions.UnfilteredPartitionIterator
      StackMap stack:
            aconst_null
            astore 9
            aconst_null
            astore 10
        14: aload 8 /* iter */
            invokeinterface org.apache.cassandra.db.partitions.UnfilteredPartitionIterator.next:()Ljava/lang/Object;
            checkcast org.apache.cassandra.db.rows.UnfilteredRowIterator
            astore 11 /* partition */
        start local 11 // org.apache.cassandra.db.rows.UnfilteredRowIterator partition
        15: .line 371
            aload 11 /* partition */
            invokeinterface org.apache.cassandra.db.rows.UnfilteredRowIterator.partitionKey:()Lorg/apache/cassandra/db/DecoratedKey;
            invokevirtual org.apache.cassandra.db.DecoratedKey.getKey:()Ljava/nio/ByteBuffer;
            aload 2 /* out */
            invokestatic org.apache.cassandra.utils.ByteBufferUtil.writeWithShortLength:(Ljava/nio/ByteBuffer;Lorg/apache/cassandra/io/util/DataOutputPlus;)V
        16: .line 372
            aload 1 /* response */
            getfield org.apache.cassandra.db.ReadResponse.command:Lorg/apache/cassandra/db/ReadCommand;
            aload 11 /* partition */
            aload 2 /* out */
            iload 3 /* version */
            invokestatic org.apache.cassandra.db.LegacyLayout.serializeAsLegacyPartition:(Lorg/apache/cassandra/db/ReadCommand;Lorg/apache/cassandra/db/rows/UnfilteredRowIterator;Lorg/apache/cassandra/io/util/DataOutputPlus;I)V
        17: .line 373
            aload 11 /* partition */
            ifnull 23
            aload 11 /* partition */
            invokeinterface org.apache.cassandra.db.rows.UnfilteredRowIterator.close:()V
            goto 23
      StackMap locals: org.apache.cassandra.db.ReadResponse$Serializer org.apache.cassandra.db.ReadResponse org.apache.cassandra.io.util.DataOutputPlus int int java.nio.ByteBuffer java.lang.Throwable java.lang.Throwable org.apache.cassandra.db.partitions.UnfilteredPartitionIterator java.lang.Throwable java.lang.Throwable org.apache.cassandra.db.rows.UnfilteredRowIterator
      StackMap stack: java.lang.Throwable
        18: astore 9
            aload 11 /* partition */
            ifnull 19
            aload 11 /* partition */
            invokeinterface org.apache.cassandra.db.rows.UnfilteredRowIterator.close:()V
        end local 11 // org.apache.cassandra.db.rows.UnfilteredRowIterator partition
      StackMap locals:
      StackMap stack:
        19: aload 9
            athrow
      StackMap locals:
      StackMap stack: java.lang.Throwable
        20: astore 10
            aload 9
            ifnonnull 21
            aload 10
            astore 9
            goto 22
      StackMap locals:
      StackMap stack:
        21: aload 9
            aload 10
            if_acmpeq 22
            aload 9
            aload 10
            invokevirtual java.lang.Throwable.addSuppressed:(Ljava/lang/Throwable;)V
      StackMap locals:
      StackMap stack:
        22: aload 9
            athrow
        23: .line 374
      StackMap locals:
      StackMap stack:
            getstatic org.apache.cassandra.db.ReadResponse$Serializer.$assertionsDisabled:Z
            ifne 24
            aload 8 /* iter */
            invokeinterface org.apache.cassandra.db.partitions.UnfilteredPartitionIterator.hasNext:()Z
            ifeq 24
            new java.lang.AssertionError
            dup
            invokespecial java.lang.AssertionError.<init>:()V
            athrow
        24: .line 375
      StackMap locals:
      StackMap stack:
            aload 8 /* iter */
            ifnull 30
            aload 8 /* iter */
            invokeinterface org.apache.cassandra.db.partitions.UnfilteredPartitionIterator.close:()V
            goto 30
      StackMap locals:
      StackMap stack: java.lang.Throwable
        25: astore 6
            aload 8 /* iter */
            ifnull 26
            aload 8 /* iter */
            invokeinterface org.apache.cassandra.db.partitions.UnfilteredPartitionIterator.close:()V
        end local 8 // org.apache.cassandra.db.partitions.UnfilteredPartitionIterator iter
      StackMap locals:
      StackMap stack:
        26: aload 6
            athrow
      StackMap locals:
      StackMap stack: java.lang.Throwable
        27: astore 7
            aload 6
            ifnonnull 28
            aload 7
            astore 6
            goto 29
      StackMap locals:
      StackMap stack:
        28: aload 6
            aload 7
            if_acmpeq 29
            aload 6
            aload 7
            invokevirtual java.lang.Throwable.addSuppressed:(Ljava/lang/Throwable;)V
      StackMap locals:
      StackMap stack:
        29: aload 6
            athrow
        30: .line 377
      StackMap locals:
      StackMap stack:
            return
        31: .line 380
      StackMap locals:
      StackMap stack:
            aload 5 /* digest */
            aload 2 /* out */
            invokestatic org.apache.cassandra.utils.ByteBufferUtil.writeWithVIntLength:(Ljava/nio/ByteBuffer;Lorg/apache/cassandra/io/util/DataOutputPlus;)V
        32: .line 381
            iload 4 /* isDigest */
            ifne 35
        33: .line 383
            aload 1 /* response */
            checkcast org.apache.cassandra.db.ReadResponse$DataResponse
            getfield org.apache.cassandra.db.ReadResponse$DataResponse.data:Ljava/nio/ByteBuffer;
            astore 6 /* data */
        start local 6 // java.nio.ByteBuffer data
        34: .line 384
            aload 6 /* data */
            aload 2 /* out */
            invokestatic org.apache.cassandra.utils.ByteBufferUtil.writeWithVIntLength:(Ljava/nio/ByteBuffer;Lorg/apache/cassandra/io/util/DataOutputPlus;)V
        end local 6 // java.nio.ByteBuffer data
        35: .line 386
      StackMap locals:
      StackMap stack:
            return
        end local 5 // java.nio.ByteBuffer digest
        end local 4 // boolean isDigest
        end local 3 // int version
        end local 2 // org.apache.cassandra.io.util.DataOutputPlus out
        end local 1 // org.apache.cassandra.db.ReadResponse response
        end local 0 // org.apache.cassandra.db.ReadResponse$Serializer this
      LocalVariableTable:
        Start  End  Slot       Name  Signature
            0   36     0       this  Lorg/apache/cassandra/db/ReadResponse$Serializer;
            0   36     1   response  Lorg/apache/cassandra/db/ReadResponse;
            0   36     2        out  Lorg/apache/cassandra/io/util/DataOutputPlus;
            0   36     3    version  I
            1   36     4   isDigest  Z
            4   36     5     digest  Ljava/nio/ByteBuffer;
           12   26     8       iter  Lorg/apache/cassandra/db/partitions/UnfilteredPartitionIterator;
           15   19    11  partition  Lorg/apache/cassandra/db/rows/UnfilteredRowIterator;
           34   35     6       data  Ljava/nio/ByteBuffer;
      Exception table:
        from    to  target  type
          15    17      18  any
          14    20      20  any
          12    24      25  any
          11    27      27  any
    Exceptions:
      throws java.io.IOException
    MethodParameters:
          Name  Flags
      response  
      out       
      version   

  public org.apache.cassandra.db.ReadResponse deserialize(org.apache.cassandra.io.util.DataInputPlus, int);
    descriptor: (Lorg/apache/cassandra/io/util/DataInputPlus;I)Lorg/apache/cassandra/db/ReadResponse;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=4, locals=10, args_size=3
        start local 0 // org.apache.cassandra.db.ReadResponse$Serializer this
        start local 1 // org.apache.cassandra.io.util.DataInputPlus in
        start local 2 // int version
         0: .line 390
            iload 2 /* version */
            bipush 10
            if_icmpge 29
         1: .line 392
            aconst_null
            astore 3 /* digest */
        start local 3 // byte[] digest
         2: .line 393
            aload 1 /* in */
            invokeinterface org.apache.cassandra.io.util.DataInputPlus.readInt:()I
            istore 4 /* digestSize */
        start local 4 // int digestSize
         3: .line 394
            iload 4 /* digestSize */
            ifle 6
         4: .line 396
            iload 4 /* digestSize */
            newarray 8
            astore 3 /* digest */
         5: .line 397
            aload 1 /* in */
            aload 3 /* digest */
            iconst_0
            iload 4 /* digestSize */
            invokeinterface org.apache.cassandra.io.util.DataInputPlus.readFully:([BII)V
         6: .line 399
      StackMap locals: byte[] int
      StackMap stack:
            aload 1 /* in */
            invokeinterface org.apache.cassandra.io.util.DataInputPlus.readBoolean:()Z
            istore 5 /* isDigest */
        start local 5 // boolean isDigest
         7: .line 400
            getstatic org.apache.cassandra.db.ReadResponse$Serializer.$assertionsDisabled:Z
            ifne 10
            iload 5 /* isDigest */
            iload 4 /* digestSize */
            ifle 8
            iconst_1
            goto 9
      StackMap locals: org.apache.cassandra.db.ReadResponse$Serializer org.apache.cassandra.io.util.DataInputPlus int byte[] int int
      StackMap stack: int
         8: iconst_0
      StackMap locals: org.apache.cassandra.db.ReadResponse$Serializer org.apache.cassandra.io.util.DataInputPlus int byte[] int int
      StackMap stack: int int
         9: if_icmpeq 10
            new java.lang.AssertionError
            dup
            invokespecial java.lang.AssertionError.<init>:()V
            athrow
        10: .line 401
      StackMap locals:
      StackMap stack:
            iload 5 /* isDigest */
            ifeq 13
        11: .line 403
            getstatic org.apache.cassandra.db.ReadResponse$Serializer.$assertionsDisabled:Z
            ifne 12
            aload 3 /* digest */
            ifnonnull 12
            new java.lang.AssertionError
            dup
            invokespecial java.lang.AssertionError.<init>:()V
            athrow
        12: .line 404
      StackMap locals:
      StackMap stack:
            new org.apache.cassandra.db.ReadResponse$DigestResponse
            dup
            aload 3 /* digest */
            invokestatic java.nio.ByteBuffer.wrap:([B)Ljava/nio/ByteBuffer;
            invokespecial org.apache.cassandra.db.ReadResponse$DigestResponse.<init>:(Ljava/nio/ByteBuffer;)V
            areturn
        13: .line 408
      StackMap locals:
      StackMap stack:
            aload 1 /* in */
            invokestatic org.apache.cassandra.utils.ByteBufferUtil.readWithShortLength:(Ljava/io/DataInput;)Ljava/nio/ByteBuffer;
            astore 6 /* key */
        start local 6 // java.nio.ByteBuffer key
        14: .line 409
            aconst_null
            astore 7
            aconst_null
            astore 8
        15: aload 1 /* in */
            iload 2 /* version */
            getstatic org.apache.cassandra.db.rows.SerializationHelper$Flag.FROM_REMOTE:Lorg/apache/cassandra/db/rows/SerializationHelper$Flag;
            aload 6 /* key */
            invokestatic org.apache.cassandra.db.LegacyLayout.deserializeLegacyPartition:(Lorg/apache/cassandra/io/util/DataInputPlus;ILorg/apache/cassandra/db/rows/SerializationHelper$Flag;Ljava/nio/ByteBuffer;)Lorg/apache/cassandra/db/rows/UnfilteredRowIterator;
            astore 9 /* rowIterator */
        start local 9 // org.apache.cassandra.db.rows.UnfilteredRowIterator rowIterator
        16: .line 411
            aload 9 /* rowIterator */
            ifnonnull 20
        17: .line 412
            new org.apache.cassandra.db.ReadResponse$LegacyRemoteDataResponse
            dup
            invokestatic java.util.Collections.emptyList:()Ljava/util/List;
            invokespecial org.apache.cassandra.db.ReadResponse$LegacyRemoteDataResponse.<init>:(Ljava/util/List;)V
        18: .line 415
            aload 9 /* rowIterator */
            ifnull 19
            aload 9 /* rowIterator */
            invokeinterface org.apache.cassandra.db.rows.UnfilteredRowIterator.close:()V
        19: .line 412
      StackMap locals: org.apache.cassandra.db.ReadResponse$Serializer org.apache.cassandra.io.util.DataInputPlus int byte[] int int java.nio.ByteBuffer java.lang.Throwable java.lang.Throwable org.apache.cassandra.db.rows.UnfilteredRowIterator
      StackMap stack: org.apache.cassandra.db.ReadResponse$LegacyRemoteDataResponse
            areturn
        20: .line 414
      StackMap locals:
      StackMap stack:
            new org.apache.cassandra.db.ReadResponse$LegacyRemoteDataResponse
            dup
            aload 9 /* rowIterator */
            invokestatic org.apache.cassandra.db.partitions.ImmutableBTreePartition.create:(Lorg/apache/cassandra/db/rows/UnfilteredRowIterator;)Lorg/apache/cassandra/db/partitions/ImmutableBTreePartition;
            invokestatic java.util.Collections.singletonList:(Ljava/lang/Object;)Ljava/util/List;
            invokespecial org.apache.cassandra.db.ReadResponse$LegacyRemoteDataResponse.<init>:(Ljava/util/List;)V
        21: .line 415
            aload 9 /* rowIterator */
            ifnull 22
            aload 9 /* rowIterator */
            invokeinterface org.apache.cassandra.db.rows.UnfilteredRowIterator.close:()V
        22: .line 414
      StackMap locals:
      StackMap stack: org.apache.cassandra.db.ReadResponse$LegacyRemoteDataResponse
            areturn
      StackMap locals:
      StackMap stack: java.lang.Throwable
        23: astore 7
        24: .line 415
            aload 9 /* rowIterator */
            ifnull 25
            aload 9 /* rowIterator */
            invokeinterface org.apache.cassandra.db.rows.UnfilteredRowIterator.close:()V
        end local 9 // org.apache.cassandra.db.rows.UnfilteredRowIterator rowIterator
      StackMap locals:
      StackMap stack:
        25: aload 7
            athrow
      StackMap locals:
      StackMap stack: java.lang.Throwable
        26: astore 8
            aload 7
            ifnonnull 27
            aload 8
            astore 7
            goto 28
      StackMap locals:
      StackMap stack:
        27: aload 7
            aload 8
            if_acmpeq 28
            aload 7
            aload 8
            invokevirtual java.lang.Throwable.addSuppressed:(Ljava/lang/Throwable;)V
      StackMap locals:
      StackMap stack:
        28: aload 7
            athrow
        end local 6 // java.nio.ByteBuffer key
        end local 5 // boolean isDigest
        end local 4 // int digestSize
        end local 3 // byte[] digest
        29: .line 418
      StackMap locals: org.apache.cassandra.db.ReadResponse$Serializer org.apache.cassandra.io.util.DataInputPlus int
      StackMap stack:
            aload 1 /* in */
            invokestatic org.apache.cassandra.utils.ByteBufferUtil.readWithVIntLength:(Lorg/apache/cassandra/io/util/DataInputPlus;)Ljava/nio/ByteBuffer;
            astore 3 /* digest */
        start local 3 // java.nio.ByteBuffer digest
        30: .line 419
            aload 3 /* digest */
            invokevirtual java.nio.ByteBuffer.hasRemaining:()Z
            ifeq 32
        31: .line 420
            new org.apache.cassandra.db.ReadResponse$DigestResponse
            dup
            aload 3 /* digest */
            invokespecial org.apache.cassandra.db.ReadResponse$DigestResponse.<init>:(Ljava/nio/ByteBuffer;)V
            areturn
        32: .line 422
      StackMap locals: java.nio.ByteBuffer
      StackMap stack:
            getstatic org.apache.cassandra.db.ReadResponse$Serializer.$assertionsDisabled:Z
            ifne 33
            iload 2 /* version */
            bipush 10
            if_icmpge 33
            new java.lang.AssertionError
            dup
            invokespecial java.lang.AssertionError.<init>:()V
            athrow
        33: .line 423
      StackMap locals:
      StackMap stack:
            aload 1 /* in */
            invokestatic org.apache.cassandra.utils.ByteBufferUtil.readWithVIntLength:(Lorg/apache/cassandra/io/util/DataInputPlus;)Ljava/nio/ByteBuffer;
            astore 4 /* data */
        start local 4 // java.nio.ByteBuffer data
        34: .line 424
            new org.apache.cassandra.db.ReadResponse$RemoteDataResponse
            dup
            aload 4 /* data */
            invokespecial org.apache.cassandra.db.ReadResponse$RemoteDataResponse.<init>:(Ljava/nio/ByteBuffer;)V
            areturn
        end local 4 // java.nio.ByteBuffer data
        end local 3 // java.nio.ByteBuffer digest
        end local 2 // int version
        end local 1 // org.apache.cassandra.io.util.DataInputPlus in
        end local 0 // org.apache.cassandra.db.ReadResponse$Serializer this
      LocalVariableTable:
        Start  End  Slot         Name  Signature
            0   35     0         this  Lorg/apache/cassandra/db/ReadResponse$Serializer;
            0   35     1           in  Lorg/apache/cassandra/io/util/DataInputPlus;
            0   35     2      version  I
            2   29     3       digest  [B
            3   29     4   digestSize  I
            7   29     5     isDigest  Z
           14   29     6          key  Ljava/nio/ByteBuffer;
           16   25     9  rowIterator  Lorg/apache/cassandra/db/rows/UnfilteredRowIterator;
           30   35     3       digest  Ljava/nio/ByteBuffer;
           34   35     4         data  Ljava/nio/ByteBuffer;
      Exception table:
        from    to  target  type
          16    18      23  any
          20    21      23  any
          15    19      26  any
          20    22      26  any
          23    26      26  any
    Exceptions:
      throws java.io.IOException
    MethodParameters:
         Name  Flags
      in       
      version  

  public long serializedSize(org.apache.cassandra.db.ReadResponse, int);
    descriptor: (Lorg/apache/cassandra/db/ReadResponse;I)J
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=5, locals=13, args_size=3
        start local 0 // org.apache.cassandra.db.ReadResponse$Serializer this
        start local 1 // org.apache.cassandra.db.ReadResponse response
        start local 2 // int version
         0: .line 429
            aload 1 /* response */
            instanceof org.apache.cassandra.db.ReadResponse$DigestResponse
            istore 3 /* isDigest */
        start local 3 // boolean isDigest
         1: .line 430
            iload 3 /* isDigest */
            ifeq 2
            aload 1 /* response */
            checkcast org.apache.cassandra.db.ReadResponse$DigestResponse
            getfield org.apache.cassandra.db.ReadResponse$DigestResponse.digest:Ljava/nio/ByteBuffer;
            goto 3
      StackMap locals: int
      StackMap stack:
         2: getstatic org.apache.cassandra.utils.ByteBufferUtil.EMPTY_BYTE_BUFFER:Ljava/nio/ByteBuffer;
      StackMap locals:
      StackMap stack: java.nio.ByteBuffer
         3: astore 4 /* digest */
        start local 4 // java.nio.ByteBuffer digest
         4: .line 432
            iload 2 /* version */
            bipush 10
            if_icmpge 33
         5: .line 434
            aload 4 /* digest */
            invokevirtual java.nio.ByteBuffer.remaining:()I
            invokestatic org.apache.cassandra.db.TypeSizes.sizeof:(I)I
         6: .line 435
            aload 4 /* digest */
            invokevirtual java.nio.ByteBuffer.remaining:()I
         7: .line 434
            iadd
         8: .line 436
            iload 3 /* isDigest */
            invokestatic org.apache.cassandra.db.TypeSizes.sizeof:(Z)I
         9: .line 434
            iadd
            i2l
            lstore 5 /* size */
        start local 5 // long size
        10: .line 437
            iload 3 /* isDigest */
            ifne 32
        11: .line 439
            getstatic org.apache.cassandra.db.ReadResponse$Serializer.$assertionsDisabled:Z
            ifne 12
            aload 1 /* response */
            getfield org.apache.cassandra.db.ReadResponse.command:Lorg/apache/cassandra/db/ReadCommand;
            ifnonnull 12
            new java.lang.AssertionError
            dup
            invokespecial java.lang.AssertionError.<init>:()V
            athrow
        12: .line 440
      StackMap locals: java.nio.ByteBuffer long
      StackMap stack:
            aconst_null
            astore 7
            aconst_null
            astore 8
        13: aload 1 /* response */
            aload 1 /* response */
            getfield org.apache.cassandra.db.ReadResponse.command:Lorg/apache/cassandra/db/ReadCommand;
            invokevirtual org.apache.cassandra.db.ReadResponse.makeIterator:(Lorg/apache/cassandra/db/ReadCommand;)Lorg/apache/cassandra/db/partitions/UnfilteredPartitionIterator;
            astore 9 /* iter */
        start local 9 // org.apache.cassandra.db.partitions.UnfilteredPartitionIterator iter
        14: .line 442
            getstatic org.apache.cassandra.db.ReadResponse$Serializer.$assertionsDisabled:Z
            ifne 15
            aload 9 /* iter */
            invokeinterface org.apache.cassandra.db.partitions.UnfilteredPartitionIterator.hasNext:()Z
            ifne 15
            new java.lang.AssertionError
            dup
            invokespecial java.lang.AssertionError.<init>:()V
            athrow
        15: .line 443
      StackMap locals: java.lang.Throwable java.lang.Throwable org.apache.cassandra.db.partitions.UnfilteredPartitionIterator
      StackMap stack:
            aconst_null
            astore 10
            aconst_null
            astore 11
        16: aload 9 /* iter */
            invokeinterface org.apache.cassandra.db.partitions.UnfilteredPartitionIterator.next:()Ljava/lang/Object;
            checkcast org.apache.cassandra.db.rows.UnfilteredRowIterator
            astore 12 /* partition */
        start local 12 // org.apache.cassandra.db.rows.UnfilteredRowIterator partition
        17: .line 445
            lload 5 /* size */
            aload 12 /* partition */
            invokeinterface org.apache.cassandra.db.rows.UnfilteredRowIterator.partitionKey:()Lorg/apache/cassandra/db/DecoratedKey;
            invokevirtual org.apache.cassandra.db.DecoratedKey.getKey:()Ljava/nio/ByteBuffer;
            invokestatic org.apache.cassandra.utils.ByteBufferUtil.serializedSizeWithShortLength:(Ljava/nio/ByteBuffer;)I
            i2l
            ladd
            lstore 5 /* size */
        18: .line 446
            lload 5 /* size */
            aload 1 /* response */
            getfield org.apache.cassandra.db.ReadResponse.command:Lorg/apache/cassandra/db/ReadCommand;
            aload 12 /* partition */
            iload 2 /* version */
            invokestatic org.apache.cassandra.db.LegacyLayout.serializedSizeAsLegacyPartition:(Lorg/apache/cassandra/db/ReadCommand;Lorg/apache/cassandra/db/rows/UnfilteredRowIterator;I)J
            ladd
            lstore 5 /* size */
        19: .line 447
            aload 12 /* partition */
            ifnull 25
            aload 12 /* partition */
            invokeinterface org.apache.cassandra.db.rows.UnfilteredRowIterator.close:()V
            goto 25
      StackMap locals: org.apache.cassandra.db.ReadResponse$Serializer org.apache.cassandra.db.ReadResponse int int java.nio.ByteBuffer long java.lang.Throwable java.lang.Throwable org.apache.cassandra.db.partitions.UnfilteredPartitionIterator java.lang.Throwable java.lang.Throwable org.apache.cassandra.db.rows.UnfilteredRowIterator
      StackMap stack: java.lang.Throwable
        20: astore 10
            aload 12 /* partition */
            ifnull 21
            aload 12 /* partition */
            invokeinterface org.apache.cassandra.db.rows.UnfilteredRowIterator.close:()V
        end local 12 // org.apache.cassandra.db.rows.UnfilteredRowIterator partition
      StackMap locals:
      StackMap stack:
        21: aload 10
            athrow
      StackMap locals:
      StackMap stack: java.lang.Throwable
        22: astore 11
            aload 10
            ifnonnull 23
            aload 11
            astore 10
            goto 24
      StackMap locals:
      StackMap stack:
        23: aload 10
            aload 11
            if_acmpeq 24
            aload 10
            aload 11
            invokevirtual java.lang.Throwable.addSuppressed:(Ljava/lang/Throwable;)V
      StackMap locals:
      StackMap stack:
        24: aload 10
            athrow
        25: .line 448
      StackMap locals:
      StackMap stack:
            getstatic org.apache.cassandra.db.ReadResponse$Serializer.$assertionsDisabled:Z
            ifne 26
            aload 9 /* iter */
            invokeinterface org.apache.cassandra.db.partitions.UnfilteredPartitionIterator.hasNext:()Z
            ifeq 26
            new java.lang.AssertionError
            dup
            invokespecial java.lang.AssertionError.<init>:()V
            athrow
        26: .line 449
      StackMap locals:
      StackMap stack:
            aload 9 /* iter */
            ifnull 32
            aload 9 /* iter */
            invokeinterface org.apache.cassandra.db.partitions.UnfilteredPartitionIterator.close:()V
            goto 32
      StackMap locals:
      StackMap stack: java.lang.Throwable
        27: astore 7
            aload 9 /* iter */
            ifnull 28
            aload 9 /* iter */
            invokeinterface org.apache.cassandra.db.partitions.UnfilteredPartitionIterator.close:()V
        end local 9 // org.apache.cassandra.db.partitions.UnfilteredPartitionIterator iter
      StackMap locals:
      StackMap stack:
        28: aload 7
            athrow
      StackMap locals:
      StackMap stack: java.lang.Throwable
        29: astore 8
            aload 7
            ifnonnull 30
            aload 8
            astore 7
            goto 31
      StackMap locals:
      StackMap stack:
        30: aload 7
            aload 8
            if_acmpeq 31
            aload 7
            aload 8
            invokevirtual java.lang.Throwable.addSuppressed:(Ljava/lang/Throwable;)V
      StackMap locals:
      StackMap stack:
        31: aload 7
            athrow
        32: .line 451
      StackMap locals:
      StackMap stack:
            lload 5 /* size */
            lreturn
        end local 5 // long size
        33: .line 454
      StackMap locals:
      StackMap stack:
            aload 4 /* digest */
            invokestatic org.apache.cassandra.utils.ByteBufferUtil.serializedSizeWithVIntLength:(Ljava/nio/ByteBuffer;)I
            i2l
            lstore 5 /* size */
        start local 5 // long size
        34: .line 455
            iload 3 /* isDigest */
            ifne 38
        35: .line 460
            getstatic org.apache.cassandra.db.ReadResponse$Serializer.$assertionsDisabled:Z
            ifne 36
            iload 2 /* version */
            bipush 10
            if_icmpge 36
            new java.lang.AssertionError
            dup
            invokespecial java.lang.AssertionError.<init>:()V
            athrow
        36: .line 461
      StackMap locals: long
      StackMap stack:
            aload 1 /* response */
            checkcast org.apache.cassandra.db.ReadResponse$DataResponse
            getfield org.apache.cassandra.db.ReadResponse$DataResponse.data:Ljava/nio/ByteBuffer;
            astore 7 /* data */
        start local 7 // java.nio.ByteBuffer data
        37: .line 462
            lload 5 /* size */
            aload 7 /* data */
            invokestatic org.apache.cassandra.utils.ByteBufferUtil.serializedSizeWithVIntLength:(Ljava/nio/ByteBuffer;)I
            i2l
            ladd
            lstore 5 /* size */
        end local 7 // java.nio.ByteBuffer data
        38: .line 464
      StackMap locals:
      StackMap stack:
            lload 5 /* size */
            lreturn
        end local 5 // long size
        end local 4 // java.nio.ByteBuffer digest
        end local 3 // boolean isDigest
        end local 2 // int version
        end local 1 // org.apache.cassandra.db.ReadResponse response
        end local 0 // org.apache.cassandra.db.ReadResponse$Serializer this
      LocalVariableTable:
        Start  End  Slot       Name  Signature
            0   39     0       this  Lorg/apache/cassandra/db/ReadResponse$Serializer;
            0   39     1   response  Lorg/apache/cassandra/db/ReadResponse;
            0   39     2    version  I
            1   39     3   isDigest  Z
            4   39     4     digest  Ljava/nio/ByteBuffer;
           10   33     5       size  J
           14   28     9       iter  Lorg/apache/cassandra/db/partitions/UnfilteredPartitionIterator;
           17   21    12  partition  Lorg/apache/cassandra/db/rows/UnfilteredRowIterator;
           34   39     5       size  J
           37   38     7       data  Ljava/nio/ByteBuffer;
      Exception table:
        from    to  target  type
          17    19      20  any
          16    22      22  any
          14    26      27  any
          13    29      29  any
    MethodParameters:
          Name  Flags
      response  
      version   

  public void serialize(java.lang.Object, org.apache.cassandra.io.util.DataOutputPlus, int);
    descriptor: (Ljava/lang/Object;Lorg/apache/cassandra/io/util/DataOutputPlus;I)V
    flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
    Code:
      stack=4, locals=4, args_size=4
         0: .line 1
            aload 0
            aload 1
            checkcast org.apache.cassandra.db.ReadResponse
            aload 2
            iload 3
            invokevirtual org.apache.cassandra.db.ReadResponse$Serializer.serialize:(Lorg/apache/cassandra/db/ReadResponse;Lorg/apache/cassandra/io/util/DataOutputPlus;I)V
            return
      LocalVariableTable:
        Start  End  Slot  Name  Signature
    Exceptions:
      throws java.io.IOException

  public long serializedSize(java.lang.Object, int);
    descriptor: (Ljava/lang/Object;I)J
    flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
    Code:
      stack=3, locals=3, args_size=3
         0: .line 1
            aload 0
            aload 1
            checkcast org.apache.cassandra.db.ReadResponse
            iload 2
            invokevirtual org.apache.cassandra.db.ReadResponse$Serializer.serializedSize:(Lorg/apache/cassandra/db/ReadResponse;I)J
            lreturn
      LocalVariableTable:
        Start  End  Slot  Name  Signature

  public java.lang.Object deserialize(org.apache.cassandra.io.util.DataInputPlus, int);
    descriptor: (Lorg/apache/cassandra/io/util/DataInputPlus;I)Ljava/lang/Object;
    flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
    Code:
      stack=3, locals=3, args_size=3
         0: .line 1
            aload 0
            aload 1
            iload 2
            invokevirtual org.apache.cassandra.db.ReadResponse$Serializer.deserialize:(Lorg/apache/cassandra/io/util/DataInputPlus;I)Lorg/apache/cassandra/db/ReadResponse;
            areturn
      LocalVariableTable:
        Start  End  Slot  Name  Signature
    Exceptions:
      throws java.io.IOException
}
Signature: Ljava/lang/Object;Lorg/apache/cassandra/io/IVersionedSerializer<Lorg/apache/cassandra/db/ReadResponse;>;
SourceFile: "ReadResponse.java"
NestHost: org.apache.cassandra.db.ReadResponse
InnerClasses:
  abstract DataResponse = org.apache.cassandra.db.ReadResponse$DataResponse of org.apache.cassandra.db.ReadResponse
  private DigestResponse = org.apache.cassandra.db.ReadResponse$DigestResponse of org.apache.cassandra.db.ReadResponse
  LegacyRemoteDataResponse = org.apache.cassandra.db.ReadResponse$LegacyRemoteDataResponse of org.apache.cassandra.db.ReadResponse
  private RemoteDataResponse = org.apache.cassandra.db.ReadResponse$RemoteDataResponse of org.apache.cassandra.db.ReadResponse
  private Serializer = org.apache.cassandra.db.ReadResponse$Serializer of org.apache.cassandra.db.ReadResponse
  public final Flag = org.apache.cassandra.db.rows.SerializationHelper$Flag of org.apache.cassandra.db.rows.SerializationHelper