org.apache.cassandra/cassandra-all/3.11.5 : org/apache/cassandra/db/commitlog/CommitLogReplayer$MutationInitiator$1.class

CommitLogReplayer$MutationInitiator$1
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.
The Apache Software License, Version 2.0
Andres de la Peña
Avinash Lakshman
Aleksey Yeschenko
Aaron Morton
Ariel Weisberg
Blake Eggleston
Benedict Elliott Smith
Benjamin Lerer
Branimir Lambov
Brandon Williams
Carl Yeksigian
David Brosiusd
Dikang Gu
Eric Evans
Gary Dusbabek
Chris Goffinet
Alex Petrov
Laine Jaakko Olavi
T Jake Luciani
Jason Brown
Jonathan Ellis
Jake Farrell
Jeff Jirsa
Joel Knighton
Josh McKenzie
Johan Oskarsson
Jun Rao
Jay Zhuang
Sankalp Kohli
Marcus Eriksson
Michael Semb Wever
Mikhail Stepura
Michael Shuler
Paulo Motta
Prashant Malik
Robert Stupp
Peter Schuller
Sam Tunnicliffe
Sylvain Lebresne
Stefania Alborghetti
Tyler Hobbs
Vijay Parthasarathy
Pavel Yaskevich
Yuki Morishita
Nate McCall
class org.apache.cassandra.db.commitlog.CommitLogReplayer$MutationInitiator$1 extends org.apache.cassandra.utils.WrappedRunnable
  minor version: 0
  major version: 59
  flags: flags: (0x0020) ACC_SUPER
  this_class: org.apache.cassandra.db.commitlog.CommitLogReplayer$MutationInitiator$1
  super_class: org.apache.cassandra.utils.WrappedRunnable
{
  final org.apache.cassandra.db.commitlog.CommitLogReplayer$MutationInitiator this$1;
    descriptor: Lorg/apache/cassandra/db/commitlog/CommitLogReplayer$MutationInitiator;
    flags: (0x1010) ACC_FINAL, ACC_SYNTHETIC

  private final org.apache.cassandra.db.Mutation val$mutation;
    descriptor: Lorg/apache/cassandra/db/Mutation;
    flags: (0x1012) ACC_PRIVATE, ACC_FINAL, ACC_SYNTHETIC

  private final org.apache.cassandra.db.commitlog.CommitLogReplayer val$commitLogReplayer;
    descriptor: Lorg/apache/cassandra/db/commitlog/CommitLogReplayer;
    flags: (0x1012) ACC_PRIVATE, ACC_FINAL, ACC_SYNTHETIC

  private final long val$segmentId;
    descriptor: J
    flags: (0x1012) ACC_PRIVATE, ACC_FINAL, ACC_SYNTHETIC

  private final int val$entryLocation;
    descriptor: I
    flags: (0x1012) ACC_PRIVATE, ACC_FINAL, ACC_SYNTHETIC

  void <init>(org.apache.cassandra.db.commitlog.CommitLogReplayer$MutationInitiator, org.apache.cassandra.db.Mutation, org.apache.cassandra.db.commitlog.CommitLogReplayer, long, int);
    descriptor: (Lorg/apache/cassandra/db/commitlog/CommitLogReplayer$MutationInitiator;Lorg/apache/cassandra/db/Mutation;Lorg/apache/cassandra/db/commitlog/CommitLogReplayer;JI)V
    flags: (0x0000) 
    Code:
      stack=3, locals=7, args_size=6
        start local 0 // org.apache.cassandra.db.commitlog.CommitLogReplayer$MutationInitiator$1 this
         0: .line 188
            aload 0 /* this */
            aload 1
            putfield org.apache.cassandra.db.commitlog.CommitLogReplayer$MutationInitiator$1.this$1:Lorg/apache/cassandra/db/commitlog/CommitLogReplayer$MutationInitiator;
            aload 0 /* this */
            aload 2
            putfield org.apache.cassandra.db.commitlog.CommitLogReplayer$MutationInitiator$1.val$mutation:Lorg/apache/cassandra/db/Mutation;
            aload 0 /* this */
            aload 3
            putfield org.apache.cassandra.db.commitlog.CommitLogReplayer$MutationInitiator$1.val$commitLogReplayer:Lorg/apache/cassandra/db/commitlog/CommitLogReplayer;
            aload 0 /* this */
            lload 4
            putfield org.apache.cassandra.db.commitlog.CommitLogReplayer$MutationInitiator$1.val$segmentId:J
            aload 0 /* this */
            iload 6
            putfield org.apache.cassandra.db.commitlog.CommitLogReplayer$MutationInitiator$1.val$entryLocation:I
            aload 0 /* this */
            invokespecial org.apache.cassandra.utils.WrappedRunnable.<init>:()V
            return
        end local 0 // org.apache.cassandra.db.commitlog.CommitLogReplayer$MutationInitiator$1 this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lorg/apache/cassandra/db/commitlog/CommitLogReplayer$MutationInitiator$1;
    MethodParameters:
                       Name  Flags
      this$0                 final
      val$mutation           final
      val$commitLogReplayer  final
      val$segmentId          final
      val$entryLocation      final

  public void runMayThrow();
    descriptor: ()V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=7, locals=5, args_size=1
        start local 0 // org.apache.cassandra.db.commitlog.CommitLogReplayer$MutationInitiator$1 this
         0: .line 192
            getstatic org.apache.cassandra.config.Schema.instance:Lorg/apache/cassandra/config/Schema;
            aload 0 /* this */
            getfield org.apache.cassandra.db.commitlog.CommitLogReplayer$MutationInitiator$1.val$mutation:Lorg/apache/cassandra/db/Mutation;
            invokevirtual org.apache.cassandra.db.Mutation.getKeyspaceName:()Ljava/lang/String;
            invokevirtual org.apache.cassandra.config.Schema.getKSMetaData:(Ljava/lang/String;)Lorg/apache/cassandra/schema/KeyspaceMetadata;
            ifnonnull 2
         1: .line 193
            return
         2: .line 194
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield org.apache.cassandra.db.commitlog.CommitLogReplayer$MutationInitiator$1.val$commitLogReplayer:Lorg/apache/cassandra/db/commitlog/CommitLogReplayer;
            aload 0 /* this */
            getfield org.apache.cassandra.db.commitlog.CommitLogReplayer$MutationInitiator$1.val$mutation:Lorg/apache/cassandra/db/Mutation;
            invokevirtual org.apache.cassandra.db.commitlog.CommitLogReplayer.pointInTimeExceeded:(Lorg/apache/cassandra/db/Mutation;)Z
            ifeq 4
         3: .line 195
            return
         4: .line 197
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield org.apache.cassandra.db.commitlog.CommitLogReplayer$MutationInitiator$1.val$mutation:Lorg/apache/cassandra/db/Mutation;
            invokevirtual org.apache.cassandra.db.Mutation.getKeyspaceName:()Ljava/lang/String;
            invokestatic org.apache.cassandra.db.Keyspace.open:(Ljava/lang/String;)Lorg/apache/cassandra/db/Keyspace;
            astore 1 /* keyspace */
        start local 1 // org.apache.cassandra.db.Keyspace keyspace
         5: .line 204
            aconst_null
            astore 2 /* newMutation */
        start local 2 // org.apache.cassandra.db.Mutation newMutation
         6: .line 205
            aload 0 /* this */
            getfield org.apache.cassandra.db.commitlog.CommitLogReplayer$MutationInitiator$1.val$commitLogReplayer:Lorg/apache/cassandra/db/commitlog/CommitLogReplayer;
            getfield org.apache.cassandra.db.commitlog.CommitLogReplayer.replayFilter:Lorg/apache/cassandra/db/commitlog/CommitLogReplayer$ReplayFilter;
            aload 0 /* this */
            getfield org.apache.cassandra.db.commitlog.CommitLogReplayer$MutationInitiator$1.val$mutation:Lorg/apache/cassandra/db/Mutation;
            invokevirtual org.apache.cassandra.db.commitlog.CommitLogReplayer$ReplayFilter.filter:(Lorg/apache/cassandra/db/Mutation;)Ljava/lang/Iterable;
            invokeinterface java.lang.Iterable.iterator:()Ljava/util/Iterator;
            astore 4
            goto 15
      StackMap locals: org.apache.cassandra.db.commitlog.CommitLogReplayer$MutationInitiator$1 org.apache.cassandra.db.Keyspace org.apache.cassandra.db.Mutation top java.util.Iterator
      StackMap stack:
         7: aload 4
            invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
            checkcast org.apache.cassandra.db.partitions.PartitionUpdate
            astore 3 /* update */
        start local 3 // org.apache.cassandra.db.partitions.PartitionUpdate update
         8: .line 207
            getstatic org.apache.cassandra.config.Schema.instance:Lorg/apache/cassandra/config/Schema;
            aload 3 /* update */
            invokevirtual org.apache.cassandra.db.partitions.PartitionUpdate.metadata:()Lorg/apache/cassandra/config/CFMetaData;
            getfield org.apache.cassandra.config.CFMetaData.cfId:Ljava/util/UUID;
            invokevirtual org.apache.cassandra.config.Schema.getCF:(Ljava/util/UUID;)Lorg/apache/cassandra/utils/Pair;
            ifnonnull 10
         9: .line 208
            goto 15
        10: .line 212
      StackMap locals: org.apache.cassandra.db.commitlog.CommitLogReplayer$MutationInitiator$1 org.apache.cassandra.db.Keyspace org.apache.cassandra.db.Mutation org.apache.cassandra.db.partitions.PartitionUpdate java.util.Iterator
      StackMap stack:
            aload 0 /* this */
            getfield org.apache.cassandra.db.commitlog.CommitLogReplayer$MutationInitiator$1.val$commitLogReplayer:Lorg/apache/cassandra/db/commitlog/CommitLogReplayer;
            aload 3 /* update */
            invokevirtual org.apache.cassandra.db.partitions.PartitionUpdate.metadata:()Lorg/apache/cassandra/config/CFMetaData;
            getfield org.apache.cassandra.config.CFMetaData.cfId:Ljava/util/UUID;
            new org.apache.cassandra.db.commitlog.CommitLogPosition
            dup
            aload 0 /* this */
            getfield org.apache.cassandra.db.commitlog.CommitLogReplayer$MutationInitiator$1.val$segmentId:J
            aload 0 /* this */
            getfield org.apache.cassandra.db.commitlog.CommitLogReplayer$MutationInitiator$1.val$entryLocation:I
            invokespecial org.apache.cassandra.db.commitlog.CommitLogPosition.<init>:(JI)V
            invokevirtual org.apache.cassandra.db.commitlog.CommitLogReplayer.shouldReplay:(Ljava/util/UUID;Lorg/apache/cassandra/db/commitlog/CommitLogPosition;)Z
            ifeq 15
        11: .line 214
            aload 2 /* newMutation */
            ifnonnull 13
        12: .line 215
            new org.apache.cassandra.db.Mutation
            dup
            aload 0 /* this */
            getfield org.apache.cassandra.db.commitlog.CommitLogReplayer$MutationInitiator$1.val$mutation:Lorg/apache/cassandra/db/Mutation;
            invokevirtual org.apache.cassandra.db.Mutation.getKeyspaceName:()Ljava/lang/String;
            aload 0 /* this */
            getfield org.apache.cassandra.db.commitlog.CommitLogReplayer$MutationInitiator$1.val$mutation:Lorg/apache/cassandra/db/Mutation;
            invokevirtual org.apache.cassandra.db.Mutation.key:()Lorg/apache/cassandra/db/DecoratedKey;
            invokespecial org.apache.cassandra.db.Mutation.<init>:(Ljava/lang/String;Lorg/apache/cassandra/db/DecoratedKey;)V
            astore 2 /* newMutation */
        13: .line 216
      StackMap locals:
      StackMap stack:
            aload 2 /* newMutation */
            aload 3 /* update */
            invokevirtual org.apache.cassandra.db.Mutation.add:(Lorg/apache/cassandra/db/partitions/PartitionUpdate;)Lorg/apache/cassandra/db/Mutation;
            pop
        14: .line 217
            aload 0 /* this */
            getfield org.apache.cassandra.db.commitlog.CommitLogReplayer$MutationInitiator$1.val$commitLogReplayer:Lorg/apache/cassandra/db/commitlog/CommitLogReplayer;
            getfield org.apache.cassandra.db.commitlog.CommitLogReplayer.replayedCount:Ljava/util/concurrent/atomic/AtomicInteger;
            invokevirtual java.util.concurrent.atomic.AtomicInteger.incrementAndGet:()I
            pop
        end local 3 // org.apache.cassandra.db.partitions.PartitionUpdate update
        15: .line 205
      StackMap locals: org.apache.cassandra.db.commitlog.CommitLogReplayer$MutationInitiator$1 org.apache.cassandra.db.Keyspace org.apache.cassandra.db.Mutation top java.util.Iterator
      StackMap stack:
            aload 4
            invokeinterface java.util.Iterator.hasNext:()Z
            ifne 7
        16: .line 220
            aload 2 /* newMutation */
            ifnull 20
        17: .line 222
            getstatic org.apache.cassandra.db.commitlog.CommitLogReplayer$MutationInitiator.$assertionsDisabled:Z
            ifne 18
            aload 2 /* newMutation */
            invokevirtual org.apache.cassandra.db.Mutation.isEmpty:()Z
            ifeq 18
            new java.lang.AssertionError
            dup
            invokespecial java.lang.AssertionError.<init>:()V
            athrow
        18: .line 224
      StackMap locals: org.apache.cassandra.db.commitlog.CommitLogReplayer$MutationInitiator$1 org.apache.cassandra.db.Keyspace org.apache.cassandra.db.Mutation
      StackMap stack:
            aload 2 /* newMutation */
            invokevirtual org.apache.cassandra.db.Mutation.getKeyspaceName:()Ljava/lang/String;
            invokestatic org.apache.cassandra.db.Keyspace.open:(Ljava/lang/String;)Lorg/apache/cassandra/db/Keyspace;
            aload 2 /* newMutation */
            iconst_0
            iconst_1
            iconst_0
            invokevirtual org.apache.cassandra.db.Keyspace.apply:(Lorg/apache/cassandra/db/Mutation;ZZZ)V
        19: .line 225
            aload 0 /* this */
            getfield org.apache.cassandra.db.commitlog.CommitLogReplayer$MutationInitiator$1.val$commitLogReplayer:Lorg/apache/cassandra/db/commitlog/CommitLogReplayer;
            getfield org.apache.cassandra.db.commitlog.CommitLogReplayer.keyspacesReplayed:Ljava/util/Set;
            aload 1 /* keyspace */
            invokeinterface java.util.Set.add:(Ljava/lang/Object;)Z
            pop
        20: .line 227
      StackMap locals:
      StackMap stack:
            return
        end local 2 // org.apache.cassandra.db.Mutation newMutation
        end local 1 // org.apache.cassandra.db.Keyspace keyspace
        end local 0 // org.apache.cassandra.db.commitlog.CommitLogReplayer$MutationInitiator$1 this
      LocalVariableTable:
        Start  End  Slot         Name  Signature
            0   21     0         this  Lorg/apache/cassandra/db/commitlog/CommitLogReplayer$MutationInitiator$1;
            5   21     1     keyspace  Lorg/apache/cassandra/db/Keyspace;
            6   21     2  newMutation  Lorg/apache/cassandra/db/Mutation;
            8   15     3       update  Lorg/apache/cassandra/db/partitions/PartitionUpdate;
}
SourceFile: "CommitLogReplayer.java"
EnclosingMethod: org.apache.cassandra.db.commitlog.CommitLogReplayer$MutationInitiator.initiateMutation:(Lorg/apache/cassandra/db/Mutation;JIILorg/apache/cassandra/db/commitlog/CommitLogReplayer;)Ljava/util/concurrent/Future;
NestHost: org.apache.cassandra.db.commitlog.CommitLogReplayer
InnerClasses:
  public MutationInitiator = org.apache.cassandra.db.commitlog.CommitLogReplayer$MutationInitiator of org.apache.cassandra.db.commitlog.CommitLogReplayer
  org.apache.cassandra.db.commitlog.CommitLogReplayer$MutationInitiator$1
  abstract ReplayFilter = org.apache.cassandra.db.commitlog.CommitLogReplayer$ReplayFilter of org.apache.cassandra.db.commitlog.CommitLogReplayer
/

org.apache.cassandra/ cassandra-all/ 3.11.5/ org/apache/cassandra/db/commitlog/CommitLogReplayer$MutationInitiator$1.class
