import org.apache.cassandra.db.DataTracker; //导入依赖的package包/类
/**
 * Returns a Pair of all compacting and non-compacting sstables.  Non-compacting sstables will be marked as
 * compacting.
 */
private Pair<List<SSTableReader>, Multimap<DataTracker, SSTableReader>> getCompactingAndNonCompactingSSTables()
{
    List<SSTableReader> allCompacting = new ArrayList<>();
    Multimap<DataTracker, SSTableReader> allNonCompacting = HashMultimap.create();
    for (Keyspace ks : Keyspace.all())
    {
        for (ColumnFamilyStore cfStore: ks.getColumnFamilyStores())
        {
            Set<SSTableReader> nonCompacting, allSSTables;
            do
            {
                allSSTables = cfStore.getDataTracker().getSSTables();
                nonCompacting = Sets.newHashSet(cfStore.getDataTracker().getUncompactingSSTables(allSSTables));
            }
            while (!(nonCompacting.isEmpty() || cfStore.getDataTracker().markCompacting(nonCompacting)));
            allNonCompacting.putAll(cfStore.getDataTracker(), nonCompacting);
            allCompacting.addAll(Sets.difference(allSSTables, nonCompacting));
        }
    }
    return Pair.create(allCompacting, allNonCompacting);
}
 

import org.apache.cassandra.db.DataTracker; //导入依赖的package包/类
private void refreshOverlaps()
{
    if (this.overlappingSSTables != null)
        overlappingSSTables.release();

    if (compacting == null)
        overlappingSSTables = Refs.tryRef(Collections.<SSTableReader>emptyList());
    else
        overlappingSSTables = cfs.getAndReferenceOverlappingSSTables(compacting);
    this.overlappingTree = DataTracker.buildIntervalTree(overlappingSSTables);
}
 

import org.apache.cassandra.db.DataTracker; //导入依赖的package包/类
public void setTracker(DataTracker tracker)
{
    // the tracker is used only to notify listeners of deletion of the sstable;
    // since deletion of a non-final file is not really deletion of the sstable,
    // we don't want to notify the listeners in this event
    if (desc.type == Descriptor.Type.FINAL)
        this.tracker = tracker;
}
 

import org.apache.cassandra.db.DataTracker; //导入依赖的package包/类
public void setTrackedBy(DataTracker tracker)
{
    tidy.type.deletingTask.setTracker(tracker);
    // under normal operation we can do this at any time, but SSTR is also used outside C* proper,
    // e.g. by BulkLoader, which does not initialize the cache.  As a kludge, we set up the cache
    // here when we know we're being wired into the rest of the server infrastructure.
    keyCache = CacheService.instance.keyCache;
}
 

import org.apache.cassandra.db.DataTracker; //导入依赖的package包/类
public void redistributeSummaries() throws IOException
{
    Pair<List<SSTableReader>, Multimap<DataTracker, SSTableReader>> compactingAndNonCompacting = getCompactingAndNonCompactingSSTables();
    try
    {
        redistributeSummaries(compactingAndNonCompacting.left, Lists.newArrayList(compactingAndNonCompacting.right.values()), this.memoryPoolBytes);
    }
    finally
    {
        for(DataTracker tracker : compactingAndNonCompacting.right.keySet())
            tracker.unmarkCompacting(compactingAndNonCompacting.right.get(tracker));
    }
}
 

import org.apache.cassandra.db.DataTracker; //导入依赖的package包/类
public void setTrackedBy(DataTracker tracker)
{
    deletingTask.setTracker(tracker);
    // under normal operation we can do this at any time, but SSTR is also used outside C* proper,
    // e.g. by BulkLoader, which does not initialize the cache.  As a kludge, we set up the cache
    // here when we know we're being wired into the rest of the server infrastructure.
    keyCache = CacheService.instance.keyCache;
}
 

import org.apache.cassandra.db.DataTracker; //导入依赖的package包/类
SSTableDeletingReference(DataTracker tracker, SSTableReader referent, ReferenceQueue<? super SSTableReader> q)
{
    super(referent, q);
    this.tracker = tracker;
    this.desc = referent.descriptor;
    this.components = referent.components;
    this.size = referent.bytesOnDisk();
}
 

import org.apache.cassandra.db.DataTracker; //导入依赖的package包/类
public void setTracker(DataTracker tracker)
{
    this.tracker = tracker;
}