public class org.apache.cassandra.db.lifecycle.Tracker
minor version: 0
major version: 59
flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
this_class: org.apache.cassandra.db.lifecycle.Tracker
super_class: java.lang.Object
{
private static final org.slf4j.Logger logger;
descriptor: Lorg/slf4j/Logger;
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
private final java.util.Collection<org.apache.cassandra.notifications.INotificationConsumer> subscribers;
descriptor: Ljava/util/Collection;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Ljava/util/Collection<Lorg/apache/cassandra/notifications/INotificationConsumer;>;
public final org.apache.cassandra.db.ColumnFamilyStore cfstore;
descriptor: Lorg/apache/cassandra/db/ColumnFamilyStore;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
final java.util.concurrent.atomic.AtomicReference<org.apache.cassandra.db.lifecycle.View> view;
descriptor: Ljava/util/concurrent/atomic/AtomicReference;
flags: (0x0010) ACC_FINAL
Signature: Ljava/util/concurrent/atomic/AtomicReference<Lorg/apache/cassandra/db/lifecycle/View;>;
public final boolean loadsstables;
descriptor: Z
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
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/lifecycle/Tracker;
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.lifecycle.Tracker.$assertionsDisabled:Z
3: ldc Lorg/apache/cassandra/db/lifecycle/Tracker;
invokestatic org.slf4j.LoggerFactory.getLogger:(Ljava/lang/Class;)Lorg/slf4j/Logger;
putstatic org.apache.cassandra.db.lifecycle.Tracker.logger:Lorg/slf4j/Logger;
return
LocalVariableTable:
Start End Slot Name Signature
public void <init>(org.apache.cassandra.db.Memtable, boolean);
descriptor: (Lorg/apache/cassandra/db/Memtable;Z)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
invokespecial java.lang.Object.<init>:()V
1: aload 0
new java.util.concurrent.CopyOnWriteArrayList
dup
invokespecial java.util.concurrent.CopyOnWriteArrayList.<init>:()V
putfield org.apache.cassandra.db.lifecycle.Tracker.subscribers:Ljava/util/Collection;
2: aload 0
aload 1
ifnull 3
aload 1
getfield org.apache.cassandra.db.Memtable.cfs:Lorg/apache/cassandra/db/ColumnFamilyStore;
goto 4
StackMap locals: org.apache.cassandra.db.lifecycle.Tracker org.apache.cassandra.db.Memtable int
StackMap stack: org.apache.cassandra.db.lifecycle.Tracker
3: aconst_null
StackMap locals: org.apache.cassandra.db.lifecycle.Tracker org.apache.cassandra.db.Memtable int
StackMap stack: org.apache.cassandra.db.lifecycle.Tracker org.apache.cassandra.db.ColumnFamilyStore
4: putfield org.apache.cassandra.db.lifecycle.Tracker.cfstore:Lorg/apache/cassandra/db/ColumnFamilyStore;
5: aload 0
new java.util.concurrent.atomic.AtomicReference
dup
invokespecial java.util.concurrent.atomic.AtomicReference.<init>:()V
putfield org.apache.cassandra.db.lifecycle.Tracker.view:Ljava/util/concurrent/atomic/AtomicReference;
6: aload 0
iload 2
putfield org.apache.cassandra.db.lifecycle.Tracker.loadsstables:Z
7: aload 0
aload 1
invokevirtual org.apache.cassandra.db.lifecycle.Tracker.reset:(Lorg/apache/cassandra/db/Memtable;)V
8: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 9 0 this Lorg/apache/cassandra/db/lifecycle/Tracker;
0 9 1 memtable Lorg/apache/cassandra/db/Memtable;
0 9 2 loadsstables Z
MethodParameters:
Name Flags
memtable
loadsstables
public org.apache.cassandra.db.lifecycle.LifecycleTransaction tryModify(org.apache.cassandra.io.sstable.format.SSTableReader, org.apache.cassandra.db.compaction.OperationType);
descriptor: (Lorg/apache/cassandra/io/sstable/format/SSTableReader;Lorg/apache/cassandra/db/compaction/OperationType;)Lorg/apache/cassandra/db/lifecycle/LifecycleTransaction;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
aload 1
invokestatic java.util.Collections.singleton:(Ljava/lang/Object;)Ljava/util/Set;
aload 2
invokevirtual org.apache.cassandra.db.lifecycle.Tracker.tryModify:(Ljava/lang/Iterable;Lorg/apache/cassandra/db/compaction/OperationType;)Lorg/apache/cassandra/db/lifecycle/LifecycleTransaction;
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/db/lifecycle/Tracker;
0 1 1 sstable Lorg/apache/cassandra/io/sstable/format/SSTableReader;
0 1 2 operationType Lorg/apache/cassandra/db/compaction/OperationType;
MethodParameters:
Name Flags
sstable
operationType
public org.apache.cassandra.db.lifecycle.LifecycleTransaction tryModify(java.lang.Iterable<org.apache.cassandra.io.sstable.format.SSTableReader>, org.apache.cassandra.db.compaction.OperationType);
descriptor: (Ljava/lang/Iterable;Lorg/apache/cassandra/db/compaction/OperationType;)Lorg/apache/cassandra/db/lifecycle/LifecycleTransaction;
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 1
invokestatic com.google.common.collect.Iterables.isEmpty:(Ljava/lang/Iterable;)Z
ifeq 2
1: new org.apache.cassandra.db.lifecycle.LifecycleTransaction
dup
aload 0
aload 2
aload 1
invokespecial org.apache.cassandra.db.lifecycle.LifecycleTransaction.<init>:(Lorg/apache/cassandra/db/lifecycle/Tracker;Lorg/apache/cassandra/db/compaction/OperationType;Ljava/lang/Iterable;)V
areturn
2: StackMap locals:
StackMap stack:
aload 0
aload 1
invokestatic org.apache.cassandra.db.lifecycle.View.permitCompacting:(Ljava/lang/Iterable;)Lcom/google/common/base/Predicate;
invokestatic org.apache.cassandra.db.lifecycle.Tracker.emptySet:()Ljava/util/Set;
aload 1
invokestatic org.apache.cassandra.db.lifecycle.View.updateCompacting:(Ljava/util/Set;Ljava/lang/Iterable;)Lcom/google/common/base/Function;
invokevirtual org.apache.cassandra.db.lifecycle.Tracker.apply:(Lcom/google/common/base/Predicate;Lcom/google/common/base/Function;)Lorg/apache/cassandra/utils/Pair;
ifnonnull 4
3: aconst_null
areturn
4: StackMap locals:
StackMap stack:
new org.apache.cassandra.db.lifecycle.LifecycleTransaction
dup
aload 0
aload 2
aload 1
invokespecial org.apache.cassandra.db.lifecycle.LifecycleTransaction.<init>:(Lorg/apache/cassandra/db/lifecycle/Tracker;Lorg/apache/cassandra/db/compaction/OperationType;Ljava/lang/Iterable;)V
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lorg/apache/cassandra/db/lifecycle/Tracker;
0 5 1 sstables Ljava/lang/Iterable<Lorg/apache/cassandra/io/sstable/format/SSTableReader;>;
0 5 2 operationType Lorg/apache/cassandra/db/compaction/OperationType;
Signature: (Ljava/lang/Iterable<Lorg/apache/cassandra/io/sstable/format/SSTableReader;>;Lorg/apache/cassandra/db/compaction/OperationType;)Lorg/apache/cassandra/db/lifecycle/LifecycleTransaction;
MethodParameters:
Name Flags
sstables
operationType
org.apache.cassandra.utils.Pair<org.apache.cassandra.db.lifecycle.View, org.apache.cassandra.db.lifecycle.View> apply(com.google.common.base.Function<org.apache.cassandra.db.lifecycle.View, org.apache.cassandra.db.lifecycle.View>);
descriptor: (Lcom/google/common/base/Function;)Lorg/apache/cassandra/utils/Pair;
flags: (0x0000)
Code:
stack=3, locals=2, args_size=2
start local 0 start local 1 0: aload 0
invokestatic com.google.common.base.Predicates.alwaysTrue:()Lcom/google/common/base/Predicate;
aload 1
invokevirtual org.apache.cassandra.db.lifecycle.Tracker.apply:(Lcom/google/common/base/Predicate;Lcom/google/common/base/Function;)Lorg/apache/cassandra/utils/Pair;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/db/lifecycle/Tracker;
0 1 1 function Lcom/google/common/base/Function<Lorg/apache/cassandra/db/lifecycle/View;Lorg/apache/cassandra/db/lifecycle/View;>;
Signature: (Lcom/google/common/base/Function<Lorg/apache/cassandra/db/lifecycle/View;Lorg/apache/cassandra/db/lifecycle/View;>;)Lorg/apache/cassandra/utils/Pair<Lorg/apache/cassandra/db/lifecycle/View;Lorg/apache/cassandra/db/lifecycle/View;>;
MethodParameters:
Name Flags
function
java.lang.Throwable apply(com.google.common.base.Function<org.apache.cassandra.db.lifecycle.View, org.apache.cassandra.db.lifecycle.View>, java.lang.Throwable);
descriptor: (Lcom/google/common/base/Function;Ljava/lang/Throwable;)Ljava/lang/Throwable;
flags: (0x0000)
Code:
stack=2, locals=4, args_size=3
start local 0 start local 1 start local 2 0: aload 0
aload 1
invokevirtual org.apache.cassandra.db.lifecycle.Tracker.apply:(Lcom/google/common/base/Function;)Lorg/apache/cassandra/utils/Pair;
pop
1: goto 4
2: StackMap locals:
StackMap stack: java.lang.Throwable
astore 3
start local 3 3: aload 2
aload 3
invokestatic org.apache.cassandra.utils.Throwables.merge:(Ljava/lang/Throwable;Ljava/lang/Throwable;)Ljava/lang/Throwable;
astore 2
end local 3 4: StackMap locals:
StackMap stack:
aload 2
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lorg/apache/cassandra/db/lifecycle/Tracker;
0 5 1 function Lcom/google/common/base/Function<Lorg/apache/cassandra/db/lifecycle/View;Lorg/apache/cassandra/db/lifecycle/View;>;
0 5 2 accumulate Ljava/lang/Throwable;
3 4 3 t Ljava/lang/Throwable;
Exception table:
from to target type
0 1 2 Class java.lang.Throwable
Signature: (Lcom/google/common/base/Function<Lorg/apache/cassandra/db/lifecycle/View;Lorg/apache/cassandra/db/lifecycle/View;>;Ljava/lang/Throwable;)Ljava/lang/Throwable;
MethodParameters:
Name Flags
function
accumulate
org.apache.cassandra.utils.Pair<org.apache.cassandra.db.lifecycle.View, org.apache.cassandra.db.lifecycle.View> apply(com.google.common.base.Predicate<org.apache.cassandra.db.lifecycle.View>, com.google.common.base.Function<org.apache.cassandra.db.lifecycle.View, org.apache.cassandra.db.lifecycle.View>);
descriptor: (Lcom/google/common/base/Predicate;Lcom/google/common/base/Function;)Lorg/apache/cassandra/utils/Pair;
flags: (0x0000)
Code:
stack=3, locals=5, args_size=3
start local 0 start local 1 start local 2 0: StackMap locals:
StackMap stack:
aload 0
getfield org.apache.cassandra.db.lifecycle.Tracker.view:Ljava/util/concurrent/atomic/AtomicReference;
invokevirtual java.util.concurrent.atomic.AtomicReference.get:()Ljava/lang/Object;
checkcast org.apache.cassandra.db.lifecycle.View
astore 3
start local 3 1: aload 1
aload 3
invokeinterface com.google.common.base.Predicate.apply:(Ljava/lang/Object;)Z
ifne 3
2: aconst_null
areturn
3: StackMap locals: org.apache.cassandra.db.lifecycle.View
StackMap stack:
aload 2
aload 3
invokeinterface com.google.common.base.Function.apply:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast org.apache.cassandra.db.lifecycle.View
astore 4
start local 4 4: aload 0
getfield org.apache.cassandra.db.lifecycle.Tracker.view:Ljava/util/concurrent/atomic/AtomicReference;
aload 3
aload 4
invokevirtual java.util.concurrent.atomic.AtomicReference.compareAndSet:(Ljava/lang/Object;Ljava/lang/Object;)Z
ifeq 0
5: aload 3
aload 4
invokestatic org.apache.cassandra.utils.Pair.create:(Ljava/lang/Object;Ljava/lang/Object;)Lorg/apache/cassandra/utils/Pair;
areturn
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 this Lorg/apache/cassandra/db/lifecycle/Tracker;
0 6 1 permit Lcom/google/common/base/Predicate<Lorg/apache/cassandra/db/lifecycle/View;>;
0 6 2 function Lcom/google/common/base/Function<Lorg/apache/cassandra/db/lifecycle/View;Lorg/apache/cassandra/db/lifecycle/View;>;
1 6 3 cur Lorg/apache/cassandra/db/lifecycle/View;
4 6 4 updated Lorg/apache/cassandra/db/lifecycle/View;
Signature: (Lcom/google/common/base/Predicate<Lorg/apache/cassandra/db/lifecycle/View;>;Lcom/google/common/base/Function<Lorg/apache/cassandra/db/lifecycle/View;Lorg/apache/cassandra/db/lifecycle/View;>;)Lorg/apache/cassandra/utils/Pair<Lorg/apache/cassandra/db/lifecycle/View;Lorg/apache/cassandra/db/lifecycle/View;>;
MethodParameters:
Name Flags
permit
function
java.lang.Throwable updateSizeTracking(java.lang.Iterable<org.apache.cassandra.io.sstable.format.SSTableReader>, java.lang.Iterable<org.apache.cassandra.io.sstable.format.SSTableReader>, java.lang.Throwable);
descriptor: (Ljava/lang/Iterable;Ljava/lang/Iterable;Ljava/lang/Throwable;)Ljava/lang/Throwable;
flags: (0x0000)
Code:
stack=6, 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.lifecycle.Tracker.isDummy:()Z
ifeq 2
1: aload 3
areturn
2: StackMap locals:
StackMap stack:
lconst_0
lstore 4
start local 4 3: aload 2
invokeinterface java.lang.Iterable.iterator:()Ljava/util/Iterator;
astore 7
goto 11
StackMap locals: org.apache.cassandra.db.lifecycle.Tracker java.lang.Iterable java.lang.Iterable java.lang.Throwable long top java.util.Iterator
StackMap stack:
4: aload 7
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.io.sstable.format.SSTableReader
astore 6
start local 6 5: getstatic org.apache.cassandra.db.lifecycle.Tracker.logger:Lorg/slf4j/Logger;
invokeinterface org.slf4j.Logger.isTraceEnabled:()Z
ifeq 7
6: getstatic org.apache.cassandra.db.lifecycle.Tracker.logger:Lorg/slf4j/Logger;
ldc "adding {} to list of files tracked for {}.{}"
iconst_3
anewarray java.lang.Object
dup
iconst_0
aload 6
getfield org.apache.cassandra.io.sstable.format.SSTableReader.descriptor:Lorg/apache/cassandra/io/sstable/Descriptor;
aastore
dup
iconst_1
aload 0
getfield org.apache.cassandra.db.lifecycle.Tracker.cfstore: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;
aastore
dup
iconst_2
aload 0
getfield org.apache.cassandra.db.lifecycle.Tracker.cfstore:Lorg/apache/cassandra/db/ColumnFamilyStore;
getfield org.apache.cassandra.db.ColumnFamilyStore.name:Ljava/lang/String;
aastore
invokeinterface org.slf4j.Logger.trace:(Ljava/lang/String;[Ljava/lang/Object;)V
7: StackMap locals: org.apache.cassandra.db.lifecycle.Tracker java.lang.Iterable java.lang.Iterable java.lang.Throwable long org.apache.cassandra.io.sstable.format.SSTableReader java.util.Iterator
StackMap stack:
lload 4
aload 6
invokevirtual org.apache.cassandra.io.sstable.format.SSTableReader.bytesOnDisk:()J
ladd
lstore 4
8: goto 11
9: StackMap locals:
StackMap stack: java.lang.Throwable
astore 8
start local 8 10: aload 3
aload 8
invokestatic org.apache.cassandra.utils.Throwables.merge:(Ljava/lang/Throwable;Ljava/lang/Throwable;)Ljava/lang/Throwable;
astore 3
end local 8 end local 6 11: StackMap locals: org.apache.cassandra.db.lifecycle.Tracker java.lang.Iterable java.lang.Iterable java.lang.Throwable long top java.util.Iterator
StackMap stack:
aload 7
invokeinterface java.util.Iterator.hasNext:()Z
ifne 4
12: lconst_0
lstore 6
start local 6 13: aload 1
invokeinterface java.lang.Iterable.iterator:()Ljava/util/Iterator;
astore 9
goto 21
StackMap locals: org.apache.cassandra.db.lifecycle.Tracker java.lang.Iterable java.lang.Iterable java.lang.Throwable long long top java.util.Iterator
StackMap stack:
14: aload 9
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.io.sstable.format.SSTableReader
astore 8
start local 8 15: getstatic org.apache.cassandra.db.lifecycle.Tracker.logger:Lorg/slf4j/Logger;
invokeinterface org.slf4j.Logger.isTraceEnabled:()Z
ifeq 17
16: getstatic org.apache.cassandra.db.lifecycle.Tracker.logger:Lorg/slf4j/Logger;
ldc "removing {} from list of files tracked for {}.{}"
iconst_3
anewarray java.lang.Object
dup
iconst_0
aload 8
getfield org.apache.cassandra.io.sstable.format.SSTableReader.descriptor:Lorg/apache/cassandra/io/sstable/Descriptor;
aastore
dup
iconst_1
aload 0
getfield org.apache.cassandra.db.lifecycle.Tracker.cfstore: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;
aastore
dup
iconst_2
aload 0
getfield org.apache.cassandra.db.lifecycle.Tracker.cfstore:Lorg/apache/cassandra/db/ColumnFamilyStore;
getfield org.apache.cassandra.db.ColumnFamilyStore.name:Ljava/lang/String;
aastore
invokeinterface org.slf4j.Logger.trace:(Ljava/lang/String;[Ljava/lang/Object;)V
17: StackMap locals: org.apache.cassandra.db.lifecycle.Tracker java.lang.Iterable java.lang.Iterable java.lang.Throwable long long org.apache.cassandra.io.sstable.format.SSTableReader java.util.Iterator
StackMap stack:
lload 6
aload 8
invokevirtual org.apache.cassandra.io.sstable.format.SSTableReader.bytesOnDisk:()J
ladd
lstore 6
18: goto 21
19: StackMap locals:
StackMap stack: java.lang.Throwable
astore 10
start local 10 20: aload 3
aload 10
invokestatic org.apache.cassandra.utils.Throwables.merge:(Ljava/lang/Throwable;Ljava/lang/Throwable;)Ljava/lang/Throwable;
astore 3
end local 10 end local 8 21: StackMap locals: org.apache.cassandra.db.lifecycle.Tracker java.lang.Iterable java.lang.Iterable java.lang.Throwable long long top java.util.Iterator
StackMap stack:
aload 9
invokeinterface java.util.Iterator.hasNext:()Z
ifne 14
22: getstatic org.apache.cassandra.metrics.StorageMetrics.load:Lcom/codahale/metrics/Counter;
lload 4
lload 6
lsub
invokevirtual com.codahale.metrics.Counter.inc:(J)V
23: aload 0
getfield org.apache.cassandra.db.lifecycle.Tracker.cfstore:Lorg/apache/cassandra/db/ColumnFamilyStore;
getfield org.apache.cassandra.db.ColumnFamilyStore.metric:Lorg/apache/cassandra/metrics/TableMetrics;
getfield org.apache.cassandra.metrics.TableMetrics.liveDiskSpaceUsed:Lcom/codahale/metrics/Counter;
lload 4
lload 6
lsub
invokevirtual com.codahale.metrics.Counter.inc:(J)V
24: aload 0
getfield org.apache.cassandra.db.lifecycle.Tracker.cfstore:Lorg/apache/cassandra/db/ColumnFamilyStore;
getfield org.apache.cassandra.db.ColumnFamilyStore.metric:Lorg/apache/cassandra/metrics/TableMetrics;
getfield org.apache.cassandra.metrics.TableMetrics.totalDiskSpaceUsed:Lcom/codahale/metrics/Counter;
lload 4
invokevirtual com.codahale.metrics.Counter.inc:(J)V
25: aload 3
areturn
end local 6 end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 26 0 this Lorg/apache/cassandra/db/lifecycle/Tracker;
0 26 1 oldSSTables Ljava/lang/Iterable<Lorg/apache/cassandra/io/sstable/format/SSTableReader;>;
0 26 2 newSSTables Ljava/lang/Iterable<Lorg/apache/cassandra/io/sstable/format/SSTableReader;>;
0 26 3 accumulate Ljava/lang/Throwable;
3 26 4 add J
5 11 6 sstable Lorg/apache/cassandra/io/sstable/format/SSTableReader;
10 11 8 t Ljava/lang/Throwable;
13 26 6 subtract J
15 21 8 sstable Lorg/apache/cassandra/io/sstable/format/SSTableReader;
20 21 10 t Ljava/lang/Throwable;
Exception table:
from to target type
7 8 9 Class java.lang.Throwable
17 18 19 Class java.lang.Throwable
Signature: (Ljava/lang/Iterable<Lorg/apache/cassandra/io/sstable/format/SSTableReader;>;Ljava/lang/Iterable<Lorg/apache/cassandra/io/sstable/format/SSTableReader;>;Ljava/lang/Throwable;)Ljava/lang/Throwable;
MethodParameters:
Name Flags
oldSSTables
newSSTables
accumulate
public void addInitialSSTables(java.lang.Iterable<org.apache.cassandra.io.sstable.format.SSTableReader>);
descriptor: (Ljava/lang/Iterable;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=2, args_size=2
start local 0 start local 1 0: aload 0
invokevirtual org.apache.cassandra.db.lifecycle.Tracker.isDummy:()Z
ifne 2
1: aload 1
invokestatic org.apache.cassandra.db.lifecycle.Helpers.setupOnline:(Ljava/lang/Iterable;)V
2: StackMap locals:
StackMap stack:
aload 0
invokestatic org.apache.cassandra.db.lifecycle.Tracker.emptySet:()Ljava/util/Set;
aload 1
invokestatic org.apache.cassandra.db.lifecycle.View.updateLiveSet:(Ljava/util/Set;Ljava/lang/Iterable;)Lcom/google/common/base/Function;
invokevirtual org.apache.cassandra.db.lifecycle.Tracker.apply:(Lcom/google/common/base/Function;)Lorg/apache/cassandra/utils/Pair;
pop
3: aload 0
invokestatic org.apache.cassandra.db.lifecycle.Tracker.emptySet:()Ljava/util/Set;
aload 1
aconst_null
invokevirtual org.apache.cassandra.db.lifecycle.Tracker.updateSizeTracking:(Ljava/lang/Iterable;Ljava/lang/Iterable;Ljava/lang/Throwable;)Ljava/lang/Throwable;
invokestatic org.apache.cassandra.utils.Throwables.maybeFail:(Ljava/lang/Throwable;)V
4: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lorg/apache/cassandra/db/lifecycle/Tracker;
0 5 1 sstables Ljava/lang/Iterable<Lorg/apache/cassandra/io/sstable/format/SSTableReader;>;
Signature: (Ljava/lang/Iterable<Lorg/apache/cassandra/io/sstable/format/SSTableReader;>;)V
MethodParameters:
Name Flags
sstables
public void addSSTables(java.lang.Iterable<org.apache.cassandra.io.sstable.format.SSTableReader>);
descriptor: (Ljava/lang/Iterable;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
invokevirtual org.apache.cassandra.db.lifecycle.Tracker.addInitialSSTables:(Ljava/lang/Iterable;)V
1: aload 0
aload 1
invokevirtual org.apache.cassandra.db.lifecycle.Tracker.maybeIncrementallyBackup:(Ljava/lang/Iterable;)V
2: aload 0
aload 1
invokevirtual org.apache.cassandra.db.lifecycle.Tracker.notifyAdded:(Ljava/lang/Iterable;)V
3: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lorg/apache/cassandra/db/lifecycle/Tracker;
0 4 1 sstables Ljava/lang/Iterable<Lorg/apache/cassandra/io/sstable/format/SSTableReader;>;
Signature: (Ljava/lang/Iterable<Lorg/apache/cassandra/io/sstable/format/SSTableReader;>;)V
MethodParameters:
Name Flags
sstables
public void reset(org.apache.cassandra.db.Memtable);
descriptor: (Lorg/apache/cassandra/db/Memtable;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=8, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield org.apache.cassandra.db.lifecycle.Tracker.view:Ljava/util/concurrent/atomic/AtomicReference;
1: new org.apache.cassandra.db.lifecycle.View
dup
aload 1
ifnull 2
aload 1
invokestatic java.util.Collections.singletonList:(Ljava/lang/Object;)Ljava/util/List;
goto 3
StackMap locals: org.apache.cassandra.db.lifecycle.Tracker org.apache.cassandra.db.Memtable
StackMap stack: java.util.concurrent.atomic.AtomicReference new 1 new 1
2: invokestatic java.util.Collections.emptyList:()Ljava/util/List;
3: StackMap locals: org.apache.cassandra.db.lifecycle.Tracker org.apache.cassandra.db.Memtable
StackMap stack: java.util.concurrent.atomic.AtomicReference new 1 new 1 java.util.List
invokestatic java.util.Collections.emptyList:()Ljava/util/List;
4: invokestatic java.util.Collections.emptyMap:()Ljava/util/Map;
5: invokestatic java.util.Collections.emptyMap:()Ljava/util/Map;
6: invokestatic org.apache.cassandra.db.lifecycle.SSTableIntervalTree.empty:()Lorg/apache/cassandra/db/lifecycle/SSTableIntervalTree;
invokespecial org.apache.cassandra.db.lifecycle.View.<init>:(Ljava/util/List;Ljava/util/List;Ljava/util/Map;Ljava/util/Map;Lorg/apache/cassandra/db/lifecycle/SSTableIntervalTree;)V
7: invokevirtual java.util.concurrent.atomic.AtomicReference.set:(Ljava/lang/Object;)V
8: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 9 0 this Lorg/apache/cassandra/db/lifecycle/Tracker;
0 9 1 memtable Lorg/apache/cassandra/db/Memtable;
RuntimeInvisibleAnnotations:
com.google.common.annotations.VisibleForTesting()
MethodParameters:
Name Flags
memtable
public java.lang.Throwable dropSSTablesIfInvalid(java.lang.Throwable);
descriptor: (Ljava/lang/Throwable;)Ljava/lang/Throwable;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
invokevirtual org.apache.cassandra.db.lifecycle.Tracker.isDummy:()Z
ifne 2
aload 0
getfield org.apache.cassandra.db.lifecycle.Tracker.cfstore:Lorg/apache/cassandra/db/ColumnFamilyStore;
invokevirtual org.apache.cassandra.db.ColumnFamilyStore.isValid:()Z
ifne 2
1: aload 0
aload 1
invokevirtual org.apache.cassandra.db.lifecycle.Tracker.dropSSTables:(Ljava/lang/Throwable;)Ljava/lang/Throwable;
astore 1
2: StackMap locals:
StackMap stack:
aload 1
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lorg/apache/cassandra/db/lifecycle/Tracker;
0 3 1 accumulate Ljava/lang/Throwable;
MethodParameters:
Name Flags
accumulate
public void dropSSTables();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
aconst_null
invokevirtual org.apache.cassandra.db.lifecycle.Tracker.dropSSTables:(Ljava/lang/Throwable;)Ljava/lang/Throwable;
invokestatic org.apache.cassandra.utils.Throwables.maybeFail:(Ljava/lang/Throwable;)V
1: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/apache/cassandra/db/lifecycle/Tracker;
public java.lang.Throwable dropSSTables(java.lang.Throwable);
descriptor: (Ljava/lang/Throwable;)Ljava/lang/Throwable;
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=2, args_size=2
start local 0 start local 1 0: aload 0
invokestatic com.google.common.base.Predicates.alwaysTrue:()Lcom/google/common/base/Predicate;
getstatic org.apache.cassandra.db.compaction.OperationType.UNKNOWN:Lorg/apache/cassandra/db/compaction/OperationType;
aload 1
invokevirtual org.apache.cassandra.db.lifecycle.Tracker.dropSSTables:(Lcom/google/common/base/Predicate;Lorg/apache/cassandra/db/compaction/OperationType;Ljava/lang/Throwable;)Ljava/lang/Throwable;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/db/lifecycle/Tracker;
0 1 1 accumulate Ljava/lang/Throwable;
MethodParameters:
Name Flags
accumulate
public java.lang.Throwable dropSSTables(com.google.common.base.Predicate<org.apache.cassandra.io.sstable.format.SSTableReader>, org.apache.cassandra.db.compaction.OperationType, java.lang.Throwable);
descriptor: (Lcom/google/common/base/Predicate;Lorg/apache/cassandra/db/compaction/OperationType;Ljava/lang/Throwable;)Ljava/lang/Throwable;
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=11, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aconst_null
astore 4
aconst_null
astore 5
1: new org.apache.cassandra.db.lifecycle.LogTransaction
dup
aload 2
aload 0
invokespecial org.apache.cassandra.db.lifecycle.LogTransaction.<init>:(Lorg/apache/cassandra/db/compaction/OperationType;Lorg/apache/cassandra/db/lifecycle/Tracker;)V
astore 6
start local 6 2: aload 0
aload 1
invokedynamic apply(Lcom/google/common/base/Predicate;)Lcom/google/common/base/Function;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)Ljava/lang/Object;
org/apache/cassandra/db/lifecycle/Tracker.lambda$0(Lcom/google/common/base/Predicate;Lorg/apache/cassandra/db/lifecycle/View;)Lorg/apache/cassandra/db/lifecycle/View; (6)
(Lorg/apache/cassandra/db/lifecycle/View;)Lorg/apache/cassandra/db/lifecycle/View;
invokevirtual org.apache.cassandra.db.lifecycle.Tracker.apply:(Lcom/google/common/base/Function;)Lorg/apache/cassandra/utils/Pair;
astore 7
start local 7 3: aload 7
getfield org.apache.cassandra.utils.Pair.left:Ljava/lang/Object;
checkcast org.apache.cassandra.db.lifecycle.View
getfield org.apache.cassandra.db.lifecycle.View.sstables:Ljava/util/Set;
aload 7
getfield org.apache.cassandra.utils.Pair.right:Ljava/lang/Object;
checkcast org.apache.cassandra.db.lifecycle.View
getfield org.apache.cassandra.db.lifecycle.View.sstables:Ljava/util/Set;
invokestatic com.google.common.collect.Sets.difference:(Ljava/util/Set;Ljava/util/Set;)Lcom/google/common/collect/Sets$SetView;
astore 8
start local 8 4: getstatic org.apache.cassandra.db.lifecycle.Tracker.$assertionsDisabled:Z
ifne 5
aload 8
aload 1
invokestatic com.google.common.collect.Iterables.all:(Ljava/lang/Iterable;Lcom/google/common/base/Predicate;)Z
ifne 5
new java.lang.AssertionError
dup
invokespecial java.lang.AssertionError.<init>:()V
athrow
5: StackMap locals: org.apache.cassandra.db.lifecycle.Tracker com.google.common.base.Predicate org.apache.cassandra.db.compaction.OperationType java.lang.Throwable java.lang.Throwable java.lang.Throwable org.apache.cassandra.db.lifecycle.LogTransaction org.apache.cassandra.utils.Pair java.util.Set
StackMap stack:
new java.util.ArrayList
dup
invokespecial java.util.ArrayList.<init>:()V
astore 9
start local 9 6: aload 8
aload 6
aload 9
aload 3
invokestatic org.apache.cassandra.db.lifecycle.Helpers.prepareForObsoletion:(Ljava/lang/Iterable;Lorg/apache/cassandra/db/lifecycle/LogTransaction;Ljava/util/List;Ljava/lang/Throwable;)Ljava/lang/Throwable;
astore 3
7: aload 6
invokevirtual org.apache.cassandra.db.lifecycle.LogTransaction.finish:()Ljava/lang/Object;
pop
8: aload 8
invokeinterface java.util.Set.isEmpty:()Z
ifne 17
9: aload 9
aload 3
invokestatic org.apache.cassandra.db.lifecycle.Helpers.markObsolete:(Ljava/util/List;Ljava/lang/Throwable;)Ljava/lang/Throwable;
astore 3
10: aload 0
aload 8
invokestatic org.apache.cassandra.db.lifecycle.Tracker.emptySet:()Ljava/util/Set;
aload 3
invokevirtual org.apache.cassandra.db.lifecycle.Tracker.updateSizeTracking:(Ljava/lang/Iterable;Ljava/lang/Iterable;Ljava/lang/Throwable;)Ljava/lang/Throwable;
astore 3
11: aload 8
invokestatic org.apache.cassandra.utils.concurrent.Refs.selfRefs:(Ljava/lang/Iterable;)Ljava/lang/Iterable;
aload 3
invokestatic org.apache.cassandra.utils.concurrent.Refs.release:(Ljava/lang/Iterable;Ljava/lang/Throwable;)Ljava/lang/Throwable;
astore 3
12: aload 0
aload 8
invokestatic java.util.Collections.emptySet:()Ljava/util/Set;
aload 6
invokevirtual org.apache.cassandra.db.lifecycle.LogTransaction.type:()Lorg/apache/cassandra/db/compaction/OperationType;
aload 3
invokevirtual org.apache.cassandra.db.lifecycle.Tracker.notifySSTablesChanged:(Ljava/util/Collection;Ljava/util/Collection;Lorg/apache/cassandra/db/compaction/OperationType;Ljava/lang/Throwable;)Ljava/lang/Throwable;
astore 3
13: goto 17
14: StackMap locals: org.apache.cassandra.db.lifecycle.Tracker com.google.common.base.Predicate org.apache.cassandra.db.compaction.OperationType java.lang.Throwable java.lang.Throwable java.lang.Throwable org.apache.cassandra.db.lifecycle.LogTransaction org.apache.cassandra.utils.Pair java.util.Set java.util.List
StackMap stack: java.lang.Throwable
astore 10
start local 10 15: aload 9
aload 3
invokestatic org.apache.cassandra.db.lifecycle.Helpers.abortObsoletion:(Ljava/util/List;Ljava/lang/Throwable;)Ljava/lang/Throwable;
astore 3
16: aload 3
aload 10
invokestatic org.apache.cassandra.utils.Throwables.merge:(Ljava/lang/Throwable;Ljava/lang/Throwable;)Ljava/lang/Throwable;
astore 3
end local 10 end local 9 end local 8 end local 7 17: StackMap locals:
StackMap stack:
aload 6
ifnull 25
aload 6
invokevirtual org.apache.cassandra.db.lifecycle.LogTransaction.close:()V
goto 25
StackMap locals:
StackMap stack: java.lang.Throwable
18: astore 4
aload 6
ifnull 19
aload 6
invokevirtual org.apache.cassandra.db.lifecycle.LogTransaction.close:()V
end local 6 StackMap locals:
StackMap stack:
19: aload 4
athrow
StackMap locals:
StackMap stack: java.lang.Throwable
20: astore 5
aload 4
ifnonnull 21
aload 5
astore 4
goto 22
StackMap locals:
StackMap stack:
21: aload 4
aload 5
if_acmpeq 22
aload 4
aload 5
invokevirtual java.lang.Throwable.addSuppressed:(Ljava/lang/Throwable;)V
StackMap locals:
StackMap stack:
22: aload 4
athrow
23: StackMap locals: org.apache.cassandra.db.lifecycle.Tracker com.google.common.base.Predicate org.apache.cassandra.db.compaction.OperationType java.lang.Throwable
StackMap stack: java.lang.Throwable
astore 4
start local 4 24: aload 3
aload 4
invokestatic org.apache.cassandra.utils.Throwables.merge:(Ljava/lang/Throwable;Ljava/lang/Throwable;)Ljava/lang/Throwable;
astore 3
end local 4 25: StackMap locals:
StackMap stack:
aload 3
areturn
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 26 0 this Lorg/apache/cassandra/db/lifecycle/Tracker;
0 26 1 remove Lcom/google/common/base/Predicate<Lorg/apache/cassandra/io/sstable/format/SSTableReader;>;
0 26 2 operationType Lorg/apache/cassandra/db/compaction/OperationType;
0 26 3 accumulate Ljava/lang/Throwable;
2 19 6 txnLogs Lorg/apache/cassandra/db/lifecycle/LogTransaction;
3 17 7 result Lorg/apache/cassandra/utils/Pair<Lorg/apache/cassandra/db/lifecycle/View;Lorg/apache/cassandra/db/lifecycle/View;>;
4 17 8 removed Ljava/util/Set<Lorg/apache/cassandra/io/sstable/format/SSTableReader;>;
6 17 9 obsoletions Ljava/util/List<Lorg/apache/cassandra/db/lifecycle/LogTransaction$Obsoletion;>;
15 17 10 t Ljava/lang/Throwable;
24 25 4 t Ljava/lang/Throwable;
Exception table:
from to target type
7 13 14 Class java.lang.Throwable
2 17 18 any
1 20 20 any
0 23 23 Class java.lang.Throwable
Signature: (Lcom/google/common/base/Predicate<Lorg/apache/cassandra/io/sstable/format/SSTableReader;>;Lorg/apache/cassandra/db/compaction/OperationType;Ljava/lang/Throwable;)Ljava/lang/Throwable;
MethodParameters:
Name Flags
remove final
operationType
accumulate
public void removeUnreadableSSTables(java.io.File);
descriptor: (Ljava/io/File;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=2, args_size=2
start local 0 start local 1 0: aload 0
new org.apache.cassandra.db.lifecycle.Tracker$1
dup
aload 0
aload 1
invokespecial org.apache.cassandra.db.lifecycle.Tracker$1.<init>:(Lorg/apache/cassandra/db/lifecycle/Tracker;Ljava/io/File;)V
1: getstatic org.apache.cassandra.db.compaction.OperationType.UNKNOWN:Lorg/apache/cassandra/db/compaction/OperationType;
aconst_null
2: invokevirtual org.apache.cassandra.db.lifecycle.Tracker.dropSSTables:(Lcom/google/common/base/Predicate;Lorg/apache/cassandra/db/compaction/OperationType;Ljava/lang/Throwable;)Ljava/lang/Throwable;
invokestatic org.apache.cassandra.utils.Throwables.maybeFail:(Ljava/lang/Throwable;)V
3: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lorg/apache/cassandra/db/lifecycle/Tracker;
0 4 1 directory Ljava/io/File;
MethodParameters:
Name Flags
directory final
public org.apache.cassandra.db.Memtable getMemtableFor(org.apache.cassandra.utils.concurrent.OpOrder$Group, org.apache.cassandra.db.commitlog.CommitLogPosition);
descriptor: (Lorg/apache/cassandra/utils/concurrent/OpOrder$Group;Lorg/apache/cassandra/db/commitlog/CommitLogPosition;)Lorg/apache/cassandra/db/Memtable;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=5, args_size=3
start local 0 start local 1 start local 2 0: aload 0
getfield org.apache.cassandra.db.lifecycle.Tracker.view:Ljava/util/concurrent/atomic/AtomicReference;
invokevirtual java.util.concurrent.atomic.AtomicReference.get:()Ljava/lang/Object;
checkcast org.apache.cassandra.db.lifecycle.View
getfield org.apache.cassandra.db.lifecycle.View.liveMemtables:Ljava/util/List;
invokeinterface java.util.List.iterator:()Ljava/util/Iterator;
astore 4
goto 4
StackMap locals: org.apache.cassandra.db.lifecycle.Tracker org.apache.cassandra.utils.concurrent.OpOrder$Group org.apache.cassandra.db.commitlog.CommitLogPosition top java.util.Iterator
StackMap stack:
1: aload 4
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.db.Memtable
astore 3
start local 3 2: aload 3
aload 1
aload 2
invokevirtual org.apache.cassandra.db.Memtable.accepts:(Lorg/apache/cassandra/utils/concurrent/OpOrder$Group;Lorg/apache/cassandra/db/commitlog/CommitLogPosition;)Z
ifeq 4
3: aload 3
areturn
end local 3 4: StackMap locals:
StackMap stack:
aload 4
invokeinterface java.util.Iterator.hasNext:()Z
ifne 1
5: new java.lang.AssertionError
dup
aload 0
getfield org.apache.cassandra.db.lifecycle.Tracker.view:Ljava/util/concurrent/atomic/AtomicReference;
invokevirtual java.util.concurrent.atomic.AtomicReference.get:()Ljava/lang/Object;
checkcast org.apache.cassandra.db.lifecycle.View
getfield org.apache.cassandra.db.lifecycle.View.liveMemtables:Ljava/util/List;
invokevirtual java.lang.Object.toString:()Ljava/lang/String;
invokespecial java.lang.AssertionError.<init>:(Ljava/lang/Object;)V
athrow
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 this Lorg/apache/cassandra/db/lifecycle/Tracker;
0 6 1 opGroup Lorg/apache/cassandra/utils/concurrent/OpOrder$Group;
0 6 2 commitLogPosition Lorg/apache/cassandra/db/commitlog/CommitLogPosition;
2 4 3 memtable Lorg/apache/cassandra/db/Memtable;
MethodParameters:
Name Flags
opGroup
commitLogPosition
public org.apache.cassandra.db.Memtable switchMemtable(boolean, org.apache.cassandra.db.Memtable);
descriptor: (ZLorg/apache/cassandra/db/Memtable;)Lorg/apache/cassandra/db/Memtable;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=4, args_size=3
start local 0 start local 1 start local 2 0: aload 0
aload 2
invokestatic org.apache.cassandra.db.lifecycle.View.switchMemtable:(Lorg/apache/cassandra/db/Memtable;)Lcom/google/common/base/Function;
invokevirtual org.apache.cassandra.db.lifecycle.Tracker.apply:(Lcom/google/common/base/Function;)Lorg/apache/cassandra/utils/Pair;
astore 3
start local 3 1: iload 1
ifeq 3
2: aload 0
aload 2
invokevirtual org.apache.cassandra.db.lifecycle.Tracker.notifyRenewed:(Lorg/apache/cassandra/db/Memtable;)V
goto 4
3: StackMap locals: org.apache.cassandra.utils.Pair
StackMap stack:
aload 0
aload 3
getfield org.apache.cassandra.utils.Pair.left:Ljava/lang/Object;
checkcast org.apache.cassandra.db.lifecycle.View
invokevirtual org.apache.cassandra.db.lifecycle.View.getCurrentMemtable:()Lorg/apache/cassandra/db/Memtable;
invokevirtual org.apache.cassandra.db.lifecycle.Tracker.notifySwitched:(Lorg/apache/cassandra/db/Memtable;)V
4: StackMap locals:
StackMap stack:
aload 3
getfield org.apache.cassandra.utils.Pair.left:Ljava/lang/Object;
checkcast org.apache.cassandra.db.lifecycle.View
invokevirtual org.apache.cassandra.db.lifecycle.View.getCurrentMemtable:()Lorg/apache/cassandra/db/Memtable;
areturn
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lorg/apache/cassandra/db/lifecycle/Tracker;
0 5 1 truncating Z
0 5 2 newMemtable Lorg/apache/cassandra/db/Memtable;
1 5 3 result Lorg/apache/cassandra/utils/Pair<Lorg/apache/cassandra/db/lifecycle/View;Lorg/apache/cassandra/db/lifecycle/View;>;
MethodParameters:
Name Flags
truncating
newMemtable
public void markFlushing(org.apache.cassandra.db.Memtable);
descriptor: (Lorg/apache/cassandra/db/Memtable;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
invokestatic org.apache.cassandra.db.lifecycle.View.markFlushing:(Lorg/apache/cassandra/db/Memtable;)Lcom/google/common/base/Function;
invokevirtual org.apache.cassandra.db.lifecycle.Tracker.apply:(Lcom/google/common/base/Function;)Lorg/apache/cassandra/utils/Pair;
pop
1: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/apache/cassandra/db/lifecycle/Tracker;
0 2 1 memtable Lorg/apache/cassandra/db/Memtable;
MethodParameters:
Name Flags
memtable
public void replaceFlushed(org.apache.cassandra.db.Memtable, java.lang.Iterable<org.apache.cassandra.io.sstable.format.SSTableReader>);
descriptor: (Lorg/apache/cassandra/db/Memtable;Ljava/lang/Iterable;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=4, args_size=3
start local 0 start local 1 start local 2 0: getstatic org.apache.cassandra.db.lifecycle.Tracker.$assertionsDisabled:Z
ifne 1
aload 0
invokevirtual org.apache.cassandra.db.lifecycle.Tracker.isDummy:()Z
ifeq 1
new java.lang.AssertionError
dup
invokespecial java.lang.AssertionError.<init>:()V
athrow
1: StackMap locals:
StackMap stack:
aload 2
invokestatic com.google.common.collect.Iterables.isEmpty:(Ljava/lang/Iterable;)Z
ifeq 4
2: aload 0
aload 1
aconst_null
invokestatic org.apache.cassandra.db.lifecycle.View.replaceFlushed:(Lorg/apache/cassandra/db/Memtable;Ljava/lang/Iterable;)Lcom/google/common/base/Function;
invokevirtual org.apache.cassandra.db.lifecycle.Tracker.apply:(Lcom/google/common/base/Function;)Lorg/apache/cassandra/utils/Pair;
pop
3: return
4: StackMap locals:
StackMap stack:
aload 2
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/io/sstable/format/SSTableReader.setupOnline()V (5)
(Lorg/apache/cassandra/io/sstable/format/SSTableReader;)V
invokeinterface java.lang.Iterable.forEach:(Ljava/util/function/Consumer;)V
5: aload 0
aload 2
invokevirtual org.apache.cassandra.db.lifecycle.Tracker.maybeIncrementallyBackup:(Ljava/lang/Iterable;)V
6: aload 0
aload 1
aload 2
invokestatic org.apache.cassandra.db.lifecycle.View.replaceFlushed:(Lorg/apache/cassandra/db/Memtable;Ljava/lang/Iterable;)Lcom/google/common/base/Function;
invokevirtual org.apache.cassandra.db.lifecycle.Tracker.apply:(Lcom/google/common/base/Function;)Lorg/apache/cassandra/utils/Pair;
pop
7: aload 0
invokestatic org.apache.cassandra.db.lifecycle.Tracker.emptySet:()Ljava/util/Set;
aload 2
aconst_null
invokevirtual org.apache.cassandra.db.lifecycle.Tracker.updateSizeTracking:(Ljava/lang/Iterable;Ljava/lang/Iterable;Ljava/lang/Throwable;)Ljava/lang/Throwable;
astore 3
start local 3 8: aload 0
aload 1
invokevirtual org.apache.cassandra.db.lifecycle.Tracker.notifyDiscarded:(Lorg/apache/cassandra/db/Memtable;)V
9: aload 0
aload 2
aload 3
invokevirtual org.apache.cassandra.db.lifecycle.Tracker.notifyAdded:(Ljava/lang/Iterable;Ljava/lang/Throwable;)Ljava/lang/Throwable;
astore 3
10: aload 0
invokevirtual org.apache.cassandra.db.lifecycle.Tracker.isDummy:()Z
ifne 12
aload 0
getfield org.apache.cassandra.db.lifecycle.Tracker.cfstore:Lorg/apache/cassandra/db/ColumnFamilyStore;
invokevirtual org.apache.cassandra.db.ColumnFamilyStore.isValid:()Z
ifne 12
11: aload 0
invokevirtual org.apache.cassandra.db.lifecycle.Tracker.dropSSTables:()V
12: StackMap locals: java.lang.Throwable
StackMap stack:
aload 3
invokestatic org.apache.cassandra.utils.Throwables.maybeFail:(Ljava/lang/Throwable;)V
13: return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 14 0 this Lorg/apache/cassandra/db/lifecycle/Tracker;
0 14 1 memtable Lorg/apache/cassandra/db/Memtable;
0 14 2 sstables Ljava/lang/Iterable<Lorg/apache/cassandra/io/sstable/format/SSTableReader;>;
8 14 3 fail Ljava/lang/Throwable;
Signature: (Lorg/apache/cassandra/db/Memtable;Ljava/lang/Iterable<Lorg/apache/cassandra/io/sstable/format/SSTableReader;>;)V
MethodParameters:
Name Flags
memtable
sstables
public java.util.Set<org.apache.cassandra.io.sstable.format.SSTableReader> getCompacting();
descriptor: ()Ljava/util/Set;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.db.lifecycle.Tracker.view:Ljava/util/concurrent/atomic/AtomicReference;
invokevirtual java.util.concurrent.atomic.AtomicReference.get:()Ljava/lang/Object;
checkcast org.apache.cassandra.db.lifecycle.View
getfield org.apache.cassandra.db.lifecycle.View.compacting:Ljava/util/Set;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/db/lifecycle/Tracker;
Signature: ()Ljava/util/Set<Lorg/apache/cassandra/io/sstable/format/SSTableReader;>;
public java.lang.Iterable<org.apache.cassandra.io.sstable.format.SSTableReader> getUncompacting();
descriptor: ()Ljava/lang/Iterable;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.db.lifecycle.Tracker.view:Ljava/util/concurrent/atomic/AtomicReference;
invokevirtual java.util.concurrent.atomic.AtomicReference.get:()Ljava/lang/Object;
checkcast org.apache.cassandra.db.lifecycle.View
getstatic org.apache.cassandra.db.lifecycle.SSTableSet.NONCOMPACTING:Lorg/apache/cassandra/db/lifecycle/SSTableSet;
invokevirtual org.apache.cassandra.db.lifecycle.View.select:(Lorg/apache/cassandra/db/lifecycle/SSTableSet;)Ljava/lang/Iterable;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/db/lifecycle/Tracker;
Signature: ()Ljava/lang/Iterable<Lorg/apache/cassandra/io/sstable/format/SSTableReader;>;
public java.lang.Iterable<org.apache.cassandra.io.sstable.format.SSTableReader> getUncompacting(java.lang.Iterable<org.apache.cassandra.io.sstable.format.SSTableReader>);
descriptor: (Ljava/lang/Iterable;)Ljava/lang/Iterable;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield org.apache.cassandra.db.lifecycle.Tracker.view:Ljava/util/concurrent/atomic/AtomicReference;
invokevirtual java.util.concurrent.atomic.AtomicReference.get:()Ljava/lang/Object;
checkcast org.apache.cassandra.db.lifecycle.View
aload 1
invokevirtual org.apache.cassandra.db.lifecycle.View.getUncompacting:(Ljava/lang/Iterable;)Ljava/lang/Iterable;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/db/lifecycle/Tracker;
0 1 1 candidates Ljava/lang/Iterable<Lorg/apache/cassandra/io/sstable/format/SSTableReader;>;
Signature: (Ljava/lang/Iterable<Lorg/apache/cassandra/io/sstable/format/SSTableReader;>;)Ljava/lang/Iterable<Lorg/apache/cassandra/io/sstable/format/SSTableReader;>;
MethodParameters:
Name Flags
candidates
public void maybeIncrementallyBackup(java.lang.Iterable<org.apache.cassandra.io.sstable.format.SSTableReader>);
descriptor: (Ljava/lang/Iterable;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=5, args_size=2
start local 0 start local 1 0: invokestatic org.apache.cassandra.config.DatabaseDescriptor.isIncrementalBackupsEnabled:()Z
ifne 2
1: return
2: StackMap locals:
StackMap stack:
aload 1
invokeinterface java.lang.Iterable.iterator:()Ljava/util/Iterator;
astore 3
goto 6
StackMap locals: org.apache.cassandra.db.lifecycle.Tracker java.lang.Iterable top java.util.Iterator
StackMap stack:
3: aload 3
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.io.sstable.format.SSTableReader
astore 2
start local 2 4: aload 2
getfield org.apache.cassandra.io.sstable.format.SSTableReader.descriptor:Lorg/apache/cassandra/io/sstable/Descriptor;
invokestatic org.apache.cassandra.db.Directories.getBackupsDirectory:(Lorg/apache/cassandra/io/sstable/Descriptor;)Ljava/io/File;
astore 4
start local 4 5: aload 2
aload 4
invokestatic org.apache.cassandra.io.util.FileUtils.getCanonicalPath:(Ljava/io/File;)Ljava/lang/String;
invokevirtual org.apache.cassandra.io.sstable.format.SSTableReader.createLinks:(Ljava/lang/String;)V
end local 4 end local 2 6: StackMap locals:
StackMap stack:
aload 3
invokeinterface java.util.Iterator.hasNext:()Z
ifne 3
7: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 8 0 this Lorg/apache/cassandra/db/lifecycle/Tracker;
0 8 1 sstables Ljava/lang/Iterable<Lorg/apache/cassandra/io/sstable/format/SSTableReader;>;
4 6 2 sstable Lorg/apache/cassandra/io/sstable/format/SSTableReader;
5 6 4 backupsDir Ljava/io/File;
Signature: (Ljava/lang/Iterable<Lorg/apache/cassandra/io/sstable/format/SSTableReader;>;)V
MethodParameters:
Name Flags
sstables final
java.lang.Throwable notifySSTablesChanged(java.util.Collection<org.apache.cassandra.io.sstable.format.SSTableReader>, java.util.Collection<org.apache.cassandra.io.sstable.format.SSTableReader>, org.apache.cassandra.db.compaction.OperationType, java.lang.Throwable);
descriptor: (Ljava/util/Collection;Ljava/util/Collection;Lorg/apache/cassandra/db/compaction/OperationType;Ljava/lang/Throwable;)Ljava/lang/Throwable;
flags: (0x0000)
Code:
stack=5, locals=9, args_size=5
start local 0 start local 1 start local 2 start local 3 start local 4 0: new org.apache.cassandra.notifications.SSTableListChangedNotification
dup
aload 2
aload 1
aload 3
invokespecial org.apache.cassandra.notifications.SSTableListChangedNotification.<init>:(Ljava/util/Collection;Ljava/util/Collection;Lorg/apache/cassandra/db/compaction/OperationType;)V
astore 5
start local 5 1: aload 0
getfield org.apache.cassandra.db.lifecycle.Tracker.subscribers:Ljava/util/Collection;
invokeinterface java.util.Collection.iterator:()Ljava/util/Iterator;
astore 7
goto 7
StackMap locals: org.apache.cassandra.db.lifecycle.Tracker java.util.Collection java.util.Collection org.apache.cassandra.db.compaction.OperationType java.lang.Throwable org.apache.cassandra.notifications.INotification top java.util.Iterator
StackMap stack:
2: aload 7
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.notifications.INotificationConsumer
astore 6
start local 6 3: aload 6
aload 5
aload 0
invokeinterface org.apache.cassandra.notifications.INotificationConsumer.handleNotification:(Lorg/apache/cassandra/notifications/INotification;Ljava/lang/Object;)V
4: goto 7
5: StackMap locals: org.apache.cassandra.db.lifecycle.Tracker java.util.Collection java.util.Collection org.apache.cassandra.db.compaction.OperationType java.lang.Throwable org.apache.cassandra.notifications.INotification org.apache.cassandra.notifications.INotificationConsumer java.util.Iterator
StackMap stack: java.lang.Throwable
astore 8
start local 8 6: aload 4
aload 8
invokestatic org.apache.cassandra.utils.Throwables.merge:(Ljava/lang/Throwable;Ljava/lang/Throwable;)Ljava/lang/Throwable;
astore 4
end local 8 end local 6 7: StackMap locals: org.apache.cassandra.db.lifecycle.Tracker java.util.Collection java.util.Collection org.apache.cassandra.db.compaction.OperationType java.lang.Throwable org.apache.cassandra.notifications.INotification top java.util.Iterator
StackMap stack:
aload 7
invokeinterface java.util.Iterator.hasNext:()Z
ifne 2
8: aload 4
areturn
end local 5 end local 4 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/lifecycle/Tracker;
0 9 1 removed Ljava/util/Collection<Lorg/apache/cassandra/io/sstable/format/SSTableReader;>;
0 9 2 added Ljava/util/Collection<Lorg/apache/cassandra/io/sstable/format/SSTableReader;>;
0 9 3 compactionType Lorg/apache/cassandra/db/compaction/OperationType;
0 9 4 accumulate Ljava/lang/Throwable;
1 9 5 notification Lorg/apache/cassandra/notifications/INotification;
3 7 6 subscriber Lorg/apache/cassandra/notifications/INotificationConsumer;
6 7 8 t Ljava/lang/Throwable;
Exception table:
from to target type
3 4 5 Class java.lang.Throwable
Signature: (Ljava/util/Collection<Lorg/apache/cassandra/io/sstable/format/SSTableReader;>;Ljava/util/Collection<Lorg/apache/cassandra/io/sstable/format/SSTableReader;>;Lorg/apache/cassandra/db/compaction/OperationType;Ljava/lang/Throwable;)Ljava/lang/Throwable;
MethodParameters:
Name Flags
removed
added
compactionType
accumulate
java.lang.Throwable notifyAdded(java.lang.Iterable<org.apache.cassandra.io.sstable.format.SSTableReader>, java.lang.Throwable);
descriptor: (Ljava/lang/Iterable;Ljava/lang/Throwable;)Ljava/lang/Throwable;
flags: (0x0000)
Code:
stack=3, locals=7, args_size=3
start local 0 start local 1 start local 2 0: new org.apache.cassandra.notifications.SSTableAddedNotification
dup
aload 1
invokespecial org.apache.cassandra.notifications.SSTableAddedNotification.<init>:(Ljava/lang/Iterable;)V
astore 3
start local 3 1: aload 0
getfield org.apache.cassandra.db.lifecycle.Tracker.subscribers:Ljava/util/Collection;
invokeinterface java.util.Collection.iterator:()Ljava/util/Iterator;
astore 5
goto 7
StackMap locals: org.apache.cassandra.db.lifecycle.Tracker java.lang.Iterable java.lang.Throwable org.apache.cassandra.notifications.INotification top java.util.Iterator
StackMap stack:
2: aload 5
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.notifications.INotificationConsumer
astore 4
start local 4 3: aload 4
aload 3
aload 0
invokeinterface org.apache.cassandra.notifications.INotificationConsumer.handleNotification:(Lorg/apache/cassandra/notifications/INotification;Ljava/lang/Object;)V
4: goto 7
5: StackMap locals: org.apache.cassandra.db.lifecycle.Tracker java.lang.Iterable java.lang.Throwable org.apache.cassandra.notifications.INotification org.apache.cassandra.notifications.INotificationConsumer java.util.Iterator
StackMap stack: java.lang.Throwable
astore 6
start local 6 6: aload 2
aload 6
invokestatic org.apache.cassandra.utils.Throwables.merge:(Ljava/lang/Throwable;Ljava/lang/Throwable;)Ljava/lang/Throwable;
astore 2
end local 6 end local 4 7: StackMap locals: org.apache.cassandra.db.lifecycle.Tracker java.lang.Iterable java.lang.Throwable org.apache.cassandra.notifications.INotification top java.util.Iterator
StackMap stack:
aload 5
invokeinterface java.util.Iterator.hasNext:()Z
ifne 2
8: aload 2
areturn
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/lifecycle/Tracker;
0 9 1 added Ljava/lang/Iterable<Lorg/apache/cassandra/io/sstable/format/SSTableReader;>;
0 9 2 accumulate Ljava/lang/Throwable;
1 9 3 notification Lorg/apache/cassandra/notifications/INotification;
3 7 4 subscriber Lorg/apache/cassandra/notifications/INotificationConsumer;
6 7 6 t Ljava/lang/Throwable;
Exception table:
from to target type
3 4 5 Class java.lang.Throwable
Signature: (Ljava/lang/Iterable<Lorg/apache/cassandra/io/sstable/format/SSTableReader;>;Ljava/lang/Throwable;)Ljava/lang/Throwable;
MethodParameters:
Name Flags
added
accumulate
public void notifyAdded(java.lang.Iterable<org.apache.cassandra.io.sstable.format.SSTableReader>);
descriptor: (Ljava/lang/Iterable;)V
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.lifecycle.Tracker.notifyAdded:(Ljava/lang/Iterable;Ljava/lang/Throwable;)Ljava/lang/Throwable;
invokestatic org.apache.cassandra.utils.Throwables.maybeFail:(Ljava/lang/Throwable;)V
1: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/apache/cassandra/db/lifecycle/Tracker;
0 2 1 added Ljava/lang/Iterable<Lorg/apache/cassandra/io/sstable/format/SSTableReader;>;
Signature: (Ljava/lang/Iterable<Lorg/apache/cassandra/io/sstable/format/SSTableReader;>;)V
MethodParameters:
Name Flags
added
public void notifySSTableRepairedStatusChanged(java.util.Collection<org.apache.cassandra.io.sstable.format.SSTableReader>);
descriptor: (Ljava/util/Collection;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=5, args_size=2
start local 0 start local 1 0: new org.apache.cassandra.notifications.SSTableRepairStatusChanged
dup
aload 1
invokespecial org.apache.cassandra.notifications.SSTableRepairStatusChanged.<init>:(Ljava/util/Collection;)V
astore 2
start local 2 1: aload 0
getfield org.apache.cassandra.db.lifecycle.Tracker.subscribers:Ljava/util/Collection;
invokeinterface java.util.Collection.iterator:()Ljava/util/Iterator;
astore 4
goto 4
StackMap locals: org.apache.cassandra.db.lifecycle.Tracker java.util.Collection org.apache.cassandra.notifications.INotification top java.util.Iterator
StackMap stack:
2: aload 4
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.notifications.INotificationConsumer
astore 3
start local 3 3: aload 3
aload 2
aload 0
invokeinterface org.apache.cassandra.notifications.INotificationConsumer.handleNotification:(Lorg/apache/cassandra/notifications/INotification;Ljava/lang/Object;)V
end local 3 4: StackMap locals:
StackMap stack:
aload 4
invokeinterface java.util.Iterator.hasNext:()Z
ifne 2
5: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 this Lorg/apache/cassandra/db/lifecycle/Tracker;
0 6 1 repairStatusesChanged Ljava/util/Collection<Lorg/apache/cassandra/io/sstable/format/SSTableReader;>;
1 6 2 notification Lorg/apache/cassandra/notifications/INotification;
3 4 3 subscriber Lorg/apache/cassandra/notifications/INotificationConsumer;
Signature: (Ljava/util/Collection<Lorg/apache/cassandra/io/sstable/format/SSTableReader;>;)V
MethodParameters:
Name Flags
repairStatusesChanged
public void notifyDeleting(org.apache.cassandra.io.sstable.format.SSTableReader);
descriptor: (Lorg/apache/cassandra/io/sstable/format/SSTableReader;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=5, args_size=2
start local 0 start local 1 0: new org.apache.cassandra.notifications.SSTableDeletingNotification
dup
aload 1
invokespecial org.apache.cassandra.notifications.SSTableDeletingNotification.<init>:(Lorg/apache/cassandra/io/sstable/format/SSTableReader;)V
astore 2
start local 2 1: aload 0
getfield org.apache.cassandra.db.lifecycle.Tracker.subscribers:Ljava/util/Collection;
invokeinterface java.util.Collection.iterator:()Ljava/util/Iterator;
astore 4
goto 4
StackMap locals: org.apache.cassandra.db.lifecycle.Tracker org.apache.cassandra.io.sstable.format.SSTableReader org.apache.cassandra.notifications.INotification top java.util.Iterator
StackMap stack:
2: aload 4
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.notifications.INotificationConsumer
astore 3
start local 3 3: aload 3
aload 2
aload 0
invokeinterface org.apache.cassandra.notifications.INotificationConsumer.handleNotification:(Lorg/apache/cassandra/notifications/INotification;Ljava/lang/Object;)V
end local 3 4: StackMap locals:
StackMap stack:
aload 4
invokeinterface java.util.Iterator.hasNext:()Z
ifne 2
5: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 this Lorg/apache/cassandra/db/lifecycle/Tracker;
0 6 1 deleting Lorg/apache/cassandra/io/sstable/format/SSTableReader;
1 6 2 notification Lorg/apache/cassandra/notifications/INotification;
3 4 3 subscriber Lorg/apache/cassandra/notifications/INotificationConsumer;
MethodParameters:
Name Flags
deleting
public void notifyTruncated(long);
descriptor: (J)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=6, args_size=2
start local 0 start local 1 0: new org.apache.cassandra.notifications.TruncationNotification
dup
lload 1
invokespecial org.apache.cassandra.notifications.TruncationNotification.<init>:(J)V
astore 3
start local 3 1: aload 0
getfield org.apache.cassandra.db.lifecycle.Tracker.subscribers:Ljava/util/Collection;
invokeinterface java.util.Collection.iterator:()Ljava/util/Iterator;
astore 5
goto 4
StackMap locals: org.apache.cassandra.db.lifecycle.Tracker long org.apache.cassandra.notifications.INotification top java.util.Iterator
StackMap stack:
2: aload 5
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.notifications.INotificationConsumer
astore 4
start local 4 3: aload 4
aload 3
aload 0
invokeinterface org.apache.cassandra.notifications.INotificationConsumer.handleNotification:(Lorg/apache/cassandra/notifications/INotification;Ljava/lang/Object;)V
end local 4 4: StackMap locals:
StackMap stack:
aload 5
invokeinterface java.util.Iterator.hasNext:()Z
ifne 2
5: return
end local 3 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 this Lorg/apache/cassandra/db/lifecycle/Tracker;
0 6 1 truncatedAt J
1 6 3 notification Lorg/apache/cassandra/notifications/INotification;
3 4 4 subscriber Lorg/apache/cassandra/notifications/INotificationConsumer;
MethodParameters:
Name Flags
truncatedAt
public void notifyRenewed(org.apache.cassandra.db.Memtable);
descriptor: (Lorg/apache/cassandra/db/Memtable;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=2, args_size=2
start local 0 start local 1 0: aload 0
new org.apache.cassandra.notifications.MemtableRenewedNotification
dup
aload 1
invokespecial org.apache.cassandra.notifications.MemtableRenewedNotification.<init>:(Lorg/apache/cassandra/db/Memtable;)V
invokevirtual org.apache.cassandra.db.lifecycle.Tracker.notify:(Lorg/apache/cassandra/notifications/INotification;)V
1: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/apache/cassandra/db/lifecycle/Tracker;
0 2 1 renewed Lorg/apache/cassandra/db/Memtable;
MethodParameters:
Name Flags
renewed
public void notifySwitched(org.apache.cassandra.db.Memtable);
descriptor: (Lorg/apache/cassandra/db/Memtable;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=2, args_size=2
start local 0 start local 1 0: aload 0
new org.apache.cassandra.notifications.MemtableSwitchedNotification
dup
aload 1
invokespecial org.apache.cassandra.notifications.MemtableSwitchedNotification.<init>:(Lorg/apache/cassandra/db/Memtable;)V
invokevirtual org.apache.cassandra.db.lifecycle.Tracker.notify:(Lorg/apache/cassandra/notifications/INotification;)V
1: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/apache/cassandra/db/lifecycle/Tracker;
0 2 1 previous Lorg/apache/cassandra/db/Memtable;
MethodParameters:
Name Flags
previous
public void notifyDiscarded(org.apache.cassandra.db.Memtable);
descriptor: (Lorg/apache/cassandra/db/Memtable;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=2, args_size=2
start local 0 start local 1 0: aload 0
new org.apache.cassandra.notifications.MemtableDiscardedNotification
dup
aload 1
invokespecial org.apache.cassandra.notifications.MemtableDiscardedNotification.<init>:(Lorg/apache/cassandra/db/Memtable;)V
invokevirtual org.apache.cassandra.db.lifecycle.Tracker.notify:(Lorg/apache/cassandra/notifications/INotification;)V
1: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/apache/cassandra/db/lifecycle/Tracker;
0 2 1 discarded Lorg/apache/cassandra/db/Memtable;
MethodParameters:
Name Flags
discarded
private void notify(org.apache.cassandra.notifications.INotification);
descriptor: (Lorg/apache/cassandra/notifications/INotification;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=3, locals=4, args_size=2
start local 0 start local 1 0: aload 0
getfield org.apache.cassandra.db.lifecycle.Tracker.subscribers:Ljava/util/Collection;
invokeinterface java.util.Collection.iterator:()Ljava/util/Iterator;
astore 3
goto 3
StackMap locals: org.apache.cassandra.db.lifecycle.Tracker org.apache.cassandra.notifications.INotification top java.util.Iterator
StackMap stack:
1: aload 3
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.notifications.INotificationConsumer
astore 2
start local 2 2: aload 2
aload 1
aload 0
invokeinterface org.apache.cassandra.notifications.INotificationConsumer.handleNotification:(Lorg/apache/cassandra/notifications/INotification;Ljava/lang/Object;)V
end local 2 3: StackMap locals:
StackMap stack:
aload 3
invokeinterface java.util.Iterator.hasNext:()Z
ifne 1
4: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lorg/apache/cassandra/db/lifecycle/Tracker;
0 5 1 notification Lorg/apache/cassandra/notifications/INotification;
2 3 2 subscriber Lorg/apache/cassandra/notifications/INotificationConsumer;
MethodParameters:
Name Flags
notification
public boolean isDummy();
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.lifecycle.Tracker.cfstore:Lorg/apache/cassandra/db/ColumnFamilyStore;
ifnull 1
invokestatic org.apache.cassandra.config.DatabaseDescriptor.isDaemonInitialized:()Z
ifeq 1
iconst_0
ireturn
StackMap locals:
StackMap stack:
1: iconst_1
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/apache/cassandra/db/lifecycle/Tracker;
public void subscribe(org.apache.cassandra.notifications.INotificationConsumer);
descriptor: (Lorg/apache/cassandra/notifications/INotificationConsumer;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield org.apache.cassandra.db.lifecycle.Tracker.subscribers:Ljava/util/Collection;
aload 1
invokeinterface java.util.Collection.add:(Ljava/lang/Object;)Z
pop
1: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/apache/cassandra/db/lifecycle/Tracker;
0 2 1 consumer Lorg/apache/cassandra/notifications/INotificationConsumer;
MethodParameters:
Name Flags
consumer
public void unsubscribe(org.apache.cassandra.notifications.INotificationConsumer);
descriptor: (Lorg/apache/cassandra/notifications/INotificationConsumer;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield org.apache.cassandra.db.lifecycle.Tracker.subscribers:Ljava/util/Collection;
aload 1
invokeinterface java.util.Collection.remove:(Ljava/lang/Object;)Z
pop
1: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/apache/cassandra/db/lifecycle/Tracker;
0 2 1 consumer Lorg/apache/cassandra/notifications/INotificationConsumer;
MethodParameters:
Name Flags
consumer
private static java.util.Set<org.apache.cassandra.io.sstable.format.SSTableReader> emptySet();
descriptor: ()Ljava/util/Set;
flags: (0x000a) ACC_PRIVATE, ACC_STATIC
Code:
stack=1, locals=0, args_size=0
0: invokestatic java.util.Collections.emptySet:()Ljava/util/Set;
areturn
LocalVariableTable:
Start End Slot Name Signature
Signature: ()Ljava/util/Set<Lorg/apache/cassandra/io/sstable/format/SSTableReader;>;
public org.apache.cassandra.db.lifecycle.View getView();
descriptor: ()Lorg/apache/cassandra/db/lifecycle/View;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.db.lifecycle.Tracker.view:Ljava/util/concurrent/atomic/AtomicReference;
invokevirtual java.util.concurrent.atomic.AtomicReference.get:()Ljava/lang/Object;
checkcast org.apache.cassandra.db.lifecycle.View
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/db/lifecycle/Tracker;
public void removeUnsafe(java.util.Set<org.apache.cassandra.io.sstable.format.SSTableReader>);
descriptor: (Ljava/util/Set;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
invokedynamic apply(Ljava/util/Set;)Lcom/google/common/base/Function;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)Ljava/lang/Object;
org/apache/cassandra/db/lifecycle/Tracker.lambda$2(Ljava/util/Set;Lorg/apache/cassandra/db/lifecycle/View;)Lorg/apache/cassandra/db/lifecycle/View; (6)
(Lorg/apache/cassandra/db/lifecycle/View;)Lorg/apache/cassandra/db/lifecycle/View;
invokevirtual org.apache.cassandra.db.lifecycle.Tracker.apply:(Lcom/google/common/base/Function;)Lorg/apache/cassandra/utils/Pair;
pop
1: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/apache/cassandra/db/lifecycle/Tracker;
0 2 1 toRemove Ljava/util/Set<Lorg/apache/cassandra/io/sstable/format/SSTableReader;>;
Signature: (Ljava/util/Set<Lorg/apache/cassandra/io/sstable/format/SSTableReader;>;)V
RuntimeInvisibleAnnotations:
com.google.common.annotations.VisibleForTesting()
MethodParameters:
Name Flags
toRemove
private static org.apache.cassandra.db.lifecycle.View lambda$0(com.google.common.base.Predicate, org.apache.cassandra.db.lifecycle.View);
descriptor: (Lcom/google/common/base/Predicate;Lorg/apache/cassandra/db/lifecycle/View;)Lorg/apache/cassandra/db/lifecycle/View;
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=6, locals=3, args_size=2
start local 1 0: aload 1
getfield org.apache.cassandra.db.lifecycle.View.sstables:Ljava/util/Set;
aload 0
iconst_1
anewarray java.util.Set
dup
iconst_0
aload 1
getfield org.apache.cassandra.db.lifecycle.View.compacting:Ljava/util/Set;
aastore
invokestatic org.apache.cassandra.db.lifecycle.Helpers.notIn:([Ljava/util/Set;)Lcom/google/common/base/Predicate;
invokestatic com.google.common.base.Predicates.and:(Lcom/google/common/base/Predicate;Lcom/google/common/base/Predicate;)Lcom/google/common/base/Predicate;
invokestatic com.google.common.collect.Iterables.filter:(Ljava/lang/Iterable;Lcom/google/common/base/Predicate;)Ljava/lang/Iterable;
invokestatic com.google.common.collect.ImmutableSet.copyOf:(Ljava/lang/Iterable;)Lcom/google/common/collect/ImmutableSet;
astore 2
start local 2 1: aload 2
invokestatic org.apache.cassandra.db.lifecycle.Tracker.emptySet:()Ljava/util/Set;
invokestatic org.apache.cassandra.db.lifecycle.View.updateLiveSet:(Ljava/util/Set;Ljava/lang/Iterable;)Lcom/google/common/base/Function;
aload 1
invokeinterface com.google.common.base.Function.apply:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast org.apache.cassandra.db.lifecycle.View
areturn
end local 2 end local 1 LocalVariableTable:
Start End Slot Name Signature
0 2 1 view Lorg/apache/cassandra/db/lifecycle/View;
1 2 2 toremove Ljava/util/Set<Lorg/apache/cassandra/io/sstable/format/SSTableReader;>;
private static org.apache.cassandra.db.lifecycle.View lambda$2(java.util.Set, org.apache.cassandra.db.lifecycle.View);
descriptor: (Ljava/util/Set;Lorg/apache/cassandra/db/lifecycle/View;)Lorg/apache/cassandra/db/lifecycle/View;
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=2, locals=2, args_size=2
start local 1 0: aload 0
invokestatic org.apache.cassandra.db.lifecycle.Tracker.emptySet:()Ljava/util/Set;
invokestatic org.apache.cassandra.db.lifecycle.View.updateLiveSet:(Ljava/util/Set;Ljava/lang/Iterable;)Lcom/google/common/base/Function;
aload 1
invokeinterface com.google.common.base.Function.apply:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast org.apache.cassandra.db.lifecycle.View
areturn
end local 1 LocalVariableTable:
Start End Slot Name Signature
0 1 1 view Lorg/apache/cassandra/db/lifecycle/View;
}
SourceFile: "Tracker.java"
NestMembers:
org.apache.cassandra.db.lifecycle.Tracker$1
InnerClasses:
public abstract SetView = com.google.common.collect.Sets$SetView of com.google.common.collect.Sets
public final Lookup = java.lang.invoke.MethodHandles$Lookup of java.lang.invoke.MethodHandles
Obsoletion = org.apache.cassandra.db.lifecycle.LogTransaction$Obsoletion of org.apache.cassandra.db.lifecycle.LogTransaction
org.apache.cassandra.db.lifecycle.Tracker$1
public final Group = org.apache.cassandra.utils.concurrent.OpOrder$Group of org.apache.cassandra.utils.concurrent.OpOrder