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.service.ReadCallback$AsyncRepairRunner implements java.lang.Runnable
  minor version: 0
  major version: 59
  flags: flags: (0x0020) ACC_SUPER
  this_class: org.apache.cassandra.service.ReadCallback$AsyncRepairRunner
  super_class: java.lang.Object
{
  private final org.apache.cassandra.tracing.TraceState traceState;
    descriptor: Lorg/apache/cassandra/tracing/TraceState;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

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

  final org.apache.cassandra.service.ReadCallback this$0;
    descriptor: Lorg/apache/cassandra/service/ReadCallback;
    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 215
            ldc Lorg/apache/cassandra/service/ReadCallback;
            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.ReadCallback$AsyncRepairRunner.$assertionsDisabled:Z
            return
      LocalVariableTable:
        Start  End  Slot  Name  Signature

  public void <init>(org.apache.cassandra.service.ReadCallback, org.apache.cassandra.tracing.TraceState, long);
    descriptor: (Lorg/apache/cassandra/service/ReadCallback;Lorg/apache/cassandra/tracing/TraceState;J)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=5, args_size=4
        start local 0 // org.apache.cassandra.service.ReadCallback$AsyncRepairRunner this
        start local 2 // org.apache.cassandra.tracing.TraceState traceState
        start local 3 // long queryStartNanoTime
         0: .line 221
            aload 0 /* this */
            aload 1
            putfield org.apache.cassandra.service.ReadCallback$AsyncRepairRunner.this$0:Lorg/apache/cassandra/service/ReadCallback;
         1: .line 220
            aload 0 /* this */
            invokespecial java.lang.Object.<init>:()V
         2: .line 222
            aload 0 /* this */
            aload 2 /* traceState */
            putfield org.apache.cassandra.service.ReadCallback$AsyncRepairRunner.traceState:Lorg/apache/cassandra/tracing/TraceState;
         3: .line 223
            aload 0 /* this */
            lload 3 /* queryStartNanoTime */
            putfield org.apache.cassandra.service.ReadCallback$AsyncRepairRunner.queryStartNanoTime:J
         4: .line 224
            return
        end local 3 // long queryStartNanoTime
        end local 2 // org.apache.cassandra.tracing.TraceState traceState
        end local 0 // org.apache.cassandra.service.ReadCallback$AsyncRepairRunner this
      LocalVariableTable:
        Start  End  Slot                Name  Signature
            0    5     0                this  Lorg/apache/cassandra/service/ReadCallback$AsyncRepairRunner;
            0    5     2          traceState  Lorg/apache/cassandra/tracing/TraceState;
            0    5     3  queryStartNanoTime  J
    MethodParameters:
                    Name  Flags
      this$0              final
      traceState          
      queryStartNanoTime  

  public void run();
    descriptor: ()V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=8, locals=7, args_size=1
        start local 0 // org.apache.cassandra.service.ReadCallback$AsyncRepairRunner this
         0: .line 233
            aload 0 /* this */
            getfield org.apache.cassandra.service.ReadCallback$AsyncRepairRunner.this$0:Lorg/apache/cassandra/service/ReadCallback;
            getfield org.apache.cassandra.service.ReadCallback.resolver:Lorg/apache/cassandra/service/ResponseResolver;
            invokevirtual org.apache.cassandra.service.ResponseResolver.compareResponses:()V
         1: .line 234
            goto 16
         2: .line 235
      StackMap locals:
      StackMap stack: org.apache.cassandra.service.DigestMismatchException
            astore 1 /* e */
        start local 1 // org.apache.cassandra.service.DigestMismatchException e
         3: .line 237
            getstatic org.apache.cassandra.service.ReadCallback$AsyncRepairRunner.$assertionsDisabled:Z
            ifne 4
            aload 0 /* this */
            getfield org.apache.cassandra.service.ReadCallback$AsyncRepairRunner.this$0:Lorg/apache/cassandra/service/ReadCallback;
            getfield org.apache.cassandra.service.ReadCallback.resolver:Lorg/apache/cassandra/service/ResponseResolver;
            instanceof org.apache.cassandra.service.DigestResolver
            ifne 4
            new java.lang.AssertionError
            dup
            invokespecial java.lang.AssertionError.<init>:()V
            athrow
         4: .line 239
      StackMap locals: org.apache.cassandra.service.DigestMismatchException
      StackMap stack:
            aload 0 /* this */
            getfield org.apache.cassandra.service.ReadCallback$AsyncRepairRunner.traceState:Lorg/apache/cassandra/tracing/TraceState;
            ifnull 6
         5: .line 240
            aload 0 /* this */
            getfield org.apache.cassandra.service.ReadCallback$AsyncRepairRunner.traceState:Lorg/apache/cassandra/tracing/TraceState;
            ldc "Digest mismatch: {}"
            aload 1 /* e */
            invokevirtual org.apache.cassandra.service.DigestMismatchException.toString:()Ljava/lang/String;
            invokevirtual org.apache.cassandra.tracing.TraceState.trace:(Ljava/lang/String;Ljava/lang/Object;)V
         6: .line 241
      StackMap locals:
      StackMap stack:
            getstatic org.apache.cassandra.service.ReadCallback.logger:Lorg/slf4j/Logger;
            invokeinterface org.slf4j.Logger.isDebugEnabled:()Z
            ifeq 8
         7: .line 242
            getstatic org.apache.cassandra.service.ReadCallback.logger:Lorg/slf4j/Logger;
            ldc "Digest mismatch:"
            aload 1 /* e */
            invokeinterface org.slf4j.Logger.debug:(Ljava/lang/String;Ljava/lang/Throwable;)V
         8: .line 244
      StackMap locals:
      StackMap stack:
            getstatic org.apache.cassandra.metrics.ReadRepairMetrics.repairedBackground:Lcom/codahale/metrics/Meter;
            invokevirtual com.codahale.metrics.Meter.mark:()V
         9: .line 246
            new org.apache.cassandra.service.DataResolver
            dup
            aload 0 /* this */
            getfield org.apache.cassandra.service.ReadCallback$AsyncRepairRunner.this$0:Lorg/apache/cassandra/service/ReadCallback;
            getfield org.apache.cassandra.service.ReadCallback.keyspace:Lorg/apache/cassandra/db/Keyspace;
            aload 0 /* this */
            getfield org.apache.cassandra.service.ReadCallback$AsyncRepairRunner.this$0:Lorg/apache/cassandra/service/ReadCallback;
            getfield org.apache.cassandra.service.ReadCallback.command:Lorg/apache/cassandra/db/ReadCommand;
            aload 0 /* this */
            getfield org.apache.cassandra.service.ReadCallback$AsyncRepairRunner.this$0:Lorg/apache/cassandra/service/ReadCallback;
            getfield org.apache.cassandra.service.ReadCallback.consistencyLevel:Lorg/apache/cassandra/db/ConsistencyLevel;
            aload 0 /* this */
            getfield org.apache.cassandra.service.ReadCallback$AsyncRepairRunner.this$0:Lorg/apache/cassandra/service/ReadCallback;
            getfield org.apache.cassandra.service.ReadCallback.endpoints:Ljava/util/List;
            invokeinterface java.util.List.size:()I
            aload 0 /* this */
            getfield org.apache.cassandra.service.ReadCallback$AsyncRepairRunner.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 /* repairResolver */
        start local 2 // org.apache.cassandra.service.DataResolver repairResolver
        10: .line 247
            new org.apache.cassandra.service.AsyncRepairCallback
            dup
            aload 2 /* repairResolver */
            aload 0 /* this */
            getfield org.apache.cassandra.service.ReadCallback$AsyncRepairRunner.this$0:Lorg/apache/cassandra/service/ReadCallback;
            getfield org.apache.cassandra.service.ReadCallback.endpoints:Ljava/util/List;
            invokeinterface java.util.List.size:()I
            invokespecial org.apache.cassandra.service.AsyncRepairCallback.<init>:(Lorg/apache/cassandra/service/DataResolver;I)V
            astore 3 /* repairHandler */
        start local 3 // org.apache.cassandra.service.AsyncRepairCallback repairHandler
        11: .line 249
            aload 0 /* this */
            getfield org.apache.cassandra.service.ReadCallback$AsyncRepairRunner.this$0:Lorg/apache/cassandra/service/ReadCallback;
            getfield org.apache.cassandra.service.ReadCallback.endpoints:Ljava/util/List;
            invokeinterface java.util.List.iterator:()Ljava/util/Iterator;
            astore 5
            goto 15
      StackMap locals: org.apache.cassandra.service.ReadCallback$AsyncRepairRunner org.apache.cassandra.service.DigestMismatchException org.apache.cassandra.service.DataResolver org.apache.cassandra.service.AsyncRepairCallback top java.util.Iterator
      StackMap stack:
        12: aload 5
            invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
            checkcast java.net.InetAddress
            astore 4 /* endpoint */
        start local 4 // java.net.InetAddress endpoint
        13: .line 251
            aload 0 /* this */
            getfield org.apache.cassandra.service.ReadCallback$AsyncRepairRunner.this$0:Lorg/apache/cassandra/service/ReadCallback;
            getfield org.apache.cassandra.service.ReadCallback.command:Lorg/apache/cassandra/db/ReadCommand;
            invokestatic org.apache.cassandra.net.MessagingService.instance:()Lorg/apache/cassandra/net/MessagingService;
            aload 4 /* endpoint */
            invokevirtual org.apache.cassandra.net.MessagingService.getVersion:(Ljava/net/InetAddress;)I
            invokevirtual org.apache.cassandra.db.ReadCommand.createMessage:(I)Lorg/apache/cassandra/net/MessageOut;
            astore 6 /* message */
        start local 6 // org.apache.cassandra.net.MessageOut message
        14: .line 252
            invokestatic org.apache.cassandra.net.MessagingService.instance:()Lorg/apache/cassandra/net/MessagingService;
            aload 6 /* message */
            aload 4 /* endpoint */
            aload 3 /* repairHandler */
            invokevirtual org.apache.cassandra.net.MessagingService.sendRR:(Lorg/apache/cassandra/net/MessageOut;Ljava/net/InetAddress;Lorg/apache/cassandra/net/IAsyncCallback;)I
            pop
        end local 6 // org.apache.cassandra.net.MessageOut message
        end local 4 // java.net.InetAddress endpoint
        15: .line 249
      StackMap locals:
      StackMap stack:
            aload 5
            invokeinterface java.util.Iterator.hasNext:()Z
            ifne 12
        end local 3 // org.apache.cassandra.service.AsyncRepairCallback repairHandler
        end local 2 // org.apache.cassandra.service.DataResolver repairResolver
        end local 1 // org.apache.cassandra.service.DigestMismatchException e
        16: .line 255
      StackMap locals: org.apache.cassandra.service.ReadCallback$AsyncRepairRunner
      StackMap stack:
            return
        end local 0 // org.apache.cassandra.service.ReadCallback$AsyncRepairRunner this
      LocalVariableTable:
        Start  End  Slot            Name  Signature
            0   17     0            this  Lorg/apache/cassandra/service/ReadCallback$AsyncRepairRunner;
            3   16     1               e  Lorg/apache/cassandra/service/DigestMismatchException;
           10   16     2  repairResolver  Lorg/apache/cassandra/service/DataResolver;
           11   16     3   repairHandler  Lorg/apache/cassandra/service/AsyncRepairCallback;
           13   15     4        endpoint  Ljava/net/InetAddress;
           14   15     6         message  Lorg/apache/cassandra/net/MessageOut<Lorg/apache/cassandra/db/ReadCommand;>;
      Exception table:
        from    to  target  type
           0     1       2  Class org.apache.cassandra.service.DigestMismatchException
}
SourceFile: "ReadCallback.java"
NestHost: org.apache.cassandra.service.ReadCallback
InnerClasses:
  private AsyncRepairRunner = org.apache.cassandra.service.ReadCallback$AsyncRepairRunner of org.apache.cassandra.service.ReadCallback