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.batchlog.BatchlogManager$ReplayingBatch
  minor version: 0
  major version: 59
  flags: flags: (0x0020) ACC_SUPER
  this_class: org.apache.cassandra.batchlog.BatchlogManager$ReplayingBatch
  super_class: java.lang.Object
{
  private final java.util.UUID id;
    descriptor: Ljava/util/UUID;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

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

  private final java.util.List<org.apache.cassandra.db.Mutation> mutations;
    descriptor: Ljava/util/List;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL
    Signature: Ljava/util/List<Lorg/apache/cassandra/db/Mutation;>;

  private final int replayedBytes;
    descriptor: I
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  private java.util.List<org.apache.cassandra.batchlog.BatchlogManager$ReplayingBatch$ReplayWriteResponseHandler<org.apache.cassandra.db.Mutation>> replayHandlers;
    descriptor: Ljava/util/List;
    flags: (0x0002) ACC_PRIVATE
    Signature: Ljava/util/List<Lorg/apache/cassandra/batchlog/BatchlogManager$ReplayingBatch$ReplayWriteResponseHandler<Lorg/apache/cassandra/db/Mutation;>;>;

  void <init>(java.util.UUID, int, java.util.List<java.nio.ByteBuffer>);
    descriptor: (Ljava/util/UUID;ILjava/util/List;)V
    flags: (0x0000) 
    Code:
      stack=4, locals=4, args_size=4
        start local 0 // org.apache.cassandra.batchlog.BatchlogManager$ReplayingBatch this
        start local 1 // java.util.UUID id
        start local 2 // int version
        start local 3 // java.util.List serializedMutations
         0: .line 314
            aload 0 /* this */
            invokespecial java.lang.Object.<init>:()V
         1: .line 316
            aload 0 /* this */
            aload 1 /* id */
            putfield org.apache.cassandra.batchlog.BatchlogManager$ReplayingBatch.id:Ljava/util/UUID;
         2: .line 317
            aload 0 /* this */
            aload 1 /* id */
            invokestatic org.apache.cassandra.utils.UUIDGen.unixTimestamp:(Ljava/util/UUID;)J
            putfield org.apache.cassandra.batchlog.BatchlogManager$ReplayingBatch.writtenAt:J
         3: .line 318
            aload 0 /* this */
            new java.util.ArrayList
            dup
            aload 3 /* serializedMutations */
            invokeinterface java.util.List.size:()I
            invokespecial java.util.ArrayList.<init>:(I)V
            putfield org.apache.cassandra.batchlog.BatchlogManager$ReplayingBatch.mutations:Ljava/util/List;
         4: .line 319
            aload 0 /* this */
            aload 0 /* this */
            iload 2 /* version */
            aload 3 /* serializedMutations */
            invokevirtual org.apache.cassandra.batchlog.BatchlogManager$ReplayingBatch.addMutations:(ILjava/util/List;)I
            putfield org.apache.cassandra.batchlog.BatchlogManager$ReplayingBatch.replayedBytes:I
         5: .line 320
            return
        end local 3 // java.util.List serializedMutations
        end local 2 // int version
        end local 1 // java.util.UUID id
        end local 0 // org.apache.cassandra.batchlog.BatchlogManager$ReplayingBatch this
      LocalVariableTable:
        Start  End  Slot                 Name  Signature
            0    6     0                 this  Lorg/apache/cassandra/batchlog/BatchlogManager$ReplayingBatch;
            0    6     1                   id  Ljava/util/UUID;
            0    6     2              version  I
            0    6     3  serializedMutations  Ljava/util/List<Ljava/nio/ByteBuffer;>;
    Exceptions:
      throws java.io.IOException
    Signature: (Ljava/util/UUID;ILjava/util/List<Ljava/nio/ByteBuffer;>;)V
    MethodParameters:
                     Name  Flags
      id                   
      version              
      serializedMutations  

  public int replay(com.google.common.util.concurrent.RateLimiter, java.util.Set<java.net.InetAddress>);
    descriptor: (Lcom/google/common/util/concurrent/RateLimiter;Ljava/util/Set;)I
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=5, locals=4, args_size=3
        start local 0 // org.apache.cassandra.batchlog.BatchlogManager$ReplayingBatch this
        start local 1 // com.google.common.util.concurrent.RateLimiter rateLimiter
        start local 2 // java.util.Set hintedNodes
         0: .line 324
            getstatic org.apache.cassandra.batchlog.BatchlogManager.logger:Lorg/slf4j/Logger;
            ldc "Replaying batch {}"
            aload 0 /* this */
            getfield org.apache.cassandra.batchlog.BatchlogManager$ReplayingBatch.id:Ljava/util/UUID;
            invokeinterface org.slf4j.Logger.trace:(Ljava/lang/String;Ljava/lang/Object;)V
         1: .line 326
            aload 0 /* this */
            getfield org.apache.cassandra.batchlog.BatchlogManager$ReplayingBatch.mutations:Ljava/util/List;
            invokeinterface java.util.List.isEmpty:()Z
            ifeq 3
         2: .line 327
            iconst_0
            ireturn
         3: .line 329
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield org.apache.cassandra.batchlog.BatchlogManager$ReplayingBatch.mutations:Ljava/util/List;
            invokestatic org.apache.cassandra.batchlog.BatchlogManager$ReplayingBatch.gcgs:(Ljava/util/Collection;)I
            istore 3 /* gcgs */
        start local 3 // int gcgs
         4: .line 330
            getstatic java.util.concurrent.TimeUnit.MILLISECONDS:Ljava/util/concurrent/TimeUnit;
            aload 0 /* this */
            getfield org.apache.cassandra.batchlog.BatchlogManager$ReplayingBatch.writtenAt:J
            invokevirtual java.util.concurrent.TimeUnit.toSeconds:(J)J
            iload 3 /* gcgs */
            i2l
            ladd
            invokestatic org.apache.cassandra.utils.FBUtilities.nowInSeconds:()I
            i2l
            lcmp
            ifgt 6
         5: .line 331
            iconst_0
            ireturn
         6: .line 333
      StackMap locals: int
      StackMap stack:
            aload 0 /* this */
            aload 0 /* this */
            getfield org.apache.cassandra.batchlog.BatchlogManager$ReplayingBatch.mutations:Ljava/util/List;
            aload 0 /* this */
            getfield org.apache.cassandra.batchlog.BatchlogManager$ReplayingBatch.writtenAt:J
            aload 2 /* hintedNodes */
            invokestatic org.apache.cassandra.batchlog.BatchlogManager$ReplayingBatch.sendReplays:(Ljava/util/List;JLjava/util/Set;)Ljava/util/List;
            putfield org.apache.cassandra.batchlog.BatchlogManager$ReplayingBatch.replayHandlers:Ljava/util/List;
         7: .line 335
            aload 1 /* rateLimiter */
            aload 0 /* this */
            getfield org.apache.cassandra.batchlog.BatchlogManager$ReplayingBatch.replayedBytes:I
            invokevirtual com.google.common.util.concurrent.RateLimiter.acquire:(I)D
            pop2
         8: .line 337
            aload 0 /* this */
            getfield org.apache.cassandra.batchlog.BatchlogManager$ReplayingBatch.replayHandlers:Ljava/util/List;
            invokeinterface java.util.List.size:()I
            ireturn
        end local 3 // int gcgs
        end local 2 // java.util.Set hintedNodes
        end local 1 // com.google.common.util.concurrent.RateLimiter rateLimiter
        end local 0 // org.apache.cassandra.batchlog.BatchlogManager$ReplayingBatch this
      LocalVariableTable:
        Start  End  Slot         Name  Signature
            0    9     0         this  Lorg/apache/cassandra/batchlog/BatchlogManager$ReplayingBatch;
            0    9     1  rateLimiter  Lcom/google/common/util/concurrent/RateLimiter;
            0    9     2  hintedNodes  Ljava/util/Set<Ljava/net/InetAddress;>;
            4    9     3         gcgs  I
    Exceptions:
      throws java.io.IOException
    Signature: (Lcom/google/common/util/concurrent/RateLimiter;Ljava/util/Set<Ljava/net/InetAddress;>;)I
    MethodParameters:
             Name  Flags
      rateLimiter  
      hintedNodes  

  public void finish(java.util.Set<java.net.InetAddress>);
    descriptor: (Ljava/util/Set;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=5, args_size=2
        start local 0 // org.apache.cassandra.batchlog.BatchlogManager$ReplayingBatch this
        start local 1 // java.util.Set hintedNodes
         0: .line 342
            iconst_0
            istore 2 /* i */
        start local 2 // int i
         1: goto 11
         2: .line 344
      StackMap locals: int
      StackMap stack:
            aload 0 /* this */
            getfield org.apache.cassandra.batchlog.BatchlogManager$ReplayingBatch.replayHandlers:Ljava/util/List;
            iload 2 /* i */
            invokeinterface java.util.List.get:(I)Ljava/lang/Object;
            checkcast org.apache.cassandra.batchlog.BatchlogManager$ReplayingBatch$ReplayWriteResponseHandler
            astore 3 /* handler */
        start local 3 // org.apache.cassandra.batchlog.BatchlogManager$ReplayingBatch$ReplayWriteResponseHandler handler
         3: .line 347
            aload 3 /* handler */
            invokevirtual org.apache.cassandra.batchlog.BatchlogManager$ReplayingBatch$ReplayWriteResponseHandler.get:()V
         4: .line 348
            goto 10
         5: .line 349
      StackMap locals: org.apache.cassandra.batchlog.BatchlogManager$ReplayingBatch java.util.Set int org.apache.cassandra.batchlog.BatchlogManager$ReplayingBatch$ReplayWriteResponseHandler
      StackMap stack: org.apache.cassandra.exceptions.RequestExecutionException
            astore 4 /* e */
        start local 4 // org.apache.cassandra.exceptions.RequestExecutionException e
         6: .line 351
            getstatic org.apache.cassandra.batchlog.BatchlogManager.logger:Lorg/slf4j/Logger;
            ldc "Failed replaying a batched mutation to a node, will write a hint"
            invokeinterface org.slf4j.Logger.trace:(Ljava/lang/String;)V
         7: .line 352
            getstatic org.apache.cassandra.batchlog.BatchlogManager.logger:Lorg/slf4j/Logger;
            ldc "Failure was : {}"
            aload 4 /* e */
            invokevirtual org.apache.cassandra.exceptions.RequestExecutionException.getMessage:()Ljava/lang/String;
            invokeinterface org.slf4j.Logger.trace:(Ljava/lang/String;Ljava/lang/Object;)V
         8: .line 354
            aload 0 /* this */
            iload 2 /* i */
            aload 1 /* hintedNodes */
            invokevirtual org.apache.cassandra.batchlog.BatchlogManager$ReplayingBatch.writeHintsForUndeliveredEndpoints:(ILjava/util/Set;)V
         9: .line 355
            return
        end local 4 // org.apache.cassandra.exceptions.RequestExecutionException e
        end local 3 // org.apache.cassandra.batchlog.BatchlogManager$ReplayingBatch$ReplayWriteResponseHandler handler
        10: .line 342
      StackMap locals:
      StackMap stack:
            iinc 2 /* i */ 1
      StackMap locals:
      StackMap stack:
        11: iload 2 /* i */
            aload 0 /* this */
            getfield org.apache.cassandra.batchlog.BatchlogManager$ReplayingBatch.replayHandlers:Ljava/util/List;
            invokeinterface java.util.List.size:()I
            if_icmplt 2
        end local 2 // int i
        12: .line 358
            return
        end local 1 // java.util.Set hintedNodes
        end local 0 // org.apache.cassandra.batchlog.BatchlogManager$ReplayingBatch this
      LocalVariableTable:
        Start  End  Slot         Name  Signature
            0   13     0         this  Lorg/apache/cassandra/batchlog/BatchlogManager$ReplayingBatch;
            0   13     1  hintedNodes  Ljava/util/Set<Ljava/net/InetAddress;>;
            1   12     2            i  I
            3   10     3      handler  Lorg/apache/cassandra/batchlog/BatchlogManager$ReplayingBatch$ReplayWriteResponseHandler<Lorg/apache/cassandra/db/Mutation;>;
            6   10     4            e  Lorg/apache/cassandra/exceptions/RequestExecutionException;
      Exception table:
        from    to  target  type
           3     4       5  Class org.apache.cassandra.exceptions.WriteTimeoutException
           3     4       5  Class org.apache.cassandra.exceptions.WriteFailureException
    Signature: (Ljava/util/Set<Ljava/net/InetAddress;>;)V
    MethodParameters:
             Name  Flags
      hintedNodes  

  private int addMutations(int, java.util.List<java.nio.ByteBuffer>);
    descriptor: (ILjava/util/List;)I
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=4, locals=9, args_size=3
        start local 0 // org.apache.cassandra.batchlog.BatchlogManager$ReplayingBatch this
        start local 1 // int version
        start local 2 // java.util.List serializedMutations
         0: .line 362
            iconst_0
            istore 3 /* ret */
        start local 3 // int ret
         1: .line 363
            aload 2 /* serializedMutations */
            invokeinterface java.util.List.iterator:()Ljava/util/Iterator;
            astore 5
            goto 13
      StackMap locals: org.apache.cassandra.batchlog.BatchlogManager$ReplayingBatch int java.util.List int top java.util.Iterator
      StackMap stack:
         2: aload 5
            invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
            checkcast java.nio.ByteBuffer
            astore 4 /* serializedMutation */
        start local 4 // java.nio.ByteBuffer serializedMutation
         3: .line 365
            iload 3 /* ret */
            aload 4 /* serializedMutation */
            invokevirtual java.nio.ByteBuffer.remaining:()I
            iadd
            istore 3 /* ret */
         4: .line 366
            aconst_null
            astore 6
            aconst_null
            astore 7
         5: new org.apache.cassandra.io.util.DataInputBuffer
            dup
            aload 4 /* serializedMutation */
            iconst_1
            invokespecial org.apache.cassandra.io.util.DataInputBuffer.<init>:(Ljava/nio/ByteBuffer;Z)V
            astore 8 /* in */
        start local 8 // org.apache.cassandra.io.util.DataInputBuffer in
         6: .line 368
            aload 0 /* this */
            getstatic org.apache.cassandra.db.Mutation.serializer:Lorg/apache/cassandra/db/Mutation$MutationSerializer;
            aload 8 /* in */
            iload 1 /* version */
            invokevirtual org.apache.cassandra.db.Mutation$MutationSerializer.deserialize:(Lorg/apache/cassandra/io/util/DataInputPlus;I)Lorg/apache/cassandra/db/Mutation;
            invokevirtual org.apache.cassandra.batchlog.BatchlogManager$ReplayingBatch.addMutation:(Lorg/apache/cassandra/db/Mutation;)V
         7: .line 369
            aload 8 /* in */
            ifnull 13
            aload 8 /* in */
            invokevirtual org.apache.cassandra.io.util.DataInputBuffer.close:()V
            goto 13
      StackMap locals: org.apache.cassandra.batchlog.BatchlogManager$ReplayingBatch int java.util.List int java.nio.ByteBuffer java.util.Iterator java.lang.Throwable java.lang.Throwable org.apache.cassandra.io.util.DataInputBuffer
      StackMap stack: java.lang.Throwable
         8: astore 6
            aload 8 /* in */
            ifnull 9
            aload 8 /* in */
            invokevirtual org.apache.cassandra.io.util.DataInputBuffer.close:()V
        end local 8 // org.apache.cassandra.io.util.DataInputBuffer in
      StackMap locals:
      StackMap stack:
         9: aload 6
            athrow
      StackMap locals:
      StackMap stack: java.lang.Throwable
        10: astore 7
            aload 6
            ifnonnull 11
            aload 7
            astore 6
            goto 12
      StackMap locals:
      StackMap stack:
        11: aload 6
            aload 7
            if_acmpeq 12
            aload 6
            aload 7
            invokevirtual java.lang.Throwable.addSuppressed:(Ljava/lang/Throwable;)V
      StackMap locals:
      StackMap stack:
        12: aload 6
            athrow
        end local 4 // java.nio.ByteBuffer serializedMutation
        13: .line 363
      StackMap locals: org.apache.cassandra.batchlog.BatchlogManager$ReplayingBatch int java.util.List int top java.util.Iterator
      StackMap stack:
            aload 5
            invokeinterface java.util.Iterator.hasNext:()Z
            ifne 2
        14: .line 372
            iload 3 /* ret */
            ireturn
        end local 3 // int ret
        end local 2 // java.util.List serializedMutations
        end local 1 // int version
        end local 0 // org.apache.cassandra.batchlog.BatchlogManager$ReplayingBatch this
      LocalVariableTable:
        Start  End  Slot                 Name  Signature
            0   15     0                 this  Lorg/apache/cassandra/batchlog/BatchlogManager$ReplayingBatch;
            0   15     1              version  I
            0   15     2  serializedMutations  Ljava/util/List<Ljava/nio/ByteBuffer;>;
            1   15     3                  ret  I
            3   13     4   serializedMutation  Ljava/nio/ByteBuffer;
            6    9     8                   in  Lorg/apache/cassandra/io/util/DataInputBuffer;
      Exception table:
        from    to  target  type
           6     7       8  any
           5    10      10  any
    Exceptions:
      throws java.io.IOException
    Signature: (ILjava/util/List<Ljava/nio/ByteBuffer;>;)I
    MethodParameters:
                     Name  Flags
      version              
      serializedMutations  

  private void addMutation(org.apache.cassandra.db.Mutation);
    descriptor: (Lorg/apache/cassandra/db/Mutation;)V
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=4, locals=4, args_size=2
        start local 0 // org.apache.cassandra.batchlog.BatchlogManager$ReplayingBatch this
        start local 1 // org.apache.cassandra.db.Mutation mutation
         0: .line 380
            aload 1 /* mutation */
            invokevirtual org.apache.cassandra.db.Mutation.getColumnFamilyIds:()Ljava/util/Collection;
            invokeinterface java.util.Collection.iterator:()Ljava/util/Iterator;
            astore 3
            goto 4
      StackMap locals: org.apache.cassandra.batchlog.BatchlogManager$ReplayingBatch org.apache.cassandra.db.Mutation top java.util.Iterator
      StackMap stack:
         1: aload 3
            invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
            checkcast java.util.UUID
            astore 2 /* cfId */
        start local 2 // java.util.UUID cfId
         2: .line 381
            aload 0 /* this */
            getfield org.apache.cassandra.batchlog.BatchlogManager$ReplayingBatch.writtenAt:J
            aload 2 /* cfId */
            invokestatic org.apache.cassandra.db.SystemKeyspace.getTruncatedAt:(Ljava/util/UUID;)J
            lcmp
            ifgt 4
         3: .line 382
            aload 1 /* mutation */
            aload 2 /* cfId */
            invokevirtual org.apache.cassandra.db.Mutation.without:(Ljava/util/UUID;)Lorg/apache/cassandra/db/Mutation;
            astore 1 /* mutation */
        end local 2 // java.util.UUID cfId
         4: .line 380
      StackMap locals:
      StackMap stack:
            aload 3
            invokeinterface java.util.Iterator.hasNext:()Z
            ifne 1
         5: .line 384
            aload 1 /* mutation */
            invokevirtual org.apache.cassandra.db.Mutation.isEmpty:()Z
            ifne 7
         6: .line 385
            aload 0 /* this */
            getfield org.apache.cassandra.batchlog.BatchlogManager$ReplayingBatch.mutations:Ljava/util/List;
            aload 1 /* mutation */
            invokeinterface java.util.List.add:(Ljava/lang/Object;)Z
            pop
         7: .line 386
      StackMap locals: org.apache.cassandra.batchlog.BatchlogManager$ReplayingBatch org.apache.cassandra.db.Mutation
      StackMap stack:
            return
        end local 1 // org.apache.cassandra.db.Mutation mutation
        end local 0 // org.apache.cassandra.batchlog.BatchlogManager$ReplayingBatch this
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0    8     0      this  Lorg/apache/cassandra/batchlog/BatchlogManager$ReplayingBatch;
            0    8     1  mutation  Lorg/apache/cassandra/db/Mutation;
            2    4     2      cfId  Ljava/util/UUID;
    MethodParameters:
          Name  Flags
      mutation  

  private void writeHintsForUndeliveredEndpoints(int, java.util.Set<java.net.InetAddress>);
    descriptor: (ILjava/util/Set;)V
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=5, locals=7, args_size=3
        start local 0 // org.apache.cassandra.batchlog.BatchlogManager$ReplayingBatch this
        start local 1 // int startFrom
        start local 2 // java.util.Set hintedNodes
         0: .line 390
            aload 0 /* this */
            getfield org.apache.cassandra.batchlog.BatchlogManager$ReplayingBatch.mutations:Ljava/util/List;
            invokestatic org.apache.cassandra.batchlog.BatchlogManager$ReplayingBatch.gcgs:(Ljava/util/Collection;)I
            istore 3 /* gcgs */
        start local 3 // int gcgs
         1: .line 393
            getstatic java.util.concurrent.TimeUnit.MILLISECONDS:Ljava/util/concurrent/TimeUnit;
            aload 0 /* this */
            getfield org.apache.cassandra.batchlog.BatchlogManager$ReplayingBatch.writtenAt:J
            invokevirtual java.util.concurrent.TimeUnit.toSeconds:(J)J
            iload 3 /* gcgs */
            i2l
            ladd
            invokestatic org.apache.cassandra.utils.FBUtilities.nowInSeconds:()I
            i2l
            lcmp
            ifgt 3
         2: .line 394
            return
         3: .line 396
      StackMap locals: int
      StackMap stack:
            iload 1 /* startFrom */
            istore 4 /* i */
        start local 4 // int i
         4: goto 13
         5: .line 398
      StackMap locals: int
      StackMap stack:
            aload 0 /* this */
            getfield org.apache.cassandra.batchlog.BatchlogManager$ReplayingBatch.replayHandlers:Ljava/util/List;
            iload 4 /* i */
            invokeinterface java.util.List.get:(I)Ljava/lang/Object;
            checkcast org.apache.cassandra.batchlog.BatchlogManager$ReplayingBatch$ReplayWriteResponseHandler
            astore 5 /* handler */
        start local 5 // org.apache.cassandra.batchlog.BatchlogManager$ReplayingBatch$ReplayWriteResponseHandler handler
         6: .line 399
            aload 0 /* this */
            getfield org.apache.cassandra.batchlog.BatchlogManager$ReplayingBatch.mutations:Ljava/util/List;
            iload 4 /* i */
            invokeinterface java.util.List.get:(I)Ljava/lang/Object;
            checkcast org.apache.cassandra.db.Mutation
            astore 6 /* undeliveredMutation */
        start local 6 // org.apache.cassandra.db.Mutation undeliveredMutation
         7: .line 401
            aload 5 /* handler */
            ifnull 12
         8: .line 403
            aload 2 /* hintedNodes */
            aload 5 /* handler */
            getfield org.apache.cassandra.batchlog.BatchlogManager$ReplayingBatch$ReplayWriteResponseHandler.undelivered:Ljava/util/Set;
            invokeinterface java.util.Set.addAll:(Ljava/util/Collection;)Z
            pop
         9: .line 404
            getstatic org.apache.cassandra.hints.HintsService.instance:Lorg/apache/cassandra/hints/HintsService;
            aload 5 /* handler */
            getfield org.apache.cassandra.batchlog.BatchlogManager$ReplayingBatch$ReplayWriteResponseHandler.undelivered:Ljava/util/Set;
            getstatic org.apache.cassandra.service.StorageService.instance:Lorg/apache/cassandra/service/StorageService;
            dup
            invokevirtual java.lang.Object.getClass:()Ljava/lang/Class;
            pop
            invokedynamic apply(Lorg/apache/cassandra/service/StorageService;)Lcom/google/common/base/Function;
              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;)Ljava/lang/Object;
                  org/apache/cassandra/service/StorageService.getHostIdForEndpoint(Ljava/net/InetAddress;)Ljava/util/UUID; (5)
                  (Ljava/net/InetAddress;)Ljava/util/UUID;
            invokestatic com.google.common.collect.Iterables.transform:(Ljava/lang/Iterable;Lcom/google/common/base/Function;)Ljava/lang/Iterable;
        10: .line 405
            aload 6 /* undeliveredMutation */
            aload 0 /* this */
            getfield org.apache.cassandra.batchlog.BatchlogManager$ReplayingBatch.writtenAt:J
            invokestatic org.apache.cassandra.hints.Hint.create:(Lorg/apache/cassandra/db/Mutation;J)Lorg/apache/cassandra/hints/Hint;
        11: .line 404
            invokevirtual org.apache.cassandra.hints.HintsService.write:(Ljava/lang/Iterable;Lorg/apache/cassandra/hints/Hint;)V
        end local 6 // org.apache.cassandra.db.Mutation undeliveredMutation
        end local 5 // org.apache.cassandra.batchlog.BatchlogManager$ReplayingBatch$ReplayWriteResponseHandler handler
        12: .line 396
      StackMap locals:
      StackMap stack:
            iinc 4 /* i */ 1
      StackMap locals:
      StackMap stack:
        13: iload 4 /* i */
            aload 0 /* this */
            getfield org.apache.cassandra.batchlog.BatchlogManager$ReplayingBatch.replayHandlers:Ljava/util/List;
            invokeinterface java.util.List.size:()I
            if_icmplt 5
        end local 4 // int i
        14: .line 408
            return
        end local 3 // int gcgs
        end local 2 // java.util.Set hintedNodes
        end local 1 // int startFrom
        end local 0 // org.apache.cassandra.batchlog.BatchlogManager$ReplayingBatch this
      LocalVariableTable:
        Start  End  Slot                 Name  Signature
            0   15     0                 this  Lorg/apache/cassandra/batchlog/BatchlogManager$ReplayingBatch;
            0   15     1            startFrom  I
            0   15     2          hintedNodes  Ljava/util/Set<Ljava/net/InetAddress;>;
            1   15     3                 gcgs  I
            4   14     4                    i  I
            6   12     5              handler  Lorg/apache/cassandra/batchlog/BatchlogManager$ReplayingBatch$ReplayWriteResponseHandler<Lorg/apache/cassandra/db/Mutation;>;
            7   12     6  undeliveredMutation  Lorg/apache/cassandra/db/Mutation;
    Signature: (ILjava/util/Set<Ljava/net/InetAddress;>;)V
    MethodParameters:
             Name  Flags
      startFrom    
      hintedNodes  

  private static java.util.List<org.apache.cassandra.batchlog.BatchlogManager$ReplayingBatch$ReplayWriteResponseHandler<org.apache.cassandra.db.Mutation>> sendReplays(java.util.List<org.apache.cassandra.db.Mutation>, long, java.util.Set<java.net.InetAddress>);
    descriptor: (Ljava/util/List;JLjava/util/Set;)Ljava/util/List;
    flags: (0x000a) ACC_PRIVATE, ACC_STATIC
    Code:
      stack=4, locals=8, args_size=3
        start local 0 // java.util.List mutations
        start local 1 // long writtenAt
        start local 3 // java.util.Set hintedNodes
         0: .line 414
            new java.util.ArrayList
            dup
            aload 0 /* mutations */
            invokeinterface java.util.List.size:()I
            invokespecial java.util.ArrayList.<init>:(I)V
            astore 4 /* handlers */
        start local 4 // java.util.List handlers
         1: .line 415
            aload 0 /* mutations */
            invokeinterface java.util.List.iterator:()Ljava/util/Iterator;
            astore 6
            goto 6
      StackMap locals: java.util.List long java.util.Set java.util.List top java.util.Iterator
      StackMap stack:
         2: aload 6
            invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
            checkcast org.apache.cassandra.db.Mutation
            astore 5 /* mutation */
        start local 5 // org.apache.cassandra.db.Mutation mutation
         3: .line 417
            aload 5 /* mutation */
            lload 1 /* writtenAt */
            aload 3 /* hintedNodes */
            invokestatic org.apache.cassandra.batchlog.BatchlogManager$ReplayingBatch.sendSingleReplayMutation:(Lorg/apache/cassandra/db/Mutation;JLjava/util/Set;)Lorg/apache/cassandra/batchlog/BatchlogManager$ReplayingBatch$ReplayWriteResponseHandler;
            astore 7 /* handler */
        start local 7 // org.apache.cassandra.batchlog.BatchlogManager$ReplayingBatch$ReplayWriteResponseHandler handler
         4: .line 418
            aload 7 /* handler */
            ifnull 6
         5: .line 419
            aload 4 /* handlers */
            aload 7 /* handler */
            invokeinterface java.util.List.add:(Ljava/lang/Object;)Z
            pop
        end local 7 // org.apache.cassandra.batchlog.BatchlogManager$ReplayingBatch$ReplayWriteResponseHandler handler
        end local 5 // org.apache.cassandra.db.Mutation mutation
         6: .line 415
      StackMap locals:
      StackMap stack:
            aload 6
            invokeinterface java.util.Iterator.hasNext:()Z
            ifne 2
         7: .line 421
            aload 4 /* handlers */
            areturn
        end local 4 // java.util.List handlers
        end local 3 // java.util.Set hintedNodes
        end local 1 // long writtenAt
        end local 0 // java.util.List mutations
      LocalVariableTable:
        Start  End  Slot         Name  Signature
            0    8     0    mutations  Ljava/util/List<Lorg/apache/cassandra/db/Mutation;>;
            0    8     1    writtenAt  J
            0    8     3  hintedNodes  Ljava/util/Set<Ljava/net/InetAddress;>;
            1    8     4     handlers  Ljava/util/List<Lorg/apache/cassandra/batchlog/BatchlogManager$ReplayingBatch$ReplayWriteResponseHandler<Lorg/apache/cassandra/db/Mutation;>;>;
            3    6     5     mutation  Lorg/apache/cassandra/db/Mutation;
            4    6     7      handler  Lorg/apache/cassandra/batchlog/BatchlogManager$ReplayingBatch$ReplayWriteResponseHandler<Lorg/apache/cassandra/db/Mutation;>;
    Signature: (Ljava/util/List<Lorg/apache/cassandra/db/Mutation;>;JLjava/util/Set<Ljava/net/InetAddress;>;)Ljava/util/List<Lorg/apache/cassandra/batchlog/BatchlogManager$ReplayingBatch$ReplayWriteResponseHandler<Lorg/apache/cassandra/db/Mutation;>;>;
    MethodParameters:
             Name  Flags
      mutations    
      writtenAt    
      hintedNodes  

  private static org.apache.cassandra.batchlog.BatchlogManager$ReplayingBatch$ReplayWriteResponseHandler<org.apache.cassandra.db.Mutation> sendSingleReplayMutation(org.apache.cassandra.db.Mutation, long, java.util.Set<java.net.InetAddress>);
    descriptor: (Lorg/apache/cassandra/db/Mutation;JLjava/util/Set;)Lorg/apache/cassandra/batchlog/BatchlogManager$ReplayingBatch$ReplayWriteResponseHandler;
    flags: (0x000a) ACC_PRIVATE, ACC_STATIC
    Code:
      stack=5, locals=11, args_size=3
        start local 0 // org.apache.cassandra.db.Mutation mutation
        start local 1 // long writtenAt
        start local 3 // java.util.Set hintedNodes
         0: .line 434
            new java.util.HashSet
            dup
            invokespecial java.util.HashSet.<init>:()V
            astore 4 /* liveEndpoints */
        start local 4 // java.util.Set liveEndpoints
         1: .line 435
            aload 0 /* mutation */
            invokevirtual org.apache.cassandra.db.Mutation.getKeyspaceName:()Ljava/lang/String;
            astore 5 /* ks */
        start local 5 // java.lang.String ks
         2: .line 436
            aload 0 /* mutation */
            invokevirtual org.apache.cassandra.db.Mutation.key:()Lorg/apache/cassandra/db/DecoratedKey;
            invokevirtual org.apache.cassandra.db.DecoratedKey.getToken:()Lorg/apache/cassandra/dht/Token;
            astore 6 /* tk */
        start local 6 // org.apache.cassandra.dht.Token tk
         3: .line 438
            getstatic org.apache.cassandra.service.StorageService.instance:Lorg/apache/cassandra/service/StorageService;
            aload 5 /* ks */
            aload 6 /* tk */
            invokevirtual org.apache.cassandra.service.StorageService.getNaturalAndPendingEndpoints:(Ljava/lang/String;Lorg/apache/cassandra/dht/Token;)Ljava/lang/Iterable;
            invokeinterface java.lang.Iterable.iterator:()Ljava/util/Iterator;
            astore 8
            goto 15
      StackMap locals: org.apache.cassandra.db.Mutation long java.util.Set java.util.Set java.lang.String org.apache.cassandra.dht.Token top java.util.Iterator
      StackMap stack:
         4: aload 8
            invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
            checkcast java.net.InetAddress
            astore 7 /* endpoint */
        start local 7 // java.net.InetAddress endpoint
         5: .line 440
            aload 7 /* endpoint */
            invokestatic org.apache.cassandra.utils.FBUtilities.getBroadcastAddress:()Ljava/net/InetAddress;
            invokevirtual java.net.InetAddress.equals:(Ljava/lang/Object;)Z
            ifeq 8
         6: .line 442
            aload 0 /* mutation */
            invokevirtual org.apache.cassandra.db.Mutation.apply:()V
         7: .line 443
            goto 15
         8: .line 444
      StackMap locals: org.apache.cassandra.db.Mutation long java.util.Set java.util.Set java.lang.String org.apache.cassandra.dht.Token java.net.InetAddress java.util.Iterator
      StackMap stack:
            getstatic org.apache.cassandra.gms.FailureDetector.instance:Lorg/apache/cassandra/gms/IFailureDetector;
            aload 7 /* endpoint */
            invokeinterface org.apache.cassandra.gms.IFailureDetector.isAlive:(Ljava/net/InetAddress;)Z
            ifeq 11
         9: .line 446
            aload 4 /* liveEndpoints */
            aload 7 /* endpoint */
            invokeinterface java.util.Set.add:(Ljava/lang/Object;)Z
            pop
        10: .line 447
            goto 15
        11: .line 450
      StackMap locals:
      StackMap stack:
            aload 3 /* hintedNodes */
            aload 7 /* endpoint */
            invokeinterface java.util.Set.add:(Ljava/lang/Object;)Z
            pop
        12: .line 451
            getstatic org.apache.cassandra.hints.HintsService.instance:Lorg/apache/cassandra/hints/HintsService;
            getstatic org.apache.cassandra.service.StorageService.instance:Lorg/apache/cassandra/service/StorageService;
            aload 7 /* endpoint */
            invokevirtual org.apache.cassandra.service.StorageService.getHostIdForEndpoint:(Ljava/net/InetAddress;)Ljava/util/UUID;
        13: .line 452
            aload 0 /* mutation */
            lload 1 /* writtenAt */
            invokestatic org.apache.cassandra.hints.Hint.create:(Lorg/apache/cassandra/db/Mutation;J)Lorg/apache/cassandra/hints/Hint;
        14: .line 451
            invokevirtual org.apache.cassandra.hints.HintsService.write:(Ljava/util/UUID;Lorg/apache/cassandra/hints/Hint;)V
        end local 7 // java.net.InetAddress endpoint
        15: .line 438
      StackMap locals: org.apache.cassandra.db.Mutation long java.util.Set java.util.Set java.lang.String org.apache.cassandra.dht.Token top java.util.Iterator
      StackMap stack:
            aload 8
            invokeinterface java.util.Iterator.hasNext:()Z
            ifne 4
        16: .line 456
            aload 4 /* liveEndpoints */
            invokeinterface java.util.Set.isEmpty:()Z
            ifeq 18
        17: .line 457
            aconst_null
            areturn
        18: .line 459
      StackMap locals: org.apache.cassandra.db.Mutation long java.util.Set java.util.Set java.lang.String org.apache.cassandra.dht.Token
      StackMap stack:
            new org.apache.cassandra.batchlog.BatchlogManager$ReplayingBatch$ReplayWriteResponseHandler
            dup
            aload 4 /* liveEndpoints */
            invokestatic java.lang.System.nanoTime:()J
            invokespecial org.apache.cassandra.batchlog.BatchlogManager$ReplayingBatch$ReplayWriteResponseHandler.<init>:(Ljava/util/Collection;J)V
            astore 7 /* handler */
        start local 7 // org.apache.cassandra.batchlog.BatchlogManager$ReplayingBatch$ReplayWriteResponseHandler handler
        19: .line 460
            aload 0 /* mutation */
            invokevirtual org.apache.cassandra.db.Mutation.createMessage:()Lorg/apache/cassandra/net/MessageOut;
            astore 8 /* message */
        start local 8 // org.apache.cassandra.net.MessageOut message
        20: .line 461
            aload 4 /* liveEndpoints */
            invokeinterface java.util.Set.iterator:()Ljava/util/Iterator;
            astore 10
            goto 23
      StackMap locals: org.apache.cassandra.db.Mutation long java.util.Set java.util.Set java.lang.String org.apache.cassandra.dht.Token org.apache.cassandra.batchlog.BatchlogManager$ReplayingBatch$ReplayWriteResponseHandler org.apache.cassandra.net.MessageOut top java.util.Iterator
      StackMap stack:
        21: aload 10
            invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
            checkcast java.net.InetAddress
            astore 9 /* endpoint */
        start local 9 // java.net.InetAddress endpoint
        22: .line 462
            invokestatic org.apache.cassandra.net.MessagingService.instance:()Lorg/apache/cassandra/net/MessagingService;
            aload 8 /* message */
            aload 9 /* endpoint */
            aload 7 /* handler */
            iconst_0
            invokevirtual org.apache.cassandra.net.MessagingService.sendRR:(Lorg/apache/cassandra/net/MessageOut;Ljava/net/InetAddress;Lorg/apache/cassandra/service/AbstractWriteResponseHandler;Z)I
            pop
        end local 9 // java.net.InetAddress endpoint
        23: .line 461
      StackMap locals:
      StackMap stack:
            aload 10
            invokeinterface java.util.Iterator.hasNext:()Z
            ifne 21
        24: .line 463
            aload 7 /* handler */
            areturn
        end local 8 // org.apache.cassandra.net.MessageOut message
        end local 7 // org.apache.cassandra.batchlog.BatchlogManager$ReplayingBatch$ReplayWriteResponseHandler handler
        end local 6 // org.apache.cassandra.dht.Token tk
        end local 5 // java.lang.String ks
        end local 4 // java.util.Set liveEndpoints
        end local 3 // java.util.Set hintedNodes
        end local 1 // long writtenAt
        end local 0 // org.apache.cassandra.db.Mutation mutation
      LocalVariableTable:
        Start  End  Slot           Name  Signature
            0   25     0       mutation  Lorg/apache/cassandra/db/Mutation;
            0   25     1      writtenAt  J
            0   25     3    hintedNodes  Ljava/util/Set<Ljava/net/InetAddress;>;
            1   25     4  liveEndpoints  Ljava/util/Set<Ljava/net/InetAddress;>;
            2   25     5             ks  Ljava/lang/String;
            3   25     6             tk  Lorg/apache/cassandra/dht/Token;
            5   15     7       endpoint  Ljava/net/InetAddress;
           19   25     7        handler  Lorg/apache/cassandra/batchlog/BatchlogManager$ReplayingBatch$ReplayWriteResponseHandler<Lorg/apache/cassandra/db/Mutation;>;
           20   25     8        message  Lorg/apache/cassandra/net/MessageOut<Lorg/apache/cassandra/db/Mutation;>;
           22   23     9       endpoint  Ljava/net/InetAddress;
    Signature: (Lorg/apache/cassandra/db/Mutation;JLjava/util/Set<Ljava/net/InetAddress;>;)Lorg/apache/cassandra/batchlog/BatchlogManager$ReplayingBatch$ReplayWriteResponseHandler<Lorg/apache/cassandra/db/Mutation;>;
    MethodParameters:
             Name  Flags
      mutation     final
      writtenAt    
      hintedNodes  

  private static int gcgs(java.util.Collection<org.apache.cassandra.db.Mutation>);
    descriptor: (Ljava/util/Collection;)I
    flags: (0x000a) ACC_PRIVATE, ACC_STATIC
    Code:
      stack=2, locals=4, args_size=1
        start local 0 // java.util.Collection mutations
         0: .line 468
            ldc 2147483647
            istore 1 /* gcgs */
        start local 1 // int gcgs
         1: .line 469
            aload 0 /* mutations */
            invokeinterface java.util.Collection.iterator:()Ljava/util/Iterator;
            astore 3
            goto 4
      StackMap locals: java.util.Collection int top java.util.Iterator
      StackMap stack:
         2: aload 3
            invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
            checkcast org.apache.cassandra.db.Mutation
            astore 2 /* mutation */
        start local 2 // org.apache.cassandra.db.Mutation mutation
         3: .line 470
            iload 1 /* gcgs */
            aload 2 /* mutation */
            invokevirtual org.apache.cassandra.db.Mutation.smallestGCGS:()I
            invokestatic java.lang.Math.min:(II)I
            istore 1 /* gcgs */
        end local 2 // org.apache.cassandra.db.Mutation mutation
         4: .line 469
      StackMap locals:
      StackMap stack:
            aload 3
            invokeinterface java.util.Iterator.hasNext:()Z
            ifne 2
         5: .line 471
            iload 1 /* gcgs */
            ireturn
        end local 1 // int gcgs
        end local 0 // java.util.Collection mutations
      LocalVariableTable:
        Start  End  Slot       Name  Signature
            0    6     0  mutations  Ljava/util/Collection<Lorg/apache/cassandra/db/Mutation;>;
            1    6     1       gcgs  I
            3    4     2   mutation  Lorg/apache/cassandra/db/Mutation;
    Signature: (Ljava/util/Collection<Lorg/apache/cassandra/db/Mutation;>;)I
    MethodParameters:
           Name  Flags
      mutations  
}
SourceFile: "BatchlogManager.java"
NestHost: org.apache.cassandra.batchlog.BatchlogManager
InnerClasses:
  public final Lookup = java.lang.invoke.MethodHandles$Lookup of java.lang.invoke.MethodHandles
  private ReplayingBatch = org.apache.cassandra.batchlog.BatchlogManager$ReplayingBatch of org.apache.cassandra.batchlog.BatchlogManager
  private ReplayWriteResponseHandler = org.apache.cassandra.batchlog.BatchlogManager$ReplayingBatch$ReplayWriteResponseHandler of org.apache.cassandra.batchlog.BatchlogManager$ReplayingBatch
  public MutationSerializer = org.apache.cassandra.db.Mutation$MutationSerializer of org.apache.cassandra.db.Mutation