public class org.apache.cassandra.db.compaction.CompactionStrategyManager implements org.apache.cassandra.notifications.INotificationConsumer
minor version: 0
major version: 59
flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
this_class: org.apache.cassandra.db.compaction.CompactionStrategyManager
super_class: java.lang.Object
{
private static final org.slf4j.Logger logger;
descriptor: Lorg/slf4j/Logger;
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
public final org.apache.cassandra.db.compaction.CompactionLogger compactionLogger;
descriptor: Lorg/apache/cassandra/db/compaction/CompactionLogger;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
private final org.apache.cassandra.db.ColumnFamilyStore cfs;
descriptor: Lorg/apache/cassandra/db/ColumnFamilyStore;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final boolean partitionSSTablesByTokenRange;
descriptor: Z
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final java.util.function.Supplier<org.apache.cassandra.db.DiskBoundaries> boundariesSupplier;
descriptor: Ljava/util/function/Supplier;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Ljava/util/function/Supplier<Lorg/apache/cassandra/db/DiskBoundaries;>;
private final java.util.concurrent.locks.ReentrantReadWriteLock lock;
descriptor: Ljava/util/concurrent/locks/ReentrantReadWriteLock;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final java.util.concurrent.locks.ReentrantReadWriteLock$ReadLock readLock;
descriptor: Ljava/util/concurrent/locks/ReentrantReadWriteLock$ReadLock;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final java.util.concurrent.locks.ReentrantReadWriteLock$WriteLock writeLock;
descriptor: Ljava/util/concurrent/locks/ReentrantReadWriteLock$WriteLock;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final java.util.List<org.apache.cassandra.db.compaction.AbstractCompactionStrategy> repaired;
descriptor: Ljava/util/List;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Ljava/util/List<Lorg/apache/cassandra/db/compaction/AbstractCompactionStrategy;>;
private final java.util.List<org.apache.cassandra.db.compaction.AbstractCompactionStrategy> unrepaired;
descriptor: Ljava/util/List;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Ljava/util/List<Lorg/apache/cassandra/db/compaction/AbstractCompactionStrategy;>;
private volatile org.apache.cassandra.schema.CompactionParams params;
descriptor: Lorg/apache/cassandra/schema/CompactionParams;
flags: (0x0042) ACC_PRIVATE, ACC_VOLATILE
private org.apache.cassandra.db.DiskBoundaries currentBoundaries;
descriptor: Lorg/apache/cassandra/db/DiskBoundaries;
flags: (0x0002) ACC_PRIVATE
private volatile boolean enabled;
descriptor: Z
flags: (0x0042) ACC_PRIVATE, ACC_VOLATILE
private volatile boolean isActive;
descriptor: Z
flags: (0x0042) ACC_PRIVATE, ACC_VOLATILE
private volatile org.apache.cassandra.schema.CompactionParams schemaCompactionParams;
descriptor: Lorg/apache/cassandra/schema/CompactionParams;
flags: (0x0042) ACC_PRIVATE, ACC_VOLATILE
private boolean shouldDefragment;
descriptor: Z
flags: (0x0002) ACC_PRIVATE
private boolean supportsEarlyOpen;
descriptor: Z
flags: (0x0002) ACC_PRIVATE
private int fanout;
descriptor: I
flags: (0x0002) ACC_PRIVATE
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: ldc Lorg/apache/cassandra/db/compaction/CompactionStrategyManager;
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.db.compaction.CompactionStrategyManager.$assertionsDisabled:Z
3: ldc Lorg/apache/cassandra/db/compaction/CompactionStrategyManager;
invokestatic org.slf4j.LoggerFactory.getLogger:(Ljava/lang/Class;)Lorg/slf4j/Logger;
putstatic org.apache.cassandra.db.compaction.CompactionStrategyManager.logger:Lorg/slf4j/Logger;
return
LocalVariableTable:
Start End Slot Name Signature
public void <init>(org.apache.cassandra.db.ColumnFamilyStore);
descriptor: (Lorg/apache/cassandra/db/ColumnFamilyStore;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
aload 1
dup
invokevirtual java.lang.Object.getClass:()Ljava/lang/Class;
pop
invokedynamic get(Lorg/apache/cassandra/db/ColumnFamilyStore;)Ljava/util/function/Supplier;
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;
org/apache/cassandra/db/ColumnFamilyStore.getDiskBoundaries()Lorg/apache/cassandra/db/DiskBoundaries; (5)
()Lorg/apache/cassandra/db/DiskBoundaries;
aload 1
invokevirtual org.apache.cassandra.db.ColumnFamilyStore.getPartitioner:()Lorg/apache/cassandra/dht/IPartitioner;
invokeinterface org.apache.cassandra.dht.IPartitioner.splitter:()Ljava/util/Optional;
invokevirtual java.util.Optional.isPresent:()Z
invokespecial org.apache.cassandra.db.compaction.CompactionStrategyManager.<init>:(Lorg/apache/cassandra/db/ColumnFamilyStore;Ljava/util/function/Supplier;Z)V
1: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/apache/cassandra/db/compaction/CompactionStrategyManager;
0 2 1 cfs Lorg/apache/cassandra/db/ColumnFamilyStore;
MethodParameters:
Name Flags
cfs
public void <init>(org.apache.cassandra.db.ColumnFamilyStore, java.util.function.Supplier<org.apache.cassandra.db.DiskBoundaries>, );
descriptor: (Lorg/apache/cassandra/db/ColumnFamilyStore;Ljava/util/function/Supplier;Z)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=4, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
invokespecial java.lang.Object.<init>:()V
1: aload 0
new java.util.concurrent.locks.ReentrantReadWriteLock
dup
invokespecial java.util.concurrent.locks.ReentrantReadWriteLock.<init>:()V
putfield org.apache.cassandra.db.compaction.CompactionStrategyManager.lock:Ljava/util/concurrent/locks/ReentrantReadWriteLock;
2: aload 0
aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.lock:Ljava/util/concurrent/locks/ReentrantReadWriteLock;
invokevirtual java.util.concurrent.locks.ReentrantReadWriteLock.readLock:()Ljava/util/concurrent/locks/ReentrantReadWriteLock$ReadLock;
putfield org.apache.cassandra.db.compaction.CompactionStrategyManager.readLock:Ljava/util/concurrent/locks/ReentrantReadWriteLock$ReadLock;
3: aload 0
aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.lock:Ljava/util/concurrent/locks/ReentrantReadWriteLock;
invokevirtual java.util.concurrent.locks.ReentrantReadWriteLock.writeLock:()Ljava/util/concurrent/locks/ReentrantReadWriteLock$WriteLock;
putfield org.apache.cassandra.db.compaction.CompactionStrategyManager.writeLock:Ljava/util/concurrent/locks/ReentrantReadWriteLock$WriteLock;
4: aload 0
new java.util.ArrayList
dup
invokespecial java.util.ArrayList.<init>:()V
putfield org.apache.cassandra.db.compaction.CompactionStrategyManager.repaired:Ljava/util/List;
5: aload 0
new java.util.ArrayList
dup
invokespecial java.util.ArrayList.<init>:()V
putfield org.apache.cassandra.db.compaction.CompactionStrategyManager.unrepaired:Ljava/util/List;
6: aload 0
iconst_1
putfield org.apache.cassandra.db.compaction.CompactionStrategyManager.enabled:Z
7: aload 0
iconst_1
putfield org.apache.cassandra.db.compaction.CompactionStrategyManager.isActive:Z
8: aload 1
invokevirtual org.apache.cassandra.db.ColumnFamilyStore.getTracker:()Lorg/apache/cassandra/db/lifecycle/Tracker;
aload 0
invokevirtual org.apache.cassandra.db.lifecycle.Tracker.subscribe:(Lorg/apache/cassandra/notifications/INotificationConsumer;)V
9: getstatic org.apache.cassandra.db.compaction.CompactionStrategyManager.logger:Lorg/slf4j/Logger;
ldc "{} subscribed to the data tracker."
aload 0
invokeinterface org.slf4j.Logger.trace:(Ljava/lang/String;Ljava/lang/Object;)V
10: aload 0
aload 1
putfield org.apache.cassandra.db.compaction.CompactionStrategyManager.cfs:Lorg/apache/cassandra/db/ColumnFamilyStore;
11: aload 0
new org.apache.cassandra.db.compaction.CompactionLogger
dup
aload 1
aload 0
invokespecial org.apache.cassandra.db.compaction.CompactionLogger.<init>:(Lorg/apache/cassandra/db/ColumnFamilyStore;Lorg/apache/cassandra/db/compaction/CompactionStrategyManager;)V
putfield org.apache.cassandra.db.compaction.CompactionStrategyManager.compactionLogger:Lorg/apache/cassandra/db/compaction/CompactionLogger;
12: aload 0
aload 2
putfield org.apache.cassandra.db.compaction.CompactionStrategyManager.boundariesSupplier:Ljava/util/function/Supplier;
13: aload 0
iload 3
putfield org.apache.cassandra.db.compaction.CompactionStrategyManager.partitionSSTablesByTokenRange:Z
14: aload 0
aload 1
getfield org.apache.cassandra.db.ColumnFamilyStore.metadata:Lorg/apache/cassandra/config/CFMetaData;
getfield org.apache.cassandra.config.CFMetaData.params:Lorg/apache/cassandra/schema/TableParams;
getfield org.apache.cassandra.schema.TableParams.compaction:Lorg/apache/cassandra/schema/CompactionParams;
putfield org.apache.cassandra.db.compaction.CompactionStrategyManager.params:Lorg/apache/cassandra/schema/CompactionParams;
15: aload 0
aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.params:Lorg/apache/cassandra/schema/CompactionParams;
invokevirtual org.apache.cassandra.schema.CompactionParams.isEnabled:()Z
putfield org.apache.cassandra.db.compaction.CompactionStrategyManager.enabled:Z
16: aload 0
aload 1
getfield org.apache.cassandra.db.ColumnFamilyStore.metadata:Lorg/apache/cassandra/config/CFMetaData;
getfield org.apache.cassandra.config.CFMetaData.params:Lorg/apache/cassandra/schema/TableParams;
getfield org.apache.cassandra.schema.TableParams.compaction:Lorg/apache/cassandra/schema/CompactionParams;
invokevirtual org.apache.cassandra.db.compaction.CompactionStrategyManager.reload:(Lorg/apache/cassandra/schema/CompactionParams;)V
17: return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 18 0 this Lorg/apache/cassandra/db/compaction/CompactionStrategyManager;
0 18 1 cfs Lorg/apache/cassandra/db/ColumnFamilyStore;
0 18 2 boundariesSupplier Ljava/util/function/Supplier<Lorg/apache/cassandra/db/DiskBoundaries;>;
0 18 3 partitionSSTablesByTokenRange Z
Signature: (Lorg/apache/cassandra/db/ColumnFamilyStore;Ljava/util/function/Supplier<Lorg/apache/cassandra/db/DiskBoundaries;>;Z)V
RuntimeInvisibleAnnotations:
com.google.common.annotations.VisibleForTesting()
RuntimeInvisibleTypeAnnotations:
METHOD_RETURN
com.google.common.annotations.VisibleForTesting()
MethodParameters:
Name Flags
cfs
boundariesSupplier
partitionSSTablesByTokenRange
public org.apache.cassandra.db.compaction.AbstractCompactionTask getNextBackgroundTask(int);
descriptor: (I)Lorg/apache/cassandra/db/compaction/AbstractCompactionTask;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=8, args_size=2
start local 0 start local 1 0: aload 0
invokevirtual org.apache.cassandra.db.compaction.CompactionStrategyManager.maybeReloadDiskBoundaries:()Z
pop
1: aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.readLock:Ljava/util/concurrent/locks/ReentrantReadWriteLock$ReadLock;
invokevirtual java.util.concurrent.locks.ReentrantReadWriteLock$ReadLock.lock:()V
2: aload 0
invokevirtual org.apache.cassandra.db.compaction.CompactionStrategyManager.isEnabled:()Z
ifne 5
3: aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.readLock:Ljava/util/concurrent/locks/ReentrantReadWriteLock$ReadLock;
invokevirtual java.util.concurrent.locks.ReentrantReadWriteLock$ReadLock.unlock:()V
4: aconst_null
areturn
5: StackMap locals:
StackMap stack:
new java.util.ArrayList
dup
invokespecial java.util.ArrayList.<init>:()V
astore 2
start local 2 6: aload 2
aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.repaired:Ljava/util/List;
invokeinterface java.util.List.addAll:(Ljava/util/Collection;)Z
pop
7: aload 2
aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.unrepaired:Ljava/util/List;
invokeinterface java.util.List.addAll:(Ljava/util/Collection;)Z
pop
8: aload 2
invokedynamic compare()Ljava/util/Comparator;
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;)I
org/apache/cassandra/db/compaction/CompactionStrategyManager.lambda$1(Lorg/apache/cassandra/db/compaction/AbstractCompactionStrategy;Lorg/apache/cassandra/db/compaction/AbstractCompactionStrategy;)I (6)
(Lorg/apache/cassandra/db/compaction/AbstractCompactionStrategy;Lorg/apache/cassandra/db/compaction/AbstractCompactionStrategy;)I
invokestatic java.util.Collections.sort:(Ljava/util/List;Ljava/util/Comparator;)V
9: aload 2
invokeinterface java.util.List.iterator:()Ljava/util/Iterator;
astore 4
goto 16
StackMap locals: org.apache.cassandra.db.compaction.CompactionStrategyManager int java.util.List top java.util.Iterator
StackMap stack:
10: aload 4
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.db.compaction.AbstractCompactionStrategy
astore 3
start local 3 11: aload 3
iload 1
invokevirtual org.apache.cassandra.db.compaction.AbstractCompactionStrategy.getNextBackgroundTask:(I)Lorg/apache/cassandra/db/compaction/AbstractCompactionTask;
astore 5
start local 5 12: aload 5
ifnull 16
13: aload 5
astore 7
14: aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.readLock:Ljava/util/concurrent/locks/ReentrantReadWriteLock$ReadLock;
invokevirtual java.util.concurrent.locks.ReentrantReadWriteLock$ReadLock.unlock:()V
15: aload 7
areturn
end local 5 end local 3 16: StackMap locals:
StackMap stack:
aload 4
invokeinterface java.util.Iterator.hasNext:()Z
ifne 10
end local 2 17: goto 21
18: StackMap locals: org.apache.cassandra.db.compaction.CompactionStrategyManager int
StackMap stack: java.lang.Throwable
astore 6
19: aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.readLock:Ljava/util/concurrent/locks/ReentrantReadWriteLock$ReadLock;
invokevirtual java.util.concurrent.locks.ReentrantReadWriteLock$ReadLock.unlock:()V
20: aload 6
athrow
21: StackMap locals:
StackMap stack:
aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.readLock:Ljava/util/concurrent/locks/ReentrantReadWriteLock$ReadLock;
invokevirtual java.util.concurrent.locks.ReentrantReadWriteLock$ReadLock.unlock:()V
22: aconst_null
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 23 0 this Lorg/apache/cassandra/db/compaction/CompactionStrategyManager;
0 23 1 gcBefore I
6 17 2 strategies Ljava/util/List<Lorg/apache/cassandra/db/compaction/AbstractCompactionStrategy;>;
11 16 3 strategy Lorg/apache/cassandra/db/compaction/AbstractCompactionStrategy;
12 16 5 task Lorg/apache/cassandra/db/compaction/AbstractCompactionTask;
Exception table:
from to target type
2 3 18 any
5 14 18 any
16 18 18 any
MethodParameters:
Name Flags
gcBefore
public boolean isEnabled();
descriptor: ()Z
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.enabled:Z
ifeq 1
aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.isActive:Z
ifeq 1
iconst_1
ireturn
StackMap locals:
StackMap stack:
1: iconst_0
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/apache/cassandra/db/compaction/CompactionStrategyManager;
public boolean isActive();
descriptor: ()Z
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.isActive:Z
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/db/compaction/CompactionStrategyManager;
public void resume();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.writeLock:Ljava/util/concurrent/locks/ReentrantReadWriteLock$WriteLock;
invokevirtual java.util.concurrent.locks.ReentrantReadWriteLock$WriteLock.lock:()V
1: aload 0
iconst_1
putfield org.apache.cassandra.db.compaction.CompactionStrategyManager.isActive:Z
2: goto 6
3: StackMap locals:
StackMap stack: java.lang.Throwable
astore 1
4: aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.writeLock:Ljava/util/concurrent/locks/ReentrantReadWriteLock$WriteLock;
invokevirtual java.util.concurrent.locks.ReentrantReadWriteLock$WriteLock.unlock:()V
5: aload 1
athrow
6: StackMap locals:
StackMap stack:
aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.writeLock:Ljava/util/concurrent/locks/ReentrantReadWriteLock$WriteLock;
invokevirtual java.util.concurrent.locks.ReentrantReadWriteLock$WriteLock.unlock:()V
7: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 8 0 this Lorg/apache/cassandra/db/compaction/CompactionStrategyManager;
Exception table:
from to target type
1 3 3 any
public void pause();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.writeLock:Ljava/util/concurrent/locks/ReentrantReadWriteLock$WriteLock;
invokevirtual java.util.concurrent.locks.ReentrantReadWriteLock$WriteLock.lock:()V
1: aload 0
iconst_0
putfield org.apache.cassandra.db.compaction.CompactionStrategyManager.isActive:Z
2: goto 6
3: StackMap locals:
StackMap stack: java.lang.Throwable
astore 1
4: aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.writeLock:Ljava/util/concurrent/locks/ReentrantReadWriteLock$WriteLock;
invokevirtual java.util.concurrent.locks.ReentrantReadWriteLock$WriteLock.unlock:()V
5: aload 1
athrow
6: StackMap locals:
StackMap stack:
aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.writeLock:Ljava/util/concurrent/locks/ReentrantReadWriteLock$WriteLock;
invokevirtual java.util.concurrent.locks.ReentrantReadWriteLock$WriteLock.unlock:()V
7: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 8 0 this Lorg/apache/cassandra/db/compaction/CompactionStrategyManager;
Exception table:
from to target type
1 3 3 any
private void startup();
descriptor: ()V
flags: (0x0002) ACC_PRIVATE
Code:
stack=3, locals=4, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.writeLock:Ljava/util/concurrent/locks/ReentrantReadWriteLock$WriteLock;
invokevirtual java.util.concurrent.locks.ReentrantReadWriteLock$WriteLock.lock:()V
1: aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.cfs:Lorg/apache/cassandra/db/ColumnFamilyStore;
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 2
goto 5
StackMap locals: org.apache.cassandra.db.compaction.CompactionStrategyManager top java.util.Iterator
StackMap stack:
2: aload 2
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.io.sstable.format.SSTableReader
astore 1
start local 1 3: aload 1
getfield org.apache.cassandra.io.sstable.format.SSTableReader.openReason:Lorg/apache/cassandra/io/sstable/format/SSTableReader$OpenReason;
getstatic org.apache.cassandra.io.sstable.format.SSTableReader$OpenReason.EARLY:Lorg/apache/cassandra/io/sstable/format/SSTableReader$OpenReason;
if_acmpeq 5
4: aload 0
aload 1
invokevirtual org.apache.cassandra.db.compaction.CompactionStrategyManager.compactionStrategyFor:(Lorg/apache/cassandra/io/sstable/format/SSTableReader;)Lorg/apache/cassandra/db/compaction/AbstractCompactionStrategy;
aload 1
invokevirtual org.apache.cassandra.db.compaction.AbstractCompactionStrategy.addSSTable:(Lorg/apache/cassandra/io/sstable/format/SSTableReader;)V
end local 1 5: StackMap locals:
StackMap stack:
aload 2
invokeinterface java.util.Iterator.hasNext:()Z
ifne 2
6: aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.repaired:Ljava/util/List;
invokedynamic accept()Ljava/util/function/Consumer;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)V
org/apache/cassandra/db/compaction/AbstractCompactionStrategy.startup()V (5)
(Lorg/apache/cassandra/db/compaction/AbstractCompactionStrategy;)V
invokeinterface java.util.List.forEach:(Ljava/util/function/Consumer;)V
7: aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.unrepaired:Ljava/util/List;
invokedynamic accept()Ljava/util/function/Consumer;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)V
org/apache/cassandra/db/compaction/AbstractCompactionStrategy.startup()V (5)
(Lorg/apache/cassandra/db/compaction/AbstractCompactionStrategy;)V
invokeinterface java.util.List.forEach:(Ljava/util/function/Consumer;)V
8: aload 0
aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.repaired:Ljava/util/List;
iconst_0
invokeinterface java.util.List.get:(I)Ljava/lang/Object;
checkcast org.apache.cassandra.db.compaction.AbstractCompactionStrategy
invokevirtual org.apache.cassandra.db.compaction.AbstractCompactionStrategy.shouldDefragment:()Z
putfield org.apache.cassandra.db.compaction.CompactionStrategyManager.shouldDefragment:Z
9: aload 0
aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.repaired:Ljava/util/List;
iconst_0
invokeinterface java.util.List.get:(I)Ljava/lang/Object;
checkcast org.apache.cassandra.db.compaction.AbstractCompactionStrategy
invokevirtual org.apache.cassandra.db.compaction.AbstractCompactionStrategy.supportsEarlyOpen:()Z
putfield org.apache.cassandra.db.compaction.CompactionStrategyManager.supportsEarlyOpen:Z
10: aload 0
aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.repaired:Ljava/util/List;
iconst_0
invokeinterface java.util.List.get:(I)Ljava/lang/Object;
instanceof org.apache.cassandra.db.compaction.LeveledCompactionStrategy
ifeq 11
aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.repaired:Ljava/util/List;
iconst_0
invokeinterface java.util.List.get:(I)Ljava/lang/Object;
checkcast org.apache.cassandra.db.compaction.LeveledCompactionStrategy
invokevirtual org.apache.cassandra.db.compaction.LeveledCompactionStrategy.getLevelFanoutSize:()I
goto 12
StackMap locals: org.apache.cassandra.db.compaction.CompactionStrategyManager
StackMap stack: org.apache.cassandra.db.compaction.CompactionStrategyManager
11: bipush 10
StackMap locals: org.apache.cassandra.db.compaction.CompactionStrategyManager
StackMap stack: org.apache.cassandra.db.compaction.CompactionStrategyManager int
12: putfield org.apache.cassandra.db.compaction.CompactionStrategyManager.fanout:I
13: goto 17
14: StackMap locals:
StackMap stack: java.lang.Throwable
astore 3
15: aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.writeLock:Ljava/util/concurrent/locks/ReentrantReadWriteLock$WriteLock;
invokevirtual java.util.concurrent.locks.ReentrantReadWriteLock$WriteLock.unlock:()V
16: aload 3
athrow
17: StackMap locals:
StackMap stack:
aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.writeLock:Ljava/util/concurrent/locks/ReentrantReadWriteLock$WriteLock;
invokevirtual java.util.concurrent.locks.ReentrantReadWriteLock$WriteLock.unlock:()V
18: aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.repaired:Ljava/util/List;
invokedynamic accept()Ljava/util/function/Consumer;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)V
org/apache/cassandra/db/compaction/AbstractCompactionStrategy.startup()V (5)
(Lorg/apache/cassandra/db/compaction/AbstractCompactionStrategy;)V
invokeinterface java.util.List.forEach:(Ljava/util/function/Consumer;)V
19: aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.unrepaired:Ljava/util/List;
invokedynamic accept()Ljava/util/function/Consumer;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)V
org/apache/cassandra/db/compaction/AbstractCompactionStrategy.startup()V (5)
(Lorg/apache/cassandra/db/compaction/AbstractCompactionStrategy;)V
invokeinterface java.util.List.forEach:(Ljava/util/function/Consumer;)V
20: aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.repaired:Ljava/util/List;
invokeinterface java.util.List.stream:()Ljava/util/stream/Stream;
aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.unrepaired:Ljava/util/List;
invokeinterface java.util.List.stream:()Ljava/util/stream/Stream;
invokestatic java.util.stream.Stream.concat:(Ljava/util/stream/Stream;Ljava/util/stream/Stream;)Ljava/util/stream/Stream;
invokedynamic test()Ljava/util/function/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/db/compaction/CompactionStrategyManager.lambda$6(Lorg/apache/cassandra/db/compaction/AbstractCompactionStrategy;)Z (6)
(Lorg/apache/cassandra/db/compaction/AbstractCompactionStrategy;)Z
invokeinterface java.util.stream.Stream.anyMatch:(Ljava/util/function/Predicate;)Z
ifeq 22
21: aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.compactionLogger:Lorg/apache/cassandra/db/compaction/CompactionLogger;
invokevirtual org.apache.cassandra.db.compaction.CompactionLogger.enable:()V
22: StackMap locals:
StackMap stack:
return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 23 0 this Lorg/apache/cassandra/db/compaction/CompactionStrategyManager;
3 5 1 sstable Lorg/apache/cassandra/io/sstable/format/SSTableReader;
Exception table:
from to target type
1 14 14 any
protected org.apache.cassandra.db.compaction.AbstractCompactionStrategy getCompactionStrategyFor(org.apache.cassandra.io.sstable.format.SSTableReader);
descriptor: (Lorg/apache/cassandra/io/sstable/format/SSTableReader;)Lorg/apache/cassandra/db/compaction/AbstractCompactionStrategy;
flags: (0x0004) ACC_PROTECTED
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
invokevirtual org.apache.cassandra.db.compaction.CompactionStrategyManager.maybeReloadDiskBoundaries:()Z
pop
1: aload 0
aload 1
invokevirtual org.apache.cassandra.db.compaction.CompactionStrategyManager.compactionStrategyFor:(Lorg/apache/cassandra/io/sstable/format/SSTableReader;)Lorg/apache/cassandra/db/compaction/AbstractCompactionStrategy;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/apache/cassandra/db/compaction/CompactionStrategyManager;
0 2 1 sstable Lorg/apache/cassandra/io/sstable/format/SSTableReader;
MethodParameters:
Name Flags
sstable
protected org.apache.cassandra.db.compaction.AbstractCompactionStrategy compactionStrategyFor(org.apache.cassandra.io.sstable.format.SSTableReader);
descriptor: (Lorg/apache/cassandra/io/sstable/format/SSTableReader;)Lorg/apache/cassandra/db/compaction/AbstractCompactionStrategy;
flags: (0x0004) ACC_PROTECTED
Code:
stack=2, locals=5, args_size=2
start local 0 start local 1 0: aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.readLock:Ljava/util/concurrent/locks/ReentrantReadWriteLock$ReadLock;
invokevirtual java.util.concurrent.locks.ReentrantReadWriteLock$ReadLock.lock:()V
1: aload 0
aload 1
invokevirtual org.apache.cassandra.db.compaction.CompactionStrategyManager.compactionStrategyIndexFor:(Lorg/apache/cassandra/io/sstable/format/SSTableReader;)I
istore 2
start local 2 2: aload 1
invokevirtual org.apache.cassandra.io.sstable.format.SSTableReader.isRepaired:()Z
ifeq 6
3: aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.repaired:Ljava/util/List;
iload 2
invokeinterface java.util.List.get:(I)Ljava/lang/Object;
checkcast org.apache.cassandra.db.compaction.AbstractCompactionStrategy
astore 4
4: aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.readLock:Ljava/util/concurrent/locks/ReentrantReadWriteLock$ReadLock;
invokevirtual java.util.concurrent.locks.ReentrantReadWriteLock$ReadLock.unlock:()V
5: aload 4
areturn
6: StackMap locals: int
StackMap stack:
aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.unrepaired:Ljava/util/List;
iload 2
invokeinterface java.util.List.get:(I)Ljava/lang/Object;
checkcast org.apache.cassandra.db.compaction.AbstractCompactionStrategy
astore 4
7: aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.readLock:Ljava/util/concurrent/locks/ReentrantReadWriteLock$ReadLock;
invokevirtual java.util.concurrent.locks.ReentrantReadWriteLock$ReadLock.unlock:()V
8: aload 4
areturn
end local 2 9: StackMap locals: org.apache.cassandra.db.compaction.CompactionStrategyManager org.apache.cassandra.io.sstable.format.SSTableReader
StackMap stack: java.lang.Throwable
astore 3
10: aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.readLock:Ljava/util/concurrent/locks/ReentrantReadWriteLock$ReadLock;
invokevirtual java.util.concurrent.locks.ReentrantReadWriteLock$ReadLock.unlock:()V
11: aload 3
athrow
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 12 0 this Lorg/apache/cassandra/db/compaction/CompactionStrategyManager;
0 12 1 sstable Lorg/apache/cassandra/io/sstable/format/SSTableReader;
2 9 2 index I
Exception table:
from to target type
1 4 9 any
6 7 9 any
RuntimeInvisibleAnnotations:
com.google.common.annotations.VisibleForTesting()
RuntimeInvisibleTypeAnnotations:
METHOD_RETURN
com.google.common.annotations.VisibleForTesting()
MethodParameters:
Name Flags
sstable
protected int compactionStrategyIndexFor(org.apache.cassandra.io.sstable.format.SSTableReader);
descriptor: (Lorg/apache/cassandra/io/sstable/format/SSTableReader;)I
flags: (0x0004) ACC_PROTECTED
Code:
stack=2, locals=4, args_size=2
start local 0 start local 1 0: aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.readLock:Ljava/util/concurrent/locks/ReentrantReadWriteLock$ReadLock;
invokevirtual java.util.concurrent.locks.ReentrantReadWriteLock$ReadLock.lock:()V
1: aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.partitionSSTablesByTokenRange:Z
ifne 4
2: aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.readLock:Ljava/util/concurrent/locks/ReentrantReadWriteLock$ReadLock;
invokevirtual java.util.concurrent.locks.ReentrantReadWriteLock$ReadLock.unlock:()V
3: iconst_0
ireturn
4: StackMap locals:
StackMap stack:
aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.currentBoundaries:Lorg/apache/cassandra/db/DiskBoundaries;
aload 1
invokevirtual org.apache.cassandra.db.DiskBoundaries.getDiskIndex:(Lorg/apache/cassandra/io/sstable/format/SSTableReader;)I
istore 3
5: aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.readLock:Ljava/util/concurrent/locks/ReentrantReadWriteLock$ReadLock;
invokevirtual java.util.concurrent.locks.ReentrantReadWriteLock$ReadLock.unlock:()V
6: iload 3
ireturn
7: StackMap locals:
StackMap stack: java.lang.Throwable
astore 2
8: aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.readLock:Ljava/util/concurrent/locks/ReentrantReadWriteLock$ReadLock;
invokevirtual java.util.concurrent.locks.ReentrantReadWriteLock$ReadLock.unlock:()V
9: aload 2
athrow
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 10 0 this Lorg/apache/cassandra/db/compaction/CompactionStrategyManager;
0 10 1 sstable Lorg/apache/cassandra/io/sstable/format/SSTableReader;
Exception table:
from to target type
1 2 7 any
4 5 7 any
RuntimeInvisibleAnnotations:
com.google.common.annotations.VisibleForTesting()
RuntimeInvisibleTypeAnnotations:
METHOD_RETURN
com.google.common.annotations.VisibleForTesting()
MethodParameters:
Name Flags
sstable
public void shutdown();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.writeLock:Ljava/util/concurrent/locks/ReentrantReadWriteLock$WriteLock;
invokevirtual java.util.concurrent.locks.ReentrantReadWriteLock$WriteLock.lock:()V
1: aload 0
iconst_0
putfield org.apache.cassandra.db.compaction.CompactionStrategyManager.isActive:Z
2: aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.repaired:Ljava/util/List;
invokedynamic accept()Ljava/util/function/Consumer;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)V
org/apache/cassandra/db/compaction/AbstractCompactionStrategy.shutdown()V (5)
(Lorg/apache/cassandra/db/compaction/AbstractCompactionStrategy;)V
invokeinterface java.util.List.forEach:(Ljava/util/function/Consumer;)V
3: aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.unrepaired:Ljava/util/List;
invokedynamic accept()Ljava/util/function/Consumer;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)V
org/apache/cassandra/db/compaction/AbstractCompactionStrategy.shutdown()V (5)
(Lorg/apache/cassandra/db/compaction/AbstractCompactionStrategy;)V
invokeinterface java.util.List.forEach:(Ljava/util/function/Consumer;)V
4: aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.compactionLogger:Lorg/apache/cassandra/db/compaction/CompactionLogger;
invokevirtual org.apache.cassandra.db.compaction.CompactionLogger.disable:()V
5: goto 9
6: StackMap locals:
StackMap stack: java.lang.Throwable
astore 1
7: aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.writeLock:Ljava/util/concurrent/locks/ReentrantReadWriteLock$WriteLock;
invokevirtual java.util.concurrent.locks.ReentrantReadWriteLock$WriteLock.unlock:()V
8: aload 1
athrow
9: StackMap locals:
StackMap stack:
aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.writeLock:Ljava/util/concurrent/locks/ReentrantReadWriteLock$WriteLock;
invokevirtual java.util.concurrent.locks.ReentrantReadWriteLock$WriteLock.unlock:()V
10: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 11 0 this Lorg/apache/cassandra/db/compaction/CompactionStrategyManager;
Exception table:
from to target type
1 6 6 any
public void maybeReload(org.apache.cassandra.config.CFMetaData);
descriptor: (Lorg/apache/cassandra/config/CFMetaData;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=3, args_size=2
start local 0 start local 1 0: aload 1
getfield org.apache.cassandra.config.CFMetaData.params:Lorg/apache/cassandra/schema/TableParams;
getfield org.apache.cassandra.schema.TableParams.compaction:Lorg/apache/cassandra/schema/CompactionParams;
aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.schemaCompactionParams:Lorg/apache/cassandra/schema/CompactionParams;
invokevirtual org.apache.cassandra.schema.CompactionParams.equals:(Ljava/lang/Object;)Z
ifeq 2
1: return
2: StackMap locals:
StackMap stack:
aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.writeLock:Ljava/util/concurrent/locks/ReentrantReadWriteLock$WriteLock;
invokevirtual java.util.concurrent.locks.ReentrantReadWriteLock$WriteLock.lock:()V
3: aload 1
getfield org.apache.cassandra.config.CFMetaData.params:Lorg/apache/cassandra/schema/TableParams;
getfield org.apache.cassandra.schema.TableParams.compaction:Lorg/apache/cassandra/schema/CompactionParams;
aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.schemaCompactionParams:Lorg/apache/cassandra/schema/CompactionParams;
invokevirtual org.apache.cassandra.schema.CompactionParams.equals:(Ljava/lang/Object;)Z
ifeq 6
4: aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.writeLock:Ljava/util/concurrent/locks/ReentrantReadWriteLock$WriteLock;
invokevirtual java.util.concurrent.locks.ReentrantReadWriteLock$WriteLock.unlock:()V
5: return
6: StackMap locals:
StackMap stack:
aload 0
aload 1
getfield org.apache.cassandra.config.CFMetaData.params:Lorg/apache/cassandra/schema/TableParams;
getfield org.apache.cassandra.schema.TableParams.compaction:Lorg/apache/cassandra/schema/CompactionParams;
invokevirtual org.apache.cassandra.db.compaction.CompactionStrategyManager.reload:(Lorg/apache/cassandra/schema/CompactionParams;)V
7: goto 11
8: StackMap locals:
StackMap stack: java.lang.Throwable
astore 2
9: aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.writeLock:Ljava/util/concurrent/locks/ReentrantReadWriteLock$WriteLock;
invokevirtual java.util.concurrent.locks.ReentrantReadWriteLock$WriteLock.unlock:()V
10: aload 2
athrow
11: StackMap locals:
StackMap stack:
aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.writeLock:Ljava/util/concurrent/locks/ReentrantReadWriteLock$WriteLock;
invokevirtual java.util.concurrent.locks.ReentrantReadWriteLock$WriteLock.unlock:()V
12: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 13 0 this Lorg/apache/cassandra/db/compaction/CompactionStrategyManager;
0 13 1 metadata Lorg/apache/cassandra/config/CFMetaData;
Exception table:
from to target type
3 4 8 any
6 8 8 any
MethodParameters:
Name Flags
metadata
protected boolean maybeReloadDiskBoundaries();
descriptor: ()Z
flags: (0x0004) ACC_PROTECTED
Code:
stack=2, locals=2, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.currentBoundaries:Lorg/apache/cassandra/db/DiskBoundaries;
invokevirtual org.apache.cassandra.db.DiskBoundaries.isOutOfDate:()Z
ifne 2
1: iconst_0
ireturn
2: StackMap locals:
StackMap stack:
aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.writeLock:Ljava/util/concurrent/locks/ReentrantReadWriteLock$WriteLock;
invokevirtual java.util.concurrent.locks.ReentrantReadWriteLock$WriteLock.lock:()V
3: aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.currentBoundaries:Lorg/apache/cassandra/db/DiskBoundaries;
invokevirtual org.apache.cassandra.db.DiskBoundaries.isOutOfDate:()Z
ifne 6
4: aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.writeLock:Ljava/util/concurrent/locks/ReentrantReadWriteLock$WriteLock;
invokevirtual java.util.concurrent.locks.ReentrantReadWriteLock$WriteLock.unlock:()V
5: iconst_0
ireturn
6: StackMap locals:
StackMap stack:
aload 0
aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.params:Lorg/apache/cassandra/schema/CompactionParams;
invokevirtual org.apache.cassandra.db.compaction.CompactionStrategyManager.reload:(Lorg/apache/cassandra/schema/CompactionParams;)V
7: aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.writeLock:Ljava/util/concurrent/locks/ReentrantReadWriteLock$WriteLock;
invokevirtual java.util.concurrent.locks.ReentrantReadWriteLock$WriteLock.unlock:()V
8: iconst_1
ireturn
9: StackMap locals:
StackMap stack: java.lang.Throwable
astore 1
10: aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.writeLock:Ljava/util/concurrent/locks/ReentrantReadWriteLock$WriteLock;
invokevirtual java.util.concurrent.locks.ReentrantReadWriteLock$WriteLock.unlock:()V
11: aload 1
athrow
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 12 0 this Lorg/apache/cassandra/db/compaction/CompactionStrategyManager;
Exception table:
from to target type
3 4 9 any
6 7 9 any
RuntimeInvisibleAnnotations:
com.google.common.annotations.VisibleForTesting()
RuntimeInvisibleTypeAnnotations:
METHOD_RETURN
com.google.common.annotations.VisibleForTesting()
private void reload(org.apache.cassandra.schema.CompactionParams);
descriptor: (Lorg/apache/cassandra/schema/CompactionParams;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=4, locals=4, args_size=2
start local 0 start local 1 0: aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.enabled:Z
ifeq 1
aload 0
invokevirtual org.apache.cassandra.db.compaction.CompactionStrategyManager.shouldBeEnabled:()Z
ifne 1
iconst_1
goto 2
StackMap locals:
StackMap stack:
1: iconst_0
StackMap locals:
StackMap stack: int
2: istore 2
start local 2 3: aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.enabled:Z
ifne 4
aload 0
invokevirtual org.apache.cassandra.db.compaction.CompactionStrategyManager.shouldBeEnabled:()Z
ifeq 4
iconst_1
goto 5
StackMap locals: int
StackMap stack:
4: iconst_0
StackMap locals:
StackMap stack: int
5: istore 3
start local 3 6: aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.currentBoundaries:Lorg/apache/cassandra/db/DiskBoundaries;
ifnull 11
7: aload 1
aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.schemaCompactionParams:Lorg/apache/cassandra/schema/CompactionParams;
invokevirtual org.apache.cassandra.schema.CompactionParams.equals:(Ljava/lang/Object;)Z
ifne 9
8: getstatic org.apache.cassandra.db.compaction.CompactionStrategyManager.logger:Lorg/slf4j/Logger;
ldc "Recreating compaction strategy - compaction parameters changed for {}.{}"
aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.cfs:Lorg/apache/cassandra/db/ColumnFamilyStore;
getfield org.apache.cassandra.db.ColumnFamilyStore.keyspace:Lorg/apache/cassandra/db/Keyspace;
invokevirtual org.apache.cassandra.db.Keyspace.getName:()Ljava/lang/String;
aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.cfs:Lorg/apache/cassandra/db/ColumnFamilyStore;
invokevirtual org.apache.cassandra.db.ColumnFamilyStore.getTableName:()Ljava/lang/String;
invokeinterface org.slf4j.Logger.debug:(Ljava/lang/String;Ljava/lang/Object;Ljava/lang/Object;)V
goto 11
9: StackMap locals: int
StackMap stack:
aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.currentBoundaries:Lorg/apache/cassandra/db/DiskBoundaries;
invokevirtual org.apache.cassandra.db.DiskBoundaries.isOutOfDate:()Z
ifeq 11
10: getstatic org.apache.cassandra.db.compaction.CompactionStrategyManager.logger:Lorg/slf4j/Logger;
ldc "Recreating compaction strategy - disk boundaries are out of date for {}.{}."
aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.cfs:Lorg/apache/cassandra/db/ColumnFamilyStore;
getfield org.apache.cassandra.db.ColumnFamilyStore.keyspace:Lorg/apache/cassandra/db/Keyspace;
invokevirtual org.apache.cassandra.db.Keyspace.getName:()Ljava/lang/String;
aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.cfs:Lorg/apache/cassandra/db/ColumnFamilyStore;
invokevirtual org.apache.cassandra.db.ColumnFamilyStore.getTableName:()Ljava/lang/String;
invokeinterface org.slf4j.Logger.debug:(Ljava/lang/String;Ljava/lang/Object;Ljava/lang/Object;)V
11: StackMap locals:
StackMap stack:
aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.currentBoundaries:Lorg/apache/cassandra/db/DiskBoundaries;
ifnull 12
aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.currentBoundaries:Lorg/apache/cassandra/db/DiskBoundaries;
invokevirtual org.apache.cassandra.db.DiskBoundaries.isOutOfDate:()Z
ifeq 13
12: StackMap locals:
StackMap stack:
aload 0
aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.boundariesSupplier:Ljava/util/function/Supplier;
invokeinterface java.util.function.Supplier.get:()Ljava/lang/Object;
checkcast org.apache.cassandra.db.DiskBoundaries
putfield org.apache.cassandra.db.compaction.CompactionStrategyManager.currentBoundaries:Lorg/apache/cassandra/db/DiskBoundaries;
13: StackMap locals:
StackMap stack:
aload 0
aload 1
invokevirtual org.apache.cassandra.db.compaction.CompactionStrategyManager.setStrategy:(Lorg/apache/cassandra/schema/CompactionParams;)V
14: aload 0
aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.cfs:Lorg/apache/cassandra/db/ColumnFamilyStore;
getfield org.apache.cassandra.db.ColumnFamilyStore.metadata:Lorg/apache/cassandra/config/CFMetaData;
getfield org.apache.cassandra.config.CFMetaData.params:Lorg/apache/cassandra/schema/TableParams;
getfield org.apache.cassandra.schema.TableParams.compaction:Lorg/apache/cassandra/schema/CompactionParams;
putfield org.apache.cassandra.db.compaction.CompactionStrategyManager.schemaCompactionParams:Lorg/apache/cassandra/schema/CompactionParams;
15: iload 3
ifne 16
aload 0
invokevirtual org.apache.cassandra.db.compaction.CompactionStrategyManager.shouldBeEnabled:()Z
ifne 17
iload 2
ifne 17
16: StackMap locals:
StackMap stack:
aload 0
invokevirtual org.apache.cassandra.db.compaction.CompactionStrategyManager.disable:()V
goto 18
17: StackMap locals:
StackMap stack:
aload 0
invokevirtual org.apache.cassandra.db.compaction.CompactionStrategyManager.enable:()V
18: StackMap locals:
StackMap stack:
aload 0
invokevirtual org.apache.cassandra.db.compaction.CompactionStrategyManager.startup:()V
19: return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 20 0 this Lorg/apache/cassandra/db/compaction/CompactionStrategyManager;
0 20 1 newCompactionParams Lorg/apache/cassandra/schema/CompactionParams;
3 20 2 enabledWithJMX Z
6 20 3 disabledWithJMX Z
MethodParameters:
Name Flags
newCompactionParams
public void replaceFlushed(org.apache.cassandra.db.Memtable, java.util.Collection<org.apache.cassandra.io.sstable.format.SSTableReader>);
descriptor: (Lorg/apache/cassandra/db/Memtable;Ljava/util/Collection;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.cfs:Lorg/apache/cassandra/db/ColumnFamilyStore;
invokevirtual org.apache.cassandra.db.ColumnFamilyStore.getTracker:()Lorg/apache/cassandra/db/lifecycle/Tracker;
aload 1
aload 2
invokevirtual org.apache.cassandra.db.lifecycle.Tracker.replaceFlushed:(Lorg/apache/cassandra/db/Memtable;Ljava/lang/Iterable;)V
1: aload 2
ifnull 3
aload 2
invokeinterface java.util.Collection.isEmpty:()Z
ifne 3
2: getstatic org.apache.cassandra.db.compaction.CompactionManager.instance:Lorg/apache/cassandra/db/compaction/CompactionManager;
aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.cfs:Lorg/apache/cassandra/db/ColumnFamilyStore;
invokevirtual org.apache.cassandra.db.compaction.CompactionManager.submitBackground:(Lorg/apache/cassandra/db/ColumnFamilyStore;)Ljava/util/List;
pop
3: StackMap locals:
StackMap stack:
return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lorg/apache/cassandra/db/compaction/CompactionStrategyManager;
0 4 1 memtable Lorg/apache/cassandra/db/Memtable;
0 4 2 sstables Ljava/util/Collection<Lorg/apache/cassandra/io/sstable/format/SSTableReader;>;
Signature: (Lorg/apache/cassandra/db/Memtable;Ljava/util/Collection<Lorg/apache/cassandra/io/sstable/format/SSTableReader;>;)V
MethodParameters:
Name Flags
memtable
sstables
public int getUnleveledSSTables();
descriptor: ()I
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=6, args_size=1
start local 0 0: aload 0
invokevirtual org.apache.cassandra.db.compaction.CompactionStrategyManager.maybeReloadDiskBoundaries:()Z
pop
1: aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.readLock:Ljava/util/concurrent/locks/ReentrantReadWriteLock$ReadLock;
invokevirtual java.util.concurrent.locks.ReentrantReadWriteLock$ReadLock.lock:()V
2: aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.repaired:Ljava/util/List;
iconst_0
invokeinterface java.util.List.get:(I)Ljava/lang/Object;
instanceof org.apache.cassandra.db.compaction.LeveledCompactionStrategy
ifeq 18
aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.unrepaired:Ljava/util/List;
iconst_0
invokeinterface java.util.List.get:(I)Ljava/lang/Object;
instanceof org.apache.cassandra.db.compaction.LeveledCompactionStrategy
ifeq 18
3: iconst_0
istore 1
start local 1 4: aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.repaired:Ljava/util/List;
invokeinterface java.util.List.iterator:()Ljava/util/Iterator;
astore 3
goto 7
StackMap locals: org.apache.cassandra.db.compaction.CompactionStrategyManager int top java.util.Iterator
StackMap stack:
5: aload 3
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.db.compaction.AbstractCompactionStrategy
astore 2
start local 2 6: iload 1
aload 2
checkcast org.apache.cassandra.db.compaction.LeveledCompactionStrategy
iconst_0
invokevirtual org.apache.cassandra.db.compaction.LeveledCompactionStrategy.getLevelSize:(I)I
iadd
istore 1
end local 2 7: StackMap locals:
StackMap stack:
aload 3
invokeinterface java.util.Iterator.hasNext:()Z
ifne 5
8: aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.unrepaired:Ljava/util/List;
invokeinterface java.util.List.iterator:()Ljava/util/Iterator;
astore 3
goto 11
StackMap locals:
StackMap stack:
9: aload 3
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.db.compaction.AbstractCompactionStrategy
astore 2
start local 2 10: iload 1
aload 2
checkcast org.apache.cassandra.db.compaction.LeveledCompactionStrategy
iconst_0
invokevirtual org.apache.cassandra.db.compaction.LeveledCompactionStrategy.getLevelSize:(I)I
iadd
istore 1
end local 2 11: StackMap locals:
StackMap stack:
aload 3
invokeinterface java.util.Iterator.hasNext:()Z
ifne 9
12: iload 1
istore 5
13: aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.readLock:Ljava/util/concurrent/locks/ReentrantReadWriteLock$ReadLock;
invokevirtual java.util.concurrent.locks.ReentrantReadWriteLock$ReadLock.unlock:()V
14: iload 5
ireturn
end local 1 15: StackMap locals: org.apache.cassandra.db.compaction.CompactionStrategyManager
StackMap stack: java.lang.Throwable
astore 4
16: aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.readLock:Ljava/util/concurrent/locks/ReentrantReadWriteLock$ReadLock;
invokevirtual java.util.concurrent.locks.ReentrantReadWriteLock$ReadLock.unlock:()V
17: aload 4
athrow
18: StackMap locals:
StackMap stack:
aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.readLock:Ljava/util/concurrent/locks/ReentrantReadWriteLock$ReadLock;
invokevirtual java.util.concurrent.locks.ReentrantReadWriteLock$ReadLock.unlock:()V
19: iconst_0
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 20 0 this Lorg/apache/cassandra/db/compaction/CompactionStrategyManager;
4 15 1 count I
6 7 2 strategy Lorg/apache/cassandra/db/compaction/AbstractCompactionStrategy;
10 11 2 strategy Lorg/apache/cassandra/db/compaction/AbstractCompactionStrategy;
Exception table:
from to target type
2 13 15 any
public int getLevelFanoutSize();
descriptor: ()I
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.fanout:I
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/db/compaction/CompactionStrategyManager;
public int[] getSSTableCountPerLevel();
descriptor: ()[I
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=7, args_size=1
start local 0 0: aload 0
invokevirtual org.apache.cassandra.db.compaction.CompactionStrategyManager.maybeReloadDiskBoundaries:()Z
pop
1: aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.readLock:Ljava/util/concurrent/locks/ReentrantReadWriteLock$ReadLock;
invokevirtual java.util.concurrent.locks.ReentrantReadWriteLock$ReadLock.lock:()V
2: aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.repaired:Ljava/util/List;
iconst_0
invokeinterface java.util.List.get:(I)Ljava/lang/Object;
instanceof org.apache.cassandra.db.compaction.LeveledCompactionStrategy
ifeq 20
aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.unrepaired:Ljava/util/List;
iconst_0
invokeinterface java.util.List.get:(I)Ljava/lang/Object;
instanceof org.apache.cassandra.db.compaction.LeveledCompactionStrategy
ifeq 20
3: getstatic org.apache.cassandra.db.compaction.LeveledManifest.MAX_LEVEL_COUNT:I
newarray 10
astore 1
start local 1 4: aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.repaired:Ljava/util/List;
invokeinterface java.util.List.iterator:()Ljava/util/Iterator;
astore 3
goto 8
StackMap locals: org.apache.cassandra.db.compaction.CompactionStrategyManager int[] top java.util.Iterator
StackMap stack:
5: aload 3
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.db.compaction.AbstractCompactionStrategy
astore 2
start local 2 6: aload 2
checkcast org.apache.cassandra.db.compaction.LeveledCompactionStrategy
invokevirtual org.apache.cassandra.db.compaction.LeveledCompactionStrategy.getAllLevelSize:()[I
astore 4
start local 4 7: aload 1
aload 4
invokestatic org.apache.cassandra.db.compaction.CompactionStrategyManager.sumArrays:([I[I)[I
astore 1
end local 4 end local 2 8: StackMap locals:
StackMap stack:
aload 3
invokeinterface java.util.Iterator.hasNext:()Z
ifne 5
9: aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.unrepaired:Ljava/util/List;
invokeinterface java.util.List.iterator:()Ljava/util/Iterator;
astore 3
goto 13
StackMap locals:
StackMap stack:
10: aload 3
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.db.compaction.AbstractCompactionStrategy
astore 2
start local 2 11: aload 2
checkcast org.apache.cassandra.db.compaction.LeveledCompactionStrategy
invokevirtual org.apache.cassandra.db.compaction.LeveledCompactionStrategy.getAllLevelSize:()[I
astore 4
start local 4 12: aload 1
aload 4
invokestatic org.apache.cassandra.db.compaction.CompactionStrategyManager.sumArrays:([I[I)[I
astore 1
end local 4 end local 2 13: StackMap locals:
StackMap stack:
aload 3
invokeinterface java.util.Iterator.hasNext:()Z
ifne 10
14: aload 1
astore 6
15: aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.readLock:Ljava/util/concurrent/locks/ReentrantReadWriteLock$ReadLock;
invokevirtual java.util.concurrent.locks.ReentrantReadWriteLock$ReadLock.unlock:()V
16: aload 6
areturn
end local 1 17: StackMap locals: org.apache.cassandra.db.compaction.CompactionStrategyManager
StackMap stack: java.lang.Throwable
astore 5
18: aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.readLock:Ljava/util/concurrent/locks/ReentrantReadWriteLock$ReadLock;
invokevirtual java.util.concurrent.locks.ReentrantReadWriteLock$ReadLock.unlock:()V
19: aload 5
athrow
20: StackMap locals:
StackMap stack:
aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.readLock:Ljava/util/concurrent/locks/ReentrantReadWriteLock$ReadLock;
invokevirtual java.util.concurrent.locks.ReentrantReadWriteLock$ReadLock.unlock:()V
21: aconst_null
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 22 0 this Lorg/apache/cassandra/db/compaction/CompactionStrategyManager;
4 17 1 res [I
6 8 2 strategy Lorg/apache/cassandra/db/compaction/AbstractCompactionStrategy;
7 8 4 repairedCountPerLevel [I
11 13 2 strategy Lorg/apache/cassandra/db/compaction/AbstractCompactionStrategy;
12 13 4 unrepairedCountPerLevel [I
Exception table:
from to target type
2 15 17 any
private static int[] sumArrays(int[], int[]);
descriptor: ([I[I)[I
flags: (0x000a) ACC_PRIVATE, ACC_STATIC
Code:
stack=5, locals=4, args_size=2
start local 0 start local 1 0: aload 0
arraylength
aload 1
arraylength
invokestatic java.lang.Math.max:(II)I
newarray 10
astore 2
start local 2 1: iconst_0
istore 3
start local 3 2: goto 9
3: StackMap locals: int[] int
StackMap stack:
iload 3
aload 0
arraylength
if_icmpge 5
iload 3
aload 1
arraylength
if_icmpge 5
4: aload 2
iload 3
aload 0
iload 3
iaload
aload 1
iload 3
iaload
iadd
iastore
goto 8
5: StackMap locals:
StackMap stack:
iload 3
aload 0
arraylength
if_icmpge 7
6: aload 2
iload 3
aload 0
iload 3
iaload
iastore
goto 8
7: StackMap locals:
StackMap stack:
aload 2
iload 3
aload 1
iload 3
iaload
iastore
8: StackMap locals:
StackMap stack:
iinc 3 1
StackMap locals:
StackMap stack:
9: iload 3
aload 2
arraylength
if_icmplt 3
end local 3 10: aload 2
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 11 0 a [I
0 11 1 b [I
1 11 2 res [I
2 10 3 i I
MethodParameters:
Name Flags
a
b
public boolean shouldDefragment();
descriptor: ()Z
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.shouldDefragment:Z
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/db/compaction/CompactionStrategyManager;
public org.apache.cassandra.db.Directories getDirectories();
descriptor: ()Lorg/apache/cassandra/db/Directories;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=3, args_size=1
start local 0 0: aload 0
invokevirtual org.apache.cassandra.db.compaction.CompactionStrategyManager.maybeReloadDiskBoundaries:()Z
pop
1: aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.readLock:Ljava/util/concurrent/locks/ReentrantReadWriteLock$ReadLock;
invokevirtual java.util.concurrent.locks.ReentrantReadWriteLock$ReadLock.lock:()V
2: getstatic org.apache.cassandra.db.compaction.CompactionStrategyManager.$assertionsDisabled:Z
ifne 3
aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.repaired:Ljava/util/List;
iconst_0
invokeinterface java.util.List.get:(I)Ljava/lang/Object;
checkcast org.apache.cassandra.db.compaction.AbstractCompactionStrategy
invokevirtual java.lang.Object.getClass:()Ljava/lang/Class;
aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.unrepaired:Ljava/util/List;
iconst_0
invokeinterface java.util.List.get:(I)Ljava/lang/Object;
checkcast org.apache.cassandra.db.compaction.AbstractCompactionStrategy
invokevirtual java.lang.Object.getClass:()Ljava/lang/Class;
invokevirtual java.lang.Object.equals:(Ljava/lang/Object;)Z
ifne 3
new java.lang.AssertionError
dup
invokespecial java.lang.AssertionError.<init>:()V
athrow
3: StackMap locals:
StackMap stack:
aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.repaired:Ljava/util/List;
iconst_0
invokeinterface java.util.List.get:(I)Ljava/lang/Object;
checkcast org.apache.cassandra.db.compaction.AbstractCompactionStrategy
invokevirtual org.apache.cassandra.db.compaction.AbstractCompactionStrategy.getDirectories:()Lorg/apache/cassandra/db/Directories;
astore 2
4: aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.readLock:Ljava/util/concurrent/locks/ReentrantReadWriteLock$ReadLock;
invokevirtual java.util.concurrent.locks.ReentrantReadWriteLock$ReadLock.unlock:()V
5: aload 2
areturn
6: StackMap locals:
StackMap stack: java.lang.Throwable
astore 1
7: aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.readLock:Ljava/util/concurrent/locks/ReentrantReadWriteLock$ReadLock;
invokevirtual java.util.concurrent.locks.ReentrantReadWriteLock$ReadLock.unlock:()V
8: aload 1
athrow
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 9 0 this Lorg/apache/cassandra/db/compaction/CompactionStrategyManager;
Exception table:
from to target type
2 4 6 any
private void handleFlushNotification(java.lang.Iterable<org.apache.cassandra.io.sstable.format.SSTableReader>);
descriptor: (Ljava/lang/Iterable;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=2, locals=5, args_size=2
start local 0 start local 1 0: aload 0
invokevirtual org.apache.cassandra.db.compaction.CompactionStrategyManager.maybeReloadDiskBoundaries:()Z
ifeq 2
1: return
2: StackMap locals:
StackMap stack:
aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.readLock:Ljava/util/concurrent/locks/ReentrantReadWriteLock$ReadLock;
invokevirtual java.util.concurrent.locks.ReentrantReadWriteLock$ReadLock.lock:()V
3: aload 1
invokeinterface java.lang.Iterable.iterator:()Ljava/util/Iterator;
astore 3
goto 6
StackMap locals: org.apache.cassandra.db.compaction.CompactionStrategyManager java.lang.Iterable top java.util.Iterator
StackMap stack:
4: aload 3
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.io.sstable.format.SSTableReader
astore 2
start local 2 5: aload 0
aload 2
invokevirtual org.apache.cassandra.db.compaction.CompactionStrategyManager.compactionStrategyFor:(Lorg/apache/cassandra/io/sstable/format/SSTableReader;)Lorg/apache/cassandra/db/compaction/AbstractCompactionStrategy;
aload 2
invokevirtual org.apache.cassandra.db.compaction.AbstractCompactionStrategy.addSSTable:(Lorg/apache/cassandra/io/sstable/format/SSTableReader;)V
end local 2 6: StackMap locals:
StackMap stack:
aload 3
invokeinterface java.util.Iterator.hasNext:()Z
ifne 4
7: goto 11
8: StackMap locals: org.apache.cassandra.db.compaction.CompactionStrategyManager java.lang.Iterable
StackMap stack: java.lang.Throwable
astore 4
9: aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.readLock:Ljava/util/concurrent/locks/ReentrantReadWriteLock$ReadLock;
invokevirtual java.util.concurrent.locks.ReentrantReadWriteLock$ReadLock.unlock:()V
10: aload 4
athrow
11: StackMap locals:
StackMap stack:
aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.readLock:Ljava/util/concurrent/locks/ReentrantReadWriteLock$ReadLock;
invokevirtual java.util.concurrent.locks.ReentrantReadWriteLock$ReadLock.unlock:()V
12: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 13 0 this Lorg/apache/cassandra/db/compaction/CompactionStrategyManager;
0 13 1 added Ljava/lang/Iterable<Lorg/apache/cassandra/io/sstable/format/SSTableReader;>;
5 6 2 sstable Lorg/apache/cassandra/io/sstable/format/SSTableReader;
Exception table:
from to target type
3 8 8 any
Signature: (Ljava/lang/Iterable<Lorg/apache/cassandra/io/sstable/format/SSTableReader;>;)V
MethodParameters:
Name Flags
added
private void handleListChangedNotification(java.lang.Iterable<org.apache.cassandra.io.sstable.format.SSTableReader>, java.lang.Iterable<org.apache.cassandra.io.sstable.format.SSTableReader>);
descriptor: (Ljava/lang/Iterable;Ljava/lang/Iterable;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=4, locals=12, args_size=3
start local 0 start local 1 start local 2 0: aload 0
invokevirtual org.apache.cassandra.db.compaction.CompactionStrategyManager.maybeReloadDiskBoundaries:()Z
ifeq 2
1: return
2: StackMap locals:
StackMap stack:
aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.readLock:Ljava/util/concurrent/locks/ReentrantReadWriteLock$ReadLock;
invokevirtual java.util.concurrent.locks.ReentrantReadWriteLock$ReadLock.lock:()V
3: aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.partitionSSTablesByTokenRange:Z
ifeq 4
aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.currentBoundaries:Lorg/apache/cassandra/db/DiskBoundaries;
getfield org.apache.cassandra.db.DiskBoundaries.directories:Ljava/util/List;
invokeinterface java.util.List.size:()I
goto 5
StackMap locals:
StackMap stack:
4: iconst_1
StackMap locals:
StackMap stack: int
5: istore 3
start local 3 6: new java.util.ArrayList
dup
iload 3
invokespecial java.util.ArrayList.<init>:(I)V
astore 4
start local 4 7: new java.util.ArrayList
dup
iload 3
invokespecial java.util.ArrayList.<init>:(I)V
astore 5
start local 5 8: new java.util.ArrayList
dup
iload 3
invokespecial java.util.ArrayList.<init>:(I)V
astore 6
start local 6 9: new java.util.ArrayList
dup
iload 3
invokespecial java.util.ArrayList.<init>:(I)V
astore 7
start local 7 10: iconst_0
istore 8
start local 8 11: goto 17
12: StackMap locals: org.apache.cassandra.db.compaction.CompactionStrategyManager java.lang.Iterable java.lang.Iterable int java.util.List java.util.List java.util.List java.util.List int
StackMap stack:
aload 4
new java.util.HashSet
dup
invokespecial java.util.HashSet.<init>:()V
invokeinterface java.util.List.add:(Ljava/lang/Object;)Z
pop
13: aload 5
new java.util.HashSet
dup
invokespecial java.util.HashSet.<init>:()V
invokeinterface java.util.List.add:(Ljava/lang/Object;)Z
pop
14: aload 6
new java.util.HashSet
dup
invokespecial java.util.HashSet.<init>:()V
invokeinterface java.util.List.add:(Ljava/lang/Object;)Z
pop
15: aload 7
new java.util.HashSet
dup
invokespecial java.util.HashSet.<init>:()V
invokeinterface java.util.List.add:(Ljava/lang/Object;)Z
pop
16: iinc 8 1
StackMap locals:
StackMap stack:
17: iload 8
iload 3
if_icmplt 12
end local 8 18: aload 2
invokeinterface java.lang.Iterable.iterator:()Ljava/util/Iterator;
astore 9
goto 24
StackMap locals: org.apache.cassandra.db.compaction.CompactionStrategyManager java.lang.Iterable java.lang.Iterable int java.util.List java.util.List java.util.List java.util.List top java.util.Iterator
StackMap stack:
19: aload 9
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.io.sstable.format.SSTableReader
astore 8
start local 8 20: aload 0
aload 8
invokevirtual org.apache.cassandra.db.compaction.CompactionStrategyManager.compactionStrategyIndexFor:(Lorg/apache/cassandra/io/sstable/format/SSTableReader;)I
istore 10
start local 10 21: aload 8
invokevirtual org.apache.cassandra.io.sstable.format.SSTableReader.isRepaired:()Z
ifeq 23
22: aload 4
iload 10
invokeinterface java.util.List.get:(I)Ljava/lang/Object;
checkcast java.util.Set
aload 8
invokeinterface java.util.Set.add:(Ljava/lang/Object;)Z
pop
goto 24
23: StackMap locals: org.apache.cassandra.db.compaction.CompactionStrategyManager java.lang.Iterable java.lang.Iterable int java.util.List java.util.List java.util.List java.util.List org.apache.cassandra.io.sstable.format.SSTableReader java.util.Iterator int
StackMap stack:
aload 6
iload 10
invokeinterface java.util.List.get:(I)Ljava/lang/Object;
checkcast java.util.Set
aload 8
invokeinterface java.util.Set.add:(Ljava/lang/Object;)Z
pop
end local 10 end local 8 24: StackMap locals: org.apache.cassandra.db.compaction.CompactionStrategyManager java.lang.Iterable java.lang.Iterable int java.util.List java.util.List java.util.List java.util.List top java.util.Iterator
StackMap stack:
aload 9
invokeinterface java.util.Iterator.hasNext:()Z
ifne 19
25: aload 1
invokeinterface java.lang.Iterable.iterator:()Ljava/util/Iterator;
astore 9
goto 31
StackMap locals:
StackMap stack:
26: aload 9
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.io.sstable.format.SSTableReader
astore 8
start local 8 27: aload 0
aload 8
invokevirtual org.apache.cassandra.db.compaction.CompactionStrategyManager.compactionStrategyIndexFor:(Lorg/apache/cassandra/io/sstable/format/SSTableReader;)I
istore 10
start local 10 28: aload 8
invokevirtual org.apache.cassandra.io.sstable.format.SSTableReader.isRepaired:()Z
ifeq 30
29: aload 5
iload 10
invokeinterface java.util.List.get:(I)Ljava/lang/Object;
checkcast java.util.Set
aload 8
invokeinterface java.util.Set.add:(Ljava/lang/Object;)Z
pop
goto 31
30: StackMap locals: org.apache.cassandra.db.compaction.CompactionStrategyManager java.lang.Iterable java.lang.Iterable int java.util.List java.util.List java.util.List java.util.List org.apache.cassandra.io.sstable.format.SSTableReader java.util.Iterator int
StackMap stack:
aload 7
iload 10
invokeinterface java.util.List.get:(I)Ljava/lang/Object;
checkcast java.util.Set
aload 8
invokeinterface java.util.Set.add:(Ljava/lang/Object;)Z
pop
end local 10 end local 8 31: StackMap locals: org.apache.cassandra.db.compaction.CompactionStrategyManager java.lang.Iterable java.lang.Iterable int java.util.List java.util.List java.util.List java.util.List top java.util.Iterator
StackMap stack:
aload 9
invokeinterface java.util.Iterator.hasNext:()Z
ifne 26
32: iconst_0
istore 8
start local 8 33: goto 41
34: StackMap locals: org.apache.cassandra.db.compaction.CompactionStrategyManager java.lang.Iterable java.lang.Iterable int java.util.List java.util.List java.util.List java.util.List int
StackMap stack:
aload 4
iload 8
invokeinterface java.util.List.get:(I)Ljava/lang/Object;
checkcast java.util.Set
invokeinterface java.util.Set.isEmpty:()Z
ifne 36
35: aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.repaired:Ljava/util/List;
iload 8
invokeinterface java.util.List.get:(I)Ljava/lang/Object;
checkcast org.apache.cassandra.db.compaction.AbstractCompactionStrategy
aload 4
iload 8
invokeinterface java.util.List.get:(I)Ljava/lang/Object;
checkcast java.util.Collection
aload 5
iload 8
invokeinterface java.util.List.get:(I)Ljava/lang/Object;
checkcast java.util.Collection
invokevirtual org.apache.cassandra.db.compaction.AbstractCompactionStrategy.replaceSSTables:(Ljava/util/Collection;Ljava/util/Collection;)V
goto 37
36: StackMap locals:
StackMap stack:
aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.repaired:Ljava/util/List;
iload 8
invokeinterface java.util.List.get:(I)Ljava/lang/Object;
checkcast org.apache.cassandra.db.compaction.AbstractCompactionStrategy
aload 5
iload 8
invokeinterface java.util.List.get:(I)Ljava/lang/Object;
checkcast java.lang.Iterable
invokevirtual org.apache.cassandra.db.compaction.AbstractCompactionStrategy.addSSTables:(Ljava/lang/Iterable;)V
37: StackMap locals:
StackMap stack:
aload 6
iload 8
invokeinterface java.util.List.get:(I)Ljava/lang/Object;
checkcast java.util.Set
invokeinterface java.util.Set.isEmpty:()Z
ifne 39
38: aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.unrepaired:Ljava/util/List;
iload 8
invokeinterface java.util.List.get:(I)Ljava/lang/Object;
checkcast org.apache.cassandra.db.compaction.AbstractCompactionStrategy
aload 6
iload 8
invokeinterface java.util.List.get:(I)Ljava/lang/Object;
checkcast java.util.Collection
aload 7
iload 8
invokeinterface java.util.List.get:(I)Ljava/lang/Object;
checkcast java.util.Collection
invokevirtual org.apache.cassandra.db.compaction.AbstractCompactionStrategy.replaceSSTables:(Ljava/util/Collection;Ljava/util/Collection;)V
goto 40
39: StackMap locals:
StackMap stack:
aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.unrepaired:Ljava/util/List;
iload 8
invokeinterface java.util.List.get:(I)Ljava/lang/Object;
checkcast org.apache.cassandra.db.compaction.AbstractCompactionStrategy
aload 7
iload 8
invokeinterface java.util.List.get:(I)Ljava/lang/Object;
checkcast java.lang.Iterable
invokevirtual org.apache.cassandra.db.compaction.AbstractCompactionStrategy.addSSTables:(Ljava/lang/Iterable;)V
40: StackMap locals:
StackMap stack:
iinc 8 1
StackMap locals:
StackMap stack:
41: iload 8
iload 3
if_icmplt 34
end local 8 end local 7 end local 6 end local 5 end local 4 end local 3 42: goto 46
43: StackMap locals: org.apache.cassandra.db.compaction.CompactionStrategyManager java.lang.Iterable java.lang.Iterable
StackMap stack: java.lang.Throwable
astore 11
44: aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.readLock:Ljava/util/concurrent/locks/ReentrantReadWriteLock$ReadLock;
invokevirtual java.util.concurrent.locks.ReentrantReadWriteLock$ReadLock.unlock:()V
45: aload 11
athrow
46: StackMap locals:
StackMap stack:
aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.readLock:Ljava/util/concurrent/locks/ReentrantReadWriteLock$ReadLock;
invokevirtual java.util.concurrent.locks.ReentrantReadWriteLock$ReadLock.unlock:()V
47: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 48 0 this Lorg/apache/cassandra/db/compaction/CompactionStrategyManager;
0 48 1 added Ljava/lang/Iterable<Lorg/apache/cassandra/io/sstable/format/SSTableReader;>;
0 48 2 removed Ljava/lang/Iterable<Lorg/apache/cassandra/io/sstable/format/SSTableReader;>;
6 42 3 locationSize I
7 42 4 repairedRemoved Ljava/util/List<Ljava/util/Set<Lorg/apache/cassandra/io/sstable/format/SSTableReader;>;>;
8 42 5 repairedAdded Ljava/util/List<Ljava/util/Set<Lorg/apache/cassandra/io/sstable/format/SSTableReader;>;>;
9 42 6 unrepairedRemoved Ljava/util/List<Ljava/util/Set<Lorg/apache/cassandra/io/sstable/format/SSTableReader;>;>;
10 42 7 unrepairedAdded Ljava/util/List<Ljava/util/Set<Lorg/apache/cassandra/io/sstable/format/SSTableReader;>;>;
11 18 8 i I
20 24 8 sstable Lorg/apache/cassandra/io/sstable/format/SSTableReader;
21 24 10 i I
27 31 8 sstable Lorg/apache/cassandra/io/sstable/format/SSTableReader;
28 31 10 i I
33 42 8 i I
Exception table:
from to target type
3 43 43 any
Signature: (Ljava/lang/Iterable<Lorg/apache/cassandra/io/sstable/format/SSTableReader;>;Ljava/lang/Iterable<Lorg/apache/cassandra/io/sstable/format/SSTableReader;>;)V
MethodParameters:
Name Flags
added
removed
private void handleRepairStatusChangedNotification(java.lang.Iterable<org.apache.cassandra.io.sstable.format.SSTableReader>);
descriptor: (Ljava/lang/Iterable;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=2, locals=6, args_size=2
start local 0 start local 1 0: aload 0
invokevirtual org.apache.cassandra.db.compaction.CompactionStrategyManager.maybeReloadDiskBoundaries:()Z
ifeq 2
1: return
2: StackMap locals:
StackMap stack:
aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.readLock:Ljava/util/concurrent/locks/ReentrantReadWriteLock$ReadLock;
invokevirtual java.util.concurrent.locks.ReentrantReadWriteLock$ReadLock.lock:()V
3: aload 1
invokeinterface java.lang.Iterable.iterator:()Ljava/util/Iterator;
astore 3
goto 12
StackMap locals: org.apache.cassandra.db.compaction.CompactionStrategyManager java.lang.Iterable top java.util.Iterator
StackMap stack:
4: aload 3
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.io.sstable.format.SSTableReader
astore 2
start local 2 5: aload 0
aload 2
invokevirtual org.apache.cassandra.db.compaction.CompactionStrategyManager.compactionStrategyIndexFor:(Lorg/apache/cassandra/io/sstable/format/SSTableReader;)I
istore 4
start local 4 6: aload 2
invokevirtual org.apache.cassandra.io.sstable.format.SSTableReader.isRepaired:()Z
ifeq 10
7: aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.unrepaired:Ljava/util/List;
iload 4
invokeinterface java.util.List.get:(I)Ljava/lang/Object;
checkcast org.apache.cassandra.db.compaction.AbstractCompactionStrategy
aload 2
invokevirtual org.apache.cassandra.db.compaction.AbstractCompactionStrategy.removeSSTable:(Lorg/apache/cassandra/io/sstable/format/SSTableReader;)V
8: aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.repaired:Ljava/util/List;
iload 4
invokeinterface java.util.List.get:(I)Ljava/lang/Object;
checkcast org.apache.cassandra.db.compaction.AbstractCompactionStrategy
aload 2
invokevirtual org.apache.cassandra.db.compaction.AbstractCompactionStrategy.addSSTable:(Lorg/apache/cassandra/io/sstable/format/SSTableReader;)V
9: goto 12
10: StackMap locals: org.apache.cassandra.db.compaction.CompactionStrategyManager java.lang.Iterable org.apache.cassandra.io.sstable.format.SSTableReader java.util.Iterator int
StackMap stack:
aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.repaired:Ljava/util/List;
iload 4
invokeinterface java.util.List.get:(I)Ljava/lang/Object;
checkcast org.apache.cassandra.db.compaction.AbstractCompactionStrategy
aload 2
invokevirtual org.apache.cassandra.db.compaction.AbstractCompactionStrategy.removeSSTable:(Lorg/apache/cassandra/io/sstable/format/SSTableReader;)V
11: aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.unrepaired:Ljava/util/List;
iload 4
invokeinterface java.util.List.get:(I)Ljava/lang/Object;
checkcast org.apache.cassandra.db.compaction.AbstractCompactionStrategy
aload 2
invokevirtual org.apache.cassandra.db.compaction.AbstractCompactionStrategy.addSSTable:(Lorg/apache/cassandra/io/sstable/format/SSTableReader;)V
end local 4 end local 2 12: StackMap locals: org.apache.cassandra.db.compaction.CompactionStrategyManager java.lang.Iterable top java.util.Iterator
StackMap stack:
aload 3
invokeinterface java.util.Iterator.hasNext:()Z
ifne 4
13: goto 17
14: StackMap locals: org.apache.cassandra.db.compaction.CompactionStrategyManager java.lang.Iterable
StackMap stack: java.lang.Throwable
astore 5
15: aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.readLock:Ljava/util/concurrent/locks/ReentrantReadWriteLock$ReadLock;
invokevirtual java.util.concurrent.locks.ReentrantReadWriteLock$ReadLock.unlock:()V
16: aload 5
athrow
17: StackMap locals:
StackMap stack:
aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.readLock:Ljava/util/concurrent/locks/ReentrantReadWriteLock$ReadLock;
invokevirtual java.util.concurrent.locks.ReentrantReadWriteLock$ReadLock.unlock:()V
18: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 19 0 this Lorg/apache/cassandra/db/compaction/CompactionStrategyManager;
0 19 1 sstables Ljava/lang/Iterable<Lorg/apache/cassandra/io/sstable/format/SSTableReader;>;
5 12 2 sstable Lorg/apache/cassandra/io/sstable/format/SSTableReader;
6 12 4 index I
Exception table:
from to target type
3 14 14 any
Signature: (Ljava/lang/Iterable<Lorg/apache/cassandra/io/sstable/format/SSTableReader;>;)V
MethodParameters:
Name Flags
sstables
private void handleDeletingNotification(org.apache.cassandra.io.sstable.format.SSTableReader);
descriptor: (Lorg/apache/cassandra/io/sstable/format/SSTableReader;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=2, locals=3, args_size=2
start local 0 start local 1 0: aload 0
invokevirtual org.apache.cassandra.db.compaction.CompactionStrategyManager.maybeReloadDiskBoundaries:()Z
ifeq 2
1: return
2: StackMap locals:
StackMap stack:
aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.readLock:Ljava/util/concurrent/locks/ReentrantReadWriteLock$ReadLock;
invokevirtual java.util.concurrent.locks.ReentrantReadWriteLock$ReadLock.lock:()V
3: aload 0
aload 1
invokevirtual org.apache.cassandra.db.compaction.CompactionStrategyManager.compactionStrategyFor:(Lorg/apache/cassandra/io/sstable/format/SSTableReader;)Lorg/apache/cassandra/db/compaction/AbstractCompactionStrategy;
aload 1
invokevirtual org.apache.cassandra.db.compaction.AbstractCompactionStrategy.removeSSTable:(Lorg/apache/cassandra/io/sstable/format/SSTableReader;)V
4: goto 8
5: StackMap locals:
StackMap stack: java.lang.Throwable
astore 2
6: aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.readLock:Ljava/util/concurrent/locks/ReentrantReadWriteLock$ReadLock;
invokevirtual java.util.concurrent.locks.ReentrantReadWriteLock$ReadLock.unlock:()V
7: aload 2
athrow
8: StackMap locals:
StackMap stack:
aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.readLock:Ljava/util/concurrent/locks/ReentrantReadWriteLock$ReadLock;
invokevirtual java.util.concurrent.locks.ReentrantReadWriteLock$ReadLock.unlock:()V
9: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 10 0 this Lorg/apache/cassandra/db/compaction/CompactionStrategyManager;
0 10 1 deleted Lorg/apache/cassandra/io/sstable/format/SSTableReader;
Exception table:
from to target type
3 5 5 any
MethodParameters:
Name Flags
deleted
public void handleNotification(org.apache.cassandra.notifications.INotification, java.lang.Object);
descriptor: (Lorg/apache/cassandra/notifications/INotification;Ljava/lang/Object;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=4, args_size=3
start local 0 start local 1 start local 2 0: aload 1
instanceof org.apache.cassandra.notifications.SSTableAddedNotification
ifeq 3
1: aload 0
aload 1
checkcast org.apache.cassandra.notifications.SSTableAddedNotification
getfield org.apache.cassandra.notifications.SSTableAddedNotification.added:Ljava/lang/Iterable;
invokevirtual org.apache.cassandra.db.compaction.CompactionStrategyManager.handleFlushNotification:(Ljava/lang/Iterable;)V
2: goto 12
3: StackMap locals:
StackMap stack:
aload 1
instanceof org.apache.cassandra.notifications.SSTableListChangedNotification
ifeq 7
4: aload 1
checkcast org.apache.cassandra.notifications.SSTableListChangedNotification
astore 3
start local 3 5: aload 0
aload 3
getfield org.apache.cassandra.notifications.SSTableListChangedNotification.added:Ljava/util/Collection;
aload 3
getfield org.apache.cassandra.notifications.SSTableListChangedNotification.removed:Ljava/util/Collection;
invokevirtual org.apache.cassandra.db.compaction.CompactionStrategyManager.handleListChangedNotification:(Ljava/lang/Iterable;Ljava/lang/Iterable;)V
end local 3 6: goto 12
7: StackMap locals:
StackMap stack:
aload 1
instanceof org.apache.cassandra.notifications.SSTableRepairStatusChanged
ifeq 10
8: aload 0
aload 1
checkcast org.apache.cassandra.notifications.SSTableRepairStatusChanged
getfield org.apache.cassandra.notifications.SSTableRepairStatusChanged.sstables:Ljava/util/Collection;
invokevirtual org.apache.cassandra.db.compaction.CompactionStrategyManager.handleRepairStatusChangedNotification:(Ljava/lang/Iterable;)V
9: goto 12
10: StackMap locals:
StackMap stack:
aload 1
instanceof org.apache.cassandra.notifications.SSTableDeletingNotification
ifeq 12
11: aload 0
aload 1
checkcast org.apache.cassandra.notifications.SSTableDeletingNotification
getfield org.apache.cassandra.notifications.SSTableDeletingNotification.deleting:Lorg/apache/cassandra/io/sstable/format/SSTableReader;
invokevirtual org.apache.cassandra.db.compaction.CompactionStrategyManager.handleDeletingNotification:(Lorg/apache/cassandra/io/sstable/format/SSTableReader;)V
12: StackMap locals:
StackMap stack:
return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 13 0 this Lorg/apache/cassandra/db/compaction/CompactionStrategyManager;
0 13 1 notification Lorg/apache/cassandra/notifications/INotification;
0 13 2 sender Ljava/lang/Object;
5 6 3 listChangedNotification Lorg/apache/cassandra/notifications/SSTableListChangedNotification;
MethodParameters:
Name Flags
notification
sender
public void enable();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.writeLock:Ljava/util/concurrent/locks/ReentrantReadWriteLock$WriteLock;
invokevirtual java.util.concurrent.locks.ReentrantReadWriteLock$WriteLock.lock:()V
1: aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.repaired:Ljava/util/List;
ifnull 3
2: aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.repaired:Ljava/util/List;
invokedynamic accept()Ljava/util/function/Consumer;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)V
org/apache/cassandra/db/compaction/AbstractCompactionStrategy.enable()V (5)
(Lorg/apache/cassandra/db/compaction/AbstractCompactionStrategy;)V
invokeinterface java.util.List.forEach:(Ljava/util/function/Consumer;)V
3: StackMap locals:
StackMap stack:
aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.unrepaired:Ljava/util/List;
ifnull 5
4: aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.unrepaired:Ljava/util/List;
invokedynamic accept()Ljava/util/function/Consumer;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)V
org/apache/cassandra/db/compaction/AbstractCompactionStrategy.enable()V (5)
(Lorg/apache/cassandra/db/compaction/AbstractCompactionStrategy;)V
invokeinterface java.util.List.forEach:(Ljava/util/function/Consumer;)V
5: StackMap locals:
StackMap stack:
aload 0
iconst_1
putfield org.apache.cassandra.db.compaction.CompactionStrategyManager.enabled:Z
6: goto 10
7: StackMap locals:
StackMap stack: java.lang.Throwable
astore 1
8: aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.writeLock:Ljava/util/concurrent/locks/ReentrantReadWriteLock$WriteLock;
invokevirtual java.util.concurrent.locks.ReentrantReadWriteLock$WriteLock.unlock:()V
9: aload 1
athrow
10: StackMap locals:
StackMap stack:
aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.writeLock:Ljava/util/concurrent/locks/ReentrantReadWriteLock$WriteLock;
invokevirtual java.util.concurrent.locks.ReentrantReadWriteLock$WriteLock.unlock:()V
11: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 12 0 this Lorg/apache/cassandra/db/compaction/CompactionStrategyManager;
Exception table:
from to target type
1 7 7 any
public void disable();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.writeLock:Ljava/util/concurrent/locks/ReentrantReadWriteLock$WriteLock;
invokevirtual java.util.concurrent.locks.ReentrantReadWriteLock$WriteLock.lock:()V
1: aload 0
iconst_0
putfield org.apache.cassandra.db.compaction.CompactionStrategyManager.enabled:Z
2: aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.repaired:Ljava/util/List;
ifnull 4
3: aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.repaired:Ljava/util/List;
invokedynamic accept()Ljava/util/function/Consumer;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)V
org/apache/cassandra/db/compaction/AbstractCompactionStrategy.disable()V (5)
(Lorg/apache/cassandra/db/compaction/AbstractCompactionStrategy;)V
invokeinterface java.util.List.forEach:(Ljava/util/function/Consumer;)V
4: StackMap locals:
StackMap stack:
aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.unrepaired:Ljava/util/List;
ifnull 10
5: aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.unrepaired:Ljava/util/List;
invokedynamic accept()Ljava/util/function/Consumer;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)V
org/apache/cassandra/db/compaction/AbstractCompactionStrategy.disable()V (5)
(Lorg/apache/cassandra/db/compaction/AbstractCompactionStrategy;)V
invokeinterface java.util.List.forEach:(Ljava/util/function/Consumer;)V
6: goto 10
7: StackMap locals:
StackMap stack: java.lang.Throwable
astore 1
8: aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.writeLock:Ljava/util/concurrent/locks/ReentrantReadWriteLock$WriteLock;
invokevirtual java.util.concurrent.locks.ReentrantReadWriteLock$WriteLock.unlock:()V
9: aload 1
athrow
10: StackMap locals:
StackMap stack:
aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.writeLock:Ljava/util/concurrent/locks/ReentrantReadWriteLock$WriteLock;
invokevirtual java.util.concurrent.locks.ReentrantReadWriteLock$WriteLock.unlock:()V
11: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 12 0 this Lorg/apache/cassandra/db/compaction/CompactionStrategyManager;
Exception table:
from to target type
1 7 7 any
public org.apache.cassandra.db.compaction.AbstractCompactionStrategy$ScannerList getScanners(java.util.Collection<org.apache.cassandra.io.sstable.format.SSTableReader>, java.util.Collection<org.apache.cassandra.dht.Range<org.apache.cassandra.dht.Token>>);
descriptor: (Ljava/util/Collection;Ljava/util/Collection;)Lorg/apache/cassandra/db/compaction/AbstractCompactionStrategy$ScannerList;
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=9, args_size=3
start local 0 start local 1 start local 2 0: aload 0
invokevirtual org.apache.cassandra.db.compaction.CompactionStrategyManager.maybeReloadDiskBoundaries:()Z
pop
1: aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.readLock:Ljava/util/concurrent/locks/ReentrantReadWriteLock$ReadLock;
invokevirtual java.util.concurrent.locks.ReentrantReadWriteLock$ReadLock.lock:()V
2: getstatic org.apache.cassandra.db.compaction.CompactionStrategyManager.$assertionsDisabled:Z
ifne 3
aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.repaired:Ljava/util/List;
invokeinterface java.util.List.size:()I
aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.unrepaired:Ljava/util/List;
invokeinterface java.util.List.size:()I
if_icmpeq 3
new java.lang.AssertionError
dup
invokespecial java.lang.AssertionError.<init>:()V
athrow
3: StackMap locals:
StackMap stack:
new java.util.ArrayList
dup
invokespecial java.util.ArrayList.<init>:()V
astore 3
start local 3 4: new java.util.ArrayList
dup
invokespecial java.util.ArrayList.<init>:()V
astore 4
start local 4 5: iconst_0
istore 5
start local 5 6: goto 10
7: StackMap locals: java.util.List java.util.List int
StackMap stack:
aload 3
new java.util.HashSet
dup
invokespecial java.util.HashSet.<init>:()V
invokeinterface java.util.List.add:(Ljava/lang/Object;)Z
pop
8: aload 4
new java.util.HashSet
dup
invokespecial java.util.HashSet.<init>:()V
invokeinterface java.util.List.add:(Ljava/lang/Object;)Z
pop
9: iinc 5 1
StackMap locals:
StackMap stack:
10: iload 5
aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.repaired:Ljava/util/List;
invokeinterface java.util.List.size:()I
if_icmplt 7
end local 5 11: aload 1
invokeinterface java.util.Collection.iterator:()Ljava/util/Iterator;
astore 6
goto 16
StackMap locals: org.apache.cassandra.db.compaction.CompactionStrategyManager java.util.Collection java.util.Collection java.util.List java.util.List top java.util.Iterator
StackMap stack:
12: aload 6
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.io.sstable.format.SSTableReader
astore 5
start local 5 13: aload 5
invokevirtual org.apache.cassandra.io.sstable.format.SSTableReader.isRepaired:()Z
ifeq 15
14: aload 3
aload 0
aload 5
invokevirtual org.apache.cassandra.db.compaction.CompactionStrategyManager.compactionStrategyIndexFor:(Lorg/apache/cassandra/io/sstable/format/SSTableReader;)I
invokeinterface java.util.List.get:(I)Ljava/lang/Object;
checkcast java.util.Set
aload 5
invokeinterface java.util.Set.add:(Ljava/lang/Object;)Z
pop
goto 16
15: StackMap locals: org.apache.cassandra.db.compaction.CompactionStrategyManager java.util.Collection java.util.Collection java.util.List java.util.List org.apache.cassandra.io.sstable.format.SSTableReader java.util.Iterator
StackMap stack:
aload 4
aload 0
aload 5
invokevirtual org.apache.cassandra.db.compaction.CompactionStrategyManager.compactionStrategyIndexFor:(Lorg/apache/cassandra/io/sstable/format/SSTableReader;)I
invokeinterface java.util.List.get:(I)Ljava/lang/Object;
checkcast java.util.Set
aload 5
invokeinterface java.util.Set.add:(Ljava/lang/Object;)Z
pop
end local 5 16: StackMap locals: org.apache.cassandra.db.compaction.CompactionStrategyManager java.util.Collection java.util.Collection java.util.List java.util.List top java.util.Iterator
StackMap stack:
aload 6
invokeinterface java.util.Iterator.hasNext:()Z
ifne 12
17: new java.util.ArrayList
dup
aload 1
invokeinterface java.util.Collection.size:()I
invokespecial java.util.ArrayList.<init>:(I)V
astore 5
start local 5 18: iconst_0
istore 6
start local 6 19: goto 23
20: StackMap locals: org.apache.cassandra.db.compaction.CompactionStrategyManager java.util.Collection java.util.Collection java.util.List java.util.List java.util.List int
StackMap stack:
aload 3
iload 6
invokeinterface java.util.List.get:(I)Ljava/lang/Object;
checkcast java.util.Set
invokeinterface java.util.Set.isEmpty:()Z
ifne 22
21: aload 5
aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.repaired:Ljava/util/List;
iload 6
invokeinterface java.util.List.get:(I)Ljava/lang/Object;
checkcast org.apache.cassandra.db.compaction.AbstractCompactionStrategy
aload 3
iload 6
invokeinterface java.util.List.get:(I)Ljava/lang/Object;
checkcast java.util.Collection
aload 2
invokevirtual org.apache.cassandra.db.compaction.AbstractCompactionStrategy.getScanners:(Ljava/util/Collection;Ljava/util/Collection;)Lorg/apache/cassandra/db/compaction/AbstractCompactionStrategy$ScannerList;
getfield org.apache.cassandra.db.compaction.AbstractCompactionStrategy$ScannerList.scanners:Ljava/util/List;
invokeinterface java.util.List.addAll:(Ljava/util/Collection;)Z
pop
22: StackMap locals:
StackMap stack:
iinc 6 1
StackMap locals:
StackMap stack:
23: iload 6
aload 3
invokeinterface java.util.List.size:()I
if_icmplt 20
end local 6 24: iconst_0
istore 6
start local 6 25: goto 29
26: StackMap locals:
StackMap stack:
aload 4
iload 6
invokeinterface java.util.List.get:(I)Ljava/lang/Object;
checkcast java.util.Set
invokeinterface java.util.Set.isEmpty:()Z
ifne 28
27: aload 5
aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.unrepaired:Ljava/util/List;
iload 6
invokeinterface java.util.List.get:(I)Ljava/lang/Object;
checkcast org.apache.cassandra.db.compaction.AbstractCompactionStrategy
aload 4
iload 6
invokeinterface java.util.List.get:(I)Ljava/lang/Object;
checkcast java.util.Collection
aload 2
invokevirtual org.apache.cassandra.db.compaction.AbstractCompactionStrategy.getScanners:(Ljava/util/Collection;Ljava/util/Collection;)Lorg/apache/cassandra/db/compaction/AbstractCompactionStrategy$ScannerList;
getfield org.apache.cassandra.db.compaction.AbstractCompactionStrategy$ScannerList.scanners:Ljava/util/List;
invokeinterface java.util.List.addAll:(Ljava/util/Collection;)Z
pop
28: StackMap locals:
StackMap stack:
iinc 6 1
StackMap locals:
StackMap stack:
29: iload 6
aload 4
invokeinterface java.util.List.size:()I
if_icmplt 26
end local 6 30: new org.apache.cassandra.db.compaction.AbstractCompactionStrategy$ScannerList
dup
aload 5
invokespecial org.apache.cassandra.db.compaction.AbstractCompactionStrategy$ScannerList.<init>:(Ljava/util/List;)V
astore 8
31: aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.readLock:Ljava/util/concurrent/locks/ReentrantReadWriteLock$ReadLock;
invokevirtual java.util.concurrent.locks.ReentrantReadWriteLock$ReadLock.unlock:()V
32: aload 8
areturn
end local 5 end local 4 end local 3 33: StackMap locals: org.apache.cassandra.db.compaction.CompactionStrategyManager java.util.Collection java.util.Collection
StackMap stack: java.lang.Throwable
astore 7
34: aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.readLock:Ljava/util/concurrent/locks/ReentrantReadWriteLock$ReadLock;
invokevirtual java.util.concurrent.locks.ReentrantReadWriteLock$ReadLock.unlock:()V
35: aload 7
athrow
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 36 0 this Lorg/apache/cassandra/db/compaction/CompactionStrategyManager;
0 36 1 sstables Ljava/util/Collection<Lorg/apache/cassandra/io/sstable/format/SSTableReader;>;
0 36 2 ranges Ljava/util/Collection<Lorg/apache/cassandra/dht/Range<Lorg/apache/cassandra/dht/Token;>;>;
4 33 3 repairedSSTables Ljava/util/List<Ljava/util/Set<Lorg/apache/cassandra/io/sstable/format/SSTableReader;>;>;
5 33 4 unrepairedSSTables Ljava/util/List<Ljava/util/Set<Lorg/apache/cassandra/io/sstable/format/SSTableReader;>;>;
6 11 5 i I
13 16 5 sstable Lorg/apache/cassandra/io/sstable/format/SSTableReader;
18 33 5 scanners Ljava/util/List<Lorg/apache/cassandra/io/sstable/ISSTableScanner;>;
19 24 6 i I
25 30 6 i I
Exception table:
from to target type
2 31 33 any
Signature: (Ljava/util/Collection<Lorg/apache/cassandra/io/sstable/format/SSTableReader;>;Ljava/util/Collection<Lorg/apache/cassandra/dht/Range<Lorg/apache/cassandra/dht/Token;>;>;)Lorg/apache/cassandra/db/compaction/AbstractCompactionStrategy$ScannerList;
MethodParameters:
Name Flags
sstables
ranges
public org.apache.cassandra.db.compaction.AbstractCompactionStrategy$ScannerList getScanners(java.util.Collection<org.apache.cassandra.io.sstable.format.SSTableReader>);
descriptor: (Ljava/util/Collection;)Lorg/apache/cassandra/db/compaction/AbstractCompactionStrategy$ScannerList;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
aconst_null
invokevirtual org.apache.cassandra.db.compaction.CompactionStrategyManager.getScanners:(Ljava/util/Collection;Ljava/util/Collection;)Lorg/apache/cassandra/db/compaction/AbstractCompactionStrategy$ScannerList;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/db/compaction/CompactionStrategyManager;
0 1 1 sstables Ljava/util/Collection<Lorg/apache/cassandra/io/sstable/format/SSTableReader;>;
Signature: (Ljava/util/Collection<Lorg/apache/cassandra/io/sstable/format/SSTableReader;>;)Lorg/apache/cassandra/db/compaction/AbstractCompactionStrategy$ScannerList;
MethodParameters:
Name Flags
sstables
public java.util.Collection<java.util.Collection<org.apache.cassandra.io.sstable.format.SSTableReader>> groupSSTablesForAntiCompaction(java.util.Collection<org.apache.cassandra.io.sstable.format.SSTableReader>);
descriptor: (Ljava/util/Collection;)Ljava/util/Collection;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=8, args_size=2
start local 0 start local 1 0: aload 0
invokevirtual org.apache.cassandra.db.compaction.CompactionStrategyManager.maybeReloadDiskBoundaries:()Z
pop
1: aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.readLock:Ljava/util/concurrent/locks/ReentrantReadWriteLock$ReadLock;
invokevirtual java.util.concurrent.locks.ReentrantReadWriteLock$ReadLock.lock:()V
2: aload 1
invokeinterface java.util.Collection.stream:()Ljava/util/stream/Stream;
aload 0
invokedynamic apply(Lorg/apache/cassandra/db/compaction/CompactionStrategyManager;)Ljava/util/function/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/db/compaction/CompactionStrategyManager.lambda$13(Lorg/apache/cassandra/io/sstable/format/SSTableReader;)Ljava/lang/Integer; (7)
(Lorg/apache/cassandra/io/sstable/format/SSTableReader;)Ljava/lang/Integer;
invokestatic java.util.stream.Collectors.groupingBy:(Ljava/util/function/Function;)Ljava/util/stream/Collector;
invokeinterface java.util.stream.Stream.collect:(Ljava/util/stream/Collector;)Ljava/lang/Object;
checkcast java.util.Map
astore 2
start local 2 3: new java.util.ArrayList
dup
invokespecial java.util.ArrayList.<init>:()V
astore 3
start local 3 4: aload 2
invokeinterface java.util.Map.entrySet:()Ljava/util/Set;
invokeinterface java.util.Set.iterator:()Ljava/util/Iterator;
astore 5
goto 7
StackMap locals: org.apache.cassandra.db.compaction.CompactionStrategyManager java.util.Collection java.util.Map java.util.Collection top java.util.Iterator
StackMap stack:
5: aload 5
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast java.util.Map$Entry
astore 4
start local 4 6: aload 3
aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.unrepaired:Ljava/util/List;
aload 4
invokeinterface java.util.Map$Entry.getKey:()Ljava/lang/Object;
checkcast java.lang.Integer
invokevirtual java.lang.Integer.intValue:()I
invokeinterface java.util.List.get:(I)Ljava/lang/Object;
checkcast org.apache.cassandra.db.compaction.AbstractCompactionStrategy
aload 4
invokeinterface java.util.Map$Entry.getValue:()Ljava/lang/Object;
checkcast java.util.Collection
invokevirtual org.apache.cassandra.db.compaction.AbstractCompactionStrategy.groupSSTablesForAntiCompaction:(Ljava/util/Collection;)Ljava/util/Collection;
invokeinterface java.util.Collection.addAll:(Ljava/util/Collection;)Z
pop
end local 4 7: StackMap locals:
StackMap stack:
aload 5
invokeinterface java.util.Iterator.hasNext:()Z
ifne 5
8: aload 3
astore 7
9: aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.readLock:Ljava/util/concurrent/locks/ReentrantReadWriteLock$ReadLock;
invokevirtual java.util.concurrent.locks.ReentrantReadWriteLock$ReadLock.unlock:()V
10: aload 7
areturn
end local 3 end local 2 11: StackMap locals: org.apache.cassandra.db.compaction.CompactionStrategyManager java.util.Collection
StackMap stack: java.lang.Throwable
astore 6
12: aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.readLock:Ljava/util/concurrent/locks/ReentrantReadWriteLock$ReadLock;
invokevirtual java.util.concurrent.locks.ReentrantReadWriteLock$ReadLock.unlock:()V
13: aload 6
athrow
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 14 0 this Lorg/apache/cassandra/db/compaction/CompactionStrategyManager;
0 14 1 sstablesToGroup Ljava/util/Collection<Lorg/apache/cassandra/io/sstable/format/SSTableReader;>;
3 11 2 groups Ljava/util/Map<Ljava/lang/Integer;Ljava/util/List<Lorg/apache/cassandra/io/sstable/format/SSTableReader;>;>;
4 11 3 anticompactionGroups Ljava/util/Collection<Ljava/util/Collection<Lorg/apache/cassandra/io/sstable/format/SSTableReader;>;>;
6 7 4 group Ljava/util/Map$Entry<Ljava/lang/Integer;Ljava/util/List<Lorg/apache/cassandra/io/sstable/format/SSTableReader;>;>;
Exception table:
from to target type
2 9 11 any
Signature: (Ljava/util/Collection<Lorg/apache/cassandra/io/sstable/format/SSTableReader;>;)Ljava/util/Collection<Ljava/util/Collection<Lorg/apache/cassandra/io/sstable/format/SSTableReader;>;>;
MethodParameters:
Name Flags
sstablesToGroup
public long getMaxSSTableBytes();
descriptor: ()J
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=4, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.readLock:Ljava/util/concurrent/locks/ReentrantReadWriteLock$ReadLock;
invokevirtual java.util.concurrent.locks.ReentrantReadWriteLock$ReadLock.lock:()V
1: aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.unrepaired:Ljava/util/List;
iconst_0
invokeinterface java.util.List.get:(I)Ljava/lang/Object;
checkcast org.apache.cassandra.db.compaction.AbstractCompactionStrategy
invokevirtual org.apache.cassandra.db.compaction.AbstractCompactionStrategy.getMaxSSTableBytes:()J
lstore 2
2: aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.readLock:Ljava/util/concurrent/locks/ReentrantReadWriteLock$ReadLock;
invokevirtual java.util.concurrent.locks.ReentrantReadWriteLock$ReadLock.unlock:()V
3: lload 2
lreturn
4: StackMap locals:
StackMap stack: java.lang.Throwable
astore 1
5: aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.readLock:Ljava/util/concurrent/locks/ReentrantReadWriteLock$ReadLock;
invokevirtual java.util.concurrent.locks.ReentrantReadWriteLock$ReadLock.unlock:()V
6: aload 1
athrow
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 7 0 this Lorg/apache/cassandra/db/compaction/CompactionStrategyManager;
Exception table:
from to target type
1 2 4 any
public org.apache.cassandra.db.compaction.AbstractCompactionTask getCompactionTask(org.apache.cassandra.db.lifecycle.LifecycleTransaction, int, long);
descriptor: (Lorg/apache/cassandra/db/lifecycle/LifecycleTransaction;IJ)Lorg/apache/cassandra/db/compaction/AbstractCompactionTask;
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=7, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
invokevirtual org.apache.cassandra.db.compaction.CompactionStrategyManager.maybeReloadDiskBoundaries:()Z
pop
1: aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.readLock:Ljava/util/concurrent/locks/ReentrantReadWriteLock$ReadLock;
invokevirtual java.util.concurrent.locks.ReentrantReadWriteLock$ReadLock.lock:()V
2: aload 0
aload 1
invokevirtual org.apache.cassandra.db.lifecycle.LifecycleTransaction.originals:()Ljava/util/Set;
invokevirtual org.apache.cassandra.db.compaction.CompactionStrategyManager.validateForCompaction:(Ljava/lang/Iterable;)V
3: aload 0
aload 1
invokevirtual org.apache.cassandra.db.lifecycle.LifecycleTransaction.originals:()Ljava/util/Set;
invokeinterface java.util.Set.iterator:()Ljava/util/Iterator;
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.io.sstable.format.SSTableReader
invokevirtual org.apache.cassandra.db.compaction.CompactionStrategyManager.compactionStrategyFor:(Lorg/apache/cassandra/io/sstable/format/SSTableReader;)Lorg/apache/cassandra/db/compaction/AbstractCompactionStrategy;
aload 1
iload 2
lload 3
invokevirtual org.apache.cassandra.db.compaction.AbstractCompactionStrategy.getCompactionTask:(Lorg/apache/cassandra/db/lifecycle/LifecycleTransaction;IJ)Lorg/apache/cassandra/db/compaction/AbstractCompactionTask;
astore 6
4: aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.readLock:Ljava/util/concurrent/locks/ReentrantReadWriteLock$ReadLock;
invokevirtual java.util.concurrent.locks.ReentrantReadWriteLock$ReadLock.unlock:()V
5: aload 6
areturn
6: StackMap locals:
StackMap stack: java.lang.Throwable
astore 5
7: aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.readLock:Ljava/util/concurrent/locks/ReentrantReadWriteLock$ReadLock;
invokevirtual java.util.concurrent.locks.ReentrantReadWriteLock$ReadLock.unlock:()V
8: aload 5
athrow
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 9 0 this Lorg/apache/cassandra/db/compaction/CompactionStrategyManager;
0 9 1 txn Lorg/apache/cassandra/db/lifecycle/LifecycleTransaction;
0 9 2 gcBefore I
0 9 3 maxSSTableBytes J
Exception table:
from to target type
2 4 6 any
MethodParameters:
Name Flags
txn
gcBefore
maxSSTableBytes
private void validateForCompaction(java.lang.Iterable<org.apache.cassandra.io.sstable.format.SSTableReader>);
descriptor: (Ljava/lang/Iterable;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=3, locals=8, args_size=2
start local 0 start local 1 0: aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.readLock:Ljava/util/concurrent/locks/ReentrantReadWriteLock$ReadLock;
invokevirtual java.util.concurrent.locks.ReentrantReadWriteLock$ReadLock.lock:()V
1: aload 1
aconst_null
invokestatic com.google.common.collect.Iterables.getFirst:(Ljava/lang/Iterable;Ljava/lang/Object;)Ljava/lang/Object;
checkcast org.apache.cassandra.io.sstable.format.SSTableReader
astore 2
start local 2 2: getstatic org.apache.cassandra.db.compaction.CompactionStrategyManager.$assertionsDisabled:Z
ifne 3
aload 2
ifnonnull 3
new java.lang.AssertionError
dup
invokespecial java.lang.AssertionError.<init>:()V
athrow
3: StackMap locals: org.apache.cassandra.io.sstable.format.SSTableReader
StackMap stack:
aload 2
invokevirtual org.apache.cassandra.io.sstable.format.SSTableReader.isRepaired:()Z
istore 3
start local 3 4: aload 0
aload 2
invokevirtual org.apache.cassandra.db.compaction.CompactionStrategyManager.compactionStrategyIndexFor:(Lorg/apache/cassandra/io/sstable/format/SSTableReader;)I
istore 4
start local 4 5: aload 1
invokeinterface java.lang.Iterable.iterator:()Ljava/util/Iterator;
astore 6
goto 11
StackMap locals: org.apache.cassandra.db.compaction.CompactionStrategyManager java.lang.Iterable org.apache.cassandra.io.sstable.format.SSTableReader int int top java.util.Iterator
StackMap stack:
6: aload 6
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.io.sstable.format.SSTableReader
astore 5
start local 5 7: aload 5
invokevirtual org.apache.cassandra.io.sstable.format.SSTableReader.isRepaired:()Z
iload 3
if_icmpeq 9
8: new java.lang.UnsupportedOperationException
dup
ldc "You can't mix repaired and unrepaired data in a compaction"
invokespecial java.lang.UnsupportedOperationException.<init>:(Ljava/lang/String;)V
athrow
9: StackMap locals: org.apache.cassandra.db.compaction.CompactionStrategyManager java.lang.Iterable org.apache.cassandra.io.sstable.format.SSTableReader int int org.apache.cassandra.io.sstable.format.SSTableReader java.util.Iterator
StackMap stack:
iload 4
aload 0
aload 5
invokevirtual org.apache.cassandra.db.compaction.CompactionStrategyManager.compactionStrategyIndexFor:(Lorg/apache/cassandra/io/sstable/format/SSTableReader;)I
if_icmpeq 11
10: new java.lang.UnsupportedOperationException
dup
ldc "You can't mix sstables from different directories in a compaction"
invokespecial java.lang.UnsupportedOperationException.<init>:(Ljava/lang/String;)V
athrow
end local 5 11: StackMap locals: org.apache.cassandra.db.compaction.CompactionStrategyManager java.lang.Iterable org.apache.cassandra.io.sstable.format.SSTableReader int int top java.util.Iterator
StackMap stack:
aload 6
invokeinterface java.util.Iterator.hasNext:()Z
ifne 6
end local 4 end local 3 end local 2 12: goto 16
13: StackMap locals: org.apache.cassandra.db.compaction.CompactionStrategyManager java.lang.Iterable
StackMap stack: java.lang.Throwable
astore 7
14: aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.readLock:Ljava/util/concurrent/locks/ReentrantReadWriteLock$ReadLock;
invokevirtual java.util.concurrent.locks.ReentrantReadWriteLock$ReadLock.unlock:()V
15: aload 7
athrow
16: StackMap locals:
StackMap stack:
aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.readLock:Ljava/util/concurrent/locks/ReentrantReadWriteLock$ReadLock;
invokevirtual java.util.concurrent.locks.ReentrantReadWriteLock$ReadLock.unlock:()V
17: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 18 0 this Lorg/apache/cassandra/db/compaction/CompactionStrategyManager;
0 18 1 input Ljava/lang/Iterable<Lorg/apache/cassandra/io/sstable/format/SSTableReader;>;
2 12 2 firstSSTable Lorg/apache/cassandra/io/sstable/format/SSTableReader;
4 12 3 repaired Z
5 12 4 firstIndex I
7 11 5 sstable Lorg/apache/cassandra/io/sstable/format/SSTableReader;
Exception table:
from to target type
1 13 13 any
Signature: (Ljava/lang/Iterable<Lorg/apache/cassandra/io/sstable/format/SSTableReader;>;)V
MethodParameters:
Name Flags
input
public java.util.Collection<org.apache.cassandra.db.compaction.AbstractCompactionTask> getMaximalTasks(int, boolean);
descriptor: (IZ)Ljava/util/Collection;
flags: (0x0001) ACC_PUBLIC
Code:
stack=6, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
invokevirtual org.apache.cassandra.db.compaction.CompactionStrategyManager.maybeReloadDiskBoundaries:()Z
pop
1: aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.cfs:Lorg/apache/cassandra/db/ColumnFamilyStore;
new org.apache.cassandra.db.compaction.CompactionStrategyManager$1
dup
aload 0
iload 1
iload 2
invokespecial org.apache.cassandra.db.compaction.CompactionStrategyManager$1.<init>:(Lorg/apache/cassandra/db/compaction/CompactionStrategyManager;IZ)V
2: iconst_0
iconst_0
3: invokevirtual org.apache.cassandra.db.ColumnFamilyStore.runWithCompactionsDisabled:(Ljava/util/concurrent/Callable;ZZ)Ljava/lang/Object;
checkcast java.util.Collection
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lorg/apache/cassandra/db/compaction/CompactionStrategyManager;
0 4 1 gcBefore I
0 4 2 splitOutput Z
Signature: (IZ)Ljava/util/Collection<Lorg/apache/cassandra/db/compaction/AbstractCompactionTask;>;
MethodParameters:
Name Flags
gcBefore final
splitOutput final
public java.util.List<org.apache.cassandra.db.compaction.AbstractCompactionTask> getUserDefinedTasks(java.util.Collection<org.apache.cassandra.io.sstable.format.SSTableReader>, int);
descriptor: (Ljava/util/Collection;I)Ljava/util/List;
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
aload 1
iload 2
iconst_0
invokevirtual org.apache.cassandra.db.compaction.CompactionStrategyManager.getUserDefinedTasks:(Ljava/util/Collection;IZ)Ljava/util/List;
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/db/compaction/CompactionStrategyManager;
0 1 1 sstables Ljava/util/Collection<Lorg/apache/cassandra/io/sstable/format/SSTableReader;>;
0 1 2 gcBefore I
Signature: (Ljava/util/Collection<Lorg/apache/cassandra/io/sstable/format/SSTableReader;>;I)Ljava/util/List<Lorg/apache/cassandra/db/compaction/AbstractCompactionTask;>;
MethodParameters:
Name Flags
sstables
gcBefore
public java.util.List<org.apache.cassandra.db.compaction.AbstractCompactionTask> getUserDefinedTasks(java.util.Collection<org.apache.cassandra.io.sstable.format.SSTableReader>, int, boolean);
descriptor: (Ljava/util/Collection;IZ)Ljava/util/List;
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=11, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
invokevirtual org.apache.cassandra.db.compaction.CompactionStrategyManager.maybeReloadDiskBoundaries:()Z
pop
1: new java.util.ArrayList
dup
invokespecial java.util.ArrayList.<init>:()V
astore 4
start local 4 2: aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.readLock:Ljava/util/concurrent/locks/ReentrantReadWriteLock$ReadLock;
invokevirtual java.util.concurrent.locks.ReentrantReadWriteLock$ReadLock.lock:()V
3: iload 3
ifeq 5
4: aload 0
aload 1
invokevirtual org.apache.cassandra.db.compaction.CompactionStrategyManager.validateForCompaction:(Ljava/lang/Iterable;)V
5: StackMap locals: java.util.List
StackMap stack:
aload 1
invokeinterface java.util.Collection.stream:()Ljava/util/stream/Stream;
6: invokedynamic test()Ljava/util/function/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/db/compaction/CompactionStrategyManager.lambda$14(Lorg/apache/cassandra/io/sstable/format/SSTableReader;)Z (6)
(Lorg/apache/cassandra/io/sstable/format/SSTableReader;)Z
invokeinterface java.util.stream.Stream.filter:(Ljava/util/function/Predicate;)Ljava/util/stream/Stream;
7: aload 0
invokedynamic apply(Lorg/apache/cassandra/db/compaction/CompactionStrategyManager;)Ljava/util/function/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/db/compaction/CompactionStrategyManager.lambda$15(Lorg/apache/cassandra/io/sstable/format/SSTableReader;)Ljava/lang/Integer; (7)
(Lorg/apache/cassandra/io/sstable/format/SSTableReader;)Ljava/lang/Integer;
invokestatic java.util.stream.Collectors.groupingBy:(Ljava/util/function/Function;)Ljava/util/stream/Collector;
invokeinterface java.util.stream.Stream.collect:(Ljava/util/stream/Collector;)Ljava/lang/Object;
checkcast java.util.Map
8: astore 5
start local 5 9: aload 1
invokeinterface java.util.Collection.stream:()Ljava/util/stream/Stream;
10: invokedynamic test()Ljava/util/function/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/db/compaction/CompactionStrategyManager.lambda$16(Lorg/apache/cassandra/io/sstable/format/SSTableReader;)Z (6)
(Lorg/apache/cassandra/io/sstable/format/SSTableReader;)Z
invokeinterface java.util.stream.Stream.filter:(Ljava/util/function/Predicate;)Ljava/util/stream/Stream;
11: aload 0
invokedynamic apply(Lorg/apache/cassandra/db/compaction/CompactionStrategyManager;)Ljava/util/function/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/db/compaction/CompactionStrategyManager.lambda$17(Lorg/apache/cassandra/io/sstable/format/SSTableReader;)Ljava/lang/Integer; (7)
(Lorg/apache/cassandra/io/sstable/format/SSTableReader;)Ljava/lang/Integer;
invokestatic java.util.stream.Collectors.groupingBy:(Ljava/util/function/Function;)Ljava/util/stream/Collector;
invokeinterface java.util.stream.Stream.collect:(Ljava/util/stream/Collector;)Ljava/lang/Object;
checkcast java.util.Map
12: astore 6
start local 6 13: aload 5
invokeinterface java.util.Map.entrySet:()Ljava/util/Set;
invokeinterface java.util.Set.iterator:()Ljava/util/Iterator;
astore 8
goto 16
StackMap locals: org.apache.cassandra.db.compaction.CompactionStrategyManager java.util.Collection int int java.util.List java.util.Map java.util.Map top java.util.Iterator
StackMap stack:
14: aload 8
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast java.util.Map$Entry
astore 7
start local 7 15: aload 4
aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.repaired:Ljava/util/List;
aload 7
invokeinterface java.util.Map$Entry.getKey:()Ljava/lang/Object;
checkcast java.lang.Integer
invokevirtual java.lang.Integer.intValue:()I
invokeinterface java.util.List.get:(I)Ljava/lang/Object;
checkcast org.apache.cassandra.db.compaction.AbstractCompactionStrategy
aload 7
invokeinterface java.util.Map$Entry.getValue:()Ljava/lang/Object;
checkcast java.util.Collection
iload 2
invokevirtual org.apache.cassandra.db.compaction.AbstractCompactionStrategy.getUserDefinedTask:(Ljava/util/Collection;I)Lorg/apache/cassandra/db/compaction/AbstractCompactionTask;
invokeinterface java.util.List.add:(Ljava/lang/Object;)Z
pop
end local 7 16: StackMap locals:
StackMap stack:
aload 8
invokeinterface java.util.Iterator.hasNext:()Z
ifne 14
17: aload 6
invokeinterface java.util.Map.entrySet:()Ljava/util/Set;
invokeinterface java.util.Set.iterator:()Ljava/util/Iterator;
astore 8
goto 20
StackMap locals:
StackMap stack:
18: aload 8
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast java.util.Map$Entry
astore 7
start local 7 19: aload 4
aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.unrepaired:Ljava/util/List;
aload 7
invokeinterface java.util.Map$Entry.getKey:()Ljava/lang/Object;
checkcast java.lang.Integer
invokevirtual java.lang.Integer.intValue:()I
invokeinterface java.util.List.get:(I)Ljava/lang/Object;
checkcast org.apache.cassandra.db.compaction.AbstractCompactionStrategy
aload 7
invokeinterface java.util.Map$Entry.getValue:()Ljava/lang/Object;
checkcast java.util.Collection
iload 2
invokevirtual org.apache.cassandra.db.compaction.AbstractCompactionStrategy.getUserDefinedTask:(Ljava/util/Collection;I)Lorg/apache/cassandra/db/compaction/AbstractCompactionTask;
invokeinterface java.util.List.add:(Ljava/lang/Object;)Z
pop
end local 7 20: StackMap locals:
StackMap stack:
aload 8
invokeinterface java.util.Iterator.hasNext:()Z
ifne 18
21: aload 4
astore 10
22: aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.readLock:Ljava/util/concurrent/locks/ReentrantReadWriteLock$ReadLock;
invokevirtual java.util.concurrent.locks.ReentrantReadWriteLock$ReadLock.unlock:()V
23: aload 10
areturn
end local 6 end local 5 24: StackMap locals: org.apache.cassandra.db.compaction.CompactionStrategyManager java.util.Collection int int java.util.List
StackMap stack: java.lang.Throwable
astore 9
25: aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.readLock:Ljava/util/concurrent/locks/ReentrantReadWriteLock$ReadLock;
invokevirtual java.util.concurrent.locks.ReentrantReadWriteLock$ReadLock.unlock:()V
26: aload 9
athrow
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 27 0 this Lorg/apache/cassandra/db/compaction/CompactionStrategyManager;
0 27 1 sstables Ljava/util/Collection<Lorg/apache/cassandra/io/sstable/format/SSTableReader;>;
0 27 2 gcBefore I
0 27 3 validateForCompaction Z
2 27 4 ret Ljava/util/List<Lorg/apache/cassandra/db/compaction/AbstractCompactionTask;>;
9 24 5 repairedSSTables Ljava/util/Map<Ljava/lang/Integer;Ljava/util/List<Lorg/apache/cassandra/io/sstable/format/SSTableReader;>;>;
13 24 6 unrepairedSSTables Ljava/util/Map<Ljava/lang/Integer;Ljava/util/List<Lorg/apache/cassandra/io/sstable/format/SSTableReader;>;>;
15 16 7 group Ljava/util/Map$Entry<Ljava/lang/Integer;Ljava/util/List<Lorg/apache/cassandra/io/sstable/format/SSTableReader;>;>;
19 20 7 group Ljava/util/Map$Entry<Ljava/lang/Integer;Ljava/util/List<Lorg/apache/cassandra/io/sstable/format/SSTableReader;>;>;
Exception table:
from to target type
3 22 24 any
Signature: (Ljava/util/Collection<Lorg/apache/cassandra/io/sstable/format/SSTableReader;>;IZ)Ljava/util/List<Lorg/apache/cassandra/db/compaction/AbstractCompactionTask;>;
MethodParameters:
Name Flags
sstables
gcBefore
validateForCompaction
public org.apache.cassandra.db.compaction.AbstractCompactionTask getUserDefinedTask(java.util.Collection<org.apache.cassandra.io.sstable.format.SSTableReader>, int);
descriptor: (Ljava/util/Collection;I)Lorg/apache/cassandra/db/compaction/AbstractCompactionTask;
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=4, args_size=3
start local 0 start local 1 start local 2 0: aload 0
aload 1
iload 2
iconst_1
invokevirtual org.apache.cassandra.db.compaction.CompactionStrategyManager.getUserDefinedTasks:(Ljava/util/Collection;IZ)Ljava/util/List;
astore 3
start local 3 1: getstatic org.apache.cassandra.db.compaction.CompactionStrategyManager.$assertionsDisabled:Z
ifne 2
aload 3
invokeinterface java.util.List.size:()I
iconst_1
if_icmpeq 2
new java.lang.AssertionError
dup
invokespecial java.lang.AssertionError.<init>:()V
athrow
2: StackMap locals: java.util.List
StackMap stack:
aload 3
iconst_0
invokeinterface java.util.List.get:(I)Ljava/lang/Object;
checkcast org.apache.cassandra.db.compaction.AbstractCompactionTask
areturn
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lorg/apache/cassandra/db/compaction/CompactionStrategyManager;
0 3 1 sstables Ljava/util/Collection<Lorg/apache/cassandra/io/sstable/format/SSTableReader;>;
0 3 2 gcBefore I
1 3 3 tasks Ljava/util/List<Lorg/apache/cassandra/db/compaction/AbstractCompactionTask;>;
Signature: (Ljava/util/Collection<Lorg/apache/cassandra/io/sstable/format/SSTableReader;>;I)Lorg/apache/cassandra/db/compaction/AbstractCompactionTask;
RuntimeVisibleAnnotations:
java.lang.Deprecated()
MethodParameters:
Name Flags
sstables
gcBefore
public int getEstimatedRemainingTasks();
descriptor: ()I
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=5, args_size=1
start local 0 0: aload 0
invokevirtual org.apache.cassandra.db.compaction.CompactionStrategyManager.maybeReloadDiskBoundaries:()Z
pop
1: iconst_0
istore 1
start local 1 2: aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.readLock:Ljava/util/concurrent/locks/ReentrantReadWriteLock$ReadLock;
invokevirtual java.util.concurrent.locks.ReentrantReadWriteLock$ReadLock.lock:()V
3: aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.repaired:Ljava/util/List;
invokeinterface java.util.List.iterator:()Ljava/util/Iterator;
astore 3
goto 6
StackMap locals: org.apache.cassandra.db.compaction.CompactionStrategyManager int top java.util.Iterator
StackMap stack:
4: aload 3
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.db.compaction.AbstractCompactionStrategy
astore 2
start local 2 5: iload 1
aload 2
invokevirtual org.apache.cassandra.db.compaction.AbstractCompactionStrategy.getEstimatedRemainingTasks:()I
iadd
istore 1
end local 2 6: StackMap locals:
StackMap stack:
aload 3
invokeinterface java.util.Iterator.hasNext:()Z
ifne 4
7: aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.unrepaired:Ljava/util/List;
invokeinterface java.util.List.iterator:()Ljava/util/Iterator;
astore 3
goto 10
StackMap locals:
StackMap stack:
8: aload 3
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.db.compaction.AbstractCompactionStrategy
astore 2
start local 2 9: iload 1
aload 2
invokevirtual org.apache.cassandra.db.compaction.AbstractCompactionStrategy.getEstimatedRemainingTasks:()I
iadd
istore 1
end local 2 10: StackMap locals:
StackMap stack:
aload 3
invokeinterface java.util.Iterator.hasNext:()Z
ifne 8
11: goto 15
12: StackMap locals: org.apache.cassandra.db.compaction.CompactionStrategyManager int
StackMap stack: java.lang.Throwable
astore 4
13: aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.readLock:Ljava/util/concurrent/locks/ReentrantReadWriteLock$ReadLock;
invokevirtual java.util.concurrent.locks.ReentrantReadWriteLock$ReadLock.unlock:()V
14: aload 4
athrow
15: StackMap locals:
StackMap stack:
aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.readLock:Ljava/util/concurrent/locks/ReentrantReadWriteLock$ReadLock;
invokevirtual java.util.concurrent.locks.ReentrantReadWriteLock$ReadLock.unlock:()V
16: iload 1
ireturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 17 0 this Lorg/apache/cassandra/db/compaction/CompactionStrategyManager;
2 17 1 tasks I
5 6 2 strategy Lorg/apache/cassandra/db/compaction/AbstractCompactionStrategy;
9 10 2 strategy Lorg/apache/cassandra/db/compaction/AbstractCompactionStrategy;
Exception table:
from to target type
3 12 12 any
public boolean shouldBeEnabled();
descriptor: ()Z
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.params:Lorg/apache/cassandra/schema/CompactionParams;
invokevirtual org.apache.cassandra.schema.CompactionParams.isEnabled:()Z
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/db/compaction/CompactionStrategyManager;
public java.lang.String getName();
descriptor: ()Ljava/lang/String;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=3, args_size=1
start local 0 0: aload 0
invokevirtual org.apache.cassandra.db.compaction.CompactionStrategyManager.maybeReloadDiskBoundaries:()Z
pop
1: aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.readLock:Ljava/util/concurrent/locks/ReentrantReadWriteLock$ReadLock;
invokevirtual java.util.concurrent.locks.ReentrantReadWriteLock$ReadLock.lock:()V
2: aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.unrepaired:Ljava/util/List;
iconst_0
invokeinterface java.util.List.get:(I)Ljava/lang/Object;
checkcast org.apache.cassandra.db.compaction.AbstractCompactionStrategy
invokevirtual org.apache.cassandra.db.compaction.AbstractCompactionStrategy.getName:()Ljava/lang/String;
astore 2
3: aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.readLock:Ljava/util/concurrent/locks/ReentrantReadWriteLock$ReadLock;
invokevirtual java.util.concurrent.locks.ReentrantReadWriteLock$ReadLock.unlock:()V
4: aload 2
areturn
5: StackMap locals:
StackMap stack: java.lang.Throwable
astore 1
6: aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.readLock:Ljava/util/concurrent/locks/ReentrantReadWriteLock$ReadLock;
invokevirtual java.util.concurrent.locks.ReentrantReadWriteLock$ReadLock.unlock:()V
7: aload 1
athrow
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 8 0 this Lorg/apache/cassandra/db/compaction/CompactionStrategyManager;
Exception table:
from to target type
2 3 5 any
public java.util.List<java.util.List<org.apache.cassandra.db.compaction.AbstractCompactionStrategy>> getStrategies();
descriptor: ()Ljava/util/List;
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=3, args_size=1
start local 0 0: aload 0
invokevirtual org.apache.cassandra.db.compaction.CompactionStrategyManager.maybeReloadDiskBoundaries:()Z
pop
1: aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.readLock:Ljava/util/concurrent/locks/ReentrantReadWriteLock$ReadLock;
invokevirtual java.util.concurrent.locks.ReentrantReadWriteLock$ReadLock.lock:()V
2: iconst_2
anewarray java.util.List
dup
iconst_0
aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.repaired:Ljava/util/List;
aastore
dup
iconst_1
aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.unrepaired:Ljava/util/List;
aastore
invokestatic java.util.Arrays.asList:([Ljava/lang/Object;)Ljava/util/List;
astore 2
3: aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.readLock:Ljava/util/concurrent/locks/ReentrantReadWriteLock$ReadLock;
invokevirtual java.util.concurrent.locks.ReentrantReadWriteLock$ReadLock.unlock:()V
aload 2
areturn
4: StackMap locals:
StackMap stack: java.lang.Throwable
astore 1
5: aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.readLock:Ljava/util/concurrent/locks/ReentrantReadWriteLock$ReadLock;
invokevirtual java.util.concurrent.locks.ReentrantReadWriteLock$ReadLock.unlock:()V
6: aload 1
athrow
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 7 0 this Lorg/apache/cassandra/db/compaction/CompactionStrategyManager;
Exception table:
from to target type
2 3 4 any
Signature: ()Ljava/util/List<Ljava/util/List<Lorg/apache/cassandra/db/compaction/AbstractCompactionStrategy;>;>;
public void setNewLocalCompactionStrategy(org.apache.cassandra.schema.CompactionParams);
descriptor: (Lorg/apache/cassandra/schema/CompactionParams;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=3, args_size=2
start local 0 start local 1 0: getstatic org.apache.cassandra.db.compaction.CompactionStrategyManager.logger:Lorg/slf4j/Logger;
ldc "Switching local compaction strategy from {} to {}}"
aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.params:Lorg/apache/cassandra/schema/CompactionParams;
aload 1
invokeinterface org.slf4j.Logger.info:(Ljava/lang/String;Ljava/lang/Object;Ljava/lang/Object;)V
1: aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.writeLock:Ljava/util/concurrent/locks/ReentrantReadWriteLock$WriteLock;
invokevirtual java.util.concurrent.locks.ReentrantReadWriteLock$WriteLock.lock:()V
2: aload 0
aload 1
invokevirtual org.apache.cassandra.db.compaction.CompactionStrategyManager.setStrategy:(Lorg/apache/cassandra/schema/CompactionParams;)V
3: aload 0
invokevirtual org.apache.cassandra.db.compaction.CompactionStrategyManager.shouldBeEnabled:()Z
ifeq 5
4: aload 0
invokevirtual org.apache.cassandra.db.compaction.CompactionStrategyManager.enable:()V
goto 6
5: StackMap locals:
StackMap stack:
aload 0
invokevirtual org.apache.cassandra.db.compaction.CompactionStrategyManager.disable:()V
6: StackMap locals:
StackMap stack:
aload 0
invokevirtual org.apache.cassandra.db.compaction.CompactionStrategyManager.startup:()V
7: goto 11
8: StackMap locals:
StackMap stack: java.lang.Throwable
astore 2
9: aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.writeLock:Ljava/util/concurrent/locks/ReentrantReadWriteLock$WriteLock;
invokevirtual java.util.concurrent.locks.ReentrantReadWriteLock$WriteLock.unlock:()V
10: aload 2
athrow
11: StackMap locals:
StackMap stack:
aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.writeLock:Ljava/util/concurrent/locks/ReentrantReadWriteLock$WriteLock;
invokevirtual java.util.concurrent.locks.ReentrantReadWriteLock$WriteLock.unlock:()V
12: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 13 0 this Lorg/apache/cassandra/db/compaction/CompactionStrategyManager;
0 13 1 params Lorg/apache/cassandra/schema/CompactionParams;
Exception table:
from to target type
2 8 8 any
MethodParameters:
Name Flags
params
private void setStrategy(org.apache.cassandra.schema.CompactionParams);
descriptor: (Lorg/apache/cassandra/schema/CompactionParams;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=3, locals=3, args_size=2
start local 0 start local 1 0: aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.repaired:Ljava/util/List;
invokedynamic accept()Ljava/util/function/Consumer;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)V
org/apache/cassandra/db/compaction/AbstractCompactionStrategy.shutdown()V (5)
(Lorg/apache/cassandra/db/compaction/AbstractCompactionStrategy;)V
invokeinterface java.util.List.forEach:(Ljava/util/function/Consumer;)V
1: aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.unrepaired:Ljava/util/List;
invokedynamic accept()Ljava/util/function/Consumer;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)V
org/apache/cassandra/db/compaction/AbstractCompactionStrategy.shutdown()V (5)
(Lorg/apache/cassandra/db/compaction/AbstractCompactionStrategy;)V
invokeinterface java.util.List.forEach:(Ljava/util/function/Consumer;)V
2: aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.repaired:Ljava/util/List;
invokeinterface java.util.List.clear:()V
3: aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.unrepaired:Ljava/util/List;
invokeinterface java.util.List.clear:()V
4: aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.partitionSSTablesByTokenRange:Z
ifeq 12
5: iconst_0
istore 2
start local 2 6: goto 10
7: StackMap locals: int
StackMap stack:
aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.repaired:Ljava/util/List;
aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.cfs:Lorg/apache/cassandra/db/ColumnFamilyStore;
aload 1
invokestatic org.apache.cassandra.config.CFMetaData.createCompactionStrategyInstance:(Lorg/apache/cassandra/db/ColumnFamilyStore;Lorg/apache/cassandra/schema/CompactionParams;)Lorg/apache/cassandra/db/compaction/AbstractCompactionStrategy;
invokeinterface java.util.List.add:(Ljava/lang/Object;)Z
pop
8: aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.unrepaired:Ljava/util/List;
aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.cfs:Lorg/apache/cassandra/db/ColumnFamilyStore;
aload 1
invokestatic org.apache.cassandra.config.CFMetaData.createCompactionStrategyInstance:(Lorg/apache/cassandra/db/ColumnFamilyStore;Lorg/apache/cassandra/schema/CompactionParams;)Lorg/apache/cassandra/db/compaction/AbstractCompactionStrategy;
invokeinterface java.util.List.add:(Ljava/lang/Object;)Z
pop
9: iinc 2 1
StackMap locals:
StackMap stack:
10: iload 2
aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.currentBoundaries:Lorg/apache/cassandra/db/DiskBoundaries;
getfield org.apache.cassandra.db.DiskBoundaries.directories:Ljava/util/List;
invokeinterface java.util.List.size:()I
if_icmplt 7
end local 2 11: goto 14
12: StackMap locals:
StackMap stack:
aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.repaired:Ljava/util/List;
aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.cfs:Lorg/apache/cassandra/db/ColumnFamilyStore;
aload 1
invokestatic org.apache.cassandra.config.CFMetaData.createCompactionStrategyInstance:(Lorg/apache/cassandra/db/ColumnFamilyStore;Lorg/apache/cassandra/schema/CompactionParams;)Lorg/apache/cassandra/db/compaction/AbstractCompactionStrategy;
invokeinterface java.util.List.add:(Ljava/lang/Object;)Z
pop
13: aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.unrepaired:Ljava/util/List;
aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.cfs:Lorg/apache/cassandra/db/ColumnFamilyStore;
aload 1
invokestatic org.apache.cassandra.config.CFMetaData.createCompactionStrategyInstance:(Lorg/apache/cassandra/db/ColumnFamilyStore;Lorg/apache/cassandra/schema/CompactionParams;)Lorg/apache/cassandra/db/compaction/AbstractCompactionStrategy;
invokeinterface java.util.List.add:(Ljava/lang/Object;)Z
pop
14: StackMap locals:
StackMap stack:
aload 0
aload 1
putfield org.apache.cassandra.db.compaction.CompactionStrategyManager.params:Lorg/apache/cassandra/schema/CompactionParams;
15: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 16 0 this Lorg/apache/cassandra/db/compaction/CompactionStrategyManager;
0 16 1 params Lorg/apache/cassandra/schema/CompactionParams;
6 11 2 i I
MethodParameters:
Name Flags
params
public org.apache.cassandra.schema.CompactionParams getCompactionParams();
descriptor: ()Lorg/apache/cassandra/schema/CompactionParams;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.params:Lorg/apache/cassandra/schema/CompactionParams;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/db/compaction/CompactionStrategyManager;
public boolean onlyPurgeRepairedTombstones();
descriptor: ()Z
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.params:Lorg/apache/cassandra/schema/CompactionParams;
invokevirtual org.apache.cassandra.schema.CompactionParams.options:()Ljava/util/Map;
ldc "only_purge_repaired_tombstones"
invokeinterface java.util.Map.get:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast java.lang.String
invokestatic java.lang.Boolean.parseBoolean:(Ljava/lang/String;)Z
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/db/compaction/CompactionStrategyManager;
public org.apache.cassandra.io.sstable.SSTableMultiWriter createSSTableMultiWriter(org.apache.cassandra.io.sstable.Descriptor, long, long, org.apache.cassandra.io.sstable.metadata.MetadataCollector, org.apache.cassandra.db.SerializationHeader, java.util.Collection<org.apache.cassandra.index.Index>, org.apache.cassandra.db.lifecycle.LifecycleNewTracker);
descriptor: (Lorg/apache/cassandra/io/sstable/Descriptor;JJLorg/apache/cassandra/io/sstable/metadata/MetadataCollector;Lorg/apache/cassandra/db/SerializationHeader;Ljava/util/Collection;Lorg/apache/cassandra/db/lifecycle/LifecycleNewTracker;)Lorg/apache/cassandra/io/sstable/SSTableMultiWriter;
flags: (0x0001) ACC_PUBLIC
Code:
stack=10, locals=12, args_size=8
start local 0 start local 1 start local 2 start local 4 start local 6 start local 7 start local 8 start local 9 0: aload 0
invokevirtual org.apache.cassandra.db.compaction.CompactionStrategyManager.maybeReloadDiskBoundaries:()Z
pop
1: aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.readLock:Ljava/util/concurrent/locks/ReentrantReadWriteLock$ReadLock;
invokevirtual java.util.concurrent.locks.ReentrantReadWriteLock$ReadLock.lock:()V
2: lload 4
lconst_0
lcmp
ifne 6
3: aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.unrepaired:Ljava/util/List;
iconst_0
invokeinterface java.util.List.get:(I)Ljava/lang/Object;
checkcast org.apache.cassandra.db.compaction.AbstractCompactionStrategy
aload 1
lload 2
lload 4
aload 6
aload 7
aload 8
aload 9
invokevirtual org.apache.cassandra.db.compaction.AbstractCompactionStrategy.createSSTableMultiWriter:(Lorg/apache/cassandra/io/sstable/Descriptor;JJLorg/apache/cassandra/io/sstable/metadata/MetadataCollector;Lorg/apache/cassandra/db/SerializationHeader;Ljava/util/Collection;Lorg/apache/cassandra/db/lifecycle/LifecycleNewTracker;)Lorg/apache/cassandra/io/sstable/SSTableMultiWriter;
astore 11
4: aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.readLock:Ljava/util/concurrent/locks/ReentrantReadWriteLock$ReadLock;
invokevirtual java.util.concurrent.locks.ReentrantReadWriteLock$ReadLock.unlock:()V
5: aload 11
areturn
6: StackMap locals:
StackMap stack:
aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.repaired:Ljava/util/List;
iconst_0
invokeinterface java.util.List.get:(I)Ljava/lang/Object;
checkcast org.apache.cassandra.db.compaction.AbstractCompactionStrategy
aload 1
lload 2
lload 4
aload 6
aload 7
aload 8
aload 9
invokevirtual org.apache.cassandra.db.compaction.AbstractCompactionStrategy.createSSTableMultiWriter:(Lorg/apache/cassandra/io/sstable/Descriptor;JJLorg/apache/cassandra/io/sstable/metadata/MetadataCollector;Lorg/apache/cassandra/db/SerializationHeader;Ljava/util/Collection;Lorg/apache/cassandra/db/lifecycle/LifecycleNewTracker;)Lorg/apache/cassandra/io/sstable/SSTableMultiWriter;
astore 11
7: aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.readLock:Ljava/util/concurrent/locks/ReentrantReadWriteLock$ReadLock;
invokevirtual java.util.concurrent.locks.ReentrantReadWriteLock$ReadLock.unlock:()V
8: aload 11
areturn
9: StackMap locals:
StackMap stack: java.lang.Throwable
astore 10
10: aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.readLock:Ljava/util/concurrent/locks/ReentrantReadWriteLock$ReadLock;
invokevirtual java.util.concurrent.locks.ReentrantReadWriteLock$ReadLock.unlock:()V
11: aload 10
athrow
end local 9 end local 8 end local 7 end local 6 end local 4 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 12 0 this Lorg/apache/cassandra/db/compaction/CompactionStrategyManager;
0 12 1 descriptor Lorg/apache/cassandra/io/sstable/Descriptor;
0 12 2 keyCount J
0 12 4 repairedAt J
0 12 6 collector Lorg/apache/cassandra/io/sstable/metadata/MetadataCollector;
0 12 7 header Lorg/apache/cassandra/db/SerializationHeader;
0 12 8 indexes Ljava/util/Collection<Lorg/apache/cassandra/index/Index;>;
0 12 9 lifecycleNewTracker Lorg/apache/cassandra/db/lifecycle/LifecycleNewTracker;
Exception table:
from to target type
2 4 9 any
6 7 9 any
Signature: (Lorg/apache/cassandra/io/sstable/Descriptor;JJLorg/apache/cassandra/io/sstable/metadata/MetadataCollector;Lorg/apache/cassandra/db/SerializationHeader;Ljava/util/Collection<Lorg/apache/cassandra/index/Index;>;Lorg/apache/cassandra/db/lifecycle/LifecycleNewTracker;)Lorg/apache/cassandra/io/sstable/SSTableMultiWriter;
MethodParameters:
Name Flags
descriptor
keyCount
repairedAt
collector
header
indexes
lifecycleNewTracker
public boolean isRepaired(org.apache.cassandra.db.compaction.AbstractCompactionStrategy);
descriptor: (Lorg/apache/cassandra/db/compaction/AbstractCompactionStrategy;)Z
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=4, args_size=2
start local 0 start local 1 0: aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.readLock:Ljava/util/concurrent/locks/ReentrantReadWriteLock$ReadLock;
invokevirtual java.util.concurrent.locks.ReentrantReadWriteLock$ReadLock.lock:()V
1: aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.repaired:Ljava/util/List;
aload 1
invokeinterface java.util.List.contains:(Ljava/lang/Object;)Z
istore 3
2: aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.readLock:Ljava/util/concurrent/locks/ReentrantReadWriteLock$ReadLock;
invokevirtual java.util.concurrent.locks.ReentrantReadWriteLock$ReadLock.unlock:()V
3: iload 3
ireturn
4: StackMap locals:
StackMap stack: java.lang.Throwable
astore 2
5: aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.readLock:Ljava/util/concurrent/locks/ReentrantReadWriteLock$ReadLock;
invokevirtual java.util.concurrent.locks.ReentrantReadWriteLock$ReadLock.unlock:()V
6: aload 2
athrow
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 7 0 this Lorg/apache/cassandra/db/compaction/CompactionStrategyManager;
0 7 1 strategy Lorg/apache/cassandra/db/compaction/AbstractCompactionStrategy;
Exception table:
from to target type
1 2 4 any
MethodParameters:
Name Flags
strategy
public java.util.List<java.lang.String> getStrategyFolders(org.apache.cassandra.db.compaction.AbstractCompactionStrategy);
descriptor: (Lorg/apache/cassandra/db/compaction/AbstractCompactionStrategy;)Ljava/util/List;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=8, args_size=2
start local 0 start local 1 0: aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.readLock:Ljava/util/concurrent/locks/ReentrantReadWriteLock$ReadLock;
invokevirtual java.util.concurrent.locks.ReentrantReadWriteLock$ReadLock.lock:()V
1: aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.currentBoundaries:Lorg/apache/cassandra/db/DiskBoundaries;
getfield org.apache.cassandra.db.DiskBoundaries.directories:Ljava/util/List;
astore 2
start local 2 2: aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.partitionSSTablesByTokenRange:Z
ifeq 13
3: aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.unrepaired:Ljava/util/List;
aload 1
invokeinterface java.util.List.indexOf:(Ljava/lang/Object;)I
istore 3
start local 3 4: iload 3
ifle 8
5: aload 2
iload 3
invokeinterface java.util.List.get:(I)Ljava/lang/Object;
checkcast org.apache.cassandra.db.Directories$DataDirectory
getfield org.apache.cassandra.db.Directories$DataDirectory.location:Ljava/io/File;
invokevirtual java.io.File.getAbsolutePath:()Ljava/lang/String;
invokestatic java.util.Collections.singletonList:(Ljava/lang/Object;)Ljava/util/List;
astore 7
6: aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.readLock:Ljava/util/concurrent/locks/ReentrantReadWriteLock$ReadLock;
invokevirtual java.util.concurrent.locks.ReentrantReadWriteLock$ReadLock.unlock:()V
7: aload 7
areturn
8: StackMap locals: java.util.List int
StackMap stack:
aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.repaired:Ljava/util/List;
aload 1
invokeinterface java.util.List.indexOf:(Ljava/lang/Object;)I
istore 4
start local 4 9: iload 4
ifle 13
10: aload 2
iload 4
invokeinterface java.util.List.get:(I)Ljava/lang/Object;
checkcast org.apache.cassandra.db.Directories$DataDirectory
getfield org.apache.cassandra.db.Directories$DataDirectory.location:Ljava/io/File;
invokevirtual java.io.File.getAbsolutePath:()Ljava/lang/String;
invokestatic java.util.Collections.singletonList:(Ljava/lang/Object;)Ljava/util/List;
astore 7
11: aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.readLock:Ljava/util/concurrent/locks/ReentrantReadWriteLock$ReadLock;
invokevirtual java.util.concurrent.locks.ReentrantReadWriteLock$ReadLock.unlock:()V
12: aload 7
areturn
end local 4 end local 3 13: StackMap locals:
StackMap stack:
new java.util.ArrayList
dup
aload 2
invokeinterface java.util.List.size:()I
invokespecial java.util.ArrayList.<init>:(I)V
astore 3
start local 3 14: aload 2
invokeinterface java.util.List.iterator:()Ljava/util/Iterator;
astore 5
goto 17
StackMap locals: org.apache.cassandra.db.compaction.CompactionStrategyManager org.apache.cassandra.db.compaction.AbstractCompactionStrategy java.util.List java.util.List top java.util.Iterator
StackMap stack:
15: aload 5
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.db.Directories$DataDirectory
astore 4
start local 4 16: aload 3
aload 4
getfield org.apache.cassandra.db.Directories$DataDirectory.location:Ljava/io/File;
invokevirtual java.io.File.getAbsolutePath:()Ljava/lang/String;
invokeinterface java.util.List.add:(Ljava/lang/Object;)Z
pop
end local 4 17: StackMap locals:
StackMap stack:
aload 5
invokeinterface java.util.Iterator.hasNext:()Z
ifne 15
18: aload 3
astore 7
19: aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.readLock:Ljava/util/concurrent/locks/ReentrantReadWriteLock$ReadLock;
invokevirtual java.util.concurrent.locks.ReentrantReadWriteLock$ReadLock.unlock:()V
20: aload 7
areturn
end local 3 end local 2 21: StackMap locals: org.apache.cassandra.db.compaction.CompactionStrategyManager org.apache.cassandra.db.compaction.AbstractCompactionStrategy
StackMap stack: java.lang.Throwable
astore 6
22: aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.readLock:Ljava/util/concurrent/locks/ReentrantReadWriteLock$ReadLock;
invokevirtual java.util.concurrent.locks.ReentrantReadWriteLock$ReadLock.unlock:()V
23: aload 6
athrow
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 24 0 this Lorg/apache/cassandra/db/compaction/CompactionStrategyManager;
0 24 1 strategy Lorg/apache/cassandra/db/compaction/AbstractCompactionStrategy;
2 21 2 locations Ljava/util/List<Lorg/apache/cassandra/db/Directories$DataDirectory;>;
4 13 3 unrepairedIndex I
9 13 4 repairedIndex I
14 21 3 folders Ljava/util/List<Ljava/lang/String;>;
16 17 4 location Lorg/apache/cassandra/db/Directories$DataDirectory;
Exception table:
from to target type
1 6 21 any
8 11 21 any
13 19 21 any
Signature: (Lorg/apache/cassandra/db/compaction/AbstractCompactionStrategy;)Ljava/util/List<Ljava/lang/String;>;
MethodParameters:
Name Flags
strategy
public boolean supportsEarlyOpen();
descriptor: ()Z
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.db.compaction.CompactionStrategyManager.supportsEarlyOpen:Z
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/db/compaction/CompactionStrategyManager;
private static int lambda$1(org.apache.cassandra.db.compaction.AbstractCompactionStrategy, org.apache.cassandra.db.compaction.AbstractCompactionStrategy);
descriptor: (Lorg/apache/cassandra/db/compaction/AbstractCompactionStrategy;Lorg/apache/cassandra/db/compaction/AbstractCompactionStrategy;)I
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 1
invokevirtual org.apache.cassandra.db.compaction.AbstractCompactionStrategy.getEstimatedRemainingTasks:()I
aload 0
invokevirtual org.apache.cassandra.db.compaction.AbstractCompactionStrategy.getEstimatedRemainingTasks:()I
invokestatic com.google.common.primitives.Ints.compare:(II)I
ireturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 o1 Lorg/apache/cassandra/db/compaction/AbstractCompactionStrategy;
0 1 1 o2 Lorg/apache/cassandra/db/compaction/AbstractCompactionStrategy;
private static boolean lambda$6(org.apache.cassandra.db.compaction.AbstractCompactionStrategy);
descriptor: (Lorg/apache/cassandra/db/compaction/AbstractCompactionStrategy;)Z
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.db.compaction.AbstractCompactionStrategy.logAll:Z
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 cs Lorg/apache/cassandra/db/compaction/AbstractCompactionStrategy;
private java.lang.Integer lambda$13(org.apache.cassandra.io.sstable.format.SSTableReader);
descriptor: (Lorg/apache/cassandra/io/sstable/format/SSTableReader;)Ljava/lang/Integer;
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
invokevirtual org.apache.cassandra.db.compaction.CompactionStrategyManager.compactionStrategyIndexFor:(Lorg/apache/cassandra/io/sstable/format/SSTableReader;)I
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/db/compaction/CompactionStrategyManager;
0 1 1 s Lorg/apache/cassandra/io/sstable/format/SSTableReader;
private static boolean lambda$14(org.apache.cassandra.io.sstable.format.SSTableReader);
descriptor: (Lorg/apache/cassandra/io/sstable/format/SSTableReader;)Z
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
invokevirtual org.apache.cassandra.io.sstable.format.SSTableReader.isMarkedSuspect:()Z
ifne 1
aload 0
invokevirtual org.apache.cassandra.io.sstable.format.SSTableReader.isRepaired:()Z
ifeq 1
iconst_1
goto 2
StackMap locals:
StackMap stack:
1: iconst_0
StackMap locals:
StackMap stack: int
2: ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 s Lorg/apache/cassandra/io/sstable/format/SSTableReader;
private java.lang.Integer lambda$15(org.apache.cassandra.io.sstable.format.SSTableReader);
descriptor: (Lorg/apache/cassandra/io/sstable/format/SSTableReader;)Ljava/lang/Integer;
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
invokevirtual org.apache.cassandra.db.compaction.CompactionStrategyManager.compactionStrategyIndexFor:(Lorg/apache/cassandra/io/sstable/format/SSTableReader;)I
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/db/compaction/CompactionStrategyManager;
0 1 1 s Lorg/apache/cassandra/io/sstable/format/SSTableReader;
private static boolean lambda$16(org.apache.cassandra.io.sstable.format.SSTableReader);
descriptor: (Lorg/apache/cassandra/io/sstable/format/SSTableReader;)Z
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
invokevirtual org.apache.cassandra.io.sstable.format.SSTableReader.isMarkedSuspect:()Z
ifne 1
aload 0
invokevirtual org.apache.cassandra.io.sstable.format.SSTableReader.isRepaired:()Z
ifne 1
iconst_1
goto 2
StackMap locals:
StackMap stack:
1: iconst_0
StackMap locals:
StackMap stack: int
2: ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 s Lorg/apache/cassandra/io/sstable/format/SSTableReader;
private java.lang.Integer lambda$17(org.apache.cassandra.io.sstable.format.SSTableReader);
descriptor: (Lorg/apache/cassandra/io/sstable/format/SSTableReader;)Ljava/lang/Integer;
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
invokevirtual org.apache.cassandra.db.compaction.CompactionStrategyManager.compactionStrategyIndexFor:(Lorg/apache/cassandra/io/sstable/format/SSTableReader;)I
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/db/compaction/CompactionStrategyManager;
0 1 1 s Lorg/apache/cassandra/io/sstable/format/SSTableReader;
}
SourceFile: "CompactionStrategyManager.java"
NestMembers:
org.apache.cassandra.db.compaction.CompactionStrategyManager$1
InnerClasses:
public final Lookup = java.lang.invoke.MethodHandles$Lookup of java.lang.invoke.MethodHandles
public abstract Entry = java.util.Map$Entry of java.util.Map
public ReadLock = java.util.concurrent.locks.ReentrantReadWriteLock$ReadLock of java.util.concurrent.locks.ReentrantReadWriteLock
public WriteLock = java.util.concurrent.locks.ReentrantReadWriteLock$WriteLock of java.util.concurrent.locks.ReentrantReadWriteLock
public DataDirectory = org.apache.cassandra.db.Directories$DataDirectory of org.apache.cassandra.db.Directories
public ScannerList = org.apache.cassandra.db.compaction.AbstractCompactionStrategy$ScannerList of org.apache.cassandra.db.compaction.AbstractCompactionStrategy
org.apache.cassandra.db.compaction.CompactionStrategyManager$1
public final OpenReason = org.apache.cassandra.io.sstable.format.SSTableReader$OpenReason of org.apache.cassandra.io.sstable.format.SSTableReader
CompactionStrategyManager
logger: Logger
$assertionsDisabled: boolean
getCompactionStrategyFor(SSTableReader): AbstractCompactionStrategy