comment
Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/f2a57f04 Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/f2a57f04 Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/f2a57f04 Branch: refs/heads/cassandra-1.2 Commit: f2a57f04c4ea11705d848e08f230b8201d475fc3 Parents: 0b83682 Author: Jonathan Ellis <jbel...@apache.org> Authored: Thu Feb 14 19:06:00 2013 -0600 Committer: Jonathan Ellis <jbel...@apache.org> Committed: Thu Feb 14 19:06:14 2013 -0600 ---------------------------------------------------------------------- .../compaction/SizeTieredCompactionStrategy.java | 1 + 1 files changed, 1 insertions(+), 0 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/cassandra/blob/f2a57f04/src/java/org/apache/cassandra/db/compaction/SizeTieredCompactionStrategy.java ---------------------------------------------------------------------- diff --git a/src/java/org/apache/cassandra/db/compaction/SizeTieredCompactionStrategy.java b/src/java/org/apache/cassandra/db/compaction/SizeTieredCompactionStrategy.java index 5e01733..fab087e 100644 --- a/src/java/org/apache/cassandra/db/compaction/SizeTieredCompactionStrategy.java +++ b/src/java/org/apache/cassandra/db/compaction/SizeTieredCompactionStrategy.java @@ -58,6 +58,7 @@ public class SizeTieredCompactionStrategy extends AbstractCompactionStrategy cfs.setCompactionThresholds(cfs.metadata.getMinCompactionThreshold(), cfs.metadata.getMaxCompactionThreshold()); } + // synchronized so that multiple callers as in CompactionManager.submitBackground will compute different candidates public synchronized AbstractCompactionTask getNextBackgroundTask(final int gcBefore) { // make local copies so they can't be changed out from under us mid-method
