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 
final class org.apache.cassandra.hints.HintsDispatchExecutor$DispatchHintsTask implements java.lang.Runnable
  minor version: 0
  major version: 59
  flags: flags: (0x0030) ACC_FINAL, ACC_SUPER
  this_class: org.apache.cassandra.hints.HintsDispatchExecutor$DispatchHintsTask
  super_class: java.lang.Object
{
  private final org.apache.cassandra.hints.HintsStore store;
    descriptor: Lorg/apache/cassandra/hints/HintsStore;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  private final java.util.UUID hostId;
    descriptor: Ljava/util/UUID;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  private final com.google.common.util.concurrent.RateLimiter rateLimiter;
    descriptor: Lcom/google/common/util/concurrent/RateLimiter;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

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

  void <init>(org.apache.cassandra.hints.HintsDispatchExecutor, org.apache.cassandra.hints.HintsStore, java.util.UUID);
    descriptor: (Lorg/apache/cassandra/hints/HintsDispatchExecutor;Lorg/apache/cassandra/hints/HintsStore;Ljava/util/UUID;)V
    flags: (0x0000) 
    Code:
      stack=3, locals=6, args_size=4
        start local 0 // org.apache.cassandra.hints.HintsDispatchExecutor$DispatchHintsTask this
        start local 2 // org.apache.cassandra.hints.HintsStore store
        start local 3 // java.util.UUID hostId
         0: .line 199
            aload 0 /* this */
            aload 1
            putfield org.apache.cassandra.hints.HintsDispatchExecutor$DispatchHintsTask.this$0:Lorg/apache/cassandra/hints/HintsDispatchExecutor;
         1: .line 198
            aload 0 /* this */
            invokespecial java.lang.Object.<init>:()V
         2: .line 200
            aload 0 /* this */
            aload 2 /* store */
            putfield org.apache.cassandra.hints.HintsDispatchExecutor$DispatchHintsTask.store:Lorg/apache/cassandra/hints/HintsStore;
         3: .line 201
            aload 0 /* this */
            aload 3 /* hostId */
            putfield org.apache.cassandra.hints.HintsDispatchExecutor$DispatchHintsTask.hostId:Ljava/util/UUID;
         4: .line 208
            iconst_1
            getstatic org.apache.cassandra.service.StorageService.instance:Lorg/apache/cassandra/service/StorageService;
            invokevirtual org.apache.cassandra.service.StorageService.getTokenMetadata:()Lorg/apache/cassandra/locator/TokenMetadata;
            invokevirtual org.apache.cassandra.locator.TokenMetadata.getAllEndpoints:()Ljava/util/Set;
            invokeinterface java.util.Set.size:()I
            iconst_1
            isub
            invokestatic java.lang.Math.max:(II)I
            istore 4 /* nodesCount */
        start local 4 // int nodesCount
         5: .line 209
            invokestatic org.apache.cassandra.config.DatabaseDescriptor.getHintedHandoffThrottleInKB:()I
            iload 4 /* nodesCount */
            idiv
            istore 5 /* throttleInKB */
        start local 5 // int throttleInKB
         6: .line 210
            aload 0 /* this */
            iload 5 /* throttleInKB */
            ifne 7
            ldc 1.7976931348623157E308
            goto 8
      StackMap locals: org.apache.cassandra.hints.HintsDispatchExecutor$DispatchHintsTask org.apache.cassandra.hints.HintsDispatchExecutor org.apache.cassandra.hints.HintsStore java.util.UUID int int
      StackMap stack: org.apache.cassandra.hints.HintsDispatchExecutor$DispatchHintsTask
         7: iload 5 /* throttleInKB */
            sipush 1024
            imul
            i2d
      StackMap locals: org.apache.cassandra.hints.HintsDispatchExecutor$DispatchHintsTask org.apache.cassandra.hints.HintsDispatchExecutor org.apache.cassandra.hints.HintsStore java.util.UUID int int
      StackMap stack: org.apache.cassandra.hints.HintsDispatchExecutor$DispatchHintsTask double
         8: invokestatic com.google.common.util.concurrent.RateLimiter.create:(D)Lcom/google/common/util/concurrent/RateLimiter;
            putfield org.apache.cassandra.hints.HintsDispatchExecutor$DispatchHintsTask.rateLimiter:Lcom/google/common/util/concurrent/RateLimiter;
         9: .line 211
            return
        end local 5 // int throttleInKB
        end local 4 // int nodesCount
        end local 3 // java.util.UUID hostId
        end local 2 // org.apache.cassandra.hints.HintsStore store
        end local 0 // org.apache.cassandra.hints.HintsDispatchExecutor$DispatchHintsTask this
      LocalVariableTable:
        Start  End  Slot          Name  Signature
            0   10     0          this  Lorg/apache/cassandra/hints/HintsDispatchExecutor$DispatchHintsTask;
            0   10     2         store  Lorg/apache/cassandra/hints/HintsStore;
            0   10     3        hostId  Ljava/util/UUID;
            5   10     4    nodesCount  I
            6   10     5  throttleInKB  I
    MethodParameters:
        Name  Flags
      this$0  final
      store   
      hostId  

  public void run();
    descriptor: ()V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=2, args_size=1
        start local 0 // org.apache.cassandra.hints.HintsDispatchExecutor$DispatchHintsTask this
         0: .line 217
            aload 0 /* this */
            invokevirtual org.apache.cassandra.hints.HintsDispatchExecutor$DispatchHintsTask.dispatch:()V
         1: .line 218
            goto 5
         2: .line 220
      StackMap locals:
      StackMap stack: java.lang.Throwable
            astore 1
         3: .line 221
            aload 0 /* this */
            getfield org.apache.cassandra.hints.HintsDispatchExecutor$DispatchHintsTask.this$0:Lorg/apache/cassandra/hints/HintsDispatchExecutor;
            getfield org.apache.cassandra.hints.HintsDispatchExecutor.scheduledDispatches:Ljava/util/Map;
            aload 0 /* this */
            getfield org.apache.cassandra.hints.HintsDispatchExecutor$DispatchHintsTask.hostId:Ljava/util/UUID;
            invokeinterface java.util.Map.remove:(Ljava/lang/Object;)Ljava/lang/Object;
            pop
         4: .line 222
            aload 1
            athrow
         5: .line 221
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield org.apache.cassandra.hints.HintsDispatchExecutor$DispatchHintsTask.this$0:Lorg/apache/cassandra/hints/HintsDispatchExecutor;
            getfield org.apache.cassandra.hints.HintsDispatchExecutor.scheduledDispatches:Ljava/util/Map;
            aload 0 /* this */
            getfield org.apache.cassandra.hints.HintsDispatchExecutor$DispatchHintsTask.hostId:Ljava/util/UUID;
            invokeinterface java.util.Map.remove:(Ljava/lang/Object;)Ljava/lang/Object;
            pop
         6: .line 223
            return
        end local 0 // org.apache.cassandra.hints.HintsDispatchExecutor$DispatchHintsTask this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    7     0  this  Lorg/apache/cassandra/hints/HintsDispatchExecutor$DispatchHintsTask;
      Exception table:
        from    to  target  type
           0     2       2  any

  private void dispatch();
    descriptor: ()V
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=4, locals=3, args_size=1
        start local 0 // org.apache.cassandra.hints.HintsDispatchExecutor$DispatchHintsTask this
         0: .line 229
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield org.apache.cassandra.hints.HintsDispatchExecutor$DispatchHintsTask.this$0:Lorg/apache/cassandra/hints/HintsDispatchExecutor;
            getfield org.apache.cassandra.hints.HintsDispatchExecutor.isPaused:Ljava/util/concurrent/atomic/AtomicBoolean;
            invokevirtual java.util.concurrent.atomic.AtomicBoolean.get:()Z
            ifeq 2
         1: .line 230
            goto 12
         2: .line 232
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield org.apache.cassandra.hints.HintsDispatchExecutor$DispatchHintsTask.store:Lorg/apache/cassandra/hints/HintsStore;
            invokevirtual org.apache.cassandra.hints.HintsStore.poll:()Lorg/apache/cassandra/hints/HintsDescriptor;
            astore 1 /* descriptor */
        start local 1 // org.apache.cassandra.hints.HintsDescriptor descriptor
         3: .line 233
            aload 1 /* descriptor */
            ifnonnull 5
         4: .line 234
            goto 12
         5: .line 238
      StackMap locals: org.apache.cassandra.hints.HintsDescriptor
      StackMap stack:
            aload 0 /* this */
            aload 1 /* descriptor */
            invokevirtual org.apache.cassandra.hints.HintsDispatchExecutor$DispatchHintsTask.dispatch:(Lorg/apache/cassandra/hints/HintsDescriptor;)Z
            ifne 0
         6: .line 239
            goto 12
         7: .line 241
      StackMap locals:
      StackMap stack: org.apache.cassandra.io.FSReadError
            astore 2 /* e */
        start local 2 // org.apache.cassandra.io.FSReadError e
         8: .line 243
            getstatic org.apache.cassandra.hints.HintsDispatchExecutor.logger:Lorg/slf4j/Logger;
            ldc "Failed to dispatch hints file {}: file is corrupted ({})"
            aload 1 /* descriptor */
            invokevirtual org.apache.cassandra.hints.HintsDescriptor.fileName:()Ljava/lang/String;
            aload 2 /* e */
            invokeinterface org.slf4j.Logger.error:(Ljava/lang/String;Ljava/lang/Object;Ljava/lang/Object;)V
         9: .line 244
            aload 0 /* this */
            getfield org.apache.cassandra.hints.HintsDispatchExecutor$DispatchHintsTask.store:Lorg/apache/cassandra/hints/HintsStore;
            aload 1 /* descriptor */
            invokevirtual org.apache.cassandra.hints.HintsStore.cleanUp:(Lorg/apache/cassandra/hints/HintsDescriptor;)V
        10: .line 245
            aload 0 /* this */
            getfield org.apache.cassandra.hints.HintsDispatchExecutor$DispatchHintsTask.store:Lorg/apache/cassandra/hints/HintsStore;
            aload 1 /* descriptor */
            invokevirtual org.apache.cassandra.hints.HintsStore.blacklist:(Lorg/apache/cassandra/hints/HintsDescriptor;)V
        11: .line 246
            aload 2 /* e */
            athrow
        end local 2 // org.apache.cassandra.io.FSReadError e
        end local 1 // org.apache.cassandra.hints.HintsDescriptor descriptor
        12: .line 249
      StackMap locals:
      StackMap stack:
            return
        end local 0 // org.apache.cassandra.hints.HintsDispatchExecutor$DispatchHintsTask this
      LocalVariableTable:
        Start  End  Slot        Name  Signature
            0   13     0        this  Lorg/apache/cassandra/hints/HintsDispatchExecutor$DispatchHintsTask;
            3   12     1  descriptor  Lorg/apache/cassandra/hints/HintsDescriptor;
            8   12     2           e  Lorg/apache/cassandra/io/FSReadError;
      Exception table:
        from    to  target  type
           5     6       7  Class org.apache.cassandra.io.FSReadError

  private boolean dispatch(org.apache.cassandra.hints.HintsDescriptor);
    descriptor: (Lorg/apache/cassandra/hints/HintsDescriptor;)Z
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=3, locals=3, args_size=2
        start local 0 // org.apache.cassandra.hints.HintsDispatchExecutor$DispatchHintsTask this
        start local 1 // org.apache.cassandra.hints.HintsDescriptor descriptor
         0: .line 256
            getstatic org.apache.cassandra.hints.HintsDispatchExecutor.logger:Lorg/slf4j/Logger;
            ldc "Dispatching hints file {}"
            aload 1 /* descriptor */
            invokevirtual org.apache.cassandra.hints.HintsDescriptor.fileName:()Ljava/lang/String;
            invokeinterface org.slf4j.Logger.trace:(Ljava/lang/String;Ljava/lang/Object;)V
         1: .line 258
            getstatic org.apache.cassandra.service.StorageService.instance:Lorg/apache/cassandra/service/StorageService;
            aload 0 /* this */
            getfield org.apache.cassandra.hints.HintsDispatchExecutor$DispatchHintsTask.hostId:Ljava/util/UUID;
            invokevirtual org.apache.cassandra.service.StorageService.getEndpointForHostId:(Ljava/util/UUID;)Ljava/net/InetAddress;
            astore 2 /* address */
        start local 2 // java.net.InetAddress address
         2: .line 259
            aload 2 /* address */
            ifnull 4
         3: .line 260
            aload 0 /* this */
            aload 1 /* descriptor */
            aload 2 /* address */
            invokevirtual org.apache.cassandra.hints.HintsDispatchExecutor$DispatchHintsTask.deliver:(Lorg/apache/cassandra/hints/HintsDescriptor;Ljava/net/InetAddress;)Z
            ireturn
         4: .line 263
      StackMap locals: java.net.InetAddress
      StackMap stack:
            aload 0 /* this */
            aload 1 /* descriptor */
            invokevirtual org.apache.cassandra.hints.HintsDispatchExecutor$DispatchHintsTask.convert:(Lorg/apache/cassandra/hints/HintsDescriptor;)V
         5: .line 264
            iconst_1
            ireturn
        end local 2 // java.net.InetAddress address
        end local 1 // org.apache.cassandra.hints.HintsDescriptor descriptor
        end local 0 // org.apache.cassandra.hints.HintsDispatchExecutor$DispatchHintsTask this
      LocalVariableTable:
        Start  End  Slot        Name  Signature
            0    6     0        this  Lorg/apache/cassandra/hints/HintsDispatchExecutor$DispatchHintsTask;
            0    6     1  descriptor  Lorg/apache/cassandra/hints/HintsDescriptor;
            2    6     2     address  Ljava/net/InetAddress;
    MethodParameters:
            Name  Flags
      descriptor  

  private boolean deliver(org.apache.cassandra.hints.HintsDescriptor, java.net.InetAddress);
    descriptor: (Lorg/apache/cassandra/hints/HintsDescriptor;Ljava/net/InetAddress;)Z
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=6, locals=9, args_size=3
        start local 0 // org.apache.cassandra.hints.HintsDispatchExecutor$DispatchHintsTask this
        start local 1 // org.apache.cassandra.hints.HintsDescriptor descriptor
        start local 2 // java.net.InetAddress address
         0: .line 269
            new java.io.File
            dup
            aload 0 /* this */
            getfield org.apache.cassandra.hints.HintsDispatchExecutor$DispatchHintsTask.this$0:Lorg/apache/cassandra/hints/HintsDispatchExecutor;
            getfield org.apache.cassandra.hints.HintsDispatchExecutor.hintsDirectory:Ljava/io/File;
            aload 1 /* descriptor */
            invokevirtual org.apache.cassandra.hints.HintsDescriptor.fileName:()Ljava/lang/String;
            invokespecial java.io.File.<init>:(Ljava/io/File;Ljava/lang/String;)V
            astore 3 /* file */
        start local 3 // java.io.File file
         1: .line 270
            aload 0 /* this */
            getfield org.apache.cassandra.hints.HintsDispatchExecutor$DispatchHintsTask.store:Lorg/apache/cassandra/hints/HintsStore;
            aload 1 /* descriptor */
            invokevirtual org.apache.cassandra.hints.HintsStore.getDispatchOffset:(Lorg/apache/cassandra/hints/HintsDescriptor;)Lorg/apache/cassandra/hints/InputPosition;
            astore 4 /* offset */
        start local 4 // org.apache.cassandra.hints.InputPosition offset
         2: .line 272
            aload 0 /* this */
            aload 2 /* address */
            invokedynamic getAsBoolean(Lorg/apache/cassandra/hints/HintsDispatchExecutor$DispatchHintsTask;Ljava/net/InetAddress;)Ljava/util/function/BooleanSupplier;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  ()Z
                  org/apache/cassandra/hints/HintsDispatchExecutor$DispatchHintsTask.lambda$0(Ljava/net/InetAddress;)Z (7)
                  ()Z
            astore 5 /* shouldAbort */
        start local 5 // java.util.function.BooleanSupplier shouldAbort
         3: .line 273
            aconst_null
            astore 6
            aconst_null
            astore 7
         4: aload 3 /* file */
            aload 0 /* this */
            getfield org.apache.cassandra.hints.HintsDispatchExecutor$DispatchHintsTask.rateLimiter:Lcom/google/common/util/concurrent/RateLimiter;
            aload 2 /* address */
            aload 1 /* descriptor */
            getfield org.apache.cassandra.hints.HintsDescriptor.hostId:Ljava/util/UUID;
            aload 5 /* shouldAbort */
            invokestatic org.apache.cassandra.hints.HintsDispatcher.create:(Ljava/io/File;Lcom/google/common/util/concurrent/RateLimiter;Ljava/net/InetAddress;Ljava/util/UUID;Ljava/util/function/BooleanSupplier;)Lorg/apache/cassandra/hints/HintsDispatcher;
            astore 8 /* dispatcher */
        start local 8 // org.apache.cassandra.hints.HintsDispatcher dispatcher
         5: .line 275
            aload 4 /* offset */
            ifnull 7
         6: .line 276
            aload 8 /* dispatcher */
            aload 4 /* offset */
            invokevirtual org.apache.cassandra.hints.HintsDispatcher.seek:(Lorg/apache/cassandra/hints/InputPosition;)V
         7: .line 278
      StackMap locals: org.apache.cassandra.hints.HintsDispatchExecutor$DispatchHintsTask org.apache.cassandra.hints.HintsDescriptor java.net.InetAddress java.io.File org.apache.cassandra.hints.InputPosition java.util.function.BooleanSupplier java.lang.Throwable java.lang.Throwable org.apache.cassandra.hints.HintsDispatcher
      StackMap stack:
            aload 8 /* dispatcher */
            invokevirtual org.apache.cassandra.hints.HintsDispatcher.dispatch:()Z
            ifeq 13
         8: .line 280
            aload 0 /* this */
            getfield org.apache.cassandra.hints.HintsDispatchExecutor$DispatchHintsTask.store:Lorg/apache/cassandra/hints/HintsStore;
            aload 1 /* descriptor */
            invokevirtual org.apache.cassandra.hints.HintsStore.delete:(Lorg/apache/cassandra/hints/HintsDescriptor;)V
         9: .line 281
            aload 0 /* this */
            getfield org.apache.cassandra.hints.HintsDispatchExecutor$DispatchHintsTask.store:Lorg/apache/cassandra/hints/HintsStore;
            aload 1 /* descriptor */
            invokevirtual org.apache.cassandra.hints.HintsStore.cleanUp:(Lorg/apache/cassandra/hints/HintsDescriptor;)V
        10: .line 282
            getstatic org.apache.cassandra.hints.HintsDispatchExecutor.logger:Lorg/slf4j/Logger;
            ldc "Finished hinted handoff of file {} to endpoint {}: {}"
            iconst_3
            anewarray java.lang.Object
            dup
            iconst_0
            aload 1 /* descriptor */
            invokevirtual org.apache.cassandra.hints.HintsDescriptor.fileName:()Ljava/lang/String;
            aastore
            dup
            iconst_1
            aload 2 /* address */
            aastore
            dup
            iconst_2
            aload 0 /* this */
            getfield org.apache.cassandra.hints.HintsDispatchExecutor$DispatchHintsTask.hostId:Ljava/util/UUID;
            aastore
            invokeinterface org.slf4j.Logger.info:(Ljava/lang/String;[Ljava/lang/Object;)V
        11: .line 292
            aload 8 /* dispatcher */
            ifnull 12
            aload 8 /* dispatcher */
            invokevirtual org.apache.cassandra.hints.HintsDispatcher.close:()V
        12: .line 283
      StackMap locals:
      StackMap stack:
            iconst_1
            ireturn
        13: .line 287
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield org.apache.cassandra.hints.HintsDispatchExecutor$DispatchHintsTask.store:Lorg/apache/cassandra/hints/HintsStore;
            aload 1 /* descriptor */
            aload 8 /* dispatcher */
            invokevirtual org.apache.cassandra.hints.HintsDispatcher.dispatchPosition:()Lorg/apache/cassandra/hints/InputPosition;
            invokevirtual org.apache.cassandra.hints.HintsStore.markDispatchOffset:(Lorg/apache/cassandra/hints/HintsDescriptor;Lorg/apache/cassandra/hints/InputPosition;)V
        14: .line 288
            aload 0 /* this */
            getfield org.apache.cassandra.hints.HintsDispatchExecutor$DispatchHintsTask.store:Lorg/apache/cassandra/hints/HintsStore;
            aload 1 /* descriptor */
            invokevirtual org.apache.cassandra.hints.HintsStore.offerFirst:(Lorg/apache/cassandra/hints/HintsDescriptor;)V
        15: .line 289
            getstatic org.apache.cassandra.hints.HintsDispatchExecutor.logger:Lorg/slf4j/Logger;
            ldc "Finished hinted handoff of file {} to endpoint {}: {}, partially"
            iconst_3
            anewarray java.lang.Object
            dup
            iconst_0
            aload 1 /* descriptor */
            invokevirtual org.apache.cassandra.hints.HintsDescriptor.fileName:()Ljava/lang/String;
            aastore
            dup
            iconst_1
            aload 2 /* address */
            aastore
            dup
            iconst_2
            aload 0 /* this */
            getfield org.apache.cassandra.hints.HintsDispatchExecutor$DispatchHintsTask.hostId:Ljava/util/UUID;
            aastore
            invokeinterface org.slf4j.Logger.info:(Ljava/lang/String;[Ljava/lang/Object;)V
        16: .line 292
            aload 8 /* dispatcher */
            ifnull 17
            aload 8 /* dispatcher */
            invokevirtual org.apache.cassandra.hints.HintsDispatcher.close:()V
        17: .line 290
      StackMap locals:
      StackMap stack:
            iconst_0
            ireturn
      StackMap locals:
      StackMap stack: java.lang.Throwable
        18: astore 6
        19: .line 292
            aload 8 /* dispatcher */
            ifnull 20
            aload 8 /* dispatcher */
            invokevirtual org.apache.cassandra.hints.HintsDispatcher.close:()V
        end local 8 // org.apache.cassandra.hints.HintsDispatcher dispatcher
      StackMap locals:
      StackMap stack:
        20: aload 6
            athrow
      StackMap locals:
      StackMap stack: java.lang.Throwable
        21: astore 7
            aload 6
            ifnonnull 22
            aload 7
            astore 6
            goto 23
      StackMap locals:
      StackMap stack:
        22: aload 6
            aload 7
            if_acmpeq 23
            aload 6
            aload 7
            invokevirtual java.lang.Throwable.addSuppressed:(Ljava/lang/Throwable;)V
      StackMap locals:
      StackMap stack:
        23: aload 6
            athrow
        end local 5 // java.util.function.BooleanSupplier shouldAbort
        end local 4 // org.apache.cassandra.hints.InputPosition offset
        end local 3 // java.io.File file
        end local 2 // java.net.InetAddress address
        end local 1 // org.apache.cassandra.hints.HintsDescriptor descriptor
        end local 0 // org.apache.cassandra.hints.HintsDispatchExecutor$DispatchHintsTask this
      LocalVariableTable:
        Start  End  Slot         Name  Signature
            0   24     0         this  Lorg/apache/cassandra/hints/HintsDispatchExecutor$DispatchHintsTask;
            0   24     1   descriptor  Lorg/apache/cassandra/hints/HintsDescriptor;
            0   24     2      address  Ljava/net/InetAddress;
            1   24     3         file  Ljava/io/File;
            2   24     4       offset  Lorg/apache/cassandra/hints/InputPosition;
            3   24     5  shouldAbort  Ljava/util/function/BooleanSupplier;
            5   20     8   dispatcher  Lorg/apache/cassandra/hints/HintsDispatcher;
      Exception table:
        from    to  target  type
           5    11      18  any
          13    16      18  any
           4    12      21  any
          13    17      21  any
          18    21      21  any
    MethodParameters:
            Name  Flags
      descriptor  
      address     

  private void convert(org.apache.cassandra.hints.HintsDescriptor);
    descriptor: (Lorg/apache/cassandra/hints/HintsDescriptor;)V
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=4, locals=6, args_size=2
        start local 0 // org.apache.cassandra.hints.HintsDispatchExecutor$DispatchHintsTask this
        start local 1 // org.apache.cassandra.hints.HintsDescriptor descriptor
         0: .line 298
            new java.io.File
            dup
            aload 0 /* this */
            getfield org.apache.cassandra.hints.HintsDispatchExecutor$DispatchHintsTask.this$0:Lorg/apache/cassandra/hints/HintsDispatchExecutor;
            getfield org.apache.cassandra.hints.HintsDispatchExecutor.hintsDirectory:Ljava/io/File;
            aload 1 /* descriptor */
            invokevirtual org.apache.cassandra.hints.HintsDescriptor.fileName:()Ljava/lang/String;
            invokespecial java.io.File.<init>:(Ljava/io/File;Ljava/lang/String;)V
            astore 2 /* file */
        start local 2 // java.io.File file
         1: .line 300
            aconst_null
            astore 3
            aconst_null
            astore 4
         2: aload 2 /* file */
            aload 0 /* this */
            getfield org.apache.cassandra.hints.HintsDispatchExecutor$DispatchHintsTask.rateLimiter:Lcom/google/common/util/concurrent/RateLimiter;
            invokestatic org.apache.cassandra.hints.HintsReader.open:(Ljava/io/File;Lcom/google/common/util/concurrent/RateLimiter;)Lorg/apache/cassandra/hints/HintsReader;
            astore 5 /* reader */
        start local 5 // org.apache.cassandra.hints.HintsReader reader
         3: .line 302
            aload 5 /* reader */
            invokedynamic accept()Ljava/util/function/Consumer;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  (Ljava/lang/Object;)V
                  org/apache/cassandra/hints/HintsDispatchExecutor$DispatchHintsTask.lambda$1(Lorg/apache/cassandra/hints/HintsReader$Page;)V (6)
                  (Lorg/apache/cassandra/hints/HintsReader$Page;)V
            invokevirtual org.apache.cassandra.hints.HintsReader.forEach:(Ljava/util/function/Consumer;)V
         4: .line 303
            aload 0 /* this */
            getfield org.apache.cassandra.hints.HintsDispatchExecutor$DispatchHintsTask.store:Lorg/apache/cassandra/hints/HintsStore;
            aload 1 /* descriptor */
            invokevirtual org.apache.cassandra.hints.HintsStore.delete:(Lorg/apache/cassandra/hints/HintsDescriptor;)V
         5: .line 304
            aload 0 /* this */
            getfield org.apache.cassandra.hints.HintsDispatchExecutor$DispatchHintsTask.store:Lorg/apache/cassandra/hints/HintsStore;
            aload 1 /* descriptor */
            invokevirtual org.apache.cassandra.hints.HintsStore.cleanUp:(Lorg/apache/cassandra/hints/HintsDescriptor;)V
         6: .line 305
            getstatic org.apache.cassandra.hints.HintsDispatchExecutor.logger:Lorg/slf4j/Logger;
            ldc "Finished converting hints file {}"
            aload 1 /* descriptor */
            invokevirtual org.apache.cassandra.hints.HintsDescriptor.fileName:()Ljava/lang/String;
            invokeinterface org.slf4j.Logger.info:(Ljava/lang/String;Ljava/lang/Object;)V
         7: .line 306
            aload 5 /* reader */
            ifnull 13
            aload 5 /* reader */
            invokevirtual org.apache.cassandra.hints.HintsReader.close:()V
            goto 13
      StackMap locals: org.apache.cassandra.hints.HintsDispatchExecutor$DispatchHintsTask org.apache.cassandra.hints.HintsDescriptor java.io.File java.lang.Throwable java.lang.Throwable org.apache.cassandra.hints.HintsReader
      StackMap stack: java.lang.Throwable
         8: astore 3
            aload 5 /* reader */
            ifnull 9
            aload 5 /* reader */
            invokevirtual org.apache.cassandra.hints.HintsReader.close:()V
        end local 5 // org.apache.cassandra.hints.HintsReader reader
      StackMap locals:
      StackMap stack:
         9: aload 3
            athrow
      StackMap locals:
      StackMap stack: java.lang.Throwable
        10: astore 4
            aload 3
            ifnonnull 11
            aload 4
            astore 3
            goto 12
      StackMap locals:
      StackMap stack:
        11: aload 3
            aload 4
            if_acmpeq 12
            aload 3
            aload 4
            invokevirtual java.lang.Throwable.addSuppressed:(Ljava/lang/Throwable;)V
      StackMap locals:
      StackMap stack:
        12: aload 3
            athrow
        13: .line 307
      StackMap locals:
      StackMap stack:
            return
        end local 2 // java.io.File file
        end local 1 // org.apache.cassandra.hints.HintsDescriptor descriptor
        end local 0 // org.apache.cassandra.hints.HintsDispatchExecutor$DispatchHintsTask this
      LocalVariableTable:
        Start  End  Slot        Name  Signature
            0   14     0        this  Lorg/apache/cassandra/hints/HintsDispatchExecutor$DispatchHintsTask;
            0   14     1  descriptor  Lorg/apache/cassandra/hints/HintsDescriptor;
            1   14     2        file  Ljava/io/File;
            3    9     5      reader  Lorg/apache/cassandra/hints/HintsReader;
      Exception table:
        from    to  target  type
           3     7       8  any
           2    10      10  any
    MethodParameters:
            Name  Flags
      descriptor  

  private boolean lambda$0(java.net.InetAddress);
    descriptor: (Ljava/net/InetAddress;)Z
    flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // org.apache.cassandra.hints.HintsDispatchExecutor$DispatchHintsTask this
         0: .line 272
            aload 0 /* this */
            getfield org.apache.cassandra.hints.HintsDispatchExecutor$DispatchHintsTask.this$0:Lorg/apache/cassandra/hints/HintsDispatchExecutor;
            getfield org.apache.cassandra.hints.HintsDispatchExecutor.isAlive:Ljava/util/function/Function;
            aload 1
            invokeinterface java.util.function.Function.apply:(Ljava/lang/Object;)Ljava/lang/Object;
            checkcast java.lang.Boolean
            invokevirtual java.lang.Boolean.booleanValue:()Z
            ifeq 1
            aload 0 /* this */
            getfield org.apache.cassandra.hints.HintsDispatchExecutor$DispatchHintsTask.this$0:Lorg/apache/cassandra/hints/HintsDispatchExecutor;
            getfield org.apache.cassandra.hints.HintsDispatchExecutor.isPaused:Ljava/util/concurrent/atomic/AtomicBoolean;
            invokevirtual java.util.concurrent.atomic.AtomicBoolean.get:()Z
            ifne 1
            iconst_0
            goto 2
      StackMap locals:
      StackMap stack:
         1: iconst_1
      StackMap locals:
      StackMap stack: int
         2: ireturn
        end local 0 // org.apache.cassandra.hints.HintsDispatchExecutor$DispatchHintsTask this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    3     0  this  Lorg/apache/cassandra/hints/HintsDispatchExecutor$DispatchHintsTask;

  private static void lambda$1(org.apache.cassandra.hints.HintsReader$Page);
    descriptor: (Lorg/apache/cassandra/hints/HintsReader$Page;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=3, locals=1, args_size=1
        start local 0 // org.apache.cassandra.hints.HintsReader$Page page
         0: .line 302
            aload 0 /* page */
            invokevirtual org.apache.cassandra.hints.HintsReader$Page.hintsIterator:()Ljava/util/Iterator;
            getstatic org.apache.cassandra.hints.HintsService.instance:Lorg/apache/cassandra/hints/HintsService;
            dup
            invokevirtual java.lang.Object.getClass:()Ljava/lang/Class;
            pop
            invokedynamic accept(Lorg/apache/cassandra/hints/HintsService;)Ljava/util/function/Consumer;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  (Ljava/lang/Object;)V
                  org/apache/cassandra/hints/HintsService.writeForAllReplicas(Lorg/apache/cassandra/hints/Hint;)V (5)
                  (Lorg/apache/cassandra/hints/Hint;)V
            invokeinterface java.util.Iterator.forEachRemaining:(Ljava/util/function/Consumer;)V
            return
        end local 0 // org.apache.cassandra.hints.HintsReader$Page page
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  page  Lorg/apache/cassandra/hints/HintsReader$Page;
}
SourceFile: "HintsDispatchExecutor.java"
NestHost: org.apache.cassandra.hints.HintsDispatchExecutor
InnerClasses:
  public final Lookup = java.lang.invoke.MethodHandles$Lookup of java.lang.invoke.MethodHandles
  private final DispatchHintsTask = org.apache.cassandra.hints.HintsDispatchExecutor$DispatchHintsTask of org.apache.cassandra.hints.HintsDispatchExecutor
  final Page = org.apache.cassandra.hints.HintsReader$Page of org.apache.cassandra.hints.HintsReader