public class org.apache.cassandra.db.Keyspace
minor version: 0
major version: 59
flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
this_class: org.apache.cassandra.db.Keyspace
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 static final java.lang.String TEST_FAIL_WRITES_KS;
descriptor: Ljava/lang/String;
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
private static final boolean TEST_FAIL_WRITES;
descriptor: Z
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
private static int TEST_FAIL_MV_LOCKS_COUNT;
descriptor: I
flags: (0x000a) ACC_PRIVATE, ACC_STATIC
public final org.apache.cassandra.metrics.KeyspaceMetrics metric;
descriptor: Lorg/apache/cassandra/metrics/KeyspaceMetrics;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
private volatile org.apache.cassandra.schema.KeyspaceMetadata metadata;
descriptor: Lorg/apache/cassandra/schema/KeyspaceMetadata;
flags: (0x0042) ACC_PRIVATE, ACC_VOLATILE
public static final org.apache.cassandra.utils.concurrent.OpOrder writeOrder;
descriptor: Lorg/apache/cassandra/utils/concurrent/OpOrder;
flags: (0x0019) ACC_PUBLIC, ACC_STATIC, ACC_FINAL
private final java.util.concurrent.ConcurrentMap<java.util.UUID, org.apache.cassandra.db.ColumnFamilyStore> columnFamilyStores;
descriptor: Ljava/util/concurrent/ConcurrentMap;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Ljava/util/concurrent/ConcurrentMap<Ljava/util/UUID;Lorg/apache/cassandra/db/ColumnFamilyStore;>;
private volatile org.apache.cassandra.locator.AbstractReplicationStrategy replicationStrategy;
descriptor: Lorg/apache/cassandra/locator/AbstractReplicationStrategy;
flags: (0x0042) ACC_PRIVATE, ACC_VOLATILE
public final org.apache.cassandra.db.view.ViewManager viewManager;
descriptor: Lorg/apache/cassandra/db/view/ViewManager;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
private volatile org.apache.cassandra.schema.ReplicationParams replicationParams;
descriptor: Lorg/apache/cassandra/schema/ReplicationParams;
flags: (0x0042) ACC_PRIVATE, ACC_VOLATILE
public static final com.google.common.base.Function<java.lang.String, org.apache.cassandra.db.Keyspace> keyspaceTransformer;
descriptor: Lcom/google/common/base/Function;
flags: (0x0019) ACC_PUBLIC, ACC_STATIC, ACC_FINAL
Signature: Lcom/google/common/base/Function<Ljava/lang/String;Lorg/apache/cassandra/db/Keyspace;>;
private static volatile boolean initialized;
descriptor: Z
flags: (0x004a) ACC_PRIVATE, ACC_STATIC, ACC_VOLATILE
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=2, locals=0, args_size=0
0: ldc Lorg/apache/cassandra/db/Keyspace;
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.Keyspace.$assertionsDisabled:Z
3: ldc Lorg/apache/cassandra/db/Keyspace;
invokestatic org.slf4j.LoggerFactory.getLogger:(Ljava/lang/Class;)Lorg/slf4j/Logger;
putstatic org.apache.cassandra.db.Keyspace.logger:Lorg/slf4j/Logger;
4: ldc "cassandra.test.fail_writes_ks"
ldc ""
invokestatic java.lang.System.getProperty:(Ljava/lang/String;Ljava/lang/String;)Ljava/lang/String;
putstatic org.apache.cassandra.db.Keyspace.TEST_FAIL_WRITES_KS:Ljava/lang/String;
5: getstatic org.apache.cassandra.db.Keyspace.TEST_FAIL_WRITES_KS:Ljava/lang/String;
invokevirtual java.lang.String.isEmpty:()Z
ifeq 6
iconst_0
goto 7
StackMap locals:
StackMap stack:
6: iconst_1
StackMap locals:
StackMap stack: int
7: putstatic org.apache.cassandra.db.Keyspace.TEST_FAIL_WRITES:Z
8: ldc "cassandra.test.fail_mv_locks_count"
iconst_0
invokestatic java.lang.Integer.getInteger:(Ljava/lang/String;I)Ljava/lang/Integer;
invokevirtual java.lang.Integer.intValue:()I
putstatic org.apache.cassandra.db.Keyspace.TEST_FAIL_MV_LOCKS_COUNT:I
9: invokestatic org.apache.cassandra.config.DatabaseDescriptor.isDaemonInitialized:()Z
ifne 10
invokestatic org.apache.cassandra.config.DatabaseDescriptor.isToolInitialized:()Z
ifeq 11
10: StackMap locals:
StackMap stack:
invokestatic org.apache.cassandra.config.DatabaseDescriptor.createAllDirectories:()V
11: StackMap locals:
StackMap stack:
new org.apache.cassandra.utils.concurrent.OpOrder
dup
invokespecial org.apache.cassandra.utils.concurrent.OpOrder.<init>:()V
putstatic org.apache.cassandra.db.Keyspace.writeOrder:Lorg/apache/cassandra/utils/concurrent/OpOrder;
12: new org.apache.cassandra.db.Keyspace$1
dup
invokespecial org.apache.cassandra.db.Keyspace$1.<init>:()V
putstatic org.apache.cassandra.db.Keyspace.keyspaceTransformer:Lcom/google/common/base/Function;
13: iconst_0
putstatic org.apache.cassandra.db.Keyspace.initialized:Z
return
LocalVariableTable:
Start End Slot Name Signature
public static void setInitialized();
descriptor: ()V
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=1, locals=0, args_size=0
0: iconst_1
putstatic org.apache.cassandra.db.Keyspace.initialized:Z
1: return
LocalVariableTable:
Start End Slot Name Signature
public static org.apache.cassandra.db.Keyspace open(java.lang.String);
descriptor: (Ljava/lang/String;)Lorg/apache/cassandra/db/Keyspace;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=3, locals=1, args_size=1
start local 0 0: getstatic org.apache.cassandra.db.Keyspace.$assertionsDisabled:Z
ifne 1
getstatic org.apache.cassandra.db.Keyspace.initialized:Z
ifne 1
aload 0
invokestatic org.apache.cassandra.config.SchemaConstants.isLocalSystemKeyspace:(Ljava/lang/String;)Z
ifne 1
new java.lang.AssertionError
dup
invokespecial java.lang.AssertionError.<init>:()V
athrow
1: StackMap locals:
StackMap stack:
aload 0
getstatic org.apache.cassandra.config.Schema.instance:Lorg/apache/cassandra/config/Schema;
iconst_1
invokestatic org.apache.cassandra.db.Keyspace.open:(Ljava/lang/String;Lorg/apache/cassandra/config/Schema;Z)Lorg/apache/cassandra/db/Keyspace;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 keyspaceName Ljava/lang/String;
MethodParameters:
Name Flags
keyspaceName
public static org.apache.cassandra.db.Keyspace openWithoutSSTables(java.lang.String);
descriptor: (Ljava/lang/String;)Lorg/apache/cassandra/db/Keyspace;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=3, locals=1, args_size=1
start local 0 0: aload 0
getstatic org.apache.cassandra.config.Schema.instance:Lorg/apache/cassandra/config/Schema;
iconst_0
invokestatic org.apache.cassandra.db.Keyspace.open:(Ljava/lang/String;Lorg/apache/cassandra/config/Schema;Z)Lorg/apache/cassandra/db/Keyspace;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 keyspaceName Ljava/lang/String;
MethodParameters:
Name Flags
keyspaceName
private static org.apache.cassandra.db.Keyspace open(java.lang.String, org.apache.cassandra.config.Schema, boolean);
descriptor: (Ljava/lang/String;Lorg/apache/cassandra/config/Schema;Z)Lorg/apache/cassandra/db/Keyspace;
flags: (0x000a) ACC_PRIVATE, ACC_STATIC
Code:
stack=4, locals=5, args_size=3
start local 0 start local 1 start local 2 0: aload 1
aload 0
invokevirtual org.apache.cassandra.config.Schema.getKeyspaceInstance:(Ljava/lang/String;)Lorg/apache/cassandra/db/Keyspace;
astore 3
start local 3 1: aload 3
ifnonnull 11
2: ldc Lorg/apache/cassandra/db/Keyspace;
dup
astore 4
monitorenter
3: aload 1
aload 0
invokevirtual org.apache.cassandra.config.Schema.getKeyspaceInstance:(Ljava/lang/String;)Lorg/apache/cassandra/db/Keyspace;
astore 3
4: aload 3
ifnonnull 7
5: new org.apache.cassandra.db.Keyspace
dup
aload 0
iload 2
invokespecial org.apache.cassandra.db.Keyspace.<init>:(Ljava/lang/String;Z)V
astore 3
6: aload 1
aload 3
invokevirtual org.apache.cassandra.config.Schema.storeKeyspaceInstance:(Lorg/apache/cassandra/db/Keyspace;)V
7: StackMap locals: org.apache.cassandra.db.Keyspace java.lang.Class
StackMap stack:
aload 4
monitorexit
8: goto 11
StackMap locals:
StackMap stack: java.lang.Throwable
9: aload 4
monitorexit
10: athrow
11: 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 12 0 keyspaceName Ljava/lang/String;
0 12 1 schema Lorg/apache/cassandra/config/Schema;
0 12 2 loadSSTables Z
1 12 3 keyspaceInstance Lorg/apache/cassandra/db/Keyspace;
Exception table:
from to target type
3 8 9 any
9 10 9 any
MethodParameters:
Name Flags
keyspaceName
schema
loadSSTables
public static org.apache.cassandra.db.Keyspace clear(java.lang.String);
descriptor: (Ljava/lang/String;)Lorg/apache/cassandra/db/Keyspace;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
getstatic org.apache.cassandra.config.Schema.instance:Lorg/apache/cassandra/config/Schema;
invokestatic org.apache.cassandra.db.Keyspace.clear:(Ljava/lang/String;Lorg/apache/cassandra/config/Schema;)Lorg/apache/cassandra/db/Keyspace;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 keyspaceName Ljava/lang/String;
MethodParameters:
Name Flags
keyspaceName
public static org.apache.cassandra.db.Keyspace clear(java.lang.String, org.apache.cassandra.config.Schema);
descriptor: (Ljava/lang/String;Lorg/apache/cassandra/config/Schema;)Lorg/apache/cassandra/db/Keyspace;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=2, locals=6, args_size=2
start local 0 start local 1 0: ldc Lorg/apache/cassandra/db/Keyspace;
dup
astore 2
monitorenter
1: aload 1
aload 0
invokevirtual org.apache.cassandra.config.Schema.removeKeyspaceInstance:(Ljava/lang/String;)Lorg/apache/cassandra/db/Keyspace;
astore 3
start local 3 2: aload 3
ifnull 8
3: aload 3
invokevirtual org.apache.cassandra.db.Keyspace.getColumnFamilyStores:()Ljava/util/Collection;
invokeinterface java.util.Collection.iterator:()Ljava/util/Iterator;
astore 5
goto 6
StackMap locals: java.lang.String org.apache.cassandra.config.Schema java.lang.Class org.apache.cassandra.db.Keyspace top java.util.Iterator
StackMap stack:
4: aload 5
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.db.ColumnFamilyStore
astore 4
start local 4 5: aload 3
aload 4
invokevirtual org.apache.cassandra.db.Keyspace.unloadCf:(Lorg/apache/cassandra/db/ColumnFamilyStore;)V
end local 4 6: StackMap locals:
StackMap stack:
aload 5
invokeinterface java.util.Iterator.hasNext:()Z
ifne 4
7: aload 3
getfield org.apache.cassandra.db.Keyspace.metric:Lorg/apache/cassandra/metrics/KeyspaceMetrics;
invokevirtual org.apache.cassandra.metrics.KeyspaceMetrics.release:()V
8: StackMap locals: java.lang.String org.apache.cassandra.config.Schema java.lang.Class org.apache.cassandra.db.Keyspace
StackMap stack:
aload 3
aload 2
monitorexit
9: areturn
end local 3 10: StackMap locals: java.lang.String org.apache.cassandra.config.Schema java.lang.Class
StackMap stack: java.lang.Throwable
aload 2
monitorexit
11: athrow
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 12 0 keyspaceName Ljava/lang/String;
0 12 1 schema Lorg/apache/cassandra/config/Schema;
2 10 3 t Lorg/apache/cassandra/db/Keyspace;
5 6 4 cfs Lorg/apache/cassandra/db/ColumnFamilyStore;
Exception table:
from to target type
1 9 10 any
10 11 10 any
MethodParameters:
Name Flags
keyspaceName
schema
public static org.apache.cassandra.db.ColumnFamilyStore openAndGetStore(org.apache.cassandra.config.CFMetaData);
descriptor: (Lorg/apache/cassandra/config/CFMetaData;)Lorg/apache/cassandra/db/ColumnFamilyStore;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.config.CFMetaData.ksName:Ljava/lang/String;
invokestatic org.apache.cassandra.db.Keyspace.open:(Ljava/lang/String;)Lorg/apache/cassandra/db/Keyspace;
aload 0
getfield org.apache.cassandra.config.CFMetaData.cfId:Ljava/util/UUID;
invokevirtual org.apache.cassandra.db.Keyspace.getColumnFamilyStore:(Ljava/util/UUID;)Lorg/apache/cassandra/db/ColumnFamilyStore;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 cfm Lorg/apache/cassandra/config/CFMetaData;
MethodParameters:
Name Flags
cfm
public static void removeUnreadableSSTables(java.io.File);
descriptor: (Ljava/io/File;)V
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=2, locals=7, args_size=1
start local 0 0: invokestatic org.apache.cassandra.db.Keyspace.all:()Ljava/lang/Iterable;
invokeinterface java.lang.Iterable.iterator:()Ljava/util/Iterator;
astore 2
goto 9
StackMap locals: java.io.File top java.util.Iterator
StackMap stack:
1: aload 2
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.db.Keyspace
astore 1
start local 1 2: aload 1
invokevirtual org.apache.cassandra.db.Keyspace.getColumnFamilyStores:()Ljava/util/Collection;
invokeinterface java.util.Collection.iterator:()Ljava/util/Iterator;
astore 4
goto 8
StackMap locals: java.io.File org.apache.cassandra.db.Keyspace java.util.Iterator top java.util.Iterator
StackMap stack:
3: aload 4
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.db.ColumnFamilyStore
astore 3
start local 3 4: aload 3
invokevirtual org.apache.cassandra.db.ColumnFamilyStore.concatWithIndexes:()Ljava/lang/Iterable;
invokeinterface java.lang.Iterable.iterator:()Ljava/util/Iterator;
astore 6
goto 7
StackMap locals: java.io.File org.apache.cassandra.db.Keyspace java.util.Iterator org.apache.cassandra.db.ColumnFamilyStore java.util.Iterator top java.util.Iterator
StackMap stack:
5: aload 6
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.db.ColumnFamilyStore
astore 5
start local 5 6: aload 5
aload 0
invokevirtual org.apache.cassandra.db.ColumnFamilyStore.maybeRemoveUnreadableSSTables:(Ljava/io/File;)V
end local 5 7: StackMap locals:
StackMap stack:
aload 6
invokeinterface java.util.Iterator.hasNext:()Z
ifne 5
end local 3 8: StackMap locals: java.io.File org.apache.cassandra.db.Keyspace java.util.Iterator top java.util.Iterator
StackMap stack:
aload 4
invokeinterface java.util.Iterator.hasNext:()Z
ifne 3
end local 1 9: StackMap locals: java.io.File top java.util.Iterator
StackMap stack:
aload 2
invokeinterface java.util.Iterator.hasNext:()Z
ifne 1
10: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 11 0 directory Ljava/io/File;
2 9 1 keyspace Lorg/apache/cassandra/db/Keyspace;
4 8 3 baseCfs Lorg/apache/cassandra/db/ColumnFamilyStore;
6 7 5 cfs Lorg/apache/cassandra/db/ColumnFamilyStore;
MethodParameters:
Name Flags
directory
public void setMetadata(org.apache.cassandra.schema.KeyspaceMetadata);
descriptor: (Lorg/apache/cassandra/schema/KeyspaceMetadata;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
putfield org.apache.cassandra.db.Keyspace.metadata:Lorg/apache/cassandra/schema/KeyspaceMetadata;
1: aload 0
aload 1
invokevirtual org.apache.cassandra.db.Keyspace.createReplicationStrategy:(Lorg/apache/cassandra/schema/KeyspaceMetadata;)V
2: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lorg/apache/cassandra/db/Keyspace;
0 3 1 metadata Lorg/apache/cassandra/schema/KeyspaceMetadata;
MethodParameters:
Name Flags
metadata
public org.apache.cassandra.schema.KeyspaceMetadata getMetadata();
descriptor: ()Lorg/apache/cassandra/schema/KeyspaceMetadata;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.db.Keyspace.metadata:Lorg/apache/cassandra/schema/KeyspaceMetadata;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/db/Keyspace;
public java.util.Collection<org.apache.cassandra.db.ColumnFamilyStore> getColumnFamilyStores();
descriptor: ()Ljava/util/Collection;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.db.Keyspace.columnFamilyStores:Ljava/util/concurrent/ConcurrentMap;
invokeinterface java.util.concurrent.ConcurrentMap.values:()Ljava/util/Collection;
invokestatic java.util.Collections.unmodifiableCollection:(Ljava/util/Collection;)Ljava/util/Collection;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/db/Keyspace;
Signature: ()Ljava/util/Collection<Lorg/apache/cassandra/db/ColumnFamilyStore;>;
public org.apache.cassandra.db.ColumnFamilyStore getColumnFamilyStore(java.lang.String);
descriptor: (Ljava/lang/String;)Lorg/apache/cassandra/db/ColumnFamilyStore;
flags: (0x0001) ACC_PUBLIC
Code:
stack=7, locals=3, args_size=2
start local 0 start local 1 0: getstatic org.apache.cassandra.config.Schema.instance:Lorg/apache/cassandra/config/Schema;
aload 0
invokevirtual org.apache.cassandra.db.Keyspace.getName:()Ljava/lang/String;
aload 1
invokevirtual org.apache.cassandra.config.Schema.getId:(Ljava/lang/String;Ljava/lang/String;)Ljava/util/UUID;
astore 2
start local 2 1: aload 2
ifnonnull 3
2: new java.lang.IllegalArgumentException
dup
ldc "Unknown keyspace/cf pair (%s.%s)"
iconst_2
anewarray java.lang.Object
dup
iconst_0
aload 0
invokevirtual org.apache.cassandra.db.Keyspace.getName:()Ljava/lang/String;
aastore
dup
iconst_1
aload 1
aastore
invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
invokespecial java.lang.IllegalArgumentException.<init>:(Ljava/lang/String;)V
athrow
3: StackMap locals: java.util.UUID
StackMap stack:
aload 0
aload 2
invokevirtual org.apache.cassandra.db.Keyspace.getColumnFamilyStore:(Ljava/util/UUID;)Lorg/apache/cassandra/db/ColumnFamilyStore;
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lorg/apache/cassandra/db/Keyspace;
0 4 1 cfName Ljava/lang/String;
1 4 2 id Ljava/util/UUID;
MethodParameters:
Name Flags
cfName
public org.apache.cassandra.db.ColumnFamilyStore getColumnFamilyStore(java.util.UUID);
descriptor: (Ljava/util/UUID;)Lorg/apache/cassandra/db/ColumnFamilyStore;
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=3, args_size=2
start local 0 start local 1 0: aload 0
getfield org.apache.cassandra.db.Keyspace.columnFamilyStores:Ljava/util/concurrent/ConcurrentMap;
aload 1
invokeinterface java.util.concurrent.ConcurrentMap.get:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast org.apache.cassandra.db.ColumnFamilyStore
astore 2
start local 2 1: aload 2
ifnonnull 3
2: new java.lang.IllegalArgumentException
dup
new java.lang.StringBuilder
dup
ldc "Unknown CF "
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 1
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/Object;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokespecial java.lang.IllegalArgumentException.<init>:(Ljava/lang/String;)V
athrow
3: StackMap locals: org.apache.cassandra.db.ColumnFamilyStore
StackMap stack:
aload 2
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lorg/apache/cassandra/db/Keyspace;
0 4 1 id Ljava/util/UUID;
1 4 2 cfs Lorg/apache/cassandra/db/ColumnFamilyStore;
MethodParameters:
Name Flags
id
public boolean hasColumnFamilyStore(java.util.UUID);
descriptor: (Ljava/util/UUID;)Z
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.Keyspace.columnFamilyStores:Ljava/util/concurrent/ConcurrentMap;
aload 1
invokeinterface java.util.concurrent.ConcurrentMap.containsKey:(Ljava/lang/Object;)Z
ireturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/db/Keyspace;
0 1 1 id Ljava/util/UUID;
MethodParameters:
Name Flags
id
public void snapshot(java.lang.String, java.lang.String, boolean);
descriptor: (Ljava/lang/String;Ljava/lang/String;Z)V
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: getstatic org.apache.cassandra.db.Keyspace.$assertionsDisabled:Z
ifne 1
aload 1
ifnonnull 1
new java.lang.AssertionError
dup
invokespecial java.lang.AssertionError.<init>:()V
athrow
1: StackMap locals:
StackMap stack:
iconst_0
istore 4
start local 4 2: aload 0
getfield org.apache.cassandra.db.Keyspace.columnFamilyStores:Ljava/util/concurrent/ConcurrentMap;
invokeinterface java.util.concurrent.ConcurrentMap.values:()Ljava/util/Collection;
invokeinterface java.util.Collection.iterator:()Ljava/util/Iterator;
astore 6
goto 7
StackMap locals: org.apache.cassandra.db.Keyspace java.lang.String java.lang.String int int top java.util.Iterator
StackMap stack:
3: aload 6
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.db.ColumnFamilyStore
astore 5
start local 5 4: aload 2
ifnull 5
aload 5
getfield org.apache.cassandra.db.ColumnFamilyStore.name:Ljava/lang/String;
aload 2
invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
ifeq 7
5: StackMap locals: org.apache.cassandra.db.Keyspace java.lang.String java.lang.String int int org.apache.cassandra.db.ColumnFamilyStore java.util.Iterator
StackMap stack:
iconst_1
istore 4
6: aload 5
aload 1
iload 3
invokevirtual org.apache.cassandra.db.ColumnFamilyStore.snapshot:(Ljava/lang/String;Z)Ljava/util/Set;
pop
end local 5 7: StackMap locals: org.apache.cassandra.db.Keyspace java.lang.String java.lang.String int int top java.util.Iterator
StackMap stack:
aload 6
invokeinterface java.util.Iterator.hasNext:()Z
ifne 3
8: aload 2
ifnull 10
iload 4
ifne 10
9: new java.io.IOException
dup
new java.lang.StringBuilder
dup
ldc "Failed taking snapshot. Table "
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 2
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
ldc " does not exist."
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokespecial java.io.IOException.<init>:(Ljava/lang/String;)V
athrow
10: StackMap locals: org.apache.cassandra.db.Keyspace java.lang.String java.lang.String int int
StackMap stack:
return
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 11 0 this Lorg/apache/cassandra/db/Keyspace;
0 11 1 snapshotName Ljava/lang/String;
0 11 2 columnFamilyName Ljava/lang/String;
0 11 3 skipFlush Z
2 11 4 tookSnapShot Z
4 7 5 cfStore Lorg/apache/cassandra/db/ColumnFamilyStore;
Exceptions:
throws java.io.IOException
MethodParameters:
Name Flags
snapshotName
columnFamilyName
skipFlush
public void snapshot(java.lang.String, java.lang.String);
descriptor: (Ljava/lang/String;Ljava/lang/String;)V
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
aload 2
iconst_0
invokevirtual org.apache.cassandra.db.Keyspace.snapshot:(Ljava/lang/String;Ljava/lang/String;Z)V
1: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/apache/cassandra/db/Keyspace;
0 2 1 snapshotName Ljava/lang/String;
0 2 2 columnFamilyName Ljava/lang/String;
Exceptions:
throws java.io.IOException
MethodParameters:
Name Flags
snapshotName
columnFamilyName
public static java.lang.String getTimestampedSnapshotName(java.lang.String);
descriptor: (Ljava/lang/String;)Ljava/lang/String;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=3, locals=2, args_size=1
start local 0 0: invokestatic java.lang.System.currentTimeMillis:()J
invokestatic java.lang.Long.toString:(J)Ljava/lang/String;
astore 1
start local 1 1: aload 0
ifnull 3
aload 0
ldc ""
invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
ifne 3
2: new java.lang.StringBuilder
dup
aload 1
invokestatic java.lang.String.valueOf:(Ljava/lang/Object;)Ljava/lang/String;
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
ldc "-"
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
aload 0
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
astore 1
3: StackMap locals: java.lang.String
StackMap stack:
aload 1
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 clientSuppliedName Ljava/lang/String;
1 4 1 snapshotName Ljava/lang/String;
MethodParameters:
Name Flags
clientSuppliedName
public static java.lang.String getTimestampedSnapshotNameWithPrefix(java.lang.String, java.lang.String);
descriptor: (Ljava/lang/String;Ljava/lang/String;)Ljava/lang/String;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=3, locals=2, args_size=2
start local 0 start local 1 0: new java.lang.StringBuilder
dup
aload 1
invokestatic java.lang.String.valueOf:(Ljava/lang/Object;)Ljava/lang/String;
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
ldc "-"
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
aload 0
invokestatic org.apache.cassandra.db.Keyspace.getTimestampedSnapshotName:(Ljava/lang/String;)Ljava/lang/String;
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 clientSuppliedName Ljava/lang/String;
0 1 1 prefix Ljava/lang/String;
MethodParameters:
Name Flags
clientSuppliedName
prefix
public boolean snapshotExists(java.lang.String);
descriptor: (Ljava/lang/String;)Z
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=4, args_size=2
start local 0 start local 1 0: getstatic org.apache.cassandra.db.Keyspace.$assertionsDisabled:Z
ifne 1
aload 1
ifnonnull 1
new java.lang.AssertionError
dup
invokespecial java.lang.AssertionError.<init>:()V
athrow
1: StackMap locals:
StackMap stack:
aload 0
getfield org.apache.cassandra.db.Keyspace.columnFamilyStores:Ljava/util/concurrent/ConcurrentMap;
invokeinterface java.util.concurrent.ConcurrentMap.values:()Ljava/util/Collection;
invokeinterface java.util.Collection.iterator:()Ljava/util/Iterator;
astore 3
goto 5
StackMap locals: org.apache.cassandra.db.Keyspace java.lang.String top java.util.Iterator
StackMap stack:
2: aload 3
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.db.ColumnFamilyStore
astore 2
start local 2 3: aload 2
aload 1
invokevirtual org.apache.cassandra.db.ColumnFamilyStore.snapshotExists:(Ljava/lang/String;)Z
ifeq 5
4: iconst_1
ireturn
end local 2 5: StackMap locals:
StackMap stack:
aload 3
invokeinterface java.util.Iterator.hasNext:()Z
ifne 2
6: iconst_0
ireturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 7 0 this Lorg/apache/cassandra/db/Keyspace;
0 7 1 snapshotName Ljava/lang/String;
3 5 2 cfStore Lorg/apache/cassandra/db/ColumnFamilyStore;
MethodParameters:
Name Flags
snapshotName
public static void clearSnapshot(java.lang.String, java.lang.String);
descriptor: (Ljava/lang/String;Ljava/lang/String;)V
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=2, locals=3, args_size=2
start local 0 start local 1 0: aload 1
invokestatic org.apache.cassandra.db.ColumnFamilyStore.getInitialDirectories:()[Lorg/apache/cassandra/db/Directories$DataDirectory;
invokestatic org.apache.cassandra.db.Directories.getKSChildDirectories:(Ljava/lang/String;[Lorg/apache/cassandra/db/Directories$DataDirectory;)Ljava/util/List;
astore 2
start local 2 1: aload 0
aload 2
invokestatic org.apache.cassandra.db.Directories.clearSnapshot:(Ljava/lang/String;Ljava/util/List;)V
2: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 snapshotName Ljava/lang/String;
0 3 1 keyspace Ljava/lang/String;
1 3 2 snapshotDirs Ljava/util/List<Ljava/io/File;>;
MethodParameters:
Name Flags
snapshotName
keyspace
public java.util.List<org.apache.cassandra.io.sstable.format.SSTableReader> getAllSSTables(org.apache.cassandra.db.lifecycle.SSTableSet);
descriptor: (Lorg/apache/cassandra/db/lifecycle/SSTableSet;)Ljava/util/List;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=5, args_size=2
start local 0 start local 1 0: new java.util.ArrayList
dup
aload 0
getfield org.apache.cassandra.db.Keyspace.columnFamilyStores:Ljava/util/concurrent/ConcurrentMap;
invokeinterface java.util.concurrent.ConcurrentMap.size:()I
invokespecial java.util.ArrayList.<init>:(I)V
astore 2
start local 2 1: aload 0
getfield org.apache.cassandra.db.Keyspace.columnFamilyStores:Ljava/util/concurrent/ConcurrentMap;
invokeinterface java.util.concurrent.ConcurrentMap.values:()Ljava/util/Collection;
invokeinterface java.util.Collection.iterator:()Ljava/util/Iterator;
astore 4
goto 4
StackMap locals: org.apache.cassandra.db.Keyspace org.apache.cassandra.db.lifecycle.SSTableSet java.util.List top java.util.Iterator
StackMap stack:
2: aload 4
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.db.ColumnFamilyStore
astore 3
start local 3 3: aload 2
aload 3
aload 1
invokevirtual org.apache.cassandra.db.ColumnFamilyStore.getSSTables:(Lorg/apache/cassandra/db/lifecycle/SSTableSet;)Ljava/lang/Iterable;
invokestatic com.google.common.collect.Iterables.addAll:(Ljava/util/Collection;Ljava/lang/Iterable;)Z
pop
end local 3 4: StackMap locals:
StackMap stack:
aload 4
invokeinterface java.util.Iterator.hasNext:()Z
ifne 2
5: aload 2
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 this Lorg/apache/cassandra/db/Keyspace;
0 6 1 sstableSet Lorg/apache/cassandra/db/lifecycle/SSTableSet;
1 6 2 list Ljava/util/List<Lorg/apache/cassandra/io/sstable/format/SSTableReader;>;
3 4 3 cfStore Lorg/apache/cassandra/db/ColumnFamilyStore;
Signature: (Lorg/apache/cassandra/db/lifecycle/SSTableSet;)Ljava/util/List<Lorg/apache/cassandra/io/sstable/format/SSTableReader;>;
MethodParameters:
Name Flags
sstableSet
private void <init>(java.lang.String, boolean);
descriptor: (Ljava/lang/String;Z)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=5, locals=5, 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.ConcurrentHashMap
dup
invokespecial java.util.concurrent.ConcurrentHashMap.<init>:()V
putfield org.apache.cassandra.db.Keyspace.columnFamilyStores:Ljava/util/concurrent/ConcurrentMap;
2: aload 0
getstatic org.apache.cassandra.config.Schema.instance:Lorg/apache/cassandra/config/Schema;
aload 1
invokevirtual org.apache.cassandra.config.Schema.getKSMetaData:(Ljava/lang/String;)Lorg/apache/cassandra/schema/KeyspaceMetadata;
putfield org.apache.cassandra.db.Keyspace.metadata:Lorg/apache/cassandra/schema/KeyspaceMetadata;
3: getstatic org.apache.cassandra.db.Keyspace.$assertionsDisabled:Z
ifne 4
aload 0
getfield org.apache.cassandra.db.Keyspace.metadata:Lorg/apache/cassandra/schema/KeyspaceMetadata;
ifnonnull 4
new java.lang.AssertionError
dup
new java.lang.StringBuilder
dup
ldc "Unknown keyspace "
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 1
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokespecial java.lang.AssertionError.<init>:(Ljava/lang/Object;)V
athrow
4: StackMap locals: org.apache.cassandra.db.Keyspace java.lang.String int
StackMap stack:
aload 0
aload 0
getfield org.apache.cassandra.db.Keyspace.metadata:Lorg/apache/cassandra/schema/KeyspaceMetadata;
invokevirtual org.apache.cassandra.db.Keyspace.createReplicationStrategy:(Lorg/apache/cassandra/schema/KeyspaceMetadata;)V
5: aload 0
new org.apache.cassandra.metrics.KeyspaceMetrics
dup
aload 0
invokespecial org.apache.cassandra.metrics.KeyspaceMetrics.<init>:(Lorg/apache/cassandra/db/Keyspace;)V
putfield org.apache.cassandra.db.Keyspace.metric:Lorg/apache/cassandra/metrics/KeyspaceMetrics;
6: aload 0
new org.apache.cassandra.db.view.ViewManager
dup
aload 0
invokespecial org.apache.cassandra.db.view.ViewManager.<init>:(Lorg/apache/cassandra/db/Keyspace;)V
putfield org.apache.cassandra.db.Keyspace.viewManager:Lorg/apache/cassandra/db/view/ViewManager;
7: aload 0
getfield org.apache.cassandra.db.Keyspace.metadata:Lorg/apache/cassandra/schema/KeyspaceMetadata;
invokevirtual org.apache.cassandra.schema.KeyspaceMetadata.tablesAndViews:()Ljava/lang/Iterable;
invokeinterface java.lang.Iterable.iterator:()Ljava/util/Iterator;
astore 4
goto 11
StackMap locals: org.apache.cassandra.db.Keyspace java.lang.String int top java.util.Iterator
StackMap stack:
8: aload 4
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.config.CFMetaData
astore 3
start local 3 9: getstatic org.apache.cassandra.db.Keyspace.logger:Lorg/slf4j/Logger;
ldc "Initializing {}.{}"
aload 0
invokevirtual org.apache.cassandra.db.Keyspace.getName:()Ljava/lang/String;
aload 3
getfield org.apache.cassandra.config.CFMetaData.cfName:Ljava/lang/String;
invokeinterface org.slf4j.Logger.trace:(Ljava/lang/String;Ljava/lang/Object;Ljava/lang/Object;)V
10: aload 0
aload 3
iload 2
invokevirtual org.apache.cassandra.db.Keyspace.initCf:(Lorg/apache/cassandra/config/CFMetaData;Z)V
end local 3 11: StackMap locals:
StackMap stack:
aload 4
invokeinterface java.util.Iterator.hasNext:()Z
ifne 8
12: aload 0
getfield org.apache.cassandra.db.Keyspace.viewManager:Lorg/apache/cassandra/db/view/ViewManager;
invokevirtual org.apache.cassandra.db.view.ViewManager.reload:()V
13: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 14 0 this Lorg/apache/cassandra/db/Keyspace;
0 14 1 keyspaceName Ljava/lang/String;
0 14 2 loadSSTables Z
9 11 3 cfm Lorg/apache/cassandra/config/CFMetaData;
MethodParameters:
Name Flags
keyspaceName
loadSSTables
private void <init>(org.apache.cassandra.schema.KeyspaceMetadata);
descriptor: (Lorg/apache/cassandra/schema/KeyspaceMetadata;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=4, locals=2, args_size=2
start local 0 start local 1 0: aload 0
invokespecial java.lang.Object.<init>:()V
1: aload 0
new java.util.concurrent.ConcurrentHashMap
dup
invokespecial java.util.concurrent.ConcurrentHashMap.<init>:()V
putfield org.apache.cassandra.db.Keyspace.columnFamilyStores:Ljava/util/concurrent/ConcurrentMap;
2: aload 0
aload 1
putfield org.apache.cassandra.db.Keyspace.metadata:Lorg/apache/cassandra/schema/KeyspaceMetadata;
3: aload 0
aload 1
invokevirtual org.apache.cassandra.db.Keyspace.createReplicationStrategy:(Lorg/apache/cassandra/schema/KeyspaceMetadata;)V
4: aload 0
new org.apache.cassandra.metrics.KeyspaceMetrics
dup
aload 0
invokespecial org.apache.cassandra.metrics.KeyspaceMetrics.<init>:(Lorg/apache/cassandra/db/Keyspace;)V
putfield org.apache.cassandra.db.Keyspace.metric:Lorg/apache/cassandra/metrics/KeyspaceMetrics;
5: aload 0
new org.apache.cassandra.db.view.ViewManager
dup
aload 0
invokespecial org.apache.cassandra.db.view.ViewManager.<init>:(Lorg/apache/cassandra/db/Keyspace;)V
putfield org.apache.cassandra.db.Keyspace.viewManager:Lorg/apache/cassandra/db/view/ViewManager;
6: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 7 0 this Lorg/apache/cassandra/db/Keyspace;
0 7 1 metadata Lorg/apache/cassandra/schema/KeyspaceMetadata;
MethodParameters:
Name Flags
metadata
public static org.apache.cassandra.db.Keyspace mockKS(org.apache.cassandra.schema.KeyspaceMetadata);
descriptor: (Lorg/apache/cassandra/schema/KeyspaceMetadata;)Lorg/apache/cassandra/db/Keyspace;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=3, locals=1, args_size=1
start local 0 0: new org.apache.cassandra.db.Keyspace
dup
aload 0
invokespecial org.apache.cassandra.db.Keyspace.<init>:(Lorg/apache/cassandra/schema/KeyspaceMetadata;)V
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 metadata Lorg/apache/cassandra/schema/KeyspaceMetadata;
MethodParameters:
Name Flags
metadata
private void createReplicationStrategy(org.apache.cassandra.schema.KeyspaceMetadata);
descriptor: (Lorg/apache/cassandra/schema/KeyspaceMetadata;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=6, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
getfield org.apache.cassandra.schema.KeyspaceMetadata.name:Ljava/lang/String;
1: aload 1
getfield org.apache.cassandra.schema.KeyspaceMetadata.params:Lorg/apache/cassandra/schema/KeyspaceParams;
getfield org.apache.cassandra.schema.KeyspaceParams.replication:Lorg/apache/cassandra/schema/ReplicationParams;
getfield org.apache.cassandra.schema.ReplicationParams.klass:Ljava/lang/Class;
2: getstatic org.apache.cassandra.service.StorageService.instance:Lorg/apache/cassandra/service/StorageService;
invokevirtual org.apache.cassandra.service.StorageService.getTokenMetadata:()Lorg/apache/cassandra/locator/TokenMetadata;
3: invokestatic org.apache.cassandra.config.DatabaseDescriptor.getEndpointSnitch:()Lorg/apache/cassandra/locator/IEndpointSnitch;
4: aload 1
getfield org.apache.cassandra.schema.KeyspaceMetadata.params:Lorg/apache/cassandra/schema/KeyspaceParams;
getfield org.apache.cassandra.schema.KeyspaceParams.replication:Lorg/apache/cassandra/schema/ReplicationParams;
getfield org.apache.cassandra.schema.ReplicationParams.options:Lcom/google/common/collect/ImmutableMap;
5: invokestatic org.apache.cassandra.locator.AbstractReplicationStrategy.createReplicationStrategy:(Ljava/lang/String;Ljava/lang/Class;Lorg/apache/cassandra/locator/TokenMetadata;Lorg/apache/cassandra/locator/IEndpointSnitch;Ljava/util/Map;)Lorg/apache/cassandra/locator/AbstractReplicationStrategy;
putfield org.apache.cassandra.db.Keyspace.replicationStrategy:Lorg/apache/cassandra/locator/AbstractReplicationStrategy;
6: aload 1
getfield org.apache.cassandra.schema.KeyspaceMetadata.params:Lorg/apache/cassandra/schema/KeyspaceParams;
getfield org.apache.cassandra.schema.KeyspaceParams.replication:Lorg/apache/cassandra/schema/ReplicationParams;
aload 0
getfield org.apache.cassandra.db.Keyspace.replicationParams:Lorg/apache/cassandra/schema/ReplicationParams;
invokevirtual org.apache.cassandra.schema.ReplicationParams.equals:(Ljava/lang/Object;)Z
ifne 9
7: getstatic org.apache.cassandra.db.Keyspace.logger:Lorg/slf4j/Logger;
ldc "New replication settings for keyspace {} - invalidating disk boundary caches"
aload 1
getfield org.apache.cassandra.schema.KeyspaceMetadata.name:Ljava/lang/String;
invokeinterface org.slf4j.Logger.debug:(Ljava/lang/String;Ljava/lang/Object;)V
8: aload 0
getfield org.apache.cassandra.db.Keyspace.columnFamilyStores:Ljava/util/concurrent/ConcurrentMap;
invokeinterface java.util.concurrent.ConcurrentMap.values:()Ljava/util/Collection;
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/ColumnFamilyStore.invalidateDiskBoundaries()V (5)
(Lorg/apache/cassandra/db/ColumnFamilyStore;)V
invokeinterface java.util.Collection.forEach:(Ljava/util/function/Consumer;)V
9: StackMap locals:
StackMap stack:
aload 0
aload 1
getfield org.apache.cassandra.schema.KeyspaceMetadata.params:Lorg/apache/cassandra/schema/KeyspaceParams;
getfield org.apache.cassandra.schema.KeyspaceParams.replication:Lorg/apache/cassandra/schema/ReplicationParams;
putfield org.apache.cassandra.db.Keyspace.replicationParams:Lorg/apache/cassandra/schema/ReplicationParams;
10: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 11 0 this Lorg/apache/cassandra/db/Keyspace;
0 11 1 ksm Lorg/apache/cassandra/schema/KeyspaceMetadata;
MethodParameters:
Name Flags
ksm
public void dropCf(java.util.UUID);
descriptor: (Ljava/util/UUID;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=3, args_size=2
start local 0 start local 1 0: getstatic org.apache.cassandra.db.Keyspace.$assertionsDisabled:Z
ifne 1
aload 0
getfield org.apache.cassandra.db.Keyspace.columnFamilyStores:Ljava/util/concurrent/ConcurrentMap;
aload 1
invokeinterface java.util.concurrent.ConcurrentMap.containsKey:(Ljava/lang/Object;)Z
ifne 1
new java.lang.AssertionError
dup
invokespecial java.lang.AssertionError.<init>:()V
athrow
1: StackMap locals:
StackMap stack:
aload 0
getfield org.apache.cassandra.db.Keyspace.columnFamilyStores:Ljava/util/concurrent/ConcurrentMap;
aload 1
invokeinterface java.util.concurrent.ConcurrentMap.remove:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast org.apache.cassandra.db.ColumnFamilyStore
astore 2
start local 2 2: aload 2
ifnonnull 4
3: return
4: StackMap locals: org.apache.cassandra.db.ColumnFamilyStore
StackMap stack:
aload 2
invokevirtual org.apache.cassandra.db.ColumnFamilyStore.getCompactionStrategyManager:()Lorg/apache/cassandra/db/compaction/CompactionStrategyManager;
invokevirtual org.apache.cassandra.db.compaction.CompactionStrategyManager.shutdown:()V
5: getstatic org.apache.cassandra.db.compaction.CompactionManager.instance:Lorg/apache/cassandra/db/compaction/CompactionManager;
aload 2
invokevirtual org.apache.cassandra.db.ColumnFamilyStore.concatWithIndexes:()Ljava/lang/Iterable;
iconst_1
invokevirtual org.apache.cassandra.db.compaction.CompactionManager.interruptCompactionForCFs:(Ljava/lang/Iterable;Z)V
6: aload 2
getfield org.apache.cassandra.db.ColumnFamilyStore.keyspace:Lorg/apache/cassandra/db/Keyspace;
pop
getstatic org.apache.cassandra.db.Keyspace.writeOrder:Lorg/apache/cassandra/utils/concurrent/OpOrder;
invokevirtual org.apache.cassandra.utils.concurrent.OpOrder.awaitNewBarrier:()V
7: aload 2
getfield org.apache.cassandra.db.ColumnFamilyStore.readOrdering:Lorg/apache/cassandra/utils/concurrent/OpOrder;
invokevirtual org.apache.cassandra.utils.concurrent.OpOrder.awaitNewBarrier:()V
8: aload 0
aload 2
invokevirtual org.apache.cassandra.db.Keyspace.unloadCf:(Lorg/apache/cassandra/db/ColumnFamilyStore;)V
9: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 10 0 this Lorg/apache/cassandra/db/Keyspace;
0 10 1 cfId Ljava/util/UUID;
2 10 2 cfs Lorg/apache/cassandra/db/ColumnFamilyStore;
MethodParameters:
Name Flags
cfId
private void unloadCf(org.apache.cassandra.db.ColumnFamilyStore);
descriptor: (Lorg/apache/cassandra/db/ColumnFamilyStore;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=1, locals=2, args_size=2
start local 0 start local 1 0: aload 1
invokevirtual org.apache.cassandra.db.ColumnFamilyStore.forceBlockingFlush:()Lorg/apache/cassandra/db/commitlog/CommitLogPosition;
pop
1: aload 1
invokevirtual org.apache.cassandra.db.ColumnFamilyStore.invalidate:()V
2: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lorg/apache/cassandra/db/Keyspace;
0 3 1 cfs Lorg/apache/cassandra/db/ColumnFamilyStore;
MethodParameters:
Name Flags
cfs
public void initCfCustom(org.apache.cassandra.db.ColumnFamilyStore);
descriptor: (Lorg/apache/cassandra/db/ColumnFamilyStore;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=4, args_size=2
start local 0 start local 1 0: aload 0
getfield org.apache.cassandra.db.Keyspace.columnFamilyStores:Ljava/util/concurrent/ConcurrentMap;
aload 1
getfield org.apache.cassandra.db.ColumnFamilyStore.metadata:Lorg/apache/cassandra/config/CFMetaData;
getfield org.apache.cassandra.config.CFMetaData.cfId:Ljava/util/UUID;
invokeinterface java.util.concurrent.ConcurrentMap.get:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast org.apache.cassandra.db.ColumnFamilyStore
astore 2
start local 2 1: aload 2
ifnonnull 5
2: aload 0
getfield org.apache.cassandra.db.Keyspace.columnFamilyStores:Ljava/util/concurrent/ConcurrentMap;
aload 1
getfield org.apache.cassandra.db.ColumnFamilyStore.metadata:Lorg/apache/cassandra/config/CFMetaData;
getfield org.apache.cassandra.config.CFMetaData.cfId:Ljava/util/UUID;
aload 1
invokeinterface java.util.concurrent.ConcurrentMap.putIfAbsent:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
checkcast org.apache.cassandra.db.ColumnFamilyStore
astore 3
start local 3 3: aload 3
ifnull 6
4: new java.lang.IllegalStateException
dup
new java.lang.StringBuilder
dup
ldc "added multiple mappings for cf id "
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 1
getfield org.apache.cassandra.db.ColumnFamilyStore.metadata:Lorg/apache/cassandra/config/CFMetaData;
getfield org.apache.cassandra.config.CFMetaData.cfId:Ljava/util/UUID;
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/Object;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokespecial java.lang.IllegalStateException.<init>:(Ljava/lang/String;)V
athrow
end local 3 5: StackMap locals: org.apache.cassandra.db.ColumnFamilyStore
StackMap stack:
new java.lang.IllegalStateException
dup
new java.lang.StringBuilder
dup
ldc "CFS is already initialized: "
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 2
getfield org.apache.cassandra.db.ColumnFamilyStore.name:Ljava/lang/String;
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokespecial java.lang.IllegalStateException.<init>:(Ljava/lang/String;)V
athrow
6: StackMap locals:
StackMap stack:
return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 7 0 this Lorg/apache/cassandra/db/Keyspace;
0 7 1 newCfs Lorg/apache/cassandra/db/ColumnFamilyStore;
1 7 2 cfs Lorg/apache/cassandra/db/ColumnFamilyStore;
3 5 3 oldCfs Lorg/apache/cassandra/db/ColumnFamilyStore;
MethodParameters:
Name Flags
newCfs
public void initCf(org.apache.cassandra.config.CFMetaData, boolean);
descriptor: (Lorg/apache/cassandra/config/CFMetaData;Z)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=5, args_size=3
start local 0 start local 1 start local 2 0: aload 0
getfield org.apache.cassandra.db.Keyspace.columnFamilyStores:Ljava/util/concurrent/ConcurrentMap;
aload 1
getfield org.apache.cassandra.config.CFMetaData.cfId:Ljava/util/UUID;
invokeinterface java.util.concurrent.ConcurrentMap.get:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast org.apache.cassandra.db.ColumnFamilyStore
astore 3
start local 3 1: aload 3
ifnonnull 5
2: aload 0
getfield org.apache.cassandra.db.Keyspace.columnFamilyStores:Ljava/util/concurrent/ConcurrentMap;
aload 1
getfield org.apache.cassandra.config.CFMetaData.cfId:Ljava/util/UUID;
aload 0
aload 1
iload 2
invokestatic org.apache.cassandra.db.ColumnFamilyStore.createColumnFamilyStore:(Lorg/apache/cassandra/db/Keyspace;Lorg/apache/cassandra/config/CFMetaData;Z)Lorg/apache/cassandra/db/ColumnFamilyStore;
invokeinterface java.util.concurrent.ConcurrentMap.putIfAbsent:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
checkcast org.apache.cassandra.db.ColumnFamilyStore
astore 4
start local 4 3: aload 4
ifnull 7
4: new java.lang.IllegalStateException
dup
new java.lang.StringBuilder
dup
ldc "added multiple mappings for cf id "
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 1
getfield org.apache.cassandra.config.CFMetaData.cfId:Ljava/util/UUID;
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/Object;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokespecial java.lang.IllegalStateException.<init>:(Ljava/lang/String;)V
athrow
end local 4 5: StackMap locals: org.apache.cassandra.db.ColumnFamilyStore
StackMap stack:
getstatic org.apache.cassandra.db.Keyspace.$assertionsDisabled:Z
ifne 6
aload 3
getfield org.apache.cassandra.db.ColumnFamilyStore.name:Ljava/lang/String;
aload 1
getfield org.apache.cassandra.config.CFMetaData.cfName:Ljava/lang/String;
invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
ifne 6
new java.lang.AssertionError
dup
invokespecial java.lang.AssertionError.<init>:()V
athrow
6: StackMap locals:
StackMap stack:
aload 3
invokevirtual org.apache.cassandra.db.ColumnFamilyStore.reload:()V
7: StackMap locals:
StackMap stack:
return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 8 0 this Lorg/apache/cassandra/db/Keyspace;
0 8 1 metadata Lorg/apache/cassandra/config/CFMetaData;
0 8 2 loadSSTables Z
1 8 3 cfs Lorg/apache/cassandra/db/ColumnFamilyStore;
3 5 4 oldCfs Lorg/apache/cassandra/db/ColumnFamilyStore;
MethodParameters:
Name Flags
metadata
loadSSTables
public java.util.concurrent.CompletableFuture<?> applyFuture(org.apache.cassandra.db.Mutation, boolean, boolean);
descriptor: (Lorg/apache/cassandra/db/Mutation;ZZ)Ljava/util/concurrent/CompletableFuture;
flags: (0x0001) ACC_PUBLIC
Code:
stack=8, locals=4, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
aload 1
iload 2
iload 3
iconst_1
iconst_1
new java.util.concurrent.CompletableFuture
dup
invokespecial java.util.concurrent.CompletableFuture.<init>:()V
invokevirtual org.apache.cassandra.db.Keyspace.applyInternal:(Lorg/apache/cassandra/db/Mutation;ZZZZLjava/util/concurrent/CompletableFuture;)Ljava/util/concurrent/CompletableFuture;
areturn
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/db/Keyspace;
0 1 1 mutation Lorg/apache/cassandra/db/Mutation;
0 1 2 writeCommitLog Z
0 1 3 updateIndexes Z
Signature: (Lorg/apache/cassandra/db/Mutation;ZZ)Ljava/util/concurrent/CompletableFuture<*>;
MethodParameters:
Name Flags
mutation
writeCommitLog
updateIndexes
public java.util.concurrent.CompletableFuture<?> applyFuture(org.apache.cassandra.db.Mutation, boolean, boolean, boolean, boolean);
descriptor: (Lorg/apache/cassandra/db/Mutation;ZZZZ)Ljava/util/concurrent/CompletableFuture;
flags: (0x0001) ACC_PUBLIC
Code:
stack=8, locals=6, args_size=6
start local 0 start local 1 start local 2 start local 3 start local 4 start local 5 0: aload 0
aload 1
iload 2
iload 3
iload 4
iload 5
new java.util.concurrent.CompletableFuture
dup
invokespecial java.util.concurrent.CompletableFuture.<init>:()V
invokevirtual org.apache.cassandra.db.Keyspace.applyInternal:(Lorg/apache/cassandra/db/Mutation;ZZZZLjava/util/concurrent/CompletableFuture;)Ljava/util/concurrent/CompletableFuture;
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 1 0 this Lorg/apache/cassandra/db/Keyspace;
0 1 1 mutation Lorg/apache/cassandra/db/Mutation;
0 1 2 writeCommitLog Z
0 1 3 updateIndexes Z
0 1 4 isDroppable Z
0 1 5 isDeferrable Z
Signature: (Lorg/apache/cassandra/db/Mutation;ZZZZ)Ljava/util/concurrent/CompletableFuture<*>;
MethodParameters:
Name Flags
mutation
writeCommitLog
updateIndexes
isDroppable
isDeferrable
public void apply(org.apache.cassandra.db.Mutation, boolean, boolean);
descriptor: (Lorg/apache/cassandra/db/Mutation;ZZ)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
aload 1
iload 2
iload 3
iconst_1
invokevirtual org.apache.cassandra.db.Keyspace.apply:(Lorg/apache/cassandra/db/Mutation;ZZZ)V
1: return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/apache/cassandra/db/Keyspace;
0 2 1 mutation Lorg/apache/cassandra/db/Mutation;
0 2 2 writeCommitLog Z
0 2 3 updateIndexes Z
MethodParameters:
Name Flags
mutation
writeCommitLog
updateIndexes
public void apply(org.apache.cassandra.db.Mutation, boolean);
descriptor: (Lorg/apache/cassandra/db/Mutation;Z)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
aload 1
iload 2
iconst_1
iconst_1
invokevirtual org.apache.cassandra.db.Keyspace.apply:(Lorg/apache/cassandra/db/Mutation;ZZZ)V
1: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/apache/cassandra/db/Keyspace;
0 2 1 mutation Lorg/apache/cassandra/db/Mutation;
0 2 2 writeCommitLog Z
MethodParameters:
Name Flags
mutation final
writeCommitLog final
public void apply(org.apache.cassandra.db.Mutation, boolean, boolean, boolean);
descriptor: (Lorg/apache/cassandra/db/Mutation;ZZZ)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=7, locals=5, args_size=5
start local 0 start local 1 start local 2 start local 3 start local 4 0: aload 0
aload 1
iload 2
iload 3
iload 4
iconst_0
aconst_null
invokevirtual org.apache.cassandra.db.Keyspace.applyInternal:(Lorg/apache/cassandra/db/Mutation;ZZZZLjava/util/concurrent/CompletableFuture;)Ljava/util/concurrent/CompletableFuture;
pop
1: return
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/apache/cassandra/db/Keyspace;
0 2 1 mutation Lorg/apache/cassandra/db/Mutation;
0 2 2 writeCommitLog Z
0 2 3 updateIndexes Z
0 2 4 isDroppable Z
MethodParameters:
Name Flags
mutation final
writeCommitLog final
updateIndexes
isDroppable
private java.util.concurrent.CompletableFuture<?> applyInternal(org.apache.cassandra.db.Mutation, boolean, boolean, boolean, boolean, java.util.concurrent.CompletableFuture<?>);
descriptor: (Lorg/apache/cassandra/db/Mutation;ZZZZLjava/util/concurrent/CompletableFuture;)Ljava/util/concurrent/CompletableFuture;
flags: (0x0002) ACC_PRIVATE
Code:
stack=7, locals=25, args_size=7
start local 0 start local 1 start local 2 start local 3 start local 4 start local 5 start local 6 0: getstatic org.apache.cassandra.db.Keyspace.TEST_FAIL_WRITES:Z
ifeq 2
aload 0
getfield org.apache.cassandra.db.Keyspace.metadata:Lorg/apache/cassandra/schema/KeyspaceMetadata;
getfield org.apache.cassandra.schema.KeyspaceMetadata.name:Ljava/lang/String;
getstatic org.apache.cassandra.db.Keyspace.TEST_FAIL_WRITES_KS:Ljava/lang/String;
invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
ifeq 2
1: new java.lang.RuntimeException
dup
ldc "Testing write failures"
invokespecial java.lang.RuntimeException.<init>:(Ljava/lang/String;)V
athrow
2: StackMap locals:
StackMap stack:
aconst_null
astore 7
start local 7 3: iload 3
ifeq 4
aload 0
getfield org.apache.cassandra.db.Keyspace.viewManager:Lorg/apache/cassandra/db/view/ViewManager;
aload 1
invokestatic java.util.Collections.singleton:(Ljava/lang/Object;)Ljava/util/Set;
iconst_0
invokevirtual org.apache.cassandra.db.view.ViewManager.updatesAffectView:(Ljava/util/Collection;Z)Z
ifeq 4
iconst_1
goto 5
StackMap locals: java.util.concurrent.locks.Lock[]
StackMap stack:
4: iconst_0
StackMap locals:
StackMap stack: int
5: istore 8
start local 8 6: iload 8
ifeq 54
7: aload 1
getfield org.apache.cassandra.db.Mutation.viewLockAcquireStart:Ljava/util/concurrent/atomic/AtomicLong;
lconst_0
invokestatic java.lang.System.currentTimeMillis:()J
invokevirtual java.util.concurrent.atomic.AtomicLong.compareAndSet:(JJ)Z
pop
8: aload 1
invokevirtual org.apache.cassandra.db.Mutation.getColumnFamilyIds:()Ljava/util/Collection;
astore 9
start local 9 9: aload 9
invokeinterface java.util.Collection.iterator:()Ljava/util/Iterator;
astore 10
start local 10 10: aload 9
invokeinterface java.util.Collection.size:()I
anewarray java.util.concurrent.locks.Lock
astore 7
11: iconst_0
istore 11
start local 11 12: goto 47
13: StackMap locals: org.apache.cassandra.db.Keyspace org.apache.cassandra.db.Mutation int int int int java.util.concurrent.CompletableFuture java.util.concurrent.locks.Lock[] int java.util.Collection java.util.Iterator int
StackMap stack:
aload 10
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast java.util.UUID
astore 12
start local 12 14: iconst_2
anewarray java.lang.Object
dup
iconst_0
aload 1
invokevirtual org.apache.cassandra.db.Mutation.key:()Lorg/apache/cassandra/db/DecoratedKey;
invokevirtual org.apache.cassandra.db.DecoratedKey.getKey:()Ljava/nio/ByteBuffer;
aastore
dup
iconst_1
aload 12
aastore
invokestatic java.util.Objects.hash:([Ljava/lang/Object;)I
istore 13
start local 13 15: StackMap locals: java.util.UUID int
StackMap stack:
aconst_null
astore 14
start local 14 16: getstatic org.apache.cassandra.db.Keyspace.TEST_FAIL_MV_LOCKS_COUNT:I
ifne 18
17: iload 13
invokestatic org.apache.cassandra.db.view.ViewManager.acquireLockFor:(I)Ljava/util/concurrent/locks/Lock;
astore 14
goto 19
18: StackMap locals: java.util.concurrent.locks.Lock
StackMap stack:
getstatic org.apache.cassandra.db.Keyspace.TEST_FAIL_MV_LOCKS_COUNT:I
iconst_1
isub
putstatic org.apache.cassandra.db.Keyspace.TEST_FAIL_MV_LOCKS_COUNT:I
19: StackMap locals:
StackMap stack:
aload 14
ifnonnull 45
20: iload 4
ifeq 32
invokestatic java.lang.System.currentTimeMillis:()J
aload 1
getfield org.apache.cassandra.db.Mutation.createdAt:J
lsub
invokestatic org.apache.cassandra.config.DatabaseDescriptor.getWriteRpcTimeout:()J
lcmp
ifle 32
21: iconst_0
istore 15
start local 15 22: goto 25
23: StackMap locals: int
StackMap stack:
aload 7
iload 15
aaload
invokeinterface java.util.concurrent.locks.Lock.unlock:()V
24: iinc 15 1
StackMap locals:
StackMap stack:
25: iload 15
iload 11
if_icmplt 23
end local 15 26: getstatic org.apache.cassandra.db.Keyspace.logger:Lorg/slf4j/Logger;
ldc "Could not acquire lock for {} and table {}"
aload 1
invokevirtual org.apache.cassandra.db.Mutation.key:()Lorg/apache/cassandra/db/DecoratedKey;
invokevirtual org.apache.cassandra.db.DecoratedKey.getKey:()Ljava/nio/ByteBuffer;
invokestatic org.apache.cassandra.utils.ByteBufferUtil.bytesToHex:(Ljava/nio/ByteBuffer;)Ljava/lang/String;
aload 0
getfield org.apache.cassandra.db.Keyspace.columnFamilyStores:Ljava/util/concurrent/ConcurrentMap;
aload 12
invokeinterface java.util.concurrent.ConcurrentMap.get:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast org.apache.cassandra.db.ColumnFamilyStore
getfield org.apache.cassandra.db.ColumnFamilyStore.name:Ljava/lang/String;
invokeinterface org.slf4j.Logger.trace:(Ljava/lang/String;Ljava/lang/Object;Ljava/lang/Object;)V
27: ldc "Could not acquire MV lock"
invokestatic org.apache.cassandra.tracing.Tracing.trace:(Ljava/lang/String;)V
28: aload 6
ifnull 31
29: aload 6
new org.apache.cassandra.exceptions.WriteTimeoutException
dup
getstatic org.apache.cassandra.db.WriteType.VIEW:Lorg/apache/cassandra/db/WriteType;
getstatic org.apache.cassandra.db.ConsistencyLevel.LOCAL_ONE:Lorg/apache/cassandra/db/ConsistencyLevel;
iconst_0
iconst_1
invokespecial org.apache.cassandra.exceptions.WriteTimeoutException.<init>:(Lorg/apache/cassandra/db/WriteType;Lorg/apache/cassandra/db/ConsistencyLevel;II)V
invokevirtual java.util.concurrent.CompletableFuture.completeExceptionally:(Ljava/lang/Throwable;)Z
pop
30: aload 6
areturn
31: StackMap locals:
StackMap stack:
new org.apache.cassandra.exceptions.WriteTimeoutException
dup
getstatic org.apache.cassandra.db.WriteType.VIEW:Lorg/apache/cassandra/db/WriteType;
getstatic org.apache.cassandra.db.ConsistencyLevel.LOCAL_ONE:Lorg/apache/cassandra/db/ConsistencyLevel;
iconst_0
iconst_1
invokespecial org.apache.cassandra.exceptions.WriteTimeoutException.<init>:(Lorg/apache/cassandra/db/WriteType;Lorg/apache/cassandra/db/ConsistencyLevel;II)V
athrow
32: StackMap locals:
StackMap stack:
iload 5
ifeq 41
33: iconst_0
istore 15
start local 15 34: goto 37
35: StackMap locals: int
StackMap stack:
aload 7
iload 15
aaload
invokeinterface java.util.concurrent.locks.Lock.unlock:()V
36: iinc 15 1
StackMap locals:
StackMap stack:
37: iload 15
iload 11
if_icmplt 35
end local 15 38: aload 6
astore 15
start local 15 39: getstatic org.apache.cassandra.concurrent.Stage.MUTATION:Lorg/apache/cassandra/concurrent/Stage;
invokestatic org.apache.cassandra.concurrent.StageManager.getStage:(Lorg/apache/cassandra/concurrent/Stage;)Lorg/apache/cassandra/concurrent/LocalAwareExecutorService;
aload 0
aload 1
iload 2
iload 4
aload 15
invokedynamic run(Lorg/apache/cassandra/db/Keyspace;Lorg/apache/cassandra/db/Mutation;ZZLjava/util/concurrent/CompletableFuture;)Ljava/lang/Runnable;
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:
()V
org/apache/cassandra/db/Keyspace.lambda$1(Lorg/apache/cassandra/db/Mutation;ZZLjava/util/concurrent/CompletableFuture;)V (7)
()V
invokeinterface org.apache.cassandra.concurrent.LocalAwareExecutorService.execute:(Ljava/lang/Runnable;)V
40: aload 6
areturn
end local 15 41: StackMap locals:
StackMap stack:
ldc 10
invokestatic java.lang.Thread.sleep:(J)V
42: goto 15
43: StackMap locals:
StackMap stack: java.lang.InterruptedException
pop
44: goto 15
45: StackMap locals:
StackMap stack:
aload 7
iload 11
aload 14
aastore
end local 14 end local 13 end local 12 46: iinc 11 1
StackMap locals:
StackMap stack:
47: iload 11
aload 9
invokeinterface java.util.Collection.size:()I
if_icmplt 13
end local 11 48: invokestatic java.lang.System.currentTimeMillis:()J
aload 1
getfield org.apache.cassandra.db.Mutation.viewLockAcquireStart:Ljava/util/concurrent/atomic/AtomicLong;
invokevirtual java.util.concurrent.atomic.AtomicLong.get:()J
lsub
lstore 11
start local 11 49: iload 4
ifeq 54
50: aload 9
invokeinterface java.util.Collection.iterator:()Ljava/util/Iterator;
astore 14
goto 53
StackMap locals: org.apache.cassandra.db.Keyspace org.apache.cassandra.db.Mutation int int int int java.util.concurrent.CompletableFuture java.util.concurrent.locks.Lock[] int java.util.Collection java.util.Iterator long top java.util.Iterator
StackMap stack:
51: aload 14
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast java.util.UUID
astore 13
start local 13 52: aload 0
getfield org.apache.cassandra.db.Keyspace.columnFamilyStores:Ljava/util/concurrent/ConcurrentMap;
aload 13
invokeinterface java.util.concurrent.ConcurrentMap.get:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast org.apache.cassandra.db.ColumnFamilyStore
getfield org.apache.cassandra.db.ColumnFamilyStore.metric:Lorg/apache/cassandra/metrics/TableMetrics;
getfield org.apache.cassandra.metrics.TableMetrics.viewLockAcquireTime:Lorg/apache/cassandra/metrics/TableMetrics$TableTimer;
lload 11
getstatic java.util.concurrent.TimeUnit.MILLISECONDS:Ljava/util/concurrent/TimeUnit;
invokevirtual org.apache.cassandra.metrics.TableMetrics$TableTimer.update:(JLjava/util/concurrent/TimeUnit;)V
end local 13 53: StackMap locals:
StackMap stack:
aload 14
invokeinterface java.util.Iterator.hasNext:()Z
ifne 51
end local 11 end local 10 end local 9 54: StackMap locals: org.apache.cassandra.db.Keyspace org.apache.cassandra.db.Mutation int int int int java.util.concurrent.CompletableFuture java.util.concurrent.locks.Lock[] int
StackMap stack:
invokestatic org.apache.cassandra.utils.FBUtilities.nowInSeconds:()I
istore 9
start local 9 55: aconst_null
astore 10
aconst_null
astore 11
56: getstatic org.apache.cassandra.db.Keyspace.writeOrder:Lorg/apache/cassandra/utils/concurrent/OpOrder;
invokevirtual org.apache.cassandra.utils.concurrent.OpOrder.start:()Lorg/apache/cassandra/utils/concurrent/OpOrder$Group;
astore 12
start local 12 57: aconst_null
astore 13
start local 13 58: iload 2
ifeq 61
59: ldc "Appending to commitlog"
invokestatic org.apache.cassandra.tracing.Tracing.trace:(Ljava/lang/String;)V
60: getstatic org.apache.cassandra.db.commitlog.CommitLog.instance:Lorg/apache/cassandra/db/commitlog/CommitLog;
aload 1
invokevirtual org.apache.cassandra.db.commitlog.CommitLog.add:(Lorg/apache/cassandra/db/Mutation;)Lorg/apache/cassandra/db/commitlog/CommitLogPosition;
astore 13
61: StackMap locals: org.apache.cassandra.db.Keyspace org.apache.cassandra.db.Mutation int int int int java.util.concurrent.CompletableFuture java.util.concurrent.locks.Lock[] int int java.lang.Throwable java.lang.Throwable org.apache.cassandra.utils.concurrent.OpOrder$Group org.apache.cassandra.db.commitlog.CommitLogPosition
StackMap stack:
aload 1
invokevirtual org.apache.cassandra.db.Mutation.getPartitionUpdates:()Ljava/util/Collection;
invokeinterface java.util.Collection.iterator:()Ljava/util/Iterator;
astore 15
goto 88
StackMap locals: org.apache.cassandra.db.Keyspace org.apache.cassandra.db.Mutation int int int int java.util.concurrent.CompletableFuture java.util.concurrent.locks.Lock[] int int java.lang.Throwable java.lang.Throwable org.apache.cassandra.utils.concurrent.OpOrder$Group org.apache.cassandra.db.commitlog.CommitLogPosition top java.util.Iterator
StackMap stack:
62: aload 15
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.db.partitions.PartitionUpdate
astore 14
start local 14 63: aload 0
getfield org.apache.cassandra.db.Keyspace.columnFamilyStores:Ljava/util/concurrent/ConcurrentMap;
aload 14
invokevirtual org.apache.cassandra.db.partitions.PartitionUpdate.metadata:()Lorg/apache/cassandra/config/CFMetaData;
getfield org.apache.cassandra.config.CFMetaData.cfId:Ljava/util/UUID;
invokeinterface java.util.concurrent.ConcurrentMap.get:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast org.apache.cassandra.db.ColumnFamilyStore
astore 16
start local 16 64: aload 16
ifnonnull 67
65: getstatic org.apache.cassandra.db.Keyspace.logger:Lorg/slf4j/Logger;
ldc "Attempting to mutate non-existant table {} ({}.{})"
iconst_3
anewarray java.lang.Object
dup
iconst_0
aload 14
invokevirtual org.apache.cassandra.db.partitions.PartitionUpdate.metadata:()Lorg/apache/cassandra/config/CFMetaData;
getfield org.apache.cassandra.config.CFMetaData.cfId:Ljava/util/UUID;
aastore
dup
iconst_1
aload 14
invokevirtual org.apache.cassandra.db.partitions.PartitionUpdate.metadata:()Lorg/apache/cassandra/config/CFMetaData;
getfield org.apache.cassandra.config.CFMetaData.ksName:Ljava/lang/String;
aastore
dup
iconst_2
aload 14
invokevirtual org.apache.cassandra.db.partitions.PartitionUpdate.metadata:()Lorg/apache/cassandra/config/CFMetaData;
getfield org.apache.cassandra.config.CFMetaData.cfName:Ljava/lang/String;
aastore
invokeinterface org.slf4j.Logger.error:(Ljava/lang/String;[Ljava/lang/Object;)V
66: goto 88
67: StackMap locals: org.apache.cassandra.db.Keyspace org.apache.cassandra.db.Mutation int int int int java.util.concurrent.CompletableFuture java.util.concurrent.locks.Lock[] int int java.lang.Throwable java.lang.Throwable org.apache.cassandra.utils.concurrent.OpOrder$Group org.apache.cassandra.db.commitlog.CommitLogPosition org.apache.cassandra.db.partitions.PartitionUpdate java.util.Iterator org.apache.cassandra.db.ColumnFamilyStore
StackMap stack:
new java.util.concurrent.atomic.AtomicLong
dup
ldc 9223372036854775807
invokespecial java.util.concurrent.atomic.AtomicLong.<init>:(J)V
astore 17
start local 17 68: iload 8
ifeq 80
69: ldc "Creating materialized view mutations from base table replica"
invokestatic org.apache.cassandra.tracing.Tracing.trace:(Ljava/lang/String;)V
70: aload 0
getfield org.apache.cassandra.db.Keyspace.viewManager:Lorg/apache/cassandra/db/view/ViewManager;
aload 14
invokevirtual org.apache.cassandra.db.partitions.PartitionUpdate.metadata:()Lorg/apache/cassandra/config/CFMetaData;
invokevirtual org.apache.cassandra.db.view.ViewManager.forTable:(Lorg/apache/cassandra/config/CFMetaData;)Lorg/apache/cassandra/db/view/TableViews;
aload 14
iload 2
aload 17
invokevirtual org.apache.cassandra.db.view.TableViews.pushViewReplicaUpdates:(Lorg/apache/cassandra/db/partitions/PartitionUpdate;ZLjava/util/concurrent/atomic/AtomicLong;)V
71: goto 80
72: StackMap locals: org.apache.cassandra.db.Keyspace org.apache.cassandra.db.Mutation int int int int java.util.concurrent.CompletableFuture java.util.concurrent.locks.Lock[] int int java.lang.Throwable java.lang.Throwable org.apache.cassandra.utils.concurrent.OpOrder$Group org.apache.cassandra.db.commitlog.CommitLogPosition org.apache.cassandra.db.partitions.PartitionUpdate java.util.Iterator org.apache.cassandra.db.ColumnFamilyStore java.util.concurrent.atomic.AtomicLong
StackMap stack: java.lang.Throwable
astore 18
start local 18 73: aload 18
invokestatic org.apache.cassandra.utils.JVMStabilityInspector.inspectThrowable:(Ljava/lang/Throwable;)V
74: getstatic org.apache.cassandra.db.Keyspace.logger:Lorg/slf4j/Logger;
ldc "Unknown exception caught while attempting to update MaterializedView! %s.%s"
iconst_2
anewarray java.lang.Object
dup
iconst_0
75: aload 14
invokevirtual org.apache.cassandra.db.partitions.PartitionUpdate.metadata:()Lorg/apache/cassandra/config/CFMetaData;
getfield org.apache.cassandra.config.CFMetaData.ksName:Ljava/lang/String;
aastore
dup
iconst_1
aload 14
invokevirtual org.apache.cassandra.db.partitions.PartitionUpdate.metadata:()Lorg/apache/cassandra/config/CFMetaData;
getfield org.apache.cassandra.config.CFMetaData.cfName:Ljava/lang/String;
aastore
76: invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
77: aload 18
78: invokeinterface org.slf4j.Logger.error:(Ljava/lang/String;Ljava/lang/Throwable;)V
79: aload 18
athrow
end local 18 80: StackMap locals:
StackMap stack:
ldc "Adding to {} memtable"
aload 14
invokevirtual org.apache.cassandra.db.partitions.PartitionUpdate.metadata:()Lorg/apache/cassandra/config/CFMetaData;
getfield org.apache.cassandra.config.CFMetaData.cfName:Ljava/lang/String;
invokestatic org.apache.cassandra.tracing.Tracing.trace:(Ljava/lang/String;Ljava/lang/Object;)V
81: iload 3
ifeq 83
82: aload 16
getfield org.apache.cassandra.db.ColumnFamilyStore.indexManager:Lorg/apache/cassandra/index/SecondaryIndexManager;
aload 14
aload 12
iload 9
invokevirtual org.apache.cassandra.index.SecondaryIndexManager.newUpdateTransaction:(Lorg/apache/cassandra/db/partitions/PartitionUpdate;Lorg/apache/cassandra/utils/concurrent/OpOrder$Group;I)Lorg/apache/cassandra/index/transactions/UpdateTransaction;
goto 84
83: StackMap locals:
StackMap stack:
getstatic org.apache.cassandra.index.transactions.UpdateTransaction.NO_OP:Lorg/apache/cassandra/index/transactions/UpdateTransaction;
84: StackMap locals:
StackMap stack: org.apache.cassandra.index.transactions.UpdateTransaction
astore 18
start local 18 85: aload 16
aload 14
aload 18
aload 12
aload 13
invokevirtual org.apache.cassandra.db.ColumnFamilyStore.apply:(Lorg/apache/cassandra/db/partitions/PartitionUpdate;Lorg/apache/cassandra/index/transactions/UpdateTransaction;Lorg/apache/cassandra/utils/concurrent/OpOrder$Group;Lorg/apache/cassandra/db/commitlog/CommitLogPosition;)V
86: iload 8
ifeq 88
87: aload 17
invokestatic java.lang.System.currentTimeMillis:()J
invokevirtual java.util.concurrent.atomic.AtomicLong.set:(J)V
end local 18 end local 17 end local 16 end local 14 88: StackMap locals: org.apache.cassandra.db.Keyspace org.apache.cassandra.db.Mutation int int int int java.util.concurrent.CompletableFuture java.util.concurrent.locks.Lock[] int int java.lang.Throwable java.lang.Throwable org.apache.cassandra.utils.concurrent.OpOrder$Group org.apache.cassandra.db.commitlog.CommitLogPosition top java.util.Iterator
StackMap stack:
aload 15
invokeinterface java.util.Iterator.hasNext:()Z
ifne 62
89: aload 6
ifnull 91
90: aload 6
aconst_null
invokevirtual java.util.concurrent.CompletableFuture.complete:(Ljava/lang/Object;)Z
pop
91: StackMap locals: org.apache.cassandra.db.Keyspace org.apache.cassandra.db.Mutation int int int int java.util.concurrent.CompletableFuture java.util.concurrent.locks.Lock[] int int java.lang.Throwable java.lang.Throwable org.apache.cassandra.utils.concurrent.OpOrder$Group org.apache.cassandra.db.commitlog.CommitLogPosition
StackMap stack:
aload 6
astore 20
92: aload 12
ifnull 93
aload 12
invokevirtual org.apache.cassandra.utils.concurrent.OpOrder$Group.close:()V
93: StackMap locals: org.apache.cassandra.db.Keyspace org.apache.cassandra.db.Mutation int int int int java.util.concurrent.CompletableFuture java.util.concurrent.locks.Lock[] int int java.lang.Throwable java.lang.Throwable org.apache.cassandra.utils.concurrent.OpOrder$Group org.apache.cassandra.db.commitlog.CommitLogPosition top top top top top top java.util.concurrent.CompletableFuture
StackMap stack:
aload 7
ifnull 100
94: aload 7
dup
astore 24
arraylength
istore 23
iconst_0
istore 22
goto 99
StackMap locals: org.apache.cassandra.db.Keyspace org.apache.cassandra.db.Mutation int int int int java.util.concurrent.CompletableFuture java.util.concurrent.locks.Lock[] int int java.lang.Throwable java.lang.Throwable org.apache.cassandra.utils.concurrent.OpOrder$Group org.apache.cassandra.db.commitlog.CommitLogPosition top top top top top top java.util.concurrent.CompletableFuture top int int java.util.concurrent.locks.Lock[]
StackMap stack:
95: aload 24
iload 22
aaload
astore 21
start local 21 96: aload 21
ifnull 98
97: aload 21
invokeinterface java.util.concurrent.locks.Lock.unlock:()V
end local 21 98: StackMap locals:
StackMap stack:
iinc 22 1
StackMap locals:
StackMap stack:
99: iload 22
iload 23
if_icmplt 95
100: StackMap locals: org.apache.cassandra.db.Keyspace org.apache.cassandra.db.Mutation int int int int java.util.concurrent.CompletableFuture java.util.concurrent.locks.Lock[] int int java.lang.Throwable java.lang.Throwable org.apache.cassandra.utils.concurrent.OpOrder$Group org.apache.cassandra.db.commitlog.CommitLogPosition top top top top top top java.util.concurrent.CompletableFuture
StackMap stack:
aload 20
areturn
end local 13 StackMap locals: org.apache.cassandra.db.Keyspace org.apache.cassandra.db.Mutation int int int int java.util.concurrent.CompletableFuture java.util.concurrent.locks.Lock[] int int java.lang.Throwable java.lang.Throwable org.apache.cassandra.utils.concurrent.OpOrder$Group
StackMap stack: java.lang.Throwable
101: astore 10
102: aload 12
ifnull 103
aload 12
invokevirtual org.apache.cassandra.utils.concurrent.OpOrder$Group.close:()V
end local 12 StackMap locals:
StackMap stack:
103: aload 10
athrow
StackMap locals:
StackMap stack: java.lang.Throwable
104: astore 11
aload 10
ifnonnull 105
aload 11
astore 10
goto 106
StackMap locals:
StackMap stack:
105: aload 10
aload 11
if_acmpeq 106
aload 10
aload 11
invokevirtual java.lang.Throwable.addSuppressed:(Ljava/lang/Throwable;)V
StackMap locals:
StackMap stack:
106: aload 10
athrow
107: StackMap locals: org.apache.cassandra.db.Keyspace org.apache.cassandra.db.Mutation int int int int java.util.concurrent.CompletableFuture java.util.concurrent.locks.Lock[] int int
StackMap stack: java.lang.Throwable
astore 19
108: aload 7
ifnull 115
109: aload 7
dup
astore 24
arraylength
istore 23
iconst_0
istore 22
goto 114
StackMap locals: org.apache.cassandra.db.Keyspace org.apache.cassandra.db.Mutation int int int int java.util.concurrent.CompletableFuture java.util.concurrent.locks.Lock[] int int top top top top top top top top top java.lang.Throwable top top int int java.util.concurrent.locks.Lock[]
StackMap stack:
110: aload 24
iload 22
aaload
astore 21
start local 21 111: aload 21
ifnull 113
112: aload 21
invokeinterface java.util.concurrent.locks.Lock.unlock:()V
end local 21 113: StackMap locals:
StackMap stack:
iinc 22 1
StackMap locals:
StackMap stack:
114: iload 22
iload 23
if_icmplt 110
115: StackMap locals: org.apache.cassandra.db.Keyspace org.apache.cassandra.db.Mutation int int int int java.util.concurrent.CompletableFuture java.util.concurrent.locks.Lock[] int int top top top top top top top top top java.lang.Throwable
StackMap stack:
aload 19
athrow
end local 9 end local 8 end local 7 end local 6 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 116 0 this Lorg/apache/cassandra/db/Keyspace;
0 116 1 mutation Lorg/apache/cassandra/db/Mutation;
0 116 2 writeCommitLog Z
0 116 3 updateIndexes Z
0 116 4 isDroppable Z
0 116 5 isDeferrable Z
0 116 6 future Ljava/util/concurrent/CompletableFuture<*>;
3 116 7 locks [Ljava/util/concurrent/locks/Lock;
6 116 8 requiresViewUpdate Z
9 54 9 columnFamilyIds Ljava/util/Collection<Ljava/util/UUID;>;
10 54 10 idIterator Ljava/util/Iterator<Ljava/util/UUID;>;
12 48 11 i I
14 46 12 cfid Ljava/util/UUID;
15 46 13 lockKey I
16 46 14 lock Ljava/util/concurrent/locks/Lock;
22 26 15 j I
34 38 15 j I
39 41 15 mark Ljava/util/concurrent/CompletableFuture<*>;
49 54 11 acquireTime J
52 53 13 cfid Ljava/util/UUID;
55 116 9 nowInSec I
57 103 12 opGroup Lorg/apache/cassandra/utils/concurrent/OpOrder$Group;
58 101 13 commitLogPosition Lorg/apache/cassandra/db/commitlog/CommitLogPosition;
63 88 14 upd Lorg/apache/cassandra/db/partitions/PartitionUpdate;
64 88 16 cfs Lorg/apache/cassandra/db/ColumnFamilyStore;
68 88 17 baseComplete Ljava/util/concurrent/atomic/AtomicLong;
73 80 18 t Ljava/lang/Throwable;
85 88 18 indexTransaction Lorg/apache/cassandra/index/transactions/UpdateTransaction;
96 98 21 lock Ljava/util/concurrent/locks/Lock;
111 113 21 lock Ljava/util/concurrent/locks/Lock;
Exception table:
from to target type
41 42 43 Class java.lang.InterruptedException
69 71 72 Class java.lang.Throwable
57 92 101 any
56 93 104 any
101 104 104 any
55 93 107 any
101 107 107 any
Signature: (Lorg/apache/cassandra/db/Mutation;ZZZZLjava/util/concurrent/CompletableFuture<*>;)Ljava/util/concurrent/CompletableFuture<*>;
MethodParameters:
Name Flags
mutation final
writeCommitLog final
updateIndexes
isDroppable
isDeferrable
future
public org.apache.cassandra.locator.AbstractReplicationStrategy getReplicationStrategy();
descriptor: ()Lorg/apache/cassandra/locator/AbstractReplicationStrategy;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.db.Keyspace.replicationStrategy:Lorg/apache/cassandra/locator/AbstractReplicationStrategy;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/db/Keyspace;
public java.util.List<java.util.concurrent.Future<?>> flush();
descriptor: ()Ljava/util/List;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=4, args_size=1
start local 0 0: new java.util.ArrayList
dup
aload 0
getfield org.apache.cassandra.db.Keyspace.columnFamilyStores:Ljava/util/concurrent/ConcurrentMap;
invokeinterface java.util.concurrent.ConcurrentMap.size:()I
invokespecial java.util.ArrayList.<init>:(I)V
astore 1
start local 1 1: aload 0
getfield org.apache.cassandra.db.Keyspace.columnFamilyStores:Ljava/util/concurrent/ConcurrentMap;
invokeinterface java.util.concurrent.ConcurrentMap.values:()Ljava/util/Collection;
invokeinterface java.util.Collection.iterator:()Ljava/util/Iterator;
astore 3
goto 4
StackMap locals: org.apache.cassandra.db.Keyspace java.util.List top java.util.Iterator
StackMap stack:
2: aload 3
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.db.ColumnFamilyStore
astore 2
start local 2 3: aload 1
aload 2
invokevirtual org.apache.cassandra.db.ColumnFamilyStore.forceFlush:()Lcom/google/common/util/concurrent/ListenableFuture;
invokeinterface java.util.List.add:(Ljava/lang/Object;)Z
pop
end local 2 4: StackMap locals:
StackMap stack:
aload 3
invokeinterface java.util.Iterator.hasNext:()Z
ifne 2
5: aload 1
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 this Lorg/apache/cassandra/db/Keyspace;
1 6 1 futures Ljava/util/List<Ljava/util/concurrent/Future<*>;>;
3 4 2 cfs Lorg/apache/cassandra/db/ColumnFamilyStore;
Signature: ()Ljava/util/List<Ljava/util/concurrent/Future<*>;>;
public java.lang.Iterable<org.apache.cassandra.db.ColumnFamilyStore> getValidColumnFamilies(boolean, boolean, java.lang.String[]);
descriptor: (ZZ[Ljava/lang/String;)Ljava/lang/Iterable;
flags: (0x0081) ACC_PUBLIC, ACC_VARARGS
Code:
stack=7, locals=13, args_size=4
start local 0 start local 1 start local 2 start local 3 0: new java.util.HashSet
dup
invokespecial java.util.HashSet.<init>:()V
astore 4
start local 4 1: aload 3
arraylength
ifne 9
2: aload 0
invokevirtual org.apache.cassandra.db.Keyspace.getColumnFamilyStores:()Ljava/util/Collection;
invokeinterface java.util.Collection.iterator:()Ljava/util/Iterator;
astore 6
goto 7
StackMap locals: org.apache.cassandra.db.Keyspace int int java.lang.String[] java.util.Set top java.util.Iterator
StackMap stack:
3: aload 6
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.db.ColumnFamilyStore
astore 5
start local 5 4: aload 4
aload 5
invokeinterface java.util.Set.add:(Ljava/lang/Object;)Z
pop
5: iload 2
ifeq 7
6: aload 4
aload 0
aload 5
invokevirtual org.apache.cassandra.db.Keyspace.getIndexColumnFamilyStores:(Lorg/apache/cassandra/db/ColumnFamilyStore;)Ljava/util/Set;
invokeinterface java.util.Set.addAll:(Ljava/util/Collection;)Z
pop
end local 5 7: StackMap locals:
StackMap stack:
aload 6
invokeinterface java.util.Iterator.hasNext:()Z
ifne 3
8: aload 4
areturn
9: StackMap locals: org.apache.cassandra.db.Keyspace int int java.lang.String[] java.util.Set
StackMap stack:
aload 3
dup
astore 8
arraylength
istore 7
iconst_0
istore 6
goto 32
StackMap locals: org.apache.cassandra.db.Keyspace int int java.lang.String[] java.util.Set top int int java.lang.String[]
StackMap stack:
10: aload 8
iload 6
aaload
astore 5
start local 5 11: aload 5
invokestatic org.apache.cassandra.index.SecondaryIndexManager.isIndexColumnFamily:(Ljava/lang/String;)Z
ifeq 27
12: iload 1
ifne 15
13: getstatic org.apache.cassandra.db.Keyspace.logger:Lorg/slf4j/Logger;
ldc "Operation not allowed on secondary Index table ({})"
aload 5
invokeinterface org.slf4j.Logger.warn:(Ljava/lang/String;Ljava/lang/Object;)V
14: goto 31
15: StackMap locals: org.apache.cassandra.db.Keyspace int int java.lang.String[] java.util.Set java.lang.String int int java.lang.String[]
StackMap stack:
aload 5
invokestatic org.apache.cassandra.index.SecondaryIndexManager.getParentCfsName:(Ljava/lang/String;)Ljava/lang/String;
astore 9
start local 9 16: aload 5
invokestatic org.apache.cassandra.index.SecondaryIndexManager.getIndexName:(Ljava/lang/String;)Ljava/lang/String;
astore 10
start local 10 17: aload 0
aload 9
invokevirtual org.apache.cassandra.db.Keyspace.getColumnFamilyStore:(Ljava/lang/String;)Lorg/apache/cassandra/db/ColumnFamilyStore;
astore 11
start local 11 18: aload 11
getfield org.apache.cassandra.db.ColumnFamilyStore.indexManager:Lorg/apache/cassandra/index/SecondaryIndexManager;
aload 10
invokevirtual org.apache.cassandra.index.SecondaryIndexManager.getIndexByName:(Ljava/lang/String;)Lorg/apache/cassandra/index/Index;
astore 12
start local 12 19: aload 12
ifnonnull 24
20: new java.lang.IllegalArgumentException
dup
ldc "Invalid index specified: %s/%s."
iconst_2
anewarray java.lang.Object
dup
iconst_0
21: aload 11
getfield org.apache.cassandra.db.ColumnFamilyStore.metadata:Lorg/apache/cassandra/config/CFMetaData;
getfield org.apache.cassandra.config.CFMetaData.cfName:Ljava/lang/String;
aastore
dup
iconst_1
22: aload 10
aastore
23: invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
invokespecial java.lang.IllegalArgumentException.<init>:(Ljava/lang/String;)V
athrow
24: StackMap locals: org.apache.cassandra.db.Keyspace int int java.lang.String[] java.util.Set java.lang.String int int java.lang.String[] java.lang.String java.lang.String org.apache.cassandra.db.ColumnFamilyStore org.apache.cassandra.index.Index
StackMap stack:
aload 12
invokeinterface org.apache.cassandra.index.Index.getBackingTable:()Ljava/util/Optional;
invokevirtual java.util.Optional.isPresent:()Z
ifeq 31
25: aload 4
aload 12
invokeinterface org.apache.cassandra.index.Index.getBackingTable:()Ljava/util/Optional;
invokevirtual java.util.Optional.get:()Ljava/lang/Object;
checkcast org.apache.cassandra.db.ColumnFamilyStore
invokeinterface java.util.Set.add:(Ljava/lang/Object;)Z
pop
end local 12 end local 11 end local 10 end local 9 26: goto 31
27: StackMap locals: org.apache.cassandra.db.Keyspace int int java.lang.String[] java.util.Set java.lang.String int int java.lang.String[]
StackMap stack:
aload 0
aload 5
invokevirtual org.apache.cassandra.db.Keyspace.getColumnFamilyStore:(Ljava/lang/String;)Lorg/apache/cassandra/db/ColumnFamilyStore;
astore 9
start local 9 28: aload 4
aload 9
invokeinterface java.util.Set.add:(Ljava/lang/Object;)Z
pop
29: iload 2
ifeq 31
30: aload 4
aload 0
aload 9
invokevirtual org.apache.cassandra.db.Keyspace.getIndexColumnFamilyStores:(Lorg/apache/cassandra/db/ColumnFamilyStore;)Ljava/util/Set;
invokeinterface java.util.Set.addAll:(Ljava/util/Collection;)Z
pop
end local 9 end local 5 31: StackMap locals: org.apache.cassandra.db.Keyspace int int java.lang.String[] java.util.Set top int int java.lang.String[]
StackMap stack:
iinc 6 1
StackMap locals:
StackMap stack:
32: iload 6
iload 7
if_icmplt 10
33: aload 4
areturn
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 34 0 this Lorg/apache/cassandra/db/Keyspace;
0 34 1 allowIndexes Z
0 34 2 autoAddIndexes Z
0 34 3 cfNames [Ljava/lang/String;
1 34 4 valid Ljava/util/Set<Lorg/apache/cassandra/db/ColumnFamilyStore;>;
4 7 5 cfStore Lorg/apache/cassandra/db/ColumnFamilyStore;
11 31 5 cfName Ljava/lang/String;
16 26 9 baseName Ljava/lang/String;
17 26 10 indexName Ljava/lang/String;
18 26 11 baseCfs Lorg/apache/cassandra/db/ColumnFamilyStore;
19 26 12 index Lorg/apache/cassandra/index/Index;
28 31 9 cfStore Lorg/apache/cassandra/db/ColumnFamilyStore;
Exceptions:
throws java.io.IOException
Signature: (ZZ[Ljava/lang/String;)Ljava/lang/Iterable<Lorg/apache/cassandra/db/ColumnFamilyStore;>;
MethodParameters:
Name Flags
allowIndexes
autoAddIndexes
cfNames
private java.util.Set<org.apache.cassandra.db.ColumnFamilyStore> getIndexColumnFamilyStores(org.apache.cassandra.db.ColumnFamilyStore);
descriptor: (Lorg/apache/cassandra/db/ColumnFamilyStore;)Ljava/util/Set;
flags: (0x0002) ACC_PRIVATE
Code:
stack=3, locals=5, args_size=2
start local 0 start local 1 0: new java.util.HashSet
dup
invokespecial java.util.HashSet.<init>:()V
astore 2
start local 2 1: aload 1
getfield org.apache.cassandra.db.ColumnFamilyStore.indexManager:Lorg/apache/cassandra/index/SecondaryIndexManager;
invokevirtual org.apache.cassandra.index.SecondaryIndexManager.getAllIndexColumnFamilyStores:()Ljava/util/Set;
invokeinterface java.util.Set.iterator:()Ljava/util/Iterator;
astore 4
goto 5
StackMap locals: org.apache.cassandra.db.Keyspace org.apache.cassandra.db.ColumnFamilyStore java.util.Set top java.util.Iterator
StackMap stack:
2: aload 4
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.db.ColumnFamilyStore
astore 3
start local 3 3: getstatic org.apache.cassandra.db.Keyspace.logger:Lorg/slf4j/Logger;
ldc "adding secondary index table {} to operation"
aload 3
getfield org.apache.cassandra.db.ColumnFamilyStore.metadata:Lorg/apache/cassandra/config/CFMetaData;
getfield org.apache.cassandra.config.CFMetaData.cfName:Ljava/lang/String;
invokeinterface org.slf4j.Logger.info:(Ljava/lang/String;Ljava/lang/Object;)V
4: aload 2
aload 3
invokeinterface java.util.Set.add:(Ljava/lang/Object;)Z
pop
end local 3 5: StackMap locals:
StackMap stack:
aload 4
invokeinterface java.util.Iterator.hasNext:()Z
ifne 2
6: aload 2
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 7 0 this Lorg/apache/cassandra/db/Keyspace;
0 7 1 baseCfs Lorg/apache/cassandra/db/ColumnFamilyStore;
1 7 2 stores Ljava/util/Set<Lorg/apache/cassandra/db/ColumnFamilyStore;>;
3 5 3 indexCfs Lorg/apache/cassandra/db/ColumnFamilyStore;
Signature: (Lorg/apache/cassandra/db/ColumnFamilyStore;)Ljava/util/Set<Lorg/apache/cassandra/db/ColumnFamilyStore;>;
MethodParameters:
Name Flags
baseCfs
public static java.lang.Iterable<org.apache.cassandra.db.Keyspace> all();
descriptor: ()Ljava/lang/Iterable;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=2, locals=0, args_size=0
0: getstatic org.apache.cassandra.config.Schema.instance:Lorg/apache/cassandra/config/Schema;
invokevirtual org.apache.cassandra.config.Schema.getKeyspaces:()Ljava/util/Set;
getstatic org.apache.cassandra.db.Keyspace.keyspaceTransformer:Lcom/google/common/base/Function;
invokestatic com.google.common.collect.Iterables.transform:(Ljava/lang/Iterable;Lcom/google/common/base/Function;)Ljava/lang/Iterable;
areturn
LocalVariableTable:
Start End Slot Name Signature
Signature: ()Ljava/lang/Iterable<Lorg/apache/cassandra/db/Keyspace;>;
public static java.lang.Iterable<org.apache.cassandra.db.Keyspace> nonSystem();
descriptor: ()Ljava/lang/Iterable;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=2, locals=0, args_size=0
0: getstatic org.apache.cassandra.config.Schema.instance:Lorg/apache/cassandra/config/Schema;
invokevirtual org.apache.cassandra.config.Schema.getNonSystemKeyspaces:()Ljava/util/List;
getstatic org.apache.cassandra.db.Keyspace.keyspaceTransformer:Lcom/google/common/base/Function;
invokestatic com.google.common.collect.Iterables.transform:(Ljava/lang/Iterable;Lcom/google/common/base/Function;)Ljava/lang/Iterable;
areturn
LocalVariableTable:
Start End Slot Name Signature
Signature: ()Ljava/lang/Iterable<Lorg/apache/cassandra/db/Keyspace;>;
public static java.lang.Iterable<org.apache.cassandra.db.Keyspace> nonLocalStrategy();
descriptor: ()Ljava/lang/Iterable;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=2, locals=0, args_size=0
0: getstatic org.apache.cassandra.config.Schema.instance:Lorg/apache/cassandra/config/Schema;
invokevirtual org.apache.cassandra.config.Schema.getNonLocalStrategyKeyspaces:()Ljava/util/List;
getstatic org.apache.cassandra.db.Keyspace.keyspaceTransformer:Lcom/google/common/base/Function;
invokestatic com.google.common.collect.Iterables.transform:(Ljava/lang/Iterable;Lcom/google/common/base/Function;)Ljava/lang/Iterable;
areturn
LocalVariableTable:
Start End Slot Name Signature
Signature: ()Ljava/lang/Iterable<Lorg/apache/cassandra/db/Keyspace;>;
public static java.lang.Iterable<org.apache.cassandra.db.Keyspace> system();
descriptor: ()Ljava/lang/Iterable;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=2, locals=0, args_size=0
0: getstatic org.apache.cassandra.config.SchemaConstants.LOCAL_SYSTEM_KEYSPACE_NAMES:Ljava/util/Set;
getstatic org.apache.cassandra.db.Keyspace.keyspaceTransformer:Lcom/google/common/base/Function;
invokestatic com.google.common.collect.Iterables.transform:(Ljava/lang/Iterable;Lcom/google/common/base/Function;)Ljava/lang/Iterable;
areturn
LocalVariableTable:
Start End Slot Name Signature
Signature: ()Ljava/lang/Iterable<Lorg/apache/cassandra/db/Keyspace;>;
public java.lang.String toString();
descriptor: ()Ljava/lang/String;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=1, args_size=1
start local 0 0: new java.lang.StringBuilder
dup
aload 0
invokevirtual java.lang.Object.getClass:()Ljava/lang/Class;
invokevirtual java.lang.Class.getSimpleName:()Ljava/lang/String;
invokestatic java.lang.String.valueOf:(Ljava/lang/Object;)Ljava/lang/String;
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
ldc "(name='"
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
aload 0
invokevirtual org.apache.cassandra.db.Keyspace.getName:()Ljava/lang/String;
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
ldc "')"
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/db/Keyspace;
public java.lang.String getName();
descriptor: ()Ljava/lang/String;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.db.Keyspace.metadata:Lorg/apache/cassandra/schema/KeyspaceMetadata;
getfield org.apache.cassandra.schema.KeyspaceMetadata.name:Ljava/lang/String;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/db/Keyspace;
private void lambda$1(org.apache.cassandra.db.Mutation, boolean, boolean, java.util.concurrent.CompletableFuture);
descriptor: (Lorg/apache/cassandra/db/Mutation;ZZLjava/util/concurrent/CompletableFuture;)V
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=7, locals=5, args_size=5
start local 0 0: aload 0
aload 1
iload 2
iconst_1
iload 3
iconst_1
aload 4
invokevirtual org.apache.cassandra.db.Keyspace.applyInternal:(Lorg/apache/cassandra/db/Mutation;ZZZZLjava/util/concurrent/CompletableFuture;)Ljava/util/concurrent/CompletableFuture;
return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/db/Keyspace;
}
SourceFile: "Keyspace.java"
NestMembers:
org.apache.cassandra.db.Keyspace$1
InnerClasses:
public final Lookup = java.lang.invoke.MethodHandles$Lookup of java.lang.invoke.MethodHandles
public DataDirectory = org.apache.cassandra.db.Directories$DataDirectory of org.apache.cassandra.db.Directories
org.apache.cassandra.db.Keyspace$1
public TableTimer = org.apache.cassandra.metrics.TableMetrics$TableTimer of org.apache.cassandra.metrics.TableMetrics
public final Group = org.apache.cassandra.utils.concurrent.OpOrder$Group of org.apache.cassandra.utils.concurrent.OpOrder
Keyspace
logger: Logger
$assertionsDisabled: boolean
