org.apache.cassandra/cassandra-all/3.11.5 : org/apache/cassandra/db/lifecycle/LogTransaction$SSTableTidier.class

LogTransaction$SSTableTidier
https://cassandra.apache.org: The Apache Cassandra Project develops a highly scalable second-generation distributed database, bringing together Dynamo's fully distributed design and Bigtable's ColumnFamily-based data model.
The Apache Software License, Version 2.0
Andres de la Peña
Avinash Lakshman
Aleksey Yeschenko
Aaron Morton
Ariel Weisberg
Blake Eggleston
Benedict Elliott Smith
Benjamin Lerer
Branimir Lambov
Brandon Williams
Carl Yeksigian
David Brosiusd
Dikang Gu
Eric Evans
Gary Dusbabek
Chris Goffinet
Alex Petrov
Laine Jaakko Olavi
T Jake Luciani
Jason Brown
Jonathan Ellis
Jake Farrell
Jeff Jirsa
Joel Knighton
Josh McKenzie
Johan Oskarsson
Jun Rao
Jay Zhuang
Sankalp Kohli
Marcus Eriksson
Michael Semb Wever
Mikhail Stepura
Michael Shuler
Paulo Motta
Prashant Malik
Robert Stupp
Peter Schuller
Sam Tunnicliffe
Sylvain Lebresne
Stefania Alborghetti
Tyler Hobbs
Vijay Parthasarathy
Pavel Yaskevich
Yuki Morishita
Nate McCall
public class org.apache.cassandra.db.lifecycle.LogTransaction$SSTableTidier implements java.lang.Runnable
  minor version: 0
  major version: 59
  flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
  this_class: org.apache.cassandra.db.lifecycle.LogTransaction$SSTableTidier
  super_class: java.lang.Object
{
  private final org.apache.cassandra.io.sstable.Descriptor desc;
    descriptor: Lorg/apache/cassandra/io/sstable/Descriptor;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  private final long sizeOnDisk;
    descriptor: J
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  private final org.apache.cassandra.db.lifecycle.Tracker tracker;
    descriptor: Lorg/apache/cassandra/db/lifecycle/Tracker;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  private final boolean wasNew;
    descriptor: Z
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  private final org.apache.cassandra.utils.concurrent.Ref<org.apache.cassandra.db.lifecycle.LogTransaction> parentRef;
    descriptor: Lorg/apache/cassandra/utils/concurrent/Ref;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL
    Signature: Lorg/apache/cassandra/utils/concurrent/Ref<Lorg/apache/cassandra/db/lifecycle/LogTransaction;>;

  public void <init>(org.apache.cassandra.io.sstable.format.SSTableReader, boolean, org.apache.cassandra.db.lifecycle.LogTransaction);
    descriptor: (Lorg/apache/cassandra/io/sstable/format/SSTableReader;ZLorg/apache/cassandra/db/lifecycle/LogTransaction;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=4, args_size=4
        start local 0 // org.apache.cassandra.db.lifecycle.LogTransaction$SSTableTidier this
        start local 1 // org.apache.cassandra.io.sstable.format.SSTableReader referent
        start local 2 // boolean wasNew
        start local 3 // org.apache.cassandra.db.lifecycle.LogTransaction parent
         0: .line 329
            aload 0 /* this */
            invokespecial java.lang.Object.<init>:()V
         1: .line 331
            aload 0 /* this */
            aload 1 /* referent */
            getfield org.apache.cassandra.io.sstable.format.SSTableReader.descriptor:Lorg/apache/cassandra/io/sstable/Descriptor;
            putfield org.apache.cassandra.db.lifecycle.LogTransaction$SSTableTidier.desc:Lorg/apache/cassandra/io/sstable/Descriptor;
         2: .line 332
            aload 0 /* this */
            aload 1 /* referent */
            invokevirtual org.apache.cassandra.io.sstable.format.SSTableReader.bytesOnDisk:()J
            putfield org.apache.cassandra.db.lifecycle.LogTransaction$SSTableTidier.sizeOnDisk:J
         3: .line 333
            aload 0 /* this */
            aload 3 /* parent */
            getfield org.apache.cassandra.db.lifecycle.LogTransaction.tracker:Lorg/apache/cassandra/db/lifecycle/Tracker;
            putfield org.apache.cassandra.db.lifecycle.LogTransaction$SSTableTidier.tracker:Lorg/apache/cassandra/db/lifecycle/Tracker;
         4: .line 334
            aload 0 /* this */
            iload 2 /* wasNew */
            putfield org.apache.cassandra.db.lifecycle.LogTransaction$SSTableTidier.wasNew:Z
         5: .line 335
            aload 0 /* this */
            aload 3 /* parent */
            getfield org.apache.cassandra.db.lifecycle.LogTransaction.selfRef:Lorg/apache/cassandra/utils/concurrent/Ref;
            invokevirtual org.apache.cassandra.utils.concurrent.Ref.tryRef:()Lorg/apache/cassandra/utils/concurrent/Ref;
            putfield org.apache.cassandra.db.lifecycle.LogTransaction$SSTableTidier.parentRef:Lorg/apache/cassandra/utils/concurrent/Ref;
         6: .line 336
            return
        end local 3 // org.apache.cassandra.db.lifecycle.LogTransaction parent
        end local 2 // boolean wasNew
        end local 1 // org.apache.cassandra.io.sstable.format.SSTableReader referent
        end local 0 // org.apache.cassandra.db.lifecycle.LogTransaction$SSTableTidier this
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0    7     0      this  Lorg/apache/cassandra/db/lifecycle/LogTransaction$SSTableTidier;
            0    7     1  referent  Lorg/apache/cassandra/io/sstable/format/SSTableReader;
            0    7     2    wasNew  Z
            0    7     3    parent  Lorg/apache/cassandra/db/lifecycle/LogTransaction;
    MethodParameters:
          Name  Flags
      referent  
      wasNew    
      parent    

  public void run();
    descriptor: ()V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=4, locals=2, args_size=1
        start local 0 // org.apache.cassandra.db.lifecycle.LogTransaction$SSTableTidier this
         0: .line 340
            aload 0 /* this */
            getfield org.apache.cassandra.db.lifecycle.LogTransaction$SSTableTidier.tracker:Lorg/apache/cassandra/db/lifecycle/Tracker;
            ifnull 2
            aload 0 /* this */
            getfield org.apache.cassandra.db.lifecycle.LogTransaction$SSTableTidier.tracker:Lorg/apache/cassandra/db/lifecycle/Tracker;
            invokevirtual org.apache.cassandra.db.lifecycle.Tracker.isDummy:()Z
            ifne 2
         1: .line 341
            aload 0 /* this */
            getfield org.apache.cassandra.db.lifecycle.LogTransaction$SSTableTidier.desc:Lorg/apache/cassandra/io/sstable/Descriptor;
            getfield org.apache.cassandra.io.sstable.Descriptor.ksname:Ljava/lang/String;
            aload 0 /* this */
            getfield org.apache.cassandra.db.lifecycle.LogTransaction$SSTableTidier.desc:Lorg/apache/cassandra/io/sstable/Descriptor;
            getfield org.apache.cassandra.io.sstable.Descriptor.cfname:Ljava/lang/String;
            aload 0 /* this */
            getfield org.apache.cassandra.db.lifecycle.LogTransaction$SSTableTidier.desc:Lorg/apache/cassandra/io/sstable/Descriptor;
            getfield org.apache.cassandra.io.sstable.Descriptor.generation:I
            invokestatic org.apache.cassandra.db.SystemKeyspace.clearSSTableReadMeter:(Ljava/lang/String;Ljava/lang/String;I)V
         2: .line 346
      StackMap locals:
      StackMap stack:
            new java.io.File
            dup
            aload 0 /* this */
            getfield org.apache.cassandra.db.lifecycle.LogTransaction$SSTableTidier.desc:Lorg/apache/cassandra/io/sstable/Descriptor;
            getstatic org.apache.cassandra.io.sstable.Component.DATA:Lorg/apache/cassandra/io/sstable/Component;
            invokevirtual org.apache.cassandra.io.sstable.Descriptor.filenameFor:(Lorg/apache/cassandra/io/sstable/Component;)Ljava/lang/String;
            invokespecial java.io.File.<init>:(Ljava/lang/String;)V
            astore 1 /* datafile */
        start local 1 // java.io.File datafile
         3: .line 348
            aload 1 /* datafile */
            invokevirtual java.io.File.exists:()Z
            ifeq 5
         4: .line 349
            aload 1 /* datafile */
            invokestatic org.apache.cassandra.db.lifecycle.LogTransaction.delete:(Ljava/io/File;)V
            goto 7
         5: .line 350
      StackMap locals: java.io.File
      StackMap stack:
            aload 0 /* this */
            getfield org.apache.cassandra.db.lifecycle.LogTransaction$SSTableTidier.wasNew:Z
            ifne 7
         6: .line 351
            getstatic org.apache.cassandra.db.lifecycle.LogTransaction.logger:Lorg/slf4j/Logger;
            ldc "SSTableTidier ran with no existing data file for an sstable that was not new"
            invokeinterface org.slf4j.Logger.error:(Ljava/lang/String;)V
         7: .line 354
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield org.apache.cassandra.db.lifecycle.LogTransaction$SSTableTidier.desc:Lorg/apache/cassandra/io/sstable/Descriptor;
            aload 0 /* this */
            getfield org.apache.cassandra.db.lifecycle.LogTransaction$SSTableTidier.desc:Lorg/apache/cassandra/io/sstable/Descriptor;
            invokestatic org.apache.cassandra.io.sstable.SSTable.discoverComponentsFor:(Lorg/apache/cassandra/io/sstable/Descriptor;)Ljava/util/Set;
            invokestatic org.apache.cassandra.io.sstable.SSTable.delete:(Lorg/apache/cassandra/io/sstable/Descriptor;Ljava/util/Set;)Z
            pop
        end local 1 // java.io.File datafile
         8: .line 355
            goto 13
         9: .line 356
      StackMap locals: org.apache.cassandra.db.lifecycle.LogTransaction$SSTableTidier
      StackMap stack: java.lang.Throwable
            pop
        10: .line 358
            getstatic org.apache.cassandra.db.lifecycle.LogTransaction.logger:Lorg/slf4j/Logger;
            ldc "Failed deletion for {}, we'll retry after GC and on server restart"
            aload 0 /* this */
            getfield org.apache.cassandra.db.lifecycle.LogTransaction$SSTableTidier.desc:Lorg/apache/cassandra/io/sstable/Descriptor;
            invokeinterface org.slf4j.Logger.error:(Ljava/lang/String;Ljava/lang/Object;)V
        11: .line 359
            getstatic org.apache.cassandra.db.lifecycle.LogTransaction.failedDeletions:Ljava/util/Queue;
            aload 0 /* this */
            invokeinterface java.util.Queue.add:(Ljava/lang/Object;)Z
            pop
        12: .line 360
            return
        13: .line 363
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield org.apache.cassandra.db.lifecycle.LogTransaction$SSTableTidier.tracker:Lorg/apache/cassandra/db/lifecycle/Tracker;
            ifnull 15
            aload 0 /* this */
            getfield org.apache.cassandra.db.lifecycle.LogTransaction$SSTableTidier.tracker:Lorg/apache/cassandra/db/lifecycle/Tracker;
            getfield org.apache.cassandra.db.lifecycle.Tracker.cfstore:Lorg/apache/cassandra/db/ColumnFamilyStore;
            ifnull 15
            aload 0 /* this */
            getfield org.apache.cassandra.db.lifecycle.LogTransaction$SSTableTidier.wasNew:Z
            ifne 15
        14: .line 364
            aload 0 /* this */
            getfield org.apache.cassandra.db.lifecycle.LogTransaction$SSTableTidier.tracker:Lorg/apache/cassandra/db/lifecycle/Tracker;
            getfield org.apache.cassandra.db.lifecycle.Tracker.cfstore:Lorg/apache/cassandra/db/ColumnFamilyStore;
            getfield org.apache.cassandra.db.ColumnFamilyStore.metric:Lorg/apache/cassandra/metrics/TableMetrics;
            getfield org.apache.cassandra.metrics.TableMetrics.totalDiskSpaceUsed:Lcom/codahale/metrics/Counter;
            aload 0 /* this */
            getfield org.apache.cassandra.db.lifecycle.LogTransaction$SSTableTidier.sizeOnDisk:J
            invokevirtual com.codahale.metrics.Counter.dec:(J)V
        15: .line 367
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield org.apache.cassandra.db.lifecycle.LogTransaction$SSTableTidier.parentRef:Lorg/apache/cassandra/utils/concurrent/Ref;
            invokevirtual org.apache.cassandra.utils.concurrent.Ref.release:()V
        16: .line 368
            return
        end local 0 // org.apache.cassandra.db.lifecycle.LogTransaction$SSTableTidier this
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0   17     0      this  Lorg/apache/cassandra/db/lifecycle/LogTransaction$SSTableTidier;
            3    8     1  datafile  Ljava/io/File;
      Exception table:
        from    to  target  type
           2     8       9  Class java.lang.Throwable

  public void abort();
    descriptor: ()V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // org.apache.cassandra.db.lifecycle.LogTransaction$SSTableTidier this
         0: .line 372
            aload 0 /* this */
            getfield org.apache.cassandra.db.lifecycle.LogTransaction$SSTableTidier.parentRef:Lorg/apache/cassandra/utils/concurrent/Ref;
            invokevirtual org.apache.cassandra.utils.concurrent.Ref.release:()V
         1: .line 373
            return
        end local 0 // org.apache.cassandra.db.lifecycle.LogTransaction$SSTableTidier this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    2     0  this  Lorg/apache/cassandra/db/lifecycle/LogTransaction$SSTableTidier;
}
SourceFile: "LogTransaction.java"
NestHost: org.apache.cassandra.db.lifecycle.LogTransaction
InnerClasses:
  public SSTableTidier = org.apache.cassandra.db.lifecycle.LogTransaction$SSTableTidier of org.apache.cassandra.db.lifecycle.LogTransaction
/

org.apache.cassandra/ cassandra-all/ 3.11.5/ org/apache/cassandra/db/lifecycle/LogTransaction$SSTableTidier.class
