You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@cassandra.apache.org by bd...@apache.org on 2017/02/16 16:43:25 UTC
cassandra git commit: remove unused method
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 <bd...@gmail.com>
Authored: Wed Feb 15 11:22:45 2017 -0800
Committer: Blake Eggleston <bd...@gmail.com>
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
*/