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 
public class org.apache.cassandra.service.ActiveRepairService$ParentRepairSession
  minor version: 0
  major version: 59
  flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
  this_class: org.apache.cassandra.service.ActiveRepairService$ParentRepairSession
  super_class: java.lang.Object
{
  private final java.util.Map<java.util.UUID, org.apache.cassandra.db.ColumnFamilyStore> columnFamilyStores;
    descriptor: Ljava/util/Map;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL
    Signature: Ljava/util/Map<Ljava/util/UUID;Lorg/apache/cassandra/db/ColumnFamilyStore;>;

  private final java.util.Collection<org.apache.cassandra.dht.Range<org.apache.cassandra.dht.Token>> ranges;
    descriptor: Ljava/util/Collection;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL
    Signature: Ljava/util/Collection<Lorg/apache/cassandra/dht/Range<Lorg/apache/cassandra/dht/Token;>;>;

  public final java.util.Map<java.util.UUID, java.util.Set<java.lang.String>> sstableMap;
    descriptor: Ljava/util/Map;
    flags: (0x0011) ACC_PUBLIC, ACC_FINAL
    Signature: Ljava/util/Map<Ljava/util/UUID;Ljava/util/Set<Ljava/lang/String;>;>;

  public final boolean isIncremental;
    descriptor: Z
    flags: (0x0011) ACC_PUBLIC, ACC_FINAL

  public final boolean isGlobal;
    descriptor: Z
    flags: (0x0011) ACC_PUBLIC, ACC_FINAL

  public final long repairedAt;
    descriptor: J
    flags: (0x0011) ACC_PUBLIC, ACC_FINAL

  public final java.net.InetAddress coordinator;
    descriptor: Ljava/net/InetAddress;
    flags: (0x0011) ACC_PUBLIC, ACC_FINAL

  private final java.util.Set<java.util.UUID> marked;
    descriptor: Ljava/util/Set;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL
    Signature: Ljava/util/Set<Ljava/util/UUID;>;

  static final boolean $assertionsDisabled;
    descriptor: Z
    flags: (0x1018) ACC_STATIC, ACC_FINAL, ACC_SYNTHETIC

  static void <clinit>();
    descriptor: ()V
    flags: (0x0008) ACC_STATIC
    Code:
      stack=1, locals=0, args_size=0
         0: .line 517
            ldc Lorg/apache/cassandra/service/ActiveRepairService;
            invokevirtual java.lang.Class.desiredAssertionStatus:()Z
            ifne 1
            iconst_1
            goto 2
      StackMap locals:
      StackMap stack:
         1: iconst_0
      StackMap locals:
      StackMap stack: int
         2: putstatic org.apache.cassandra.service.ActiveRepairService$ParentRepairSession.$assertionsDisabled:Z
            return
      LocalVariableTable:
        Start  End  Slot  Name  Signature

  public void <init>(java.net.InetAddress, java.util.List<org.apache.cassandra.db.ColumnFamilyStore>, java.util.Collection<org.apache.cassandra.dht.Range<org.apache.cassandra.dht.Token>>, boolean, long, );
    descriptor: (Ljava/net/InetAddress;Ljava/util/List;Ljava/util/Collection;ZJZ)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=4, locals=10, args_size=7
        start local 0 // org.apache.cassandra.service.ActiveRepairService$ParentRepairSession this
        start local 1 // java.net.InetAddress coordinator
        start local 2 // java.util.List columnFamilyStores
        start local 3 // java.util.Collection ranges
        start local 4 // boolean isIncremental
        start local 5 // long repairedAt
        start local 7 // boolean isGlobal
         0: .line 531
            aload 0 /* this */
            invokespecial java.lang.Object.<init>:()V
         1: .line 519
            aload 0 /* this */
            new java.util.HashMap
            dup
            invokespecial java.util.HashMap.<init>:()V
            putfield org.apache.cassandra.service.ActiveRepairService$ParentRepairSession.columnFamilyStores:Ljava/util/Map;
         2: .line 521
            aload 0 /* this */
            new java.util.HashMap
            dup
            invokespecial java.util.HashMap.<init>:()V
            putfield org.apache.cassandra.service.ActiveRepairService$ParentRepairSession.sstableMap:Ljava/util/Map;
         3: .line 529
            aload 0 /* this */
            new java.util.HashSet
            dup
            invokespecial java.util.HashSet.<init>:()V
            putfield org.apache.cassandra.service.ActiveRepairService$ParentRepairSession.marked:Ljava/util/Set;
         4: .line 533
            aload 0 /* this */
            aload 1 /* coordinator */
            putfield org.apache.cassandra.service.ActiveRepairService$ParentRepairSession.coordinator:Ljava/net/InetAddress;
         5: .line 534
            aload 2 /* columnFamilyStores */
            invokeinterface java.util.List.iterator:()Ljava/util/Iterator;
            astore 9
            goto 9
      StackMap locals: org.apache.cassandra.service.ActiveRepairService$ParentRepairSession java.net.InetAddress java.util.List java.util.Collection int long int top java.util.Iterator
      StackMap stack:
         6: aload 9
            invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
            checkcast org.apache.cassandra.db.ColumnFamilyStore
            astore 8 /* cfs */
        start local 8 // org.apache.cassandra.db.ColumnFamilyStore cfs
         7: .line 536
            aload 0 /* this */
            getfield org.apache.cassandra.service.ActiveRepairService$ParentRepairSession.columnFamilyStores:Ljava/util/Map;
            aload 8 /* cfs */
            getfield org.apache.cassandra.db.ColumnFamilyStore.metadata:Lorg/apache/cassandra/config/CFMetaData;
            getfield org.apache.cassandra.config.CFMetaData.cfId:Ljava/util/UUID;
            aload 8 /* cfs */
            invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
            pop
         8: .line 537
            aload 0 /* this */
            getfield org.apache.cassandra.service.ActiveRepairService$ParentRepairSession.sstableMap:Ljava/util/Map;
            aload 8 /* cfs */
            getfield org.apache.cassandra.db.ColumnFamilyStore.metadata:Lorg/apache/cassandra/config/CFMetaData;
            getfield org.apache.cassandra.config.CFMetaData.cfId:Ljava/util/UUID;
            new java.util.HashSet
            dup
            invokespecial java.util.HashSet.<init>:()V
            invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
            pop
        end local 8 // org.apache.cassandra.db.ColumnFamilyStore cfs
         9: .line 534
      StackMap locals:
      StackMap stack:
            aload 9
            invokeinterface java.util.Iterator.hasNext:()Z
            ifne 6
        10: .line 539
            aload 0 /* this */
            aload 3 /* ranges */
            putfield org.apache.cassandra.service.ActiveRepairService$ParentRepairSession.ranges:Ljava/util/Collection;
        11: .line 540
            aload 0 /* this */
            lload 5 /* repairedAt */
            putfield org.apache.cassandra.service.ActiveRepairService$ParentRepairSession.repairedAt:J
        12: .line 541
            aload 0 /* this */
            iload 4 /* isIncremental */
            putfield org.apache.cassandra.service.ActiveRepairService$ParentRepairSession.isIncremental:Z
        13: .line 542
            aload 0 /* this */
            iload 7 /* isGlobal */
            putfield org.apache.cassandra.service.ActiveRepairService$ParentRepairSession.isGlobal:Z
        14: .line 543
            return
        end local 7 // boolean isGlobal
        end local 5 // long repairedAt
        end local 4 // boolean isIncremental
        end local 3 // java.util.Collection ranges
        end local 2 // java.util.List columnFamilyStores
        end local 1 // java.net.InetAddress coordinator
        end local 0 // org.apache.cassandra.service.ActiveRepairService$ParentRepairSession this
      LocalVariableTable:
        Start  End  Slot                Name  Signature
            0   15     0                this  Lorg/apache/cassandra/service/ActiveRepairService$ParentRepairSession;
            0   15     1         coordinator  Ljava/net/InetAddress;
            0   15     2  columnFamilyStores  Ljava/util/List<Lorg/apache/cassandra/db/ColumnFamilyStore;>;
            0   15     3              ranges  Ljava/util/Collection<Lorg/apache/cassandra/dht/Range<Lorg/apache/cassandra/dht/Token;>;>;
            0   15     4       isIncremental  Z
            0   15     5          repairedAt  J
            0   15     7            isGlobal  Z
            7    9     8                 cfs  Lorg/apache/cassandra/db/ColumnFamilyStore;
    Signature: (Ljava/net/InetAddress;Ljava/util/List<Lorg/apache/cassandra/db/ColumnFamilyStore;>;Ljava/util/Collection<Lorg/apache/cassandra/dht/Range<Lorg/apache/cassandra/dht/Token;>;>;ZJZ)V
    MethodParameters:
                    Name  Flags
      coordinator         
      columnFamilyStores  
      ranges              
      isIncremental       
      repairedAt          
      isGlobal            

  public synchronized void markSSTablesRepairing(java.util.UUID, java.util.UUID);
    descriptor: (Ljava/util/UUID;Ljava/util/UUID;)V
    flags: (0x0021) ACC_PUBLIC, ACC_SYNCHRONIZED
    Code:
      stack=3, locals=5, args_size=3
        start local 0 // org.apache.cassandra.service.ActiveRepairService$ParentRepairSession this
        start local 1 // java.util.UUID cfId
        start local 2 // java.util.UUID parentSessionId
         0: .line 555
            aload 0 /* this */
            getfield org.apache.cassandra.service.ActiveRepairService$ParentRepairSession.marked:Ljava/util/Set;
            aload 1 /* cfId */
            invokeinterface java.util.Set.contains:(Ljava/lang/Object;)Z
            ifne 8
         1: .line 557
            aload 0 /* this */
            getfield org.apache.cassandra.service.ActiveRepairService$ParentRepairSession.columnFamilyStores:Ljava/util/Map;
            aload 1 /* cfId */
            invokeinterface java.util.Map.get:(Ljava/lang/Object;)Ljava/lang/Object;
            checkcast org.apache.cassandra.db.ColumnFamilyStore
            getstatic org.apache.cassandra.db.lifecycle.SSTableSet.CANONICAL:Lorg/apache/cassandra/db/lifecycle/SSTableSet;
            aload 0 /* this */
            invokedynamic apply(Lorg/apache/cassandra/service/ActiveRepairService$ParentRepairSession;)Lcom/google/common/base/Predicate;
              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;)Z
                  org/apache/cassandra/service/ActiveRepairService$ParentRepairSession.lambda$0(Lorg/apache/cassandra/io/sstable/format/SSTableReader;)Z (7)
                  (Lorg/apache/cassandra/io/sstable/format/SSTableReader;)Z
            invokestatic org.apache.cassandra.db.lifecycle.View.select:(Lorg/apache/cassandra/db/lifecycle/SSTableSet;Lcom/google/common/base/Predicate;)Lcom/google/common/base/Function;
            invokevirtual org.apache.cassandra.db.ColumnFamilyStore.select:(Lcom/google/common/base/Function;)Lorg/apache/cassandra/db/ColumnFamilyStore$ViewFragment;
            getfield org.apache.cassandra.db.ColumnFamilyStore$ViewFragment.sstables:Ljava/util/List;
            astore 3 /* sstables */
        start local 3 // java.util.List sstables
         2: .line 558
            getstatic org.apache.cassandra.service.ActiveRepairService.instance:Lorg/apache/cassandra/service/ActiveRepairService;
            aload 1 /* cfId */
            aload 2 /* parentSessionId */
            invokevirtual org.apache.cassandra.service.ActiveRepairService.currentlyRepairing:(Ljava/util/UUID;Ljava/util/UUID;)Ljava/util/Set;
            astore 4 /* currentlyRepairing */
        start local 4 // java.util.Set currentlyRepairing
         3: .line 559
            aload 4 /* currentlyRepairing */
            aload 3 /* sstables */
            invokestatic com.google.common.collect.Sets.newHashSet:(Ljava/lang/Iterable;)Ljava/util/HashSet;
            invokestatic com.google.common.collect.Sets.intersection:(Ljava/util/Set;Ljava/util/Set;)Lcom/google/common/collect/Sets$SetView;
            invokevirtual com.google.common.collect.Sets$SetView.isEmpty:()Z
            ifne 6
         4: .line 561
            getstatic org.apache.cassandra.service.ActiveRepairService.logger:Lorg/slf4j/Logger;
            ldc "Cannot start multiple repair sessions over the same sstables"
            invokeinterface org.slf4j.Logger.error:(Ljava/lang/String;)V
         5: .line 562
            new java.lang.RuntimeException
            dup
            ldc "Cannot start multiple repair sessions over the same sstables"
            invokespecial java.lang.RuntimeException.<init>:(Ljava/lang/String;)V
            athrow
         6: .line 564
      StackMap locals: java.util.List java.util.Set
      StackMap stack:
            aload 0 /* this */
            aload 1 /* cfId */
            aload 3 /* sstables */
            invokevirtual org.apache.cassandra.service.ActiveRepairService$ParentRepairSession.addSSTables:(Ljava/util/UUID;Ljava/util/Collection;)V
         7: .line 565
            aload 0 /* this */
            getfield org.apache.cassandra.service.ActiveRepairService$ParentRepairSession.marked:Ljava/util/Set;
            aload 1 /* cfId */
            invokeinterface java.util.Set.add:(Ljava/lang/Object;)Z
            pop
        end local 4 // java.util.Set currentlyRepairing
        end local 3 // java.util.List sstables
         8: .line 567
      StackMap locals:
      StackMap stack:
            return
        end local 2 // java.util.UUID parentSessionId
        end local 1 // java.util.UUID cfId
        end local 0 // org.apache.cassandra.service.ActiveRepairService$ParentRepairSession this
      LocalVariableTable:
        Start  End  Slot                Name  Signature
            0    9     0                this  Lorg/apache/cassandra/service/ActiveRepairService$ParentRepairSession;
            0    9     1                cfId  Ljava/util/UUID;
            0    9     2     parentSessionId  Ljava/util/UUID;
            2    8     3            sstables  Ljava/util/List<Lorg/apache/cassandra/io/sstable/format/SSTableReader;>;
            3    8     4  currentlyRepairing  Ljava/util/Set<Lorg/apache/cassandra/io/sstable/format/SSTableReader;>;
    MethodParameters:
                 Name  Flags
      cfId             
      parentSessionId  

  public synchronized org.apache.cassandra.utils.concurrent.Refs<org.apache.cassandra.io.sstable.format.SSTableReader> getActiveRepairedSSTableRefsForAntiCompaction(java.util.UUID, java.util.UUID);
    descriptor: (Ljava/util/UUID;Ljava/util/UUID;)Lorg/apache/cassandra/utils/concurrent/Refs;
    flags: (0x0021) ACC_PUBLIC, ACC_SYNCHRONIZED
    Code:
      stack=5, locals=9, args_size=3
        start local 0 // org.apache.cassandra.service.ActiveRepairService$ParentRepairSession this
        start local 1 // java.util.UUID cfId
        start local 2 // java.util.UUID parentSessionId
         0: .line 582
            getstatic org.apache.cassandra.service.ActiveRepairService$ParentRepairSession.$assertionsDisabled:Z
            ifne 1
            aload 0 /* this */
            getfield org.apache.cassandra.service.ActiveRepairService$ParentRepairSession.marked:Ljava/util/Set;
            aload 1 /* cfId */
            invokeinterface java.util.Set.contains:(Ljava/lang/Object;)Z
            ifne 1
            new java.lang.AssertionError
            dup
            invokespecial java.lang.AssertionError.<init>:()V
            athrow
         1: .line 583
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield org.apache.cassandra.service.ActiveRepairService$ParentRepairSession.columnFamilyStores:Ljava/util/Map;
            aload 1 /* cfId */
            invokeinterface java.util.Map.containsKey:(Ljava/lang/Object;)Z
            ifne 3
         2: .line 584
            new java.lang.RuntimeException
            dup
            new java.lang.StringBuilder
            dup
            ldc "Not possible to get sstables for anticompaction for "
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
            aload 1 /* cfId */
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/Object;)Ljava/lang/StringBuilder;
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
            invokespecial java.lang.RuntimeException.<init>:(Ljava/lang/String;)V
            athrow
         3: .line 585
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield org.apache.cassandra.service.ActiveRepairService$ParentRepairSession.columnFamilyStores:Ljava/util/Map;
            aload 1 /* cfId */
            invokeinterface java.util.Map.get:(Ljava/lang/Object;)Ljava/lang/Object;
            checkcast org.apache.cassandra.db.ColumnFamilyStore
            aload 2 /* parentSessionId */
            invokevirtual java.util.UUID.toString:()Ljava/lang/String;
            invokevirtual org.apache.cassandra.db.ColumnFamilyStore.snapshotExists:(Ljava/lang/String;)Z
            istore 3 /* isSnapshotRepair */
        start local 3 // boolean isSnapshotRepair
         4: .line 586
            invokestatic com.google.common.collect.ImmutableMap.builder:()Lcom/google/common/collect/ImmutableMap$Builder;
            astore 4 /* references */
        start local 4 // com.google.common.collect.ImmutableMap$Builder references
         5: .line 587
            iload 3 /* isSnapshotRepair */
            ifeq 6
            aload 0 /* this */
            aload 1 /* cfId */
            aload 2 /* parentSessionId */
            invokevirtual org.apache.cassandra.service.ActiveRepairService$ParentRepairSession.getSSTablesForSnapshotRepair:(Ljava/util/UUID;Ljava/util/UUID;)Ljava/util/Set;
            goto 7
      StackMap locals: int com.google.common.collect.ImmutableMap$Builder
      StackMap stack:
         6: aload 0 /* this */
            aload 1 /* cfId */
            invokevirtual org.apache.cassandra.service.ActiveRepairService$ParentRepairSession.getActiveSSTables:(Ljava/util/UUID;)Ljava/util/Set;
      StackMap locals:
      StackMap stack: java.util.Set
         7: astore 5 /* sstables */
        start local 5 // java.lang.Iterable sstables
         8: .line 589
            getstatic org.apache.cassandra.service.ActiveRepairService$ParentRepairSession.$assertionsDisabled:Z
            ifne 9
            aload 5 /* sstables */
            ifnonnull 9
            new java.lang.AssertionError
            dup
            invokespecial java.lang.AssertionError.<init>:()V
            athrow
         9: .line 590
      StackMap locals: java.lang.Iterable
      StackMap stack:
            aload 5 /* sstables */
            invokeinterface java.lang.Iterable.iterator:()Ljava/util/Iterator;
            astore 7
            goto 15
      StackMap locals: org.apache.cassandra.service.ActiveRepairService$ParentRepairSession java.util.UUID java.util.UUID int com.google.common.collect.ImmutableMap$Builder java.lang.Iterable top java.util.Iterator
      StackMap stack:
        10: aload 7
            invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
            checkcast org.apache.cassandra.io.sstable.format.SSTableReader
            astore 6 /* sstable */
        start local 6 // org.apache.cassandra.io.sstable.format.SSTableReader sstable
        11: .line 592
            aload 6 /* sstable */
            invokevirtual org.apache.cassandra.io.sstable.format.SSTableReader.tryRef:()Lorg/apache/cassandra/utils/concurrent/Ref;
            astore 8 /* ref */
        start local 8 // org.apache.cassandra.utils.concurrent.Ref ref
        12: .line 593
            aload 8 /* ref */
            ifnonnull 14
        13: .line 594
            aload 0 /* this */
            getfield org.apache.cassandra.service.ActiveRepairService$ParentRepairSession.sstableMap:Ljava/util/Map;
            aload 1 /* cfId */
            invokeinterface java.util.Map.get:(Ljava/lang/Object;)Ljava/lang/Object;
            checkcast java.util.Set
            aload 6 /* sstable */
            invokevirtual org.apache.cassandra.io.sstable.format.SSTableReader.getFilename:()Ljava/lang/String;
            invokeinterface java.util.Set.remove:(Ljava/lang/Object;)Z
            pop
            goto 15
        14: .line 596
      StackMap locals: org.apache.cassandra.service.ActiveRepairService$ParentRepairSession java.util.UUID java.util.UUID int com.google.common.collect.ImmutableMap$Builder java.lang.Iterable org.apache.cassandra.io.sstable.format.SSTableReader java.util.Iterator org.apache.cassandra.utils.concurrent.Ref
      StackMap stack:
            aload 4 /* references */
            aload 6 /* sstable */
            aload 8 /* ref */
            invokevirtual com.google.common.collect.ImmutableMap$Builder.put:(Ljava/lang/Object;Ljava/lang/Object;)Lcom/google/common/collect/ImmutableMap$Builder;
            pop
        end local 8 // org.apache.cassandra.utils.concurrent.Ref ref
        end local 6 // org.apache.cassandra.io.sstable.format.SSTableReader sstable
        15: .line 590
      StackMap locals: org.apache.cassandra.service.ActiveRepairService$ParentRepairSession java.util.UUID java.util.UUID int com.google.common.collect.ImmutableMap$Builder java.lang.Iterable top java.util.Iterator
      StackMap stack:
            aload 7
            invokeinterface java.util.Iterator.hasNext:()Z
            ifne 10
        16: .line 598
            new org.apache.cassandra.utils.concurrent.Refs
            dup
            aload 4 /* references */
            invokevirtual com.google.common.collect.ImmutableMap$Builder.build:()Lcom/google/common/collect/ImmutableMap;
            invokespecial org.apache.cassandra.utils.concurrent.Refs.<init>:(Ljava/util/Map;)V
            areturn
        end local 5 // java.lang.Iterable sstables
        end local 4 // com.google.common.collect.ImmutableMap$Builder references
        end local 3 // boolean isSnapshotRepair
        end local 2 // java.util.UUID parentSessionId
        end local 1 // java.util.UUID cfId
        end local 0 // org.apache.cassandra.service.ActiveRepairService$ParentRepairSession this
      LocalVariableTable:
        Start  End  Slot              Name  Signature
            0   17     0              this  Lorg/apache/cassandra/service/ActiveRepairService$ParentRepairSession;
            0   17     1              cfId  Ljava/util/UUID;
            0   17     2   parentSessionId  Ljava/util/UUID;
            4   17     3  isSnapshotRepair  Z
            5   17     4        references  Lcom/google/common/collect/ImmutableMap$Builder<Lorg/apache/cassandra/io/sstable/format/SSTableReader;Lorg/apache/cassandra/utils/concurrent/Ref<Lorg/apache/cassandra/io/sstable/format/SSTableReader;>;>;
            8   17     5          sstables  Ljava/lang/Iterable<Lorg/apache/cassandra/io/sstable/format/SSTableReader;>;
           11   15     6           sstable  Lorg/apache/cassandra/io/sstable/format/SSTableReader;
           12   15     8               ref  Lorg/apache/cassandra/utils/concurrent/Ref<Lorg/apache/cassandra/io/sstable/format/SSTableReader;>;
    Signature: (Ljava/util/UUID;Ljava/util/UUID;)Lorg/apache/cassandra/utils/concurrent/Refs<Lorg/apache/cassandra/io/sstable/format/SSTableReader;>;
    MethodParameters:
                 Name  Flags
      cfId             
      parentSessionId  

  private java.util.Set<org.apache.cassandra.io.sstable.format.SSTableReader> getSSTablesForSnapshotRepair(java.util.UUID, java.util.UUID);
    descriptor: (Ljava/util/UUID;Ljava/util/UUID;)Ljava/util/Set;
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=3, locals=11, args_size=3
        start local 0 // org.apache.cassandra.service.ActiveRepairService$ParentRepairSession this
        start local 1 // java.util.UUID cfId
        start local 2 // java.util.UUID parentSessionId
         0: .line 613
            new java.util.HashSet
            dup
            invokespecial java.util.HashSet.<init>:()V
            astore 3 /* activeSSTables */
        start local 3 // java.util.Set activeSSTables
         1: .line 614
            aload 0 /* this */
            getfield org.apache.cassandra.service.ActiveRepairService$ParentRepairSession.columnFamilyStores:Ljava/util/Map;
            aload 1 /* cfId */
            invokeinterface java.util.Map.get:(Ljava/lang/Object;)Ljava/lang/Object;
            checkcast org.apache.cassandra.db.ColumnFamilyStore
            astore 4 /* cfs */
        start local 4 // org.apache.cassandra.db.ColumnFamilyStore cfs
         2: .line 615
            aload 4 /* cfs */
            ifnonnull 4
         3: .line 616
            aconst_null
            areturn
         4: .line 618
      StackMap locals: java.util.Set org.apache.cassandra.db.ColumnFamilyStore
      StackMap stack:
            new java.util.HashSet
            dup
            invokespecial java.util.HashSet.<init>:()V
            astore 5 /* snapshotGenerations */
        start local 5 // java.util.Set snapshotGenerations
         5: .line 619
            aconst_null
            astore 6
            aconst_null
            astore 7
         6: aload 4 /* cfs */
            aload 2 /* parentSessionId */
            invokevirtual java.util.UUID.toString:()Ljava/lang/String;
            invokevirtual org.apache.cassandra.db.ColumnFamilyStore.getSnapshotSSTableReader:(Ljava/lang/String;)Lorg/apache/cassandra/utils/concurrent/Refs;
            astore 8 /* snapshottedSSTables */
        start local 8 // org.apache.cassandra.utils.concurrent.Refs snapshottedSSTables
         7: .line 621
            aload 8 /* snapshottedSSTables */
            invokevirtual org.apache.cassandra.utils.concurrent.Refs.iterator:()Ljava/util/Iterator;
            astore 10
            goto 10
      StackMap locals: org.apache.cassandra.service.ActiveRepairService$ParentRepairSession java.util.UUID java.util.UUID java.util.Set org.apache.cassandra.db.ColumnFamilyStore java.util.Set java.lang.Throwable java.lang.Throwable org.apache.cassandra.utils.concurrent.Refs top java.util.Iterator
      StackMap stack:
         8: aload 10
            invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
            checkcast org.apache.cassandra.io.sstable.format.SSTableReader
            astore 9 /* sstable */
        start local 9 // org.apache.cassandra.io.sstable.format.SSTableReader sstable
         9: .line 623
            aload 5 /* snapshotGenerations */
            aload 9 /* sstable */
            getfield org.apache.cassandra.io.sstable.format.SSTableReader.descriptor:Lorg/apache/cassandra/io/sstable/Descriptor;
            getfield org.apache.cassandra.io.sstable.Descriptor.generation:I
            invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
            invokeinterface java.util.Set.add:(Ljava/lang/Object;)Z
            pop
        end local 9 // org.apache.cassandra.io.sstable.format.SSTableReader sstable
        10: .line 621
      StackMap locals:
      StackMap stack:
            aload 10
            invokeinterface java.util.Iterator.hasNext:()Z
            ifne 8
        11: .line 625
            aload 8 /* snapshottedSSTables */
            ifnull 19
            aload 8 /* snapshottedSSTables */
            invokevirtual org.apache.cassandra.utils.concurrent.Refs.close:()V
            goto 19
      StackMap locals: org.apache.cassandra.service.ActiveRepairService$ParentRepairSession java.util.UUID java.util.UUID java.util.Set org.apache.cassandra.db.ColumnFamilyStore java.util.Set java.lang.Throwable java.lang.Throwable org.apache.cassandra.utils.concurrent.Refs
      StackMap stack: java.lang.Throwable
        12: astore 6
            aload 8 /* snapshottedSSTables */
            ifnull 13
            aload 8 /* snapshottedSSTables */
            invokevirtual org.apache.cassandra.utils.concurrent.Refs.close:()V
        end local 8 // org.apache.cassandra.utils.concurrent.Refs snapshottedSSTables
      StackMap locals:
      StackMap stack:
        13: aload 6
            athrow
      StackMap locals:
      StackMap stack: java.lang.Throwable
        14: astore 7
            aload 6
            ifnonnull 15
            aload 7
            astore 6
            goto 16
      StackMap locals:
      StackMap stack:
        15: aload 6
            aload 7
            if_acmpeq 16
            aload 6
            aload 7
            invokevirtual java.lang.Throwable.addSuppressed:(Ljava/lang/Throwable;)V
      StackMap locals:
      StackMap stack:
        16: aload 6
            athrow
        17: .line 626
      StackMap locals: org.apache.cassandra.service.ActiveRepairService$ParentRepairSession java.util.UUID java.util.UUID java.util.Set org.apache.cassandra.db.ColumnFamilyStore java.util.Set
      StackMap stack: java.io.IOException
            astore 6 /* e */
        start local 6 // java.io.IOException e
        18: .line 628
            new java.lang.RuntimeException
            dup
            aload 6 /* e */
            invokespecial java.lang.RuntimeException.<init>:(Ljava/lang/Throwable;)V
            athrow
        end local 6 // java.io.IOException e
        19: .line 630
      StackMap locals:
      StackMap stack:
            aload 4 /* cfs */
            getstatic org.apache.cassandra.db.lifecycle.SSTableSet.CANONICAL:Lorg/apache/cassandra/db/lifecycle/SSTableSet;
            invokevirtual org.apache.cassandra.db.ColumnFamilyStore.getSSTables:(Lorg/apache/cassandra/db/lifecycle/SSTableSet;)Ljava/lang/Iterable;
            invokeinterface java.lang.Iterable.iterator:()Ljava/util/Iterator;
            astore 7
            goto 23
      StackMap locals: org.apache.cassandra.service.ActiveRepairService$ParentRepairSession java.util.UUID java.util.UUID java.util.Set org.apache.cassandra.db.ColumnFamilyStore java.util.Set top java.util.Iterator
      StackMap stack:
        20: aload 7
            invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
            checkcast org.apache.cassandra.io.sstable.format.SSTableReader
            astore 6 /* sstable */
        start local 6 // org.apache.cassandra.io.sstable.format.SSTableReader sstable
        21: .line 631
            aload 5 /* snapshotGenerations */
            aload 6 /* sstable */
            getfield org.apache.cassandra.io.sstable.format.SSTableReader.descriptor:Lorg/apache/cassandra/io/sstable/Descriptor;
            getfield org.apache.cassandra.io.sstable.Descriptor.generation:I
            invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
            invokeinterface java.util.Set.contains:(Ljava/lang/Object;)Z
            ifeq 23
        22: .line 632
            aload 3 /* activeSSTables */
            aload 6 /* sstable */
            invokeinterface java.util.Set.add:(Ljava/lang/Object;)Z
            pop
        end local 6 // org.apache.cassandra.io.sstable.format.SSTableReader sstable
        23: .line 630
      StackMap locals:
      StackMap stack:
            aload 7
            invokeinterface java.util.Iterator.hasNext:()Z
            ifne 20
        24: .line 633
            aload 3 /* activeSSTables */
            areturn
        end local 5 // java.util.Set snapshotGenerations
        end local 4 // org.apache.cassandra.db.ColumnFamilyStore cfs
        end local 3 // java.util.Set activeSSTables
        end local 2 // java.util.UUID parentSessionId
        end local 1 // java.util.UUID cfId
        end local 0 // org.apache.cassandra.service.ActiveRepairService$ParentRepairSession this
      LocalVariableTable:
        Start  End  Slot                 Name  Signature
            0   25     0                 this  Lorg/apache/cassandra/service/ActiveRepairService$ParentRepairSession;
            0   25     1                 cfId  Ljava/util/UUID;
            0   25     2      parentSessionId  Ljava/util/UUID;
            1   25     3       activeSSTables  Ljava/util/Set<Lorg/apache/cassandra/io/sstable/format/SSTableReader;>;
            2   25     4                  cfs  Lorg/apache/cassandra/db/ColumnFamilyStore;
            5   25     5  snapshotGenerations  Ljava/util/Set<Ljava/lang/Integer;>;
            7   13     8  snapshottedSSTables  Lorg/apache/cassandra/utils/concurrent/Refs<Lorg/apache/cassandra/io/sstable/format/SSTableReader;>;
            9   10     9              sstable  Lorg/apache/cassandra/io/sstable/format/SSTableReader;
           18   19     6                    e  Ljava/io/IOException;
           21   23     6              sstable  Lorg/apache/cassandra/io/sstable/format/SSTableReader;
      Exception table:
        from    to  target  type
           7    11      12  any
           6    14      14  any
           5    17      17  Class java.io.IOException
    Signature: (Ljava/util/UUID;Ljava/util/UUID;)Ljava/util/Set<Lorg/apache/cassandra/io/sstable/format/SSTableReader;>;
    MethodParameters:
                 Name  Flags
      cfId             
      parentSessionId  

  public synchronized void maybeSnapshot(java.util.UUID, java.util.UUID);
    descriptor: (Ljava/util/UUID;Ljava/util/UUID;)V
    flags: (0x0021) ACC_PUBLIC, ACC_SYNCHRONIZED
    Code:
      stack=5, locals=5, args_size=3
        start local 0 // org.apache.cassandra.service.ActiveRepairService$ParentRepairSession this
        start local 1 // java.util.UUID cfId
        start local 2 // java.util.UUID parentSessionId
         0: .line 638
            aload 2 /* parentSessionId */
            invokevirtual java.util.UUID.toString:()Ljava/lang/String;
            astore 3 /* snapshotName */
        start local 3 // java.lang.String snapshotName
         1: .line 639
            aload 0 /* this */
            getfield org.apache.cassandra.service.ActiveRepairService$ParentRepairSession.columnFamilyStores:Ljava/util/Map;
            aload 1 /* cfId */
            invokeinterface java.util.Map.get:(Ljava/lang/Object;)Ljava/lang/Object;
            checkcast org.apache.cassandra.db.ColumnFamilyStore
            aload 3 /* snapshotName */
            invokevirtual org.apache.cassandra.db.ColumnFamilyStore.snapshotExists:(Ljava/lang/String;)Z
            ifne 11
         2: .line 641
            aload 0 /* this */
            getfield org.apache.cassandra.service.ActiveRepairService$ParentRepairSession.columnFamilyStores:Ljava/util/Map;
            aload 1 /* cfId */
            invokeinterface java.util.Map.get:(Ljava/lang/Object;)Ljava/lang/Object;
            checkcast org.apache.cassandra.db.ColumnFamilyStore
            aload 3 /* snapshotName */
            new org.apache.cassandra.service.ActiveRepairService$ParentRepairSession$1
            dup
            aload 0 /* this */
            invokespecial org.apache.cassandra.service.ActiveRepairService$ParentRepairSession$1.<init>:(Lorg/apache/cassandra/service/ActiveRepairService$ParentRepairSession;)V
         3: .line 650
            iconst_1
            iconst_0
         4: .line 641
            invokevirtual org.apache.cassandra.db.ColumnFamilyStore.snapshot:(Ljava/lang/String;Lcom/google/common/base/Predicate;ZZ)Ljava/util/Set;
            astore 4 /* snapshottedSSTables */
        start local 4 // java.util.Set snapshottedSSTables
         5: .line 652
            aload 0 /* this */
            aload 1 /* cfId */
            aload 2 /* parentSessionId */
            aload 4 /* snapshottedSSTables */
            invokevirtual org.apache.cassandra.service.ActiveRepairService$ParentRepairSession.isAlreadyRepairing:(Ljava/util/UUID;Ljava/util/UUID;Ljava/util/Collection;)Z
            ifeq 9
         6: .line 654
            aload 0 /* this */
            getfield org.apache.cassandra.service.ActiveRepairService$ParentRepairSession.columnFamilyStores:Ljava/util/Map;
            aload 1 /* cfId */
            invokeinterface java.util.Map.get:(Ljava/lang/Object;)Ljava/lang/Object;
            checkcast org.apache.cassandra.db.ColumnFamilyStore
            aload 2 /* parentSessionId */
            invokevirtual java.util.UUID.toString:()Ljava/lang/String;
            invokevirtual org.apache.cassandra.db.ColumnFamilyStore.clearSnapshot:(Ljava/lang/String;)V
         7: .line 655
            getstatic org.apache.cassandra.service.ActiveRepairService.logger:Lorg/slf4j/Logger;
            ldc "Cannot start multiple repair sessions over the same sstables"
            invokeinterface org.slf4j.Logger.error:(Ljava/lang/String;)V
         8: .line 656
            new java.lang.RuntimeException
            dup
            ldc "Cannot start multiple repair sessions over the same sstables"
            invokespecial java.lang.RuntimeException.<init>:(Ljava/lang/String;)V
            athrow
         9: .line 658
      StackMap locals: java.lang.String java.util.Set
      StackMap stack:
            aload 0 /* this */
            aload 1 /* cfId */
            aload 4 /* snapshottedSSTables */
            invokevirtual org.apache.cassandra.service.ActiveRepairService$ParentRepairSession.addSSTables:(Ljava/util/UUID;Ljava/util/Collection;)V
        10: .line 659
            aload 0 /* this */
            getfield org.apache.cassandra.service.ActiveRepairService$ParentRepairSession.marked:Ljava/util/Set;
            aload 1 /* cfId */
            invokeinterface java.util.Set.add:(Ljava/lang/Object;)Z
            pop
        end local 4 // java.util.Set snapshottedSSTables
        11: .line 661
      StackMap locals:
      StackMap stack:
            return
        end local 3 // java.lang.String snapshotName
        end local 2 // java.util.UUID parentSessionId
        end local 1 // java.util.UUID cfId
        end local 0 // org.apache.cassandra.service.ActiveRepairService$ParentRepairSession this
      LocalVariableTable:
        Start  End  Slot                 Name  Signature
            0   12     0                 this  Lorg/apache/cassandra/service/ActiveRepairService$ParentRepairSession;
            0   12     1                 cfId  Ljava/util/UUID;
            0   12     2      parentSessionId  Ljava/util/UUID;
            1   12     3         snapshotName  Ljava/lang/String;
            5   11     4  snapshottedSSTables  Ljava/util/Set<Lorg/apache/cassandra/io/sstable/format/SSTableReader;>;
    MethodParameters:
                 Name  Flags
      cfId             
      parentSessionId  

  private boolean isAlreadyRepairing(java.util.UUID, java.util.UUID, java.util.Collection<org.apache.cassandra.io.sstable.format.SSTableReader>);
    descriptor: (Ljava/util/UUID;Ljava/util/UUID;Ljava/util/Collection;)Z
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=3, locals=9, args_size=4
        start local 0 // org.apache.cassandra.service.ActiveRepairService$ParentRepairSession this
        start local 1 // java.util.UUID cfId
        start local 2 // java.util.UUID parentSessionId
        start local 3 // java.util.Collection sstables
         0: .line 676
            getstatic org.apache.cassandra.service.ActiveRepairService.instance:Lorg/apache/cassandra/service/ActiveRepairService;
            aload 1 /* cfId */
            aload 2 /* parentSessionId */
            invokevirtual org.apache.cassandra.service.ActiveRepairService.currentlyRepairing:(Ljava/util/UUID;Ljava/util/UUID;)Ljava/util/Set;
            astore 4 /* currentlyRepairing */
        start local 4 // java.util.Set currentlyRepairing
         1: .line 677
            new java.util.HashSet
            dup
            invokespecial java.util.HashSet.<init>:()V
            astore 5 /* currentlyRepairingGenerations */
        start local 5 // java.util.Set currentlyRepairingGenerations
         2: .line 678
            new java.util.HashSet
            dup
            invokespecial java.util.HashSet.<init>:()V
            astore 6 /* newRepairingGenerations */
        start local 6 // java.util.Set newRepairingGenerations
         3: .line 679
            aload 4 /* currentlyRepairing */
            invokeinterface java.util.Set.iterator:()Ljava/util/Iterator;
            astore 8
            goto 6
      StackMap locals: org.apache.cassandra.service.ActiveRepairService$ParentRepairSession java.util.UUID java.util.UUID java.util.Collection java.util.Set java.util.Set java.util.Set top java.util.Iterator
      StackMap stack:
         4: aload 8
            invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
            checkcast org.apache.cassandra.io.sstable.format.SSTableReader
            astore 7 /* sstable */
        start local 7 // org.apache.cassandra.io.sstable.format.SSTableReader sstable
         5: .line 680
            aload 5 /* currentlyRepairingGenerations */
            aload 7 /* sstable */
            getfield org.apache.cassandra.io.sstable.format.SSTableReader.descriptor:Lorg/apache/cassandra/io/sstable/Descriptor;
            getfield org.apache.cassandra.io.sstable.Descriptor.generation:I
            invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
            invokeinterface java.util.Set.add:(Ljava/lang/Object;)Z
            pop
        end local 7 // org.apache.cassandra.io.sstable.format.SSTableReader sstable
         6: .line 679
      StackMap locals:
      StackMap stack:
            aload 8
            invokeinterface java.util.Iterator.hasNext:()Z
            ifne 4
         7: .line 681
            aload 3 /* sstables */
            invokeinterface java.util.Collection.iterator:()Ljava/util/Iterator;
            astore 8
            goto 10
      StackMap locals:
      StackMap stack:
         8: aload 8
            invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
            checkcast org.apache.cassandra.io.sstable.format.SSTableReader
            astore 7 /* sstable */
        start local 7 // org.apache.cassandra.io.sstable.format.SSTableReader sstable
         9: .line 682
            aload 6 /* newRepairingGenerations */
            aload 7 /* sstable */
            getfield org.apache.cassandra.io.sstable.format.SSTableReader.descriptor:Lorg/apache/cassandra/io/sstable/Descriptor;
            getfield org.apache.cassandra.io.sstable.Descriptor.generation:I
            invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
            invokeinterface java.util.Set.add:(Ljava/lang/Object;)Z
            pop
        end local 7 // org.apache.cassandra.io.sstable.format.SSTableReader sstable
        10: .line 681
      StackMap locals:
      StackMap stack:
            aload 8
            invokeinterface java.util.Iterator.hasNext:()Z
            ifne 8
        11: .line 684
            aload 5 /* currentlyRepairingGenerations */
            aload 6 /* newRepairingGenerations */
            invokestatic com.google.common.collect.Sets.intersection:(Ljava/util/Set;Ljava/util/Set;)Lcom/google/common/collect/Sets$SetView;
            invokevirtual com.google.common.collect.Sets$SetView.isEmpty:()Z
            ifeq 12
            iconst_0
            goto 13
      StackMap locals: org.apache.cassandra.service.ActiveRepairService$ParentRepairSession java.util.UUID java.util.UUID java.util.Collection java.util.Set java.util.Set java.util.Set
      StackMap stack:
        12: iconst_1
      StackMap locals:
      StackMap stack: int
        13: ireturn
        end local 6 // java.util.Set newRepairingGenerations
        end local 5 // java.util.Set currentlyRepairingGenerations
        end local 4 // java.util.Set currentlyRepairing
        end local 3 // java.util.Collection sstables
        end local 2 // java.util.UUID parentSessionId
        end local 1 // java.util.UUID cfId
        end local 0 // org.apache.cassandra.service.ActiveRepairService$ParentRepairSession this
      LocalVariableTable:
        Start  End  Slot                           Name  Signature
            0   14     0                           this  Lorg/apache/cassandra/service/ActiveRepairService$ParentRepairSession;
            0   14     1                           cfId  Ljava/util/UUID;
            0   14     2                parentSessionId  Ljava/util/UUID;
            0   14     3                       sstables  Ljava/util/Collection<Lorg/apache/cassandra/io/sstable/format/SSTableReader;>;
            1   14     4             currentlyRepairing  Ljava/util/Set<Lorg/apache/cassandra/io/sstable/format/SSTableReader;>;
            2   14     5  currentlyRepairingGenerations  Ljava/util/Set<Ljava/lang/Integer;>;
            3   14     6        newRepairingGenerations  Ljava/util/Set<Ljava/lang/Integer;>;
            5    6     7                        sstable  Lorg/apache/cassandra/io/sstable/format/SSTableReader;
            9   10     7                        sstable  Lorg/apache/cassandra/io/sstable/format/SSTableReader;
    Signature: (Ljava/util/UUID;Ljava/util/UUID;Ljava/util/Collection<Lorg/apache/cassandra/io/sstable/format/SSTableReader;>;)Z
    MethodParameters:
                 Name  Flags
      cfId             
      parentSessionId  
      sstables         

  private java.util.Set<org.apache.cassandra.io.sstable.format.SSTableReader> getActiveSSTables(java.util.UUID);
    descriptor: (Ljava/util/UUID;)Ljava/util/Set;
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=3, locals=8, args_size=2
        start local 0 // org.apache.cassandra.service.ActiveRepairService$ParentRepairSession this
        start local 1 // java.util.UUID cfId
         0: .line 689
            aload 0 /* this */
            getfield org.apache.cassandra.service.ActiveRepairService$ParentRepairSession.columnFamilyStores:Ljava/util/Map;
            aload 1 /* cfId */
            invokeinterface java.util.Map.containsKey:(Ljava/lang/Object;)Z
            ifne 2
         1: .line 690
            aconst_null
            areturn
         2: .line 692
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield org.apache.cassandra.service.ActiveRepairService$ParentRepairSession.sstableMap:Ljava/util/Map;
            aload 1 /* cfId */
            invokeinterface java.util.Map.get:(Ljava/lang/Object;)Ljava/lang/Object;
            checkcast java.util.Set
            astore 2 /* repairedSSTables */
        start local 2 // java.util.Set repairedSSTables
         3: .line 693
            new java.util.HashSet
            dup
            invokespecial java.util.HashSet.<init>:()V
            astore 3 /* activeSSTables */
        start local 3 // java.util.Set activeSSTables
         4: .line 694
            new java.util.HashSet
            dup
            invokespecial java.util.HashSet.<init>:()V
            astore 4 /* activeSSTableNames */
        start local 4 // java.util.Set activeSSTableNames
         5: .line 695
            aload 0 /* this */
            getfield org.apache.cassandra.service.ActiveRepairService$ParentRepairSession.columnFamilyStores:Ljava/util/Map;
            aload 1 /* cfId */
            invokeinterface java.util.Map.get:(Ljava/lang/Object;)Ljava/lang/Object;
            checkcast org.apache.cassandra.db.ColumnFamilyStore
            astore 5 /* cfs */
        start local 5 // org.apache.cassandra.db.ColumnFamilyStore cfs
         6: .line 696
            aload 5 /* cfs */
            getstatic org.apache.cassandra.db.lifecycle.SSTableSet.CANONICAL:Lorg/apache/cassandra/db/lifecycle/SSTableSet;
            invokevirtual org.apache.cassandra.db.ColumnFamilyStore.getSSTables:(Lorg/apache/cassandra/db/lifecycle/SSTableSet;)Ljava/lang/Iterable;
            invokeinterface java.lang.Iterable.iterator:()Ljava/util/Iterator;
            astore 7
            goto 11
      StackMap locals: org.apache.cassandra.service.ActiveRepairService$ParentRepairSession java.util.UUID java.util.Set java.util.Set java.util.Set org.apache.cassandra.db.ColumnFamilyStore top java.util.Iterator
      StackMap stack:
         7: aload 7
            invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
            checkcast org.apache.cassandra.io.sstable.format.SSTableReader
            astore 6 /* sstable */
        start local 6 // org.apache.cassandra.io.sstable.format.SSTableReader sstable
         8: .line 698
            aload 2 /* repairedSSTables */
            aload 6 /* sstable */
            invokevirtual org.apache.cassandra.io.sstable.format.SSTableReader.getFilename:()Ljava/lang/String;
            invokeinterface java.util.Set.contains:(Ljava/lang/Object;)Z
            ifeq 11
         9: .line 700
            aload 3 /* activeSSTables */
            aload 6 /* sstable */
            invokeinterface java.util.Set.add:(Ljava/lang/Object;)Z
            pop
        10: .line 701
            aload 4 /* activeSSTableNames */
            aload 6 /* sstable */
            invokevirtual org.apache.cassandra.io.sstable.format.SSTableReader.getFilename:()Ljava/lang/String;
            invokeinterface java.util.Set.add:(Ljava/lang/Object;)Z
            pop
        end local 6 // org.apache.cassandra.io.sstable.format.SSTableReader sstable
        11: .line 696
      StackMap locals:
      StackMap stack:
            aload 7
            invokeinterface java.util.Iterator.hasNext:()Z
            ifne 7
        12: .line 704
            aload 0 /* this */
            getfield org.apache.cassandra.service.ActiveRepairService$ParentRepairSession.sstableMap:Ljava/util/Map;
            aload 1 /* cfId */
            aload 4 /* activeSSTableNames */
            invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
            pop
        13: .line 705
            aload 3 /* activeSSTables */
            areturn
        end local 5 // org.apache.cassandra.db.ColumnFamilyStore cfs
        end local 4 // java.util.Set activeSSTableNames
        end local 3 // java.util.Set activeSSTables
        end local 2 // java.util.Set repairedSSTables
        end local 1 // java.util.UUID cfId
        end local 0 // org.apache.cassandra.service.ActiveRepairService$ParentRepairSession this
      LocalVariableTable:
        Start  End  Slot                Name  Signature
            0   14     0                this  Lorg/apache/cassandra/service/ActiveRepairService$ParentRepairSession;
            0   14     1                cfId  Ljava/util/UUID;
            3   14     2    repairedSSTables  Ljava/util/Set<Ljava/lang/String;>;
            4   14     3      activeSSTables  Ljava/util/Set<Lorg/apache/cassandra/io/sstable/format/SSTableReader;>;
            5   14     4  activeSSTableNames  Ljava/util/Set<Ljava/lang/String;>;
            6   14     5                 cfs  Lorg/apache/cassandra/db/ColumnFamilyStore;
            8   11     6             sstable  Lorg/apache/cassandra/io/sstable/format/SSTableReader;
    Signature: (Ljava/util/UUID;)Ljava/util/Set<Lorg/apache/cassandra/io/sstable/format/SSTableReader;>;
    MethodParameters:
      Name  Flags
      cfId  

  private void addSSTables(java.util.UUID, java.util.Collection<org.apache.cassandra.io.sstable.format.SSTableReader>);
    descriptor: (Ljava/util/UUID;Ljava/util/Collection;)V
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=2, locals=5, args_size=3
        start local 0 // org.apache.cassandra.service.ActiveRepairService$ParentRepairSession this
        start local 1 // java.util.UUID cfId
        start local 2 // java.util.Collection sstables
         0: .line 710
            aload 2 /* sstables */
            invokeinterface java.util.Collection.iterator:()Ljava/util/Iterator;
            astore 4
            goto 3
      StackMap locals: org.apache.cassandra.service.ActiveRepairService$ParentRepairSession java.util.UUID java.util.Collection top java.util.Iterator
      StackMap stack:
         1: aload 4
            invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
            checkcast org.apache.cassandra.io.sstable.format.SSTableReader
            astore 3 /* sstable */
        start local 3 // org.apache.cassandra.io.sstable.format.SSTableReader sstable
         2: .line 711
            aload 0 /* this */
            getfield org.apache.cassandra.service.ActiveRepairService$ParentRepairSession.sstableMap:Ljava/util/Map;
            aload 1 /* cfId */
            invokeinterface java.util.Map.get:(Ljava/lang/Object;)Ljava/lang/Object;
            checkcast java.util.Set
            aload 3 /* sstable */
            invokevirtual org.apache.cassandra.io.sstable.format.SSTableReader.getFilename:()Ljava/lang/String;
            invokeinterface java.util.Set.add:(Ljava/lang/Object;)Z
            pop
        end local 3 // org.apache.cassandra.io.sstable.format.SSTableReader sstable
         3: .line 710
      StackMap locals:
      StackMap stack:
            aload 4
            invokeinterface java.util.Iterator.hasNext:()Z
            ifne 1
         4: .line 712
            return
        end local 2 // java.util.Collection sstables
        end local 1 // java.util.UUID cfId
        end local 0 // org.apache.cassandra.service.ActiveRepairService$ParentRepairSession this
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0    5     0      this  Lorg/apache/cassandra/service/ActiveRepairService$ParentRepairSession;
            0    5     1      cfId  Ljava/util/UUID;
            0    5     2  sstables  Ljava/util/Collection<Lorg/apache/cassandra/io/sstable/format/SSTableReader;>;
            2    3     3   sstable  Lorg/apache/cassandra/io/sstable/format/SSTableReader;
    Signature: (Ljava/util/UUID;Ljava/util/Collection<Lorg/apache/cassandra/io/sstable/format/SSTableReader;>;)V
    MethodParameters:
          Name  Flags
      cfId      
      sstables  

  public long getRepairedAt();
    descriptor: ()J
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // org.apache.cassandra.service.ActiveRepairService$ParentRepairSession this
         0: .line 717
            aload 0 /* this */
            getfield org.apache.cassandra.service.ActiveRepairService$ParentRepairSession.isGlobal:Z
            ifeq 2
         1: .line 718
            aload 0 /* this */
            getfield org.apache.cassandra.service.ActiveRepairService$ParentRepairSession.repairedAt:J
            lreturn
         2: .line 719
      StackMap locals:
      StackMap stack:
            lconst_0
            lreturn
        end local 0 // org.apache.cassandra.service.ActiveRepairService$ParentRepairSession this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    3     0  this  Lorg/apache/cassandra/service/ActiveRepairService$ParentRepairSession;

  public java.lang.String toString();
    descriptor: ()Ljava/lang/String;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=1, args_size=1
        start local 0 // org.apache.cassandra.service.ActiveRepairService$ParentRepairSession this
         0: .line 725
            new java.lang.StringBuilder
            dup
            ldc "ParentRepairSession{columnFamilyStores="
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
         1: .line 726
            aload 0 /* this */
            getfield org.apache.cassandra.service.ActiveRepairService$ParentRepairSession.columnFamilyStores:Ljava/util/Map;
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/Object;)Ljava/lang/StringBuilder;
         2: .line 727
            ldc ", ranges="
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            aload 0 /* this */
            getfield org.apache.cassandra.service.ActiveRepairService$ParentRepairSession.ranges:Ljava/util/Collection;
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/Object;)Ljava/lang/StringBuilder;
         3: .line 728
            ldc ", sstableMap="
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            aload 0 /* this */
            getfield org.apache.cassandra.service.ActiveRepairService$ParentRepairSession.sstableMap:Ljava/util/Map;
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/Object;)Ljava/lang/StringBuilder;
         4: .line 729
            ldc ", repairedAt="
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            aload 0 /* this */
            getfield org.apache.cassandra.service.ActiveRepairService$ParentRepairSession.repairedAt:J
            invokevirtual java.lang.StringBuilder.append:(J)Ljava/lang/StringBuilder;
         5: .line 730
            bipush 125
            invokevirtual java.lang.StringBuilder.append:(C)Ljava/lang/StringBuilder;
         6: .line 725
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
            areturn
        end local 0 // org.apache.cassandra.service.ActiveRepairService$ParentRepairSession this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    7     0  this  Lorg/apache/cassandra/service/ActiveRepairService$ParentRepairSession;

  private boolean lambda$0(org.apache.cassandra.io.sstable.format.SSTableReader);
    descriptor: (Lorg/apache/cassandra/io/sstable/format/SSTableReader;)Z
    flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
    Code:
      stack=1, locals=2, args_size=2
        start local 0 // org.apache.cassandra.service.ActiveRepairService$ParentRepairSession this
        start local 1 // org.apache.cassandra.io.sstable.format.SSTableReader s
         0: .line 557
            aload 0 /* this */
            getfield org.apache.cassandra.service.ActiveRepairService$ParentRepairSession.isIncremental:Z
            ifeq 1
            aload 1 /* s */
            invokevirtual org.apache.cassandra.io.sstable.format.SSTableReader.isRepaired:()Z
            ifeq 1
            iconst_0
            goto 2
      StackMap locals:
      StackMap stack:
         1: iconst_1
      StackMap locals:
      StackMap stack: int
         2: ireturn
        end local 1 // org.apache.cassandra.io.sstable.format.SSTableReader s
        end local 0 // org.apache.cassandra.service.ActiveRepairService$ParentRepairSession this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    3     0  this  Lorg/apache/cassandra/service/ActiveRepairService$ParentRepairSession;
            0    3     1     s  Lorg/apache/cassandra/io/sstable/format/SSTableReader;
}
SourceFile: "ActiveRepairService.java"
NestHost: org.apache.cassandra.service.ActiveRepairService
InnerClasses:
  public Builder = com.google.common.collect.ImmutableMap$Builder of com.google.common.collect.ImmutableMap
  public abstract SetView = com.google.common.collect.Sets$SetView of com.google.common.collect.Sets
  public final Lookup = java.lang.invoke.MethodHandles$Lookup of java.lang.invoke.MethodHandles
  public ViewFragment = org.apache.cassandra.db.ColumnFamilyStore$ViewFragment of org.apache.cassandra.db.ColumnFamilyStore
  public ParentRepairSession = org.apache.cassandra.service.ActiveRepairService$ParentRepairSession of org.apache.cassandra.service.ActiveRepairService
  org.apache.cassandra.service.ActiveRepairService$ParentRepairSession$1