cassandra-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From bdeggles...@apache.org
Subject cassandra git commit: remove unused method
Date Thu, 16 Feb 2017 16:43:25 GMT
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 <bdeggleston@gmail.com>
Authored: Wed Feb 15 11:22:45 2017 -0800
Committer: Blake Eggleston <bdeggleston@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
      */


Mime
View raw message