public class org.apache.cassandra.io.sstable.SSTableRewriter extends org.apache.cassandra.utils.concurrent.Transactional$AbstractTransactional implements org.apache.cassandra.utils.concurrent.Transactional
minor version: 0
major version: 59
flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
this_class: org.apache.cassandra.io.sstable.SSTableRewriter
super_class: org.apache.cassandra.utils.concurrent.Transactional$AbstractTransactional
{
public static boolean disableEarlyOpeningForTests;
descriptor: Z
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
RuntimeInvisibleAnnotations:
com.google.common.annotations.VisibleForTesting()
private final long preemptiveOpenInterval;
descriptor: J
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final long maxAge;
descriptor: J
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private long repairedAt;
descriptor: J
flags: (0x0002) ACC_PRIVATE
private final org.apache.cassandra.db.lifecycle.ILifecycleTransaction transaction;
descriptor: Lorg/apache/cassandra/db/lifecycle/ILifecycleTransaction;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final java.util.List<org.apache.cassandra.io.sstable.format.SSTableReader> preparedForCommit;
descriptor: Ljava/util/List;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Ljava/util/List<Lorg/apache/cassandra/io/sstable/format/SSTableReader;>;
private long currentlyOpenedEarlyAt;
descriptor: J
flags: (0x0002) ACC_PRIVATE
private final java.util.List<org.apache.cassandra.io.sstable.format.SSTableWriter> writers;
descriptor: Ljava/util/List;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Ljava/util/List<Lorg/apache/cassandra/io/sstable/format/SSTableWriter;>;
private final boolean keepOriginals;
descriptor: Z
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private org.apache.cassandra.io.sstable.format.SSTableWriter writer;
descriptor: Lorg/apache/cassandra/io/sstable/format/SSTableWriter;
flags: (0x0002) ACC_PRIVATE
private java.util.Map<org.apache.cassandra.db.DecoratedKey, org.apache.cassandra.db.RowIndexEntry> cachedKeys;
descriptor: Ljava/util/Map;
flags: (0x0002) ACC_PRIVATE
Signature: Ljava/util/Map<Lorg/apache/cassandra/db/DecoratedKey;Lorg/apache/cassandra/db/RowIndexEntry;>;
private boolean throwEarly;
descriptor: Z
flags: (0x0002) ACC_PRIVATE
private boolean throwLate;
descriptor: Z
flags: (0x0002) ACC_PRIVATE
static final boolean $assertionsDisabled;
descriptor: Z
flags: (0x1018) ACC_STATIC, ACC_FINAL, ACC_SYNTHETIC
static void <clinit>();
descriptor: ()V
flags: (0x0008) ACC_STATIC
Code:
stack=1, locals=0, args_size=0
0: ldc Lorg/apache/cassandra/io/sstable/SSTableRewriter;
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.io.sstable.SSTableRewriter.$assertionsDisabled:Z
3: iconst_0
putstatic org.apache.cassandra.io.sstable.SSTableRewriter.disableEarlyOpeningForTests:Z
return
LocalVariableTable:
Start End Slot Name Signature
public void <init>(org.apache.cassandra.db.lifecycle.ILifecycleTransaction, long, boolean);
descriptor: (Lorg/apache/cassandra/db/lifecycle/ILifecycleTransaction;JZ)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=6, locals=5, args_size=4
start local 0 start local 1 start local 2 start local 4 0: aload 0
aload 1
lload 2
iload 4
iconst_1
invokespecial org.apache.cassandra.io.sstable.SSTableRewriter.<init>:(Lorg/apache/cassandra/db/lifecycle/ILifecycleTransaction;JZZ)V
1: return
end local 4 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/apache/cassandra/io/sstable/SSTableRewriter;
0 2 1 transaction Lorg/apache/cassandra/db/lifecycle/ILifecycleTransaction;
0 2 2 maxAge J
0 2 4 isOffline Z
RuntimeVisibleAnnotations:
java.lang.Deprecated()
MethodParameters:
Name Flags
transaction
maxAge
isOffline
public void <init>(org.apache.cassandra.db.lifecycle.ILifecycleTransaction, long, boolean, boolean);
descriptor: (Lorg/apache/cassandra/db/lifecycle/ILifecycleTransaction;JZZ)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=7, locals=6, args_size=5
start local 0 start local 1 start local 2 start local 4 start local 5 0: aload 0
aload 1
lload 2
iload 5
invokestatic org.apache.cassandra.io.sstable.SSTableRewriter.calculateOpenInterval:(Z)J
iconst_0
invokespecial org.apache.cassandra.io.sstable.SSTableRewriter.<init>:(Lorg/apache/cassandra/db/lifecycle/ILifecycleTransaction;JJZ)V
1: return
end local 5 end local 4 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/apache/cassandra/io/sstable/SSTableRewriter;
0 2 1 transaction Lorg/apache/cassandra/db/lifecycle/ILifecycleTransaction;
0 2 2 maxAge J
0 2 4 isOffline Z
0 2 5 shouldOpenEarly Z
RuntimeVisibleAnnotations:
java.lang.Deprecated()
MethodParameters:
Name Flags
transaction
maxAge
isOffline
shouldOpenEarly
public void <init>(org.apache.cassandra.db.lifecycle.ILifecycleTransaction, long, long, boolean);
descriptor: (Lorg/apache/cassandra/db/lifecycle/ILifecycleTransaction;JJZ)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=7, args_size=5
start local 0 start local 1 start local 2 start local 4 start local 6 0: aload 0
invokespecial org.apache.cassandra.utils.concurrent.Transactional$AbstractTransactional.<init>:()V
1: aload 0
ldc -1
putfield org.apache.cassandra.io.sstable.SSTableRewriter.repairedAt:J
2: aload 0
new java.util.ArrayList
dup
invokespecial java.util.ArrayList.<init>:()V
putfield org.apache.cassandra.io.sstable.SSTableRewriter.preparedForCommit:Ljava/util/List;
3: aload 0
new java.util.ArrayList
dup
invokespecial java.util.ArrayList.<init>:()V
putfield org.apache.cassandra.io.sstable.SSTableRewriter.writers:Ljava/util/List;
4: aload 0
new java.util.HashMap
dup
invokespecial java.util.HashMap.<init>:()V
putfield org.apache.cassandra.io.sstable.SSTableRewriter.cachedKeys:Ljava/util/Map;
5: aload 0
aload 1
putfield org.apache.cassandra.io.sstable.SSTableRewriter.transaction:Lorg/apache/cassandra/db/lifecycle/ILifecycleTransaction;
6: aload 0
lload 2
putfield org.apache.cassandra.io.sstable.SSTableRewriter.maxAge:J
7: aload 0
iload 6
putfield org.apache.cassandra.io.sstable.SSTableRewriter.keepOriginals:Z
8: aload 0
lload 4
putfield org.apache.cassandra.io.sstable.SSTableRewriter.preemptiveOpenInterval:J
9: return
end local 6 end local 4 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 10 0 this Lorg/apache/cassandra/io/sstable/SSTableRewriter;
0 10 1 transaction Lorg/apache/cassandra/db/lifecycle/ILifecycleTransaction;
0 10 2 maxAge J
0 10 4 preemptiveOpenInterval J
0 10 6 keepOriginals Z
RuntimeInvisibleAnnotations:
com.google.common.annotations.VisibleForTesting()
RuntimeInvisibleTypeAnnotations:
METHOD_RETURN
com.google.common.annotations.VisibleForTesting()
MethodParameters:
Name Flags
transaction
maxAge
preemptiveOpenInterval
keepOriginals
public static org.apache.cassandra.io.sstable.SSTableRewriter constructKeepingOriginals(org.apache.cassandra.db.lifecycle.ILifecycleTransaction, boolean, long, boolean);
descriptor: (Lorg/apache/cassandra/db/lifecycle/ILifecycleTransaction;ZJZ)Lorg/apache/cassandra/io/sstable/SSTableRewriter;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=4, locals=5, args_size=4
start local 0 start local 1 start local 2 start local 4 0: aload 0
iload 1
lload 2
invokestatic org.apache.cassandra.io.sstable.SSTableRewriter.constructKeepingOriginals:(Lorg/apache/cassandra/db/lifecycle/ILifecycleTransaction;ZJ)Lorg/apache/cassandra/io/sstable/SSTableRewriter;
areturn
end local 4 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 transaction Lorg/apache/cassandra/db/lifecycle/ILifecycleTransaction;
0 1 1 keepOriginals Z
0 1 2 maxAge J
0 1 4 isOffline Z
RuntimeVisibleAnnotations:
java.lang.Deprecated()
MethodParameters:
Name Flags
transaction
keepOriginals
maxAge
isOffline
public static org.apache.cassandra.io.sstable.SSTableRewriter constructKeepingOriginals(org.apache.cassandra.db.lifecycle.ILifecycleTransaction, boolean, long);
descriptor: (Lorg/apache/cassandra/db/lifecycle/ILifecycleTransaction;ZJ)Lorg/apache/cassandra/io/sstable/SSTableRewriter;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=8, locals=4, args_size=3
start local 0 start local 1 start local 2 0: new org.apache.cassandra.io.sstable.SSTableRewriter
dup
aload 0
lload 2
iconst_1
invokestatic org.apache.cassandra.io.sstable.SSTableRewriter.calculateOpenInterval:(Z)J
iload 1
invokespecial org.apache.cassandra.io.sstable.SSTableRewriter.<init>:(Lorg/apache/cassandra/db/lifecycle/ILifecycleTransaction;JJZ)V
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 transaction Lorg/apache/cassandra/db/lifecycle/ILifecycleTransaction;
0 1 1 keepOriginals Z
0 1 2 maxAge J
MethodParameters:
Name Flags
transaction
keepOriginals
maxAge
public static org.apache.cassandra.io.sstable.SSTableRewriter constructWithoutEarlyOpening(org.apache.cassandra.db.lifecycle.ILifecycleTransaction, boolean, long);
descriptor: (Lorg/apache/cassandra/db/lifecycle/ILifecycleTransaction;ZJ)Lorg/apache/cassandra/io/sstable/SSTableRewriter;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=8, locals=4, args_size=3
start local 0 start local 1 start local 2 0: new org.apache.cassandra.io.sstable.SSTableRewriter
dup
aload 0
lload 2
iconst_0
invokestatic org.apache.cassandra.io.sstable.SSTableRewriter.calculateOpenInterval:(Z)J
iload 1
invokespecial org.apache.cassandra.io.sstable.SSTableRewriter.<init>:(Lorg/apache/cassandra/db/lifecycle/ILifecycleTransaction;JJZ)V
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 transaction Lorg/apache/cassandra/db/lifecycle/ILifecycleTransaction;
0 1 1 keepOriginals Z
0 1 2 maxAge J
MethodParameters:
Name Flags
transaction
keepOriginals
maxAge
public static org.apache.cassandra.io.sstable.SSTableRewriter construct(org.apache.cassandra.db.ColumnFamilyStore, org.apache.cassandra.db.lifecycle.ILifecycleTransaction, boolean, long);
descriptor: (Lorg/apache/cassandra/db/ColumnFamilyStore;Lorg/apache/cassandra/db/lifecycle/ILifecycleTransaction;ZJ)Lorg/apache/cassandra/io/sstable/SSTableRewriter;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=8, locals=5, args_size=4
start local 0 start local 1 start local 2 start local 3 0: new org.apache.cassandra.io.sstable.SSTableRewriter
dup
aload 1
lload 3
aload 0
invokevirtual org.apache.cassandra.db.ColumnFamilyStore.supportsEarlyOpen:()Z
invokestatic org.apache.cassandra.io.sstable.SSTableRewriter.calculateOpenInterval:(Z)J
iload 2
invokespecial org.apache.cassandra.io.sstable.SSTableRewriter.<init>:(Lorg/apache/cassandra/db/lifecycle/ILifecycleTransaction;JJZ)V
areturn
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 cfs Lorg/apache/cassandra/db/ColumnFamilyStore;
0 1 1 transaction Lorg/apache/cassandra/db/lifecycle/ILifecycleTransaction;
0 1 2 keepOriginals Z
0 1 3 maxAge J
MethodParameters:
Name Flags
cfs
transaction
keepOriginals
maxAge
private static long calculateOpenInterval(boolean);
descriptor: (Z)J
flags: (0x000a) ACC_PRIVATE, ACC_STATIC
Code:
stack=4, locals=3, args_size=1
start local 0 0: invokestatic org.apache.cassandra.config.DatabaseDescriptor.getSSTablePreempiveOpenIntervalInMB:()I
i2l
ldc 1048576
lmul
lstore 1
start local 1 1: getstatic org.apache.cassandra.io.sstable.SSTableRewriter.disableEarlyOpeningForTests:Z
ifne 2
iload 0
ifeq 2
lload 1
lconst_0
lcmp
ifge 3
2: StackMap locals: long
StackMap stack:
ldc 9223372036854775807
lstore 1
3: StackMap locals:
StackMap stack:
lload 1
lreturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 shouldOpenEarly Z
1 4 1 interval J
MethodParameters:
Name Flags
shouldOpenEarly
public org.apache.cassandra.io.sstable.format.SSTableWriter currentWriter();
descriptor: ()Lorg/apache/cassandra/io/sstable/format/SSTableWriter;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.io.sstable.SSTableRewriter.writer:Lorg/apache/cassandra/io/sstable/format/SSTableWriter;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/io/sstable/SSTableRewriter;
public org.apache.cassandra.db.RowIndexEntry append(org.apache.cassandra.db.rows.UnfilteredRowIterator);
descriptor: (Lorg/apache/cassandra/db/rows/UnfilteredRowIterator;)Lorg/apache/cassandra/db/RowIndexEntry;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=6, args_size=2
start local 0 start local 1 0: aload 1
invokeinterface org.apache.cassandra.db.rows.UnfilteredRowIterator.partitionKey:()Lorg/apache/cassandra/db/DecoratedKey;
astore 2
start local 2 1: aload 0
aload 2
invokevirtual org.apache.cassandra.io.sstable.SSTableRewriter.maybeReopenEarly:(Lorg/apache/cassandra/db/DecoratedKey;)V
2: aload 0
getfield org.apache.cassandra.io.sstable.SSTableRewriter.writer:Lorg/apache/cassandra/io/sstable/format/SSTableWriter;
aload 1
invokevirtual org.apache.cassandra.io.sstable.format.SSTableWriter.append:(Lorg/apache/cassandra/db/rows/UnfilteredRowIterator;)Lorg/apache/cassandra/db/RowIndexEntry;
astore 3
start local 3 3: aload 0
getfield org.apache.cassandra.io.sstable.SSTableRewriter.transaction:Lorg/apache/cassandra/db/lifecycle/ILifecycleTransaction;
invokeinterface org.apache.cassandra.db.lifecycle.ILifecycleTransaction.isOffline:()Z
ifne 10
aload 3
ifnull 10
4: aload 0
getfield org.apache.cassandra.io.sstable.SSTableRewriter.transaction:Lorg/apache/cassandra/db/lifecycle/ILifecycleTransaction;
invokeinterface org.apache.cassandra.db.lifecycle.ILifecycleTransaction.originals:()Ljava/util/Set;
invokeinterface java.util.Set.iterator:()Ljava/util/Iterator;
astore 5
goto 9
StackMap locals: org.apache.cassandra.io.sstable.SSTableRewriter org.apache.cassandra.db.rows.UnfilteredRowIterator org.apache.cassandra.db.DecoratedKey org.apache.cassandra.db.RowIndexEntry top java.util.Iterator
StackMap stack:
5: aload 5
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.io.sstable.format.SSTableReader
astore 4
start local 4 6: aload 4
aload 2
iconst_0
invokevirtual org.apache.cassandra.io.sstable.format.SSTableReader.getCachedPosition:(Lorg/apache/cassandra/db/DecoratedKey;Z)Lorg/apache/cassandra/db/RowIndexEntry;
ifnull 9
7: aload 0
getfield org.apache.cassandra.io.sstable.SSTableRewriter.cachedKeys:Ljava/util/Map;
aload 2
aload 3
invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
pop
8: goto 10
end local 4 9: StackMap locals:
StackMap stack:
aload 5
invokeinterface java.util.Iterator.hasNext:()Z
ifne 5
10: StackMap locals: org.apache.cassandra.io.sstable.SSTableRewriter org.apache.cassandra.db.rows.UnfilteredRowIterator org.apache.cassandra.db.DecoratedKey org.apache.cassandra.db.RowIndexEntry
StackMap stack:
aload 3
areturn
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/io/sstable/SSTableRewriter;
0 11 1 partition Lorg/apache/cassandra/db/rows/UnfilteredRowIterator;
1 11 2 key Lorg/apache/cassandra/db/DecoratedKey;
3 11 3 index Lorg/apache/cassandra/db/RowIndexEntry;
6 9 4 reader Lorg/apache/cassandra/io/sstable/format/SSTableReader;
MethodParameters:
Name Flags
partition
public org.apache.cassandra.db.RowIndexEntry tryAppend(org.apache.cassandra.db.rows.UnfilteredRowIterator);
descriptor: (Lorg/apache/cassandra/db/rows/UnfilteredRowIterator;)Lorg/apache/cassandra/db/RowIndexEntry;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=3, args_size=2
start local 0 start local 1 0: aload 0
getfield org.apache.cassandra.io.sstable.SSTableRewriter.writer:Lorg/apache/cassandra/io/sstable/format/SSTableWriter;
invokevirtual org.apache.cassandra.io.sstable.format.SSTableWriter.mark:()V
1: aload 0
aload 1
invokevirtual org.apache.cassandra.io.sstable.SSTableRewriter.append:(Lorg/apache/cassandra/db/rows/UnfilteredRowIterator;)Lorg/apache/cassandra/db/RowIndexEntry;
2: areturn
3: StackMap locals:
StackMap stack: java.lang.Throwable
astore 2
start local 2 4: aload 0
getfield org.apache.cassandra.io.sstable.SSTableRewriter.writer:Lorg/apache/cassandra/io/sstable/format/SSTableWriter;
invokevirtual org.apache.cassandra.io.sstable.format.SSTableWriter.resetAndTruncate:()V
5: aload 2
athrow
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 this Lorg/apache/cassandra/io/sstable/SSTableRewriter;
0 6 1 partition Lorg/apache/cassandra/db/rows/UnfilteredRowIterator;
4 6 2 t Ljava/lang/Throwable;
Exception table:
from to target type
1 2 3 Class java.lang.Throwable
MethodParameters:
Name Flags
partition
private void maybeReopenEarly(org.apache.cassandra.db.DecoratedKey);
descriptor: (Lorg/apache/cassandra/db/DecoratedKey;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=5, locals=5, args_size=2
start local 0 start local 1 0: aload 0
getfield org.apache.cassandra.io.sstable.SSTableRewriter.writer:Lorg/apache/cassandra/io/sstable/format/SSTableWriter;
invokevirtual org.apache.cassandra.io.sstable.format.SSTableWriter.getFilePointer:()J
aload 0
getfield org.apache.cassandra.io.sstable.SSTableRewriter.currentlyOpenedEarlyAt:J
lsub
aload 0
getfield org.apache.cassandra.io.sstable.SSTableRewriter.preemptiveOpenInterval:J
lcmp
ifle 16
1: aload 0
getfield org.apache.cassandra.io.sstable.SSTableRewriter.transaction:Lorg/apache/cassandra/db/lifecycle/ILifecycleTransaction;
invokeinterface org.apache.cassandra.db.lifecycle.ILifecycleTransaction.isOffline:()Z
ifeq 10
2: aload 0
getfield org.apache.cassandra.io.sstable.SSTableRewriter.transaction:Lorg/apache/cassandra/db/lifecycle/ILifecycleTransaction;
invokeinterface org.apache.cassandra.db.lifecycle.ILifecycleTransaction.originals:()Ljava/util/Set;
invokeinterface java.util.Set.iterator:()Ljava/util/Iterator;
astore 3
goto 8
StackMap locals: org.apache.cassandra.io.sstable.SSTableRewriter org.apache.cassandra.db.DecoratedKey top java.util.Iterator
StackMap stack:
3: aload 3
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.io.sstable.format.SSTableReader
astore 2
start local 2 4: aload 2
aload 1
getstatic org.apache.cassandra.io.sstable.format.SSTableReader$Operator.GE:Lorg/apache/cassandra/io/sstable/format/SSTableReader$Operator;
invokevirtual org.apache.cassandra.io.sstable.format.SSTableReader.getPosition:(Lorg/apache/cassandra/db/PartitionPosition;Lorg/apache/cassandra/io/sstable/format/SSTableReader$Operator;)Lorg/apache/cassandra/db/RowIndexEntry;
astore 4
start local 4 5: aload 2
invokevirtual org.apache.cassandra.io.sstable.format.SSTableReader.getFilename:()Ljava/lang/String;
lconst_0
aload 4
ifnonnull 6
lconst_0
goto 7
StackMap locals: org.apache.cassandra.io.sstable.SSTableRewriter org.apache.cassandra.db.DecoratedKey org.apache.cassandra.io.sstable.format.SSTableReader java.util.Iterator org.apache.cassandra.db.RowIndexEntry
StackMap stack: java.lang.String long
6: aload 4
getfield org.apache.cassandra.db.RowIndexEntry.position:J
StackMap locals: org.apache.cassandra.io.sstable.SSTableRewriter org.apache.cassandra.db.DecoratedKey org.apache.cassandra.io.sstable.format.SSTableReader java.util.Iterator org.apache.cassandra.db.RowIndexEntry
StackMap stack: java.lang.String long long
7: invokestatic org.apache.cassandra.utils.NativeLibrary.trySkipCache:(Ljava/lang/String;JJ)V
end local 4 end local 2 8: StackMap locals: org.apache.cassandra.io.sstable.SSTableRewriter org.apache.cassandra.db.DecoratedKey top java.util.Iterator
StackMap stack:
aload 3
invokeinterface java.util.Iterator.hasNext:()Z
ifne 3
9: goto 16
10: StackMap locals: org.apache.cassandra.io.sstable.SSTableRewriter org.apache.cassandra.db.DecoratedKey
StackMap stack:
aload 0
getfield org.apache.cassandra.io.sstable.SSTableRewriter.writer:Lorg/apache/cassandra/io/sstable/format/SSTableWriter;
aload 0
getfield org.apache.cassandra.io.sstable.SSTableRewriter.maxAge:J
invokevirtual org.apache.cassandra.io.sstable.format.SSTableWriter.setMaxDataAge:(J)Lorg/apache/cassandra/io/sstable/format/SSTableWriter;
invokevirtual org.apache.cassandra.io.sstable.format.SSTableWriter.openEarly:()Lorg/apache/cassandra/io/sstable/format/SSTableReader;
astore 2
start local 2 11: aload 2
ifnull 16
12: aload 0
getfield org.apache.cassandra.io.sstable.SSTableRewriter.transaction:Lorg/apache/cassandra/db/lifecycle/ILifecycleTransaction;
aload 2
iconst_0
invokeinterface org.apache.cassandra.db.lifecycle.ILifecycleTransaction.update:(Lorg/apache/cassandra/io/sstable/format/SSTableReader;Z)V
13: aload 0
aload 0
getfield org.apache.cassandra.io.sstable.SSTableRewriter.writer:Lorg/apache/cassandra/io/sstable/format/SSTableWriter;
invokevirtual org.apache.cassandra.io.sstable.format.SSTableWriter.getFilePointer:()J
putfield org.apache.cassandra.io.sstable.SSTableRewriter.currentlyOpenedEarlyAt:J
14: aload 0
aload 2
aload 2
getfield org.apache.cassandra.io.sstable.format.SSTableReader.last:Lorg/apache/cassandra/db/DecoratedKey;
invokevirtual org.apache.cassandra.io.sstable.SSTableRewriter.moveStarts:(Lorg/apache/cassandra/io/sstable/format/SSTableReader;Lorg/apache/cassandra/db/DecoratedKey;)V
15: aload 0
getfield org.apache.cassandra.io.sstable.SSTableRewriter.transaction:Lorg/apache/cassandra/db/lifecycle/ILifecycleTransaction;
invokeinterface org.apache.cassandra.db.lifecycle.ILifecycleTransaction.checkpoint:()V
end local 2 16: StackMap locals:
StackMap stack:
return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 17 0 this Lorg/apache/cassandra/io/sstable/SSTableRewriter;
0 17 1 key Lorg/apache/cassandra/db/DecoratedKey;
4 8 2 reader Lorg/apache/cassandra/io/sstable/format/SSTableReader;
5 8 4 index Lorg/apache/cassandra/db/RowIndexEntry;
11 16 2 reader Lorg/apache/cassandra/io/sstable/format/SSTableReader;
MethodParameters:
Name Flags
key
protected java.lang.Throwable doAbort(java.lang.Throwable);
descriptor: (Ljava/lang/Throwable;)Ljava/lang/Throwable;
flags: (0x0004) ACC_PROTECTED
Code:
stack=2, locals=4, args_size=2
start local 0 start local 1 0: aload 0
getfield org.apache.cassandra.io.sstable.SSTableRewriter.writers:Ljava/util/List;
invokeinterface java.util.List.iterator:()Ljava/util/Iterator;
astore 3
goto 3
StackMap locals: org.apache.cassandra.io.sstable.SSTableRewriter java.lang.Throwable top java.util.Iterator
StackMap stack:
1: aload 3
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.io.sstable.format.SSTableWriter
astore 2
start local 2 2: aload 2
aload 1
invokevirtual org.apache.cassandra.io.sstable.format.SSTableWriter.abort:(Ljava/lang/Throwable;)Ljava/lang/Throwable;
astore 1
end local 2 3: StackMap locals:
StackMap stack:
aload 3
invokeinterface java.util.Iterator.hasNext:()Z
ifne 1
4: aload 0
getfield org.apache.cassandra.io.sstable.SSTableRewriter.transaction:Lorg/apache/cassandra/db/lifecycle/ILifecycleTransaction;
aload 1
invokeinterface org.apache.cassandra.db.lifecycle.ILifecycleTransaction.abort:(Ljava/lang/Throwable;)Ljava/lang/Throwable;
astore 1
5: aload 1
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 this Lorg/apache/cassandra/io/sstable/SSTableRewriter;
0 6 1 accumulate Ljava/lang/Throwable;
2 3 2 writer Lorg/apache/cassandra/io/sstable/format/SSTableWriter;
MethodParameters:
Name Flags
accumulate
protected java.lang.Throwable doCommit(java.lang.Throwable);
descriptor: (Ljava/lang/Throwable;)Ljava/lang/Throwable;
flags: (0x0004) ACC_PROTECTED
Code:
stack=2, locals=4, args_size=2
start local 0 start local 1 0: aload 0
getfield org.apache.cassandra.io.sstable.SSTableRewriter.writers:Ljava/util/List;
invokeinterface java.util.List.iterator:()Ljava/util/Iterator;
astore 3
goto 3
StackMap locals: org.apache.cassandra.io.sstable.SSTableRewriter java.lang.Throwable top java.util.Iterator
StackMap stack:
1: aload 3
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.io.sstable.format.SSTableWriter
astore 2
start local 2 2: aload 2
aload 1
invokevirtual org.apache.cassandra.io.sstable.format.SSTableWriter.commit:(Ljava/lang/Throwable;)Ljava/lang/Throwable;
astore 1
end local 2 3: StackMap locals:
StackMap stack:
aload 3
invokeinterface java.util.Iterator.hasNext:()Z
ifne 1
4: aload 0
getfield org.apache.cassandra.io.sstable.SSTableRewriter.transaction:Lorg/apache/cassandra/db/lifecycle/ILifecycleTransaction;
aload 1
invokeinterface org.apache.cassandra.db.lifecycle.ILifecycleTransaction.commit:(Ljava/lang/Throwable;)Ljava/lang/Throwable;
astore 1
5: aload 1
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 this Lorg/apache/cassandra/io/sstable/SSTableRewriter;
0 6 1 accumulate Ljava/lang/Throwable;
2 3 2 writer Lorg/apache/cassandra/io/sstable/format/SSTableWriter;
MethodParameters:
Name Flags
accumulate
private void moveStarts(org.apache.cassandra.io.sstable.format.SSTableReader, org.apache.cassandra.db.DecoratedKey);
descriptor: (Lorg/apache/cassandra/io/sstable/format/SSTableReader;Lorg/apache/cassandra/db/DecoratedKey;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=4, locals=10, args_size=3
start local 0 start local 1 start local 2 0: aload 0
getfield org.apache.cassandra.io.sstable.SSTableRewriter.transaction:Lorg/apache/cassandra/db/lifecycle/ILifecycleTransaction;
invokeinterface org.apache.cassandra.db.lifecycle.ILifecycleTransaction.isOffline:()Z
ifeq 2
1: return
2: StackMap locals:
StackMap stack:
aload 0
getfield org.apache.cassandra.io.sstable.SSTableRewriter.preemptiveOpenInterval:J
ldc 9223372036854775807
lcmp
ifne 4
3: return
4: StackMap locals:
StackMap stack:
aload 1
invokevirtual org.apache.cassandra.io.sstable.format.SSTableReader.setupOnline:()V
5: aconst_null
astore 3
start local 3 6: aload 0
getfield org.apache.cassandra.io.sstable.SSTableRewriter.cachedKeys:Ljava/util/Map;
invokeinterface java.util.Map.isEmpty:()Z
ifne 13
7: new java.util.ArrayList
dup
aload 0
getfield org.apache.cassandra.io.sstable.SSTableRewriter.cachedKeys:Ljava/util/Map;
invokeinterface java.util.Map.size:()I
invokespecial java.util.ArrayList.<init>:(I)V
astore 3
8: aload 0
getfield org.apache.cassandra.io.sstable.SSTableRewriter.cachedKeys:Ljava/util/Map;
invokeinterface java.util.Map.entrySet:()Ljava/util/Set;
invokeinterface java.util.Set.iterator:()Ljava/util/Iterator;
astore 5
goto 12
StackMap locals: org.apache.cassandra.io.sstable.SSTableRewriter org.apache.cassandra.io.sstable.format.SSTableReader org.apache.cassandra.db.DecoratedKey java.util.List top java.util.Iterator
StackMap stack:
9: aload 5
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast java.util.Map$Entry
astore 4
start local 4 10: aload 3
aload 4
invokeinterface java.util.Map$Entry.getKey:()Ljava/lang/Object;
checkcast org.apache.cassandra.db.DecoratedKey
invokeinterface java.util.List.add:(Ljava/lang/Object;)Z
pop
11: aload 1
aload 4
invokeinterface java.util.Map$Entry.getKey:()Ljava/lang/Object;
checkcast org.apache.cassandra.db.DecoratedKey
aload 4
invokeinterface java.util.Map$Entry.getValue:()Ljava/lang/Object;
checkcast org.apache.cassandra.db.RowIndexEntry
invokevirtual org.apache.cassandra.io.sstable.format.SSTableReader.cacheKey:(Lorg/apache/cassandra/db/DecoratedKey;Lorg/apache/cassandra/db/RowIndexEntry;)V
end local 4 12: StackMap locals:
StackMap stack:
aload 5
invokeinterface java.util.Iterator.hasNext:()Z
ifne 9
13: StackMap locals: org.apache.cassandra.io.sstable.SSTableRewriter org.apache.cassandra.io.sstable.format.SSTableReader org.apache.cassandra.db.DecoratedKey java.util.List
StackMap stack:
aload 0
getfield org.apache.cassandra.io.sstable.SSTableRewriter.cachedKeys:Ljava/util/Map;
invokeinterface java.util.Map.clear:()V
14: aload 0
getfield org.apache.cassandra.io.sstable.SSTableRewriter.transaction:Lorg/apache/cassandra/db/lifecycle/ILifecycleTransaction;
invokeinterface org.apache.cassandra.db.lifecycle.ILifecycleTransaction.originals:()Ljava/util/Set;
invokeinterface java.util.Set.iterator:()Ljava/util/Iterator;
astore 5
goto 32
StackMap locals: org.apache.cassandra.io.sstable.SSTableRewriter org.apache.cassandra.io.sstable.format.SSTableReader org.apache.cassandra.db.DecoratedKey java.util.List top java.util.Iterator
StackMap stack:
15: aload 5
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.io.sstable.format.SSTableReader
astore 4
start local 4 16: aload 0
getfield org.apache.cassandra.io.sstable.SSTableRewriter.transaction:Lorg/apache/cassandra/db/lifecycle/ILifecycleTransaction;
aload 4
invokeinterface org.apache.cassandra.db.lifecycle.ILifecycleTransaction.current:(Lorg/apache/cassandra/io/sstable/format/SSTableReader;)Lorg/apache/cassandra/io/sstable/format/SSTableReader;
astore 6
start local 6 17: aload 6
getfield org.apache.cassandra.io.sstable.format.SSTableReader.first:Lorg/apache/cassandra/db/DecoratedKey;
aload 2
invokevirtual org.apache.cassandra.db.DecoratedKey.compareTo:(Lorg/apache/cassandra/db/PartitionPosition;)I
ifle 19
18: goto 32
19: StackMap locals: org.apache.cassandra.io.sstable.SSTableRewriter org.apache.cassandra.io.sstable.format.SSTableReader org.apache.cassandra.db.DecoratedKey java.util.List org.apache.cassandra.io.sstable.format.SSTableReader java.util.Iterator org.apache.cassandra.io.sstable.format.SSTableReader
StackMap stack:
aload 3
ifnull 20
new org.apache.cassandra.io.sstable.SSTableRewriter$InvalidateKeys
dup
aload 6
aload 3
invokespecial org.apache.cassandra.io.sstable.SSTableRewriter$InvalidateKeys.<init>:(Lorg/apache/cassandra/io/sstable/format/SSTableReader;Ljava/util/Collection;)V
goto 21
StackMap locals:
StackMap stack:
20: aconst_null
StackMap locals:
StackMap stack: org.apache.cassandra.io.sstable.SSTableRewriter$InvalidateKeys
21: astore 7
start local 7 22: aload 2
aload 6
getfield org.apache.cassandra.io.sstable.format.SSTableReader.last:Lorg/apache/cassandra/db/DecoratedKey;
invokevirtual org.apache.cassandra.db.DecoratedKey.compareTo:(Lorg/apache/cassandra/db/PartitionPosition;)I
iflt 28
23: aload 0
getfield org.apache.cassandra.io.sstable.SSTableRewriter.transaction:Lorg/apache/cassandra/db/lifecycle/ILifecycleTransaction;
aload 6
invokeinterface org.apache.cassandra.db.lifecycle.ILifecycleTransaction.isObsolete:(Lorg/apache/cassandra/io/sstable/format/SSTableReader;)Z
ifne 32
24: aload 7
ifnull 26
25: aload 6
aload 7
invokevirtual org.apache.cassandra.io.sstable.format.SSTableReader.runOnClose:(Ljava/lang/Runnable;)V
26: StackMap locals: java.lang.Runnable
StackMap stack:
aload 0
getfield org.apache.cassandra.io.sstable.SSTableRewriter.transaction:Lorg/apache/cassandra/db/lifecycle/ILifecycleTransaction;
aload 6
invokeinterface org.apache.cassandra.db.lifecycle.ILifecycleTransaction.obsolete:(Lorg/apache/cassandra/io/sstable/format/SSTableReader;)V
27: goto 32
28: StackMap locals:
StackMap stack:
aload 6
aload 2
invokevirtual org.apache.cassandra.io.sstable.format.SSTableReader.firstKeyBeyond:(Lorg/apache/cassandra/db/PartitionPosition;)Lorg/apache/cassandra/db/DecoratedKey;
astore 8
start local 8 29: getstatic org.apache.cassandra.io.sstable.SSTableRewriter.$assertionsDisabled:Z
ifne 30
aload 8
ifnonnull 30
new java.lang.AssertionError
dup
invokespecial java.lang.AssertionError.<init>:()V
athrow
30: StackMap locals: org.apache.cassandra.db.DecoratedKey
StackMap stack:
aload 6
aload 8
aload 7
invokevirtual org.apache.cassandra.io.sstable.format.SSTableReader.cloneWithNewStart:(Lorg/apache/cassandra/db/DecoratedKey;Ljava/lang/Runnable;)Lorg/apache/cassandra/io/sstable/format/SSTableReader;
astore 9
start local 9 31: aload 0
getfield org.apache.cassandra.io.sstable.SSTableRewriter.transaction:Lorg/apache/cassandra/db/lifecycle/ILifecycleTransaction;
aload 9
iconst_1
invokeinterface org.apache.cassandra.db.lifecycle.ILifecycleTransaction.update:(Lorg/apache/cassandra/io/sstable/format/SSTableReader;Z)V
end local 9 end local 8 end local 7 end local 6 end local 4 32: StackMap locals: org.apache.cassandra.io.sstable.SSTableRewriter org.apache.cassandra.io.sstable.format.SSTableReader org.apache.cassandra.db.DecoratedKey java.util.List top java.util.Iterator
StackMap stack:
aload 5
invokeinterface java.util.Iterator.hasNext:()Z
ifne 15
33: return
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/io/sstable/SSTableRewriter;
0 34 1 newReader Lorg/apache/cassandra/io/sstable/format/SSTableReader;
0 34 2 lowerbound Lorg/apache/cassandra/db/DecoratedKey;
6 34 3 invalidateKeys Ljava/util/List<Lorg/apache/cassandra/db/DecoratedKey;>;
10 12 4 cacheKey Ljava/util/Map$Entry<Lorg/apache/cassandra/db/DecoratedKey;Lorg/apache/cassandra/db/RowIndexEntry;>;
16 32 4 sstable Lorg/apache/cassandra/io/sstable/format/SSTableReader;
17 32 6 latest Lorg/apache/cassandra/io/sstable/format/SSTableReader;
22 32 7 runOnClose Ljava/lang/Runnable;
29 32 8 newStart Lorg/apache/cassandra/db/DecoratedKey;
31 32 9 replacement Lorg/apache/cassandra/io/sstable/format/SSTableReader;
MethodParameters:
Name Flags
newReader
lowerbound
public void switchWriter(org.apache.cassandra.io.sstable.format.SSTableWriter);
descriptor: (Lorg/apache/cassandra/io/sstable/format/SSTableWriter;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=3, args_size=2
start local 0 start local 1 0: aload 1
ifnull 2
1: aload 0
getfield org.apache.cassandra.io.sstable.SSTableRewriter.writers:Ljava/util/List;
aload 1
aload 0
getfield org.apache.cassandra.io.sstable.SSTableRewriter.maxAge:J
invokevirtual org.apache.cassandra.io.sstable.format.SSTableWriter.setMaxDataAge:(J)Lorg/apache/cassandra/io/sstable/format/SSTableWriter;
invokeinterface java.util.List.add:(Ljava/lang/Object;)Z
pop
2: StackMap locals:
StackMap stack:
aload 0
getfield org.apache.cassandra.io.sstable.SSTableRewriter.writer:Lorg/apache/cassandra/io/sstable/format/SSTableWriter;
ifnull 3
aload 0
getfield org.apache.cassandra.io.sstable.SSTableRewriter.writer:Lorg/apache/cassandra/io/sstable/format/SSTableWriter;
invokevirtual org.apache.cassandra.io.sstable.format.SSTableWriter.getFilePointer:()J
lconst_0
lcmp
ifne 9
3: StackMap locals:
StackMap stack:
aload 0
getfield org.apache.cassandra.io.sstable.SSTableRewriter.writer:Lorg/apache/cassandra/io/sstable/format/SSTableWriter;
ifnull 7
4: aload 0
getfield org.apache.cassandra.io.sstable.SSTableRewriter.writer:Lorg/apache/cassandra/io/sstable/format/SSTableWriter;
invokevirtual org.apache.cassandra.io.sstable.format.SSTableWriter.abort:()V
5: aload 0
getfield org.apache.cassandra.io.sstable.SSTableRewriter.transaction:Lorg/apache/cassandra/db/lifecycle/ILifecycleTransaction;
aload 0
getfield org.apache.cassandra.io.sstable.SSTableRewriter.writer:Lorg/apache/cassandra/io/sstable/format/SSTableWriter;
invokeinterface org.apache.cassandra.db.lifecycle.ILifecycleTransaction.untrackNew:(Lorg/apache/cassandra/io/sstable/SSTable;)V
6: aload 0
getfield org.apache.cassandra.io.sstable.SSTableRewriter.writers:Ljava/util/List;
aload 0
getfield org.apache.cassandra.io.sstable.SSTableRewriter.writer:Lorg/apache/cassandra/io/sstable/format/SSTableWriter;
invokeinterface java.util.List.remove:(Ljava/lang/Object;)Z
pop
7: StackMap locals:
StackMap stack:
aload 0
aload 1
putfield org.apache.cassandra.io.sstable.SSTableRewriter.writer:Lorg/apache/cassandra/io/sstable/format/SSTableWriter;
8: return
9: StackMap locals:
StackMap stack:
aload 0
getfield org.apache.cassandra.io.sstable.SSTableRewriter.preemptiveOpenInterval:J
ldc 9223372036854775807
lcmp
ifeq 14
10: aload 0
getfield org.apache.cassandra.io.sstable.SSTableRewriter.writer:Lorg/apache/cassandra/io/sstable/format/SSTableWriter;
aload 0
getfield org.apache.cassandra.io.sstable.SSTableRewriter.maxAge:J
invokevirtual org.apache.cassandra.io.sstable.format.SSTableWriter.setMaxDataAge:(J)Lorg/apache/cassandra/io/sstable/format/SSTableWriter;
invokevirtual org.apache.cassandra.io.sstable.format.SSTableWriter.openFinalEarly:()Lorg/apache/cassandra/io/sstable/format/SSTableReader;
astore 2
start local 2 11: aload 0
getfield org.apache.cassandra.io.sstable.SSTableRewriter.transaction:Lorg/apache/cassandra/db/lifecycle/ILifecycleTransaction;
aload 2
iconst_0
invokeinterface org.apache.cassandra.db.lifecycle.ILifecycleTransaction.update:(Lorg/apache/cassandra/io/sstable/format/SSTableReader;Z)V
12: aload 0
aload 2
aload 2
getfield org.apache.cassandra.io.sstable.format.SSTableReader.last:Lorg/apache/cassandra/db/DecoratedKey;
invokevirtual org.apache.cassandra.io.sstable.SSTableRewriter.moveStarts:(Lorg/apache/cassandra/io/sstable/format/SSTableReader;Lorg/apache/cassandra/db/DecoratedKey;)V
13: aload 0
getfield org.apache.cassandra.io.sstable.SSTableRewriter.transaction:Lorg/apache/cassandra/db/lifecycle/ILifecycleTransaction;
invokeinterface org.apache.cassandra.db.lifecycle.ILifecycleTransaction.checkpoint:()V
end local 2 14: StackMap locals:
StackMap stack:
aload 0
lconst_0
putfield org.apache.cassandra.io.sstable.SSTableRewriter.currentlyOpenedEarlyAt:J
15: aload 0
aload 1
putfield org.apache.cassandra.io.sstable.SSTableRewriter.writer:Lorg/apache/cassandra/io/sstable/format/SSTableWriter;
16: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 17 0 this Lorg/apache/cassandra/io/sstable/SSTableRewriter;
0 17 1 newWriter Lorg/apache/cassandra/io/sstable/format/SSTableWriter;
11 14 2 reader Lorg/apache/cassandra/io/sstable/format/SSTableReader;
MethodParameters:
Name Flags
newWriter
public org.apache.cassandra.io.sstable.SSTableRewriter setRepairedAt(long);
descriptor: (J)Lorg/apache/cassandra/io/sstable/SSTableRewriter;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=3, args_size=2
start local 0 start local 1 0: aload 0
lload 1
putfield org.apache.cassandra.io.sstable.SSTableRewriter.repairedAt:J
1: aload 0
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/apache/cassandra/io/sstable/SSTableRewriter;
0 2 1 repairedAt J
MethodParameters:
Name Flags
repairedAt
public java.util.List<org.apache.cassandra.io.sstable.format.SSTableReader> finish();
descriptor: ()Ljava/util/List;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
invokespecial org.apache.cassandra.utils.concurrent.Transactional$AbstractTransactional.finish:()Ljava/lang/Object;
pop
1: aload 0
invokevirtual org.apache.cassandra.io.sstable.SSTableRewriter.finished:()Ljava/util/List;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/apache/cassandra/io/sstable/SSTableRewriter;
Signature: ()Ljava/util/List<Lorg/apache/cassandra/io/sstable/format/SSTableReader;>;
public java.util.List<org.apache.cassandra.io.sstable.format.SSTableReader> finished();
descriptor: ()Ljava/util/List;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: getstatic org.apache.cassandra.io.sstable.SSTableRewriter.$assertionsDisabled:Z
ifne 1
aload 0
invokevirtual org.apache.cassandra.io.sstable.SSTableRewriter.state:()Lorg/apache/cassandra/utils/concurrent/Transactional$AbstractTransactional$State;
getstatic org.apache.cassandra.utils.concurrent.Transactional$AbstractTransactional$State.COMMITTED:Lorg/apache/cassandra/utils/concurrent/Transactional$AbstractTransactional$State;
if_acmpeq 1
aload 0
invokevirtual org.apache.cassandra.io.sstable.SSTableRewriter.state:()Lorg/apache/cassandra/utils/concurrent/Transactional$AbstractTransactional$State;
getstatic org.apache.cassandra.utils.concurrent.Transactional$AbstractTransactional$State.READY_TO_COMMIT:Lorg/apache/cassandra/utils/concurrent/Transactional$AbstractTransactional$State;
if_acmpeq 1
new java.lang.AssertionError
dup
invokespecial java.lang.AssertionError.<init>:()V
athrow
1: StackMap locals:
StackMap stack:
aload 0
getfield org.apache.cassandra.io.sstable.SSTableRewriter.preparedForCommit:Ljava/util/List;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/apache/cassandra/io/sstable/SSTableRewriter;
Signature: ()Ljava/util/List<Lorg/apache/cassandra/io/sstable/format/SSTableReader;>;
protected void doPrepare();
descriptor: ()V
flags: (0x0004) ACC_PROTECTED
Code:
stack=4, locals=4, args_size=1
start local 0 0: aload 0
aconst_null
invokevirtual org.apache.cassandra.io.sstable.SSTableRewriter.switchWriter:(Lorg/apache/cassandra/io/sstable/format/SSTableWriter;)V
1: aload 0
getfield org.apache.cassandra.io.sstable.SSTableRewriter.throwEarly:Z
ifeq 3
2: new java.lang.RuntimeException
dup
ldc "exception thrown early in finish, for testing"
invokespecial java.lang.RuntimeException.<init>:(Ljava/lang/String;)V
athrow
3: StackMap locals:
StackMap stack:
aload 0
getfield org.apache.cassandra.io.sstable.SSTableRewriter.writers:Ljava/util/List;
invokeinterface java.util.List.iterator:()Ljava/util/Iterator;
astore 2
goto 10
StackMap locals: org.apache.cassandra.io.sstable.SSTableRewriter top java.util.Iterator
StackMap stack:
4: aload 2
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.io.sstable.format.SSTableWriter
astore 1
start local 1 5: getstatic org.apache.cassandra.io.sstable.SSTableRewriter.$assertionsDisabled:Z
ifne 6
aload 1
invokevirtual org.apache.cassandra.io.sstable.format.SSTableWriter.getFilePointer:()J
lconst_0
lcmp
ifgt 6
new java.lang.AssertionError
dup
invokespecial java.lang.AssertionError.<init>:()V
athrow
6: StackMap locals: org.apache.cassandra.io.sstable.SSTableRewriter org.apache.cassandra.io.sstable.format.SSTableWriter java.util.Iterator
StackMap stack:
aload 1
aload 0
getfield org.apache.cassandra.io.sstable.SSTableRewriter.repairedAt:J
invokevirtual org.apache.cassandra.io.sstable.format.SSTableWriter.setRepairedAt:(J)Lorg/apache/cassandra/io/sstable/format/SSTableWriter;
iconst_1
invokevirtual org.apache.cassandra.io.sstable.format.SSTableWriter.setOpenResult:(Z)Lorg/apache/cassandra/io/sstable/format/SSTableWriter;
invokevirtual org.apache.cassandra.io.sstable.format.SSTableWriter.prepareToCommit:()V
7: aload 1
invokevirtual org.apache.cassandra.io.sstable.format.SSTableWriter.finished:()Lorg/apache/cassandra/io/sstable/format/SSTableReader;
astore 3
start local 3 8: aload 0
getfield org.apache.cassandra.io.sstable.SSTableRewriter.transaction:Lorg/apache/cassandra/db/lifecycle/ILifecycleTransaction;
aload 3
iconst_0
invokeinterface org.apache.cassandra.db.lifecycle.ILifecycleTransaction.update:(Lorg/apache/cassandra/io/sstable/format/SSTableReader;Z)V
9: aload 0
getfield org.apache.cassandra.io.sstable.SSTableRewriter.preparedForCommit:Ljava/util/List;
aload 3
invokeinterface java.util.List.add:(Ljava/lang/Object;)Z
pop
end local 3 end local 1 10: StackMap locals: org.apache.cassandra.io.sstable.SSTableRewriter top java.util.Iterator
StackMap stack:
aload 2
invokeinterface java.util.Iterator.hasNext:()Z
ifne 4
11: aload 0
getfield org.apache.cassandra.io.sstable.SSTableRewriter.transaction:Lorg/apache/cassandra/db/lifecycle/ILifecycleTransaction;
invokeinterface org.apache.cassandra.db.lifecycle.ILifecycleTransaction.checkpoint:()V
12: aload 0
getfield org.apache.cassandra.io.sstable.SSTableRewriter.throwLate:Z
ifeq 14
13: new java.lang.RuntimeException
dup
ldc "exception thrown after all sstables finished, for testing"
invokespecial java.lang.RuntimeException.<init>:(Ljava/lang/String;)V
athrow
14: StackMap locals: org.apache.cassandra.io.sstable.SSTableRewriter
StackMap stack:
aload 0
getfield org.apache.cassandra.io.sstable.SSTableRewriter.keepOriginals:Z
ifne 16
15: aload 0
getfield org.apache.cassandra.io.sstable.SSTableRewriter.transaction:Lorg/apache/cassandra/db/lifecycle/ILifecycleTransaction;
invokeinterface org.apache.cassandra.db.lifecycle.ILifecycleTransaction.obsoleteOriginals:()V
16: StackMap locals:
StackMap stack:
aload 0
getfield org.apache.cassandra.io.sstable.SSTableRewriter.transaction:Lorg/apache/cassandra/db/lifecycle/ILifecycleTransaction;
invokeinterface org.apache.cassandra.db.lifecycle.ILifecycleTransaction.prepareToCommit:()V
17: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 18 0 this Lorg/apache/cassandra/io/sstable/SSTableRewriter;
5 10 1 writer Lorg/apache/cassandra/io/sstable/format/SSTableWriter;
8 10 3 reader Lorg/apache/cassandra/io/sstable/format/SSTableReader;
public void throwDuringPrepare(boolean);
descriptor: (Z)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: iload 1
ifeq 2
1: aload 0
iconst_1
putfield org.apache.cassandra.io.sstable.SSTableRewriter.throwEarly:Z
goto 3
2: StackMap locals:
StackMap stack:
aload 0
iconst_1
putfield org.apache.cassandra.io.sstable.SSTableRewriter.throwLate:Z
3: StackMap locals:
StackMap stack:
return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lorg/apache/cassandra/io/sstable/SSTableRewriter;
0 4 1 earlyException Z
MethodParameters:
Name Flags
earlyException
public java.lang.Object finish();
descriptor: ()Ljava/lang/Object;
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=1, locals=1, args_size=1
0: aload 0
invokevirtual org.apache.cassandra.io.sstable.SSTableRewriter.finish:()Ljava/util/List;
areturn
LocalVariableTable:
Start End Slot Name Signature
}
SourceFile: "SSTableRewriter.java"
NestMembers:
org.apache.cassandra.io.sstable.SSTableRewriter$InvalidateKeys
InnerClasses:
public abstract Entry = java.util.Map$Entry of java.util.Map
private final InvalidateKeys = org.apache.cassandra.io.sstable.SSTableRewriter$InvalidateKeys of org.apache.cassandra.io.sstable.SSTableRewriter
public abstract Operator = org.apache.cassandra.io.sstable.format.SSTableReader$Operator of org.apache.cassandra.io.sstable.format.SSTableReader
public abstract AbstractTransactional = org.apache.cassandra.utils.concurrent.Transactional$AbstractTransactional of org.apache.cassandra.utils.concurrent.Transactional
public final State = org.apache.cassandra.utils.concurrent.Transactional$AbstractTransactional$State of org.apache.cassandra.utils.concurrent.Transactional$AbstractTransactional