Repository: cassandra Updated Branches: refs/heads/trunk b6fdaba6e -> aea8bbff3
remove unused method Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/aea8bbff Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/aea8bbff Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/aea8bbff Branch: refs/heads/trunk Commit: aea8bbff3b3a9fade3358c56e2c3f32a5f64862f Parents: b6fdaba Author: Blake Eggleston <[email protected]> Authored: Wed Feb 15 11:22:45 2017 -0800 Committer: Blake Eggleston <[email protected]> Committed: Thu Feb 16 08:43:03 2017 -0800 ---------------------------------------------------------------------- .../db/compaction/CompactionManager.java | 42 -------------------- 1 file changed, 42 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/cassandra/blob/aea8bbff/src/java/org/apache/cassandra/db/compaction/CompactionManager.java ---------------------------------------------------------------------- diff --git a/src/java/org/apache/cassandra/db/compaction/CompactionManager.java b/src/java/org/apache/cassandra/db/compaction/CompactionManager.java index 5a1313b..6d868c9 100644 --- a/src/java/org/apache/cassandra/db/compaction/CompactionManager.java +++ b/src/java/org/apache/cassandra/db/compaction/CompactionManager.java @@ -565,48 +565,6 @@ public class CompactionManager implements CompactionManagerMBean }, jobs, OperationType.RELOCATE); } - public ListenableFuture<?> submitAntiCompaction(final ColumnFamilyStore cfs, - final Collection<Range<Token>> ranges, - final Refs<SSTableReader> sstables, - final long repairedAt, - final UUID pendingRepair, - final UUID parentRepairSession) - { - Runnable runnable = new WrappedRunnable() - { - @Override - @SuppressWarnings("resource") - public void runMayThrow() throws Exception - { - LifecycleTransaction modifier = null; - while (modifier == null) - { - for (SSTableReader compactingSSTable : cfs.getTracker().getCompacting()) - sstables.releaseIfHolds(compactingSSTable); - Set<SSTableReader> compactedSSTables = new HashSet<>(); - for (SSTableReader sstable : sstables) - if (sstable.isMarkedCompacted()) - compactedSSTables.add(sstable); - sstables.release(compactedSSTables); - modifier = cfs.getTracker().tryModify(sstables, OperationType.ANTICOMPACTION); - } - performAnticompaction(cfs, ranges, sstables, modifier, repairedAt, pendingRepair, parentRepairSession); - } - }; - - ListenableFuture<?> ret = null; - try - { - ret = executor.submitIfRunning(runnable, "anticompaction"); - return ret; - } - finally - { - if (ret == null || ret.isCancelled()) - sstables.release(); - } - } - /** * Splits the given token ranges of the given sstables into a pending repair silo */
