class org.apache.cassandra.service.DataResolver$ShortReadPartitionsProtection extends org.apache.cassandra.db.transform.Transformation<org.apache.cassandra.db.rows.UnfilteredRowIterator> implements org.apache.cassandra.db.transform.MorePartitions<org.apache.cassandra.db.partitions.UnfilteredPartitionIterator>
  minor version: 0
  major version: 59
  flags: flags: (0x0020) ACC_SUPER
  this_class: org.apache.cassandra.service.DataResolver$ShortReadPartitionsProtection
  super_class: org.apache.cassandra.db.transform.Transformation
{
  private final java.net.InetAddress source;
    descriptor: Ljava/net/InetAddress;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  private final org.apache.cassandra.db.filter.DataLimits$Counter singleResultCounter;
    descriptor: Lorg/apache/cassandra/db/filter/DataLimits$Counter;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  private final org.apache.cassandra.db.filter.DataLimits$Counter mergedResultCounter;
    descriptor: Lorg/apache/cassandra/db/filter/DataLimits$Counter;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  private org.apache.cassandra.db.DecoratedKey lastPartitionKey;
    descriptor: Lorg/apache/cassandra/db/DecoratedKey;
    flags: (0x0002) ACC_PRIVATE

  private boolean partitionsFetched;
    descriptor: Z
    flags: (0x0002) ACC_PRIVATE

  private final long queryStartNanoTime;
    descriptor: J
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  final org.apache.cassandra.service.DataResolver this$0;
    descriptor: Lorg/apache/cassandra/service/DataResolver;
    flags: (0x1010) ACC_FINAL, ACC_SYNTHETIC

  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 565
            ldc Lorg/apache/cassandra/service/DataResolver;
            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.service.DataResolver$ShortReadPartitionsProtection.$assertionsDisabled:Z
            return
      LocalVariableTable:
        Start  End  Slot  Name  Signature

  private void <init>(org.apache.cassandra.service.DataResolver, java.net.InetAddress, org.apache.cassandra.db.filter.DataLimits$Counter, org.apache.cassandra.db.filter.DataLimits$Counter, long);
    descriptor: (Lorg/apache/cassandra/service/DataResolver;Ljava/net/InetAddress;Lorg/apache/cassandra/db/filter/DataLimits$Counter;Lorg/apache/cassandra/db/filter/DataLimits$Counter;J)V
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=3, locals=7, args_size=6
        start local 0 // org.apache.cassandra.service.DataResolver$ShortReadPartitionsProtection this
        start local 2 // java.net.InetAddress source
        start local 3 // org.apache.cassandra.db.filter.DataLimits$Counter singleResultCounter
        start local 4 // org.apache.cassandra.db.filter.DataLimits$Counter mergedResultCounter
        start local 5 // long queryStartNanoTime
         0: .line 582
            aload 0 /* this */
            aload 1
            putfield org.apache.cassandra.service.DataResolver$ShortReadPartitionsProtection.this$0:Lorg/apache/cassandra/service/DataResolver;
         1: .line 578
            aload 0 /* this */
            invokespecial org.apache.cassandra.db.transform.Transformation.<init>:()V
         2: .line 583
            aload 0 /* this */
            aload 2 /* source */
            putfield org.apache.cassandra.service.DataResolver$ShortReadPartitionsProtection.source:Ljava/net/InetAddress;
         3: .line 584
            aload 0 /* this */
            aload 3 /* singleResultCounter */
            putfield org.apache.cassandra.service.DataResolver$ShortReadPartitionsProtection.singleResultCounter:Lorg/apache/cassandra/db/filter/DataLimits$Counter;
         4: .line 585
            aload 0 /* this */
            aload 4 /* mergedResultCounter */
            putfield org.apache.cassandra.service.DataResolver$ShortReadPartitionsProtection.mergedResultCounter:Lorg/apache/cassandra/db/filter/DataLimits$Counter;
         5: .line 586
            aload 0 /* this */
            lload 5 /* queryStartNanoTime */
            putfield org.apache.cassandra.service.DataResolver$ShortReadPartitionsProtection.queryStartNanoTime:J
         6: .line 587
            return
        end local 5 // long queryStartNanoTime
        end local 4 // org.apache.cassandra.db.filter.DataLimits$Counter mergedResultCounter
        end local 3 // org.apache.cassandra.db.filter.DataLimits$Counter singleResultCounter
        end local 2 // java.net.InetAddress source
        end local 0 // org.apache.cassandra.service.DataResolver$ShortReadPartitionsProtection this
      LocalVariableTable:
        Start  End  Slot                 Name  Signature
            0    7     0                 this  Lorg/apache/cassandra/service/DataResolver$ShortReadPartitionsProtection;
            0    7     2               source  Ljava/net/InetAddress;
            0    7     3  singleResultCounter  Lorg/apache/cassandra/db/filter/DataLimits$Counter;
            0    7     4  mergedResultCounter  Lorg/apache/cassandra/db/filter/DataLimits$Counter;
            0    7     5   queryStartNanoTime  J
    MethodParameters:
                     Name  Flags
      this$0               final
      source               
      singleResultCounter  
      mergedResultCounter  
      queryStartNanoTime   

  public org.apache.cassandra.db.rows.UnfilteredRowIterator applyToPartition(org.apache.cassandra.db.rows.UnfilteredRowIterator);
    descriptor: (Lorg/apache/cassandra/db/rows/UnfilteredRowIterator;)Lorg/apache/cassandra/db/rows/UnfilteredRowIterator;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=5, locals=3, args_size=2
        start local 0 // org.apache.cassandra.service.DataResolver$ShortReadPartitionsProtection this
        start local 1 // org.apache.cassandra.db.rows.UnfilteredRowIterator partition
         0: .line 592
            aload 0 /* this */
            iconst_1
            putfield org.apache.cassandra.service.DataResolver$ShortReadPartitionsProtection.partitionsFetched:Z
         1: .line 594
            aload 0 /* this */
            aload 1 /* partition */
            invokeinterface org.apache.cassandra.db.rows.UnfilteredRowIterator.partitionKey:()Lorg/apache/cassandra/db/DecoratedKey;
            putfield org.apache.cassandra.service.DataResolver$ShortReadPartitionsProtection.lastPartitionKey:Lorg/apache/cassandra/db/DecoratedKey;
         2: .line 602
            new org.apache.cassandra.service.DataResolver$ShortReadPartitionsProtection$ShortReadRowsProtection
            dup
            aload 0 /* this */
            aload 1 /* partition */
            invokeinterface org.apache.cassandra.db.rows.UnfilteredRowIterator.metadata:()Lorg/apache/cassandra/config/CFMetaData;
            aload 1 /* partition */
            invokeinterface org.apache.cassandra.db.rows.UnfilteredRowIterator.partitionKey:()Lorg/apache/cassandra/db/DecoratedKey;
            invokespecial org.apache.cassandra.service.DataResolver$ShortReadPartitionsProtection$ShortReadRowsProtection.<init>:(Lorg/apache/cassandra/service/DataResolver$ShortReadPartitionsProtection;Lorg/apache/cassandra/config/CFMetaData;Lorg/apache/cassandra/db/DecoratedKey;)V
            astore 2 /* protection */
        start local 2 // org.apache.cassandra.service.DataResolver$ShortReadPartitionsProtection$ShortReadRowsProtection protection
         3: .line 603
            aload 1 /* partition */
            aload 2 /* protection */
            invokestatic org.apache.cassandra.db.transform.MoreRows.extend:(Lorg/apache/cassandra/db/rows/UnfilteredRowIterator;Lorg/apache/cassandra/db/transform/MoreRows;)Lorg/apache/cassandra/db/rows/UnfilteredRowIterator;
            aload 2 /* protection */
            invokestatic org.apache.cassandra.db.transform.Transformation.apply:(Lorg/apache/cassandra/db/rows/UnfilteredRowIterator;Lorg/apache/cassandra/db/transform/Transformation;)Lorg/apache/cassandra/db/rows/UnfilteredRowIterator;
            areturn
        end local 2 // org.apache.cassandra.service.DataResolver$ShortReadPartitionsProtection$ShortReadRowsProtection protection
        end local 1 // org.apache.cassandra.db.rows.UnfilteredRowIterator partition
        end local 0 // org.apache.cassandra.service.DataResolver$ShortReadPartitionsProtection this
      LocalVariableTable:
        Start  End  Slot        Name  Signature
            0    4     0        this  Lorg/apache/cassandra/service/DataResolver$ShortReadPartitionsProtection;
            0    4     1   partition  Lorg/apache/cassandra/db/rows/UnfilteredRowIterator;
            3    4     2  protection  Lorg/apache/cassandra/service/DataResolver$ShortReadPartitionsProtection$ShortReadRowsProtection;
    MethodParameters:
           Name  Flags
      partition  

  public org.apache.cassandra.db.partitions.UnfilteredPartitionIterator moreContents();
    descriptor: ()Lorg/apache/cassandra/db/partitions/UnfilteredPartitionIterator;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=3, args_size=1
        start local 0 // org.apache.cassandra.service.DataResolver$ShortReadPartitionsProtection this
         0: .line 614
            getstatic org.apache.cassandra.service.DataResolver$ShortReadPartitionsProtection.$assertionsDisabled:Z
            ifne 1
            aload 0 /* this */
            getfield org.apache.cassandra.service.DataResolver$ShortReadPartitionsProtection.mergedResultCounter:Lorg/apache/cassandra/db/filter/DataLimits$Counter;
            invokevirtual org.apache.cassandra.db.filter.DataLimits$Counter.isDone:()Z
            ifeq 1
            new java.lang.AssertionError
            dup
            invokespecial java.lang.AssertionError.<init>:()V
            athrow
         1: .line 617
      StackMap locals:
      StackMap stack:
            getstatic org.apache.cassandra.service.DataResolver$ShortReadPartitionsProtection.$assertionsDisabled:Z
            ifne 2
            aload 0 /* this */
            getfield org.apache.cassandra.service.DataResolver$ShortReadPartitionsProtection.this$0:Lorg/apache/cassandra/service/DataResolver;
            getfield org.apache.cassandra.service.DataResolver.command:Lorg/apache/cassandra/db/ReadCommand;
            invokevirtual org.apache.cassandra.db.ReadCommand.limits:()Lorg/apache/cassandra/db/filter/DataLimits;
            invokevirtual org.apache.cassandra.db.filter.DataLimits.isUnlimited:()Z
            ifeq 2
            new java.lang.AssertionError
            dup
            invokespecial java.lang.AssertionError.<init>:()V
            athrow
         2: .line 623
      StackMap locals:
      StackMap stack:
            getstatic org.apache.cassandra.service.DataResolver$ShortReadPartitionsProtection.$assertionsDisabled:Z
            ifne 3
            aload 0 /* this */
            getfield org.apache.cassandra.service.DataResolver$ShortReadPartitionsProtection.this$0:Lorg/apache/cassandra/service/DataResolver;
            getfield org.apache.cassandra.service.DataResolver.command:Lorg/apache/cassandra/db/ReadCommand;
            invokevirtual org.apache.cassandra.db.ReadCommand.isLimitedToOnePartition:()Z
            ifeq 3
            new java.lang.AssertionError
            dup
            invokespecial java.lang.AssertionError.<init>:()V
            athrow
         3: .line 631
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield org.apache.cassandra.service.DataResolver$ShortReadPartitionsProtection.singleResultCounter:Lorg/apache/cassandra/db/filter/DataLimits$Counter;
            invokevirtual org.apache.cassandra.db.filter.DataLimits$Counter.isDone:()Z
            ifne 5
            aload 0 /* this */
            getfield org.apache.cassandra.service.DataResolver$ShortReadPartitionsProtection.this$0:Lorg/apache/cassandra/service/DataResolver;
            getfield org.apache.cassandra.service.DataResolver.command:Lorg/apache/cassandra/db/ReadCommand;
            invokevirtual org.apache.cassandra.db.ReadCommand.limits:()Lorg/apache/cassandra/db/filter/DataLimits;
            invokevirtual org.apache.cassandra.db.filter.DataLimits.perPartitionCount:()I
            ldc 2147483647
            if_icmpne 5
         4: .line 632
            aconst_null
            areturn
         5: .line 638
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield org.apache.cassandra.service.DataResolver$ShortReadPartitionsProtection.partitionsFetched:Z
            ifne 7
         6: .line 639
            aconst_null
            areturn
         7: .line 640
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            iconst_0
            putfield org.apache.cassandra.service.DataResolver$ShortReadPartitionsProtection.partitionsFetched:Z
         8: .line 648
            aload 0 /* this */
            getfield org.apache.cassandra.service.DataResolver$ShortReadPartitionsProtection.this$0:Lorg/apache/cassandra/service/DataResolver;
            getfield org.apache.cassandra.service.DataResolver.command:Lorg/apache/cassandra/db/ReadCommand;
            invokevirtual org.apache.cassandra.db.ReadCommand.limits:()Lorg/apache/cassandra/db/filter/DataLimits;
            invokevirtual org.apache.cassandra.db.filter.DataLimits.count:()I
            ldc 2147483647
            if_icmpeq 10
         9: .line 649
            aload 0 /* this */
            getfield org.apache.cassandra.service.DataResolver$ShortReadPartitionsProtection.this$0:Lorg/apache/cassandra/service/DataResolver;
            getfield org.apache.cassandra.service.DataResolver.command:Lorg/apache/cassandra/db/ReadCommand;
            invokevirtual org.apache.cassandra.db.ReadCommand.limits:()Lorg/apache/cassandra/db/filter/DataLimits;
            invokevirtual org.apache.cassandra.db.filter.DataLimits.count:()I
            aload 0 /* this */
            aload 0 /* this */
            getfield org.apache.cassandra.service.DataResolver$ShortReadPartitionsProtection.mergedResultCounter:Lorg/apache/cassandra/db/filter/DataLimits$Counter;
            invokevirtual org.apache.cassandra.service.DataResolver$ShortReadPartitionsProtection.counted:(Lorg/apache/cassandra/db/filter/DataLimits$Counter;)I
            isub
            goto 11
        10: .line 650
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield org.apache.cassandra.service.DataResolver$ShortReadPartitionsProtection.this$0:Lorg/apache/cassandra/service/DataResolver;
            getfield org.apache.cassandra.service.DataResolver.command:Lorg/apache/cassandra/db/ReadCommand;
            invokevirtual org.apache.cassandra.db.ReadCommand.limits:()Lorg/apache/cassandra/db/filter/DataLimits;
            invokevirtual org.apache.cassandra.db.filter.DataLimits.perPartitionCount:()I
        11: .line 648
      StackMap locals:
      StackMap stack: int
            istore 1 /* toQuery */
        start local 1 // int toQuery
        12: .line 652
            aload 0 /* this */
            getfield org.apache.cassandra.service.DataResolver$ShortReadPartitionsProtection.this$0:Lorg/apache/cassandra/service/DataResolver;
            getfield org.apache.cassandra.service.DataResolver.command:Lorg/apache/cassandra/db/ReadCommand;
            invokevirtual org.apache.cassandra.db.ReadCommand.metadata:()Lorg/apache/cassandra/config/CFMetaData;
            getfield org.apache.cassandra.config.CFMetaData.cfId:Ljava/util/UUID;
            invokestatic org.apache.cassandra.db.ColumnFamilyStore.metricsFor:(Ljava/util/UUID;)Lorg/apache/cassandra/metrics/TableMetrics;
            getfield org.apache.cassandra.metrics.TableMetrics.shortReadProtectionRequests:Lcom/codahale/metrics/Meter;
            invokevirtual com.codahale.metrics.Meter.mark:()V
        13: .line 653
            ldc "Requesting {} extra rows from {} for short read protection"
            iload 1 /* toQuery */
            invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
            aload 0 /* this */
            getfield org.apache.cassandra.service.DataResolver$ShortReadPartitionsProtection.source:Ljava/net/InetAddress;
            invokestatic org.apache.cassandra.tracing.Tracing.trace:(Ljava/lang/String;Ljava/lang/Object;Ljava/lang/Object;)V
        14: .line 655
            aload 0 /* this */
            iload 1 /* toQuery */
            invokevirtual org.apache.cassandra.service.DataResolver$ShortReadPartitionsProtection.makeFetchAdditionalPartitionReadCommand:(I)Lorg/apache/cassandra/db/PartitionRangeReadCommand;
            astore 2 /* cmd */
        start local 2 // org.apache.cassandra.db.PartitionRangeReadCommand cmd
        15: .line 656
            aload 0 /* this */
            aload 2 /* cmd */
            invokevirtual org.apache.cassandra.service.DataResolver$ShortReadPartitionsProtection.executeReadCommand:(Lorg/apache/cassandra/db/ReadCommand;)Lorg/apache/cassandra/db/partitions/UnfilteredPartitionIterator;
            areturn
        end local 2 // org.apache.cassandra.db.PartitionRangeReadCommand cmd
        end local 1 // int toQuery
        end local 0 // org.apache.cassandra.service.DataResolver$ShortReadPartitionsProtection this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0   16     0     this  Lorg/apache/cassandra/service/DataResolver$ShortReadPartitionsProtection;
           12   16     1  toQuery  I
           15   16     2      cmd  Lorg/apache/cassandra/db/PartitionRangeReadCommand;

  private int counted(org.apache.cassandra.db.filter.DataLimits$Counter);
    descriptor: (Lorg/apache/cassandra/db/filter/DataLimits$Counter;)I
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=1, locals=2, args_size=2
        start local 0 // org.apache.cassandra.service.DataResolver$ShortReadPartitionsProtection this
        start local 1 // org.apache.cassandra.db.filter.DataLimits$Counter counter
         0: .line 662
            aload 0 /* this */
            getfield org.apache.cassandra.service.DataResolver$ShortReadPartitionsProtection.this$0:Lorg/apache/cassandra/service/DataResolver;
            getfield org.apache.cassandra.service.DataResolver.command:Lorg/apache/cassandra/db/ReadCommand;
            invokevirtual org.apache.cassandra.db.ReadCommand.limits:()Lorg/apache/cassandra/db/filter/DataLimits;
            invokevirtual org.apache.cassandra.db.filter.DataLimits.isGroupByLimit:()Z
            ifeq 2
         1: .line 663
            aload 1 /* counter */
            invokevirtual org.apache.cassandra.db.filter.DataLimits$Counter.rowCounted:()I
            goto 3
         2: .line 664
      StackMap locals:
      StackMap stack:
            aload 1 /* counter */
            invokevirtual org.apache.cassandra.db.filter.DataLimits$Counter.counted:()I
         3: .line 662
      StackMap locals:
      StackMap stack: int
            ireturn
        end local 1 // org.apache.cassandra.db.filter.DataLimits$Counter counter
        end local 0 // org.apache.cassandra.service.DataResolver$ShortReadPartitionsProtection this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    4     0     this  Lorg/apache/cassandra/service/DataResolver$ShortReadPartitionsProtection;
            0    4     1  counter  Lorg/apache/cassandra/db/filter/DataLimits$Counter;
    MethodParameters:
         Name  Flags
      counter  

  private org.apache.cassandra.db.PartitionRangeReadCommand makeFetchAdditionalPartitionReadCommand(int);
    descriptor: (I)Lorg/apache/cassandra/db/PartitionRangeReadCommand;
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=4, locals=7, args_size=2
        start local 0 // org.apache.cassandra.service.DataResolver$ShortReadPartitionsProtection this
        start local 1 // int toQuery
         0: .line 669
            aload 0 /* this */
            getfield org.apache.cassandra.service.DataResolver$ShortReadPartitionsProtection.this$0:Lorg/apache/cassandra/service/DataResolver;
            getfield org.apache.cassandra.service.DataResolver.command:Lorg/apache/cassandra/db/ReadCommand;
            checkcast org.apache.cassandra.db.PartitionRangeReadCommand
            astore 2 /* cmd */
        start local 2 // org.apache.cassandra.db.PartitionRangeReadCommand cmd
         1: .line 671
            aload 2 /* cmd */
            invokevirtual org.apache.cassandra.db.PartitionRangeReadCommand.limits:()Lorg/apache/cassandra/db/filter/DataLimits;
            iload 1 /* toQuery */
            invokevirtual org.apache.cassandra.db.filter.DataLimits.forShortReadRetry:(I)Lorg/apache/cassandra/db/filter/DataLimits;
            astore 3 /* newLimits */
        start local 3 // org.apache.cassandra.db.filter.DataLimits newLimits
         2: .line 673
            aload 2 /* cmd */
            invokevirtual org.apache.cassandra.db.PartitionRangeReadCommand.dataRange:()Lorg/apache/cassandra/db/DataRange;
            invokevirtual org.apache.cassandra.db.DataRange.keyRange:()Lorg/apache/cassandra/dht/AbstractBounds;
            astore 4 /* bounds */
        start local 4 // org.apache.cassandra.dht.AbstractBounds bounds
         3: .line 674
            aload 4 /* bounds */
            invokevirtual org.apache.cassandra.dht.AbstractBounds.inclusiveRight:()Z
            ifeq 5
         4: .line 675
            new org.apache.cassandra.dht.Range
            dup
            aload 0 /* this */
            getfield org.apache.cassandra.service.DataResolver$ShortReadPartitionsProtection.lastPartitionKey:Lorg/apache/cassandra/db/DecoratedKey;
            aload 4 /* bounds */
            getfield org.apache.cassandra.dht.AbstractBounds.right:Lorg/apache/cassandra/dht/RingPosition;
            checkcast org.apache.cassandra.db.PartitionPosition
            invokespecial org.apache.cassandra.dht.Range.<init>:(Lorg/apache/cassandra/dht/RingPosition;Lorg/apache/cassandra/dht/RingPosition;)V
            goto 6
         5: .line 676
      StackMap locals: org.apache.cassandra.db.PartitionRangeReadCommand org.apache.cassandra.db.filter.DataLimits org.apache.cassandra.dht.AbstractBounds
      StackMap stack:
            new org.apache.cassandra.dht.ExcludingBounds
            dup
            aload 0 /* this */
            getfield org.apache.cassandra.service.DataResolver$ShortReadPartitionsProtection.lastPartitionKey:Lorg/apache/cassandra/db/DecoratedKey;
            aload 4 /* bounds */
            getfield org.apache.cassandra.dht.AbstractBounds.right:Lorg/apache/cassandra/dht/RingPosition;
            checkcast org.apache.cassandra.db.PartitionPosition
            invokespecial org.apache.cassandra.dht.ExcludingBounds.<init>:(Lorg/apache/cassandra/dht/RingPosition;Lorg/apache/cassandra/dht/RingPosition;)V
         6: .line 674
      StackMap locals:
      StackMap stack: org.apache.cassandra.dht.AbstractBounds
            astore 5 /* newBounds */
        start local 5 // org.apache.cassandra.dht.AbstractBounds newBounds
         7: .line 677
            aload 2 /* cmd */
            invokevirtual org.apache.cassandra.db.PartitionRangeReadCommand.dataRange:()Lorg/apache/cassandra/db/DataRange;
            aload 5 /* newBounds */
            invokevirtual org.apache.cassandra.db.DataRange.forSubRange:(Lorg/apache/cassandra/dht/AbstractBounds;)Lorg/apache/cassandra/db/DataRange;
            astore 6 /* newDataRange */
        start local 6 // org.apache.cassandra.db.DataRange newDataRange
         8: .line 679
            aload 2 /* cmd */
            aload 3 /* newLimits */
            aload 6 /* newDataRange */
            invokevirtual org.apache.cassandra.db.PartitionRangeReadCommand.withUpdatedLimitsAndDataRange:(Lorg/apache/cassandra/db/filter/DataLimits;Lorg/apache/cassandra/db/DataRange;)Lorg/apache/cassandra/db/PartitionRangeReadCommand;
            areturn
        end local 6 // org.apache.cassandra.db.DataRange newDataRange
        end local 5 // org.apache.cassandra.dht.AbstractBounds newBounds
        end local 4 // org.apache.cassandra.dht.AbstractBounds bounds
        end local 3 // org.apache.cassandra.db.filter.DataLimits newLimits
        end local 2 // org.apache.cassandra.db.PartitionRangeReadCommand cmd
        end local 1 // int toQuery
        end local 0 // org.apache.cassandra.service.DataResolver$ShortReadPartitionsProtection this
      LocalVariableTable:
        Start  End  Slot          Name  Signature
            0    9     0          this  Lorg/apache/cassandra/service/DataResolver$ShortReadPartitionsProtection;
            0    9     1       toQuery  I
            1    9     2           cmd  Lorg/apache/cassandra/db/PartitionRangeReadCommand;
            2    9     3     newLimits  Lorg/apache/cassandra/db/filter/DataLimits;
            3    9     4        bounds  Lorg/apache/cassandra/dht/AbstractBounds<Lorg/apache/cassandra/db/PartitionPosition;>;
            7    9     5     newBounds  Lorg/apache/cassandra/dht/AbstractBounds<Lorg/apache/cassandra/db/PartitionPosition;>;
            8    9     6  newDataRange  Lorg/apache/cassandra/db/DataRange;
    MethodParameters:
         Name  Flags
      toQuery  

  private org.apache.cassandra.db.partitions.UnfilteredPartitionIterator executeReadCommand(org.apache.cassandra.db.ReadCommand);
    descriptor: (Lorg/apache/cassandra/db/ReadCommand;)Lorg/apache/cassandra/db/partitions/UnfilteredPartitionIterator;
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=8, locals=4, args_size=2
        start local 0 // org.apache.cassandra.service.DataResolver$ShortReadPartitionsProtection this
        start local 1 // org.apache.cassandra.db.ReadCommand cmd
         0: .line 832
            new org.apache.cassandra.service.DataResolver
            dup
            aload 0 /* this */
            getfield org.apache.cassandra.service.DataResolver$ShortReadPartitionsProtection.this$0:Lorg/apache/cassandra/service/DataResolver;
            getfield org.apache.cassandra.service.DataResolver.keyspace:Lorg/apache/cassandra/db/Keyspace;
            aload 1 /* cmd */
            getstatic org.apache.cassandra.db.ConsistencyLevel.ONE:Lorg/apache/cassandra/db/ConsistencyLevel;
            iconst_1
            aload 0 /* this */
            getfield org.apache.cassandra.service.DataResolver$ShortReadPartitionsProtection.queryStartNanoTime:J
            invokespecial org.apache.cassandra.service.DataResolver.<init>:(Lorg/apache/cassandra/db/Keyspace;Lorg/apache/cassandra/db/ReadCommand;Lorg/apache/cassandra/db/ConsistencyLevel;IJ)V
            astore 2 /* resolver */
        start local 2 // org.apache.cassandra.service.DataResolver resolver
         1: .line 833
            new org.apache.cassandra.service.ReadCallback
            dup
            aload 2 /* resolver */
            getstatic org.apache.cassandra.db.ConsistencyLevel.ONE:Lorg/apache/cassandra/db/ConsistencyLevel;
            aload 1 /* cmd */
            aload 0 /* this */
            getfield org.apache.cassandra.service.DataResolver$ShortReadPartitionsProtection.source:Ljava/net/InetAddress;
            invokestatic java.util.Collections.singletonList:(Ljava/lang/Object;)Ljava/util/List;
            aload 0 /* this */
            getfield org.apache.cassandra.service.DataResolver$ShortReadPartitionsProtection.queryStartNanoTime:J
            invokespecial org.apache.cassandra.service.ReadCallback.<init>:(Lorg/apache/cassandra/service/ResponseResolver;Lorg/apache/cassandra/db/ConsistencyLevel;Lorg/apache/cassandra/db/ReadCommand;Ljava/util/List;J)V
            astore 3 /* handler */
        start local 3 // org.apache.cassandra.service.ReadCallback handler
         2: .line 835
            aload 0 /* this */
            getfield org.apache.cassandra.service.DataResolver$ShortReadPartitionsProtection.source:Ljava/net/InetAddress;
            invokestatic org.apache.cassandra.service.StorageProxy.canDoLocalRequest:(Ljava/net/InetAddress;)Z
            ifeq 4
         3: .line 836
            getstatic org.apache.cassandra.concurrent.Stage.READ:Lorg/apache/cassandra/concurrent/Stage;
            invokestatic org.apache.cassandra.concurrent.StageManager.getStage:(Lorg/apache/cassandra/concurrent/Stage;)Lorg/apache/cassandra/concurrent/LocalAwareExecutorService;
            new org.apache.cassandra.service.StorageProxy$LocalReadRunnable
            dup
            aload 1 /* cmd */
            aload 3 /* handler */
            invokespecial org.apache.cassandra.service.StorageProxy$LocalReadRunnable.<init>:(Lorg/apache/cassandra/db/ReadCommand;Lorg/apache/cassandra/service/ReadCallback;)V
            invokeinterface org.apache.cassandra.concurrent.LocalAwareExecutorService.maybeExecuteImmediately:(Ljava/lang/Runnable;)V
            goto 5
         4: .line 838
      StackMap locals: org.apache.cassandra.service.DataResolver org.apache.cassandra.service.ReadCallback
      StackMap stack:
            invokestatic org.apache.cassandra.net.MessagingService.instance:()Lorg/apache/cassandra/net/MessagingService;
            aload 1 /* cmd */
            getstatic org.apache.cassandra.net.MessagingService.current_version:I
            invokevirtual org.apache.cassandra.db.ReadCommand.createMessage:(I)Lorg/apache/cassandra/net/MessageOut;
            aload 0 /* this */
            getfield org.apache.cassandra.service.DataResolver$ShortReadPartitionsProtection.source:Ljava/net/InetAddress;
            aload 3 /* handler */
            invokevirtual org.apache.cassandra.net.MessagingService.sendRRWithFailure:(Lorg/apache/cassandra/net/MessageOut;Ljava/net/InetAddress;Lorg/apache/cassandra/net/IAsyncCallbackWithFailure;)I
            pop
         5: .line 841
      StackMap locals:
      StackMap stack:
            aload 3 /* handler */
            invokevirtual org.apache.cassandra.service.ReadCallback.awaitResults:()V
         6: .line 842
            getstatic org.apache.cassandra.service.DataResolver$ShortReadPartitionsProtection.$assertionsDisabled:Z
            ifne 7
            aload 2 /* resolver */
            getfield org.apache.cassandra.service.DataResolver.responses:Lorg/apache/cassandra/utils/concurrent/Accumulator;
            invokevirtual org.apache.cassandra.utils.concurrent.Accumulator.size:()I
            iconst_1
            if_icmpeq 7
            new java.lang.AssertionError
            dup
            invokespecial java.lang.AssertionError.<init>:()V
            athrow
         7: .line 843
      StackMap locals:
      StackMap stack:
            aload 2 /* resolver */
            getfield org.apache.cassandra.service.DataResolver.responses:Lorg/apache/cassandra/utils/concurrent/Accumulator;
            iconst_0
            invokevirtual org.apache.cassandra.utils.concurrent.Accumulator.get:(I)Ljava/lang/Object;
            checkcast org.apache.cassandra.net.MessageIn
            getfield org.apache.cassandra.net.MessageIn.payload:Ljava/lang/Object;
            checkcast org.apache.cassandra.db.ReadResponse
            aload 0 /* this */
            getfield org.apache.cassandra.service.DataResolver$ShortReadPartitionsProtection.this$0:Lorg/apache/cassandra/service/DataResolver;
            getfield org.apache.cassandra.service.DataResolver.command:Lorg/apache/cassandra/db/ReadCommand;
            invokevirtual org.apache.cassandra.db.ReadResponse.makeIterator:(Lorg/apache/cassandra/db/ReadCommand;)Lorg/apache/cassandra/db/partitions/UnfilteredPartitionIterator;
            areturn
        end local 3 // org.apache.cassandra.service.ReadCallback handler
        end local 2 // org.apache.cassandra.service.DataResolver resolver
        end local 1 // org.apache.cassandra.db.ReadCommand cmd
        end local 0 // org.apache.cassandra.service.DataResolver$ShortReadPartitionsProtection this
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0    8     0      this  Lorg/apache/cassandra/service/DataResolver$ShortReadPartitionsProtection;
            0    8     1       cmd  Lorg/apache/cassandra/db/ReadCommand;
            1    8     2  resolver  Lorg/apache/cassandra/service/DataResolver;
            2    8     3   handler  Lorg/apache/cassandra/service/ReadCallback;
    MethodParameters:
      Name  Flags
      cmd   

  public java.lang.Object moreContents();
    descriptor: ()Ljava/lang/Object;
    flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
    Code:
      stack=1, locals=1, args_size=1
         0: .line 1
            aload 0
            invokevirtual org.apache.cassandra.service.DataResolver$ShortReadPartitionsProtection.moreContents:()Lorg/apache/cassandra/db/partitions/UnfilteredPartitionIterator;
            areturn
      LocalVariableTable:
        Start  End  Slot  Name  Signature

  public org.apache.cassandra.db.rows.BaseRowIterator applyToPartition(org.apache.cassandra.db.rows.BaseRowIterator);
    descriptor: (Lorg/apache/cassandra/db/rows/BaseRowIterator;)Lorg/apache/cassandra/db/rows/BaseRowIterator;
    flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
    Code:
      stack=2, locals=2, args_size=2
         0: .line 1
            aload 0
            aload 1
            checkcast org.apache.cassandra.db.rows.UnfilteredRowIterator
            invokevirtual org.apache.cassandra.service.DataResolver$ShortReadPartitionsProtection.applyToPartition:(Lorg/apache/cassandra/db/rows/UnfilteredRowIterator;)Lorg/apache/cassandra/db/rows/UnfilteredRowIterator;
            areturn
      LocalVariableTable:
        Start  End  Slot  Name  Signature

  static org.apache.cassandra.service.DataResolver access$2(org.apache.cassandra.service.DataResolver$ShortReadPartitionsProtection);
    descriptor: (Lorg/apache/cassandra/service/DataResolver$ShortReadPartitionsProtection;)Lorg/apache/cassandra/service/DataResolver;
    flags: (0x1008) ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=1, locals=1, args_size=1
         0: .line 565
            aload 0
            getfield org.apache.cassandra.service.DataResolver$ShortReadPartitionsProtection.this$0:Lorg/apache/cassandra/service/DataResolver;
            areturn
      LocalVariableTable:
        Start  End  Slot  Name  Signature
}
Signature: Lorg/apache/cassandra/db/transform/Transformation<Lorg/apache/cassandra/db/rows/UnfilteredRowIterator;>;Lorg/apache/cassandra/db/transform/MorePartitions<Lorg/apache/cassandra/db/partitions/UnfilteredPartitionIterator;>;
SourceFile: "DataResolver.java"
NestHost: org.apache.cassandra.service.DataResolver
InnerClasses:
  public abstract Counter = org.apache.cassandra.db.filter.DataLimits$Counter of org.apache.cassandra.db.filter.DataLimits
  private ShortReadPartitionsProtection = org.apache.cassandra.service.DataResolver$ShortReadPartitionsProtection of org.apache.cassandra.service.DataResolver
  private ShortReadRowsProtection = org.apache.cassandra.service.DataResolver$ShortReadPartitionsProtection$ShortReadRowsProtection of org.apache.cassandra.service.DataResolver$ShortReadPartitionsProtection
  LocalReadRunnable = org.apache.cassandra.service.StorageProxy$LocalReadRunnable of org.apache.cassandra.service.StorageProxy