Return-Path: X-Original-To: apmail-cassandra-commits-archive@www.apache.org Delivered-To: apmail-cassandra-commits-archive@www.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id C56759C33 for ; Wed, 23 May 2012 21:12:16 +0000 (UTC) Received: (qmail 78140 invoked by uid 500); 23 May 2012 21:12:16 -0000 Delivered-To: apmail-cassandra-commits-archive@cassandra.apache.org Received: (qmail 78103 invoked by uid 500); 23 May 2012 21:12:16 -0000 Mailing-List: contact commits-help@cassandra.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@cassandra.apache.org Delivered-To: mailing list commits@cassandra.apache.org Received: (qmail 77942 invoked by uid 99); 23 May 2012 21:12:16 -0000 Received: from tyr.zones.apache.org (HELO tyr.zones.apache.org) (140.211.11.114) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 23 May 2012 21:12:16 +0000 Received: by tyr.zones.apache.org (Postfix, from userid 65534) id 27A0B1785E; Wed, 23 May 2012 21:12:16 +0000 (UTC) Content-Type: text/plain; charset="us-ascii" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit From: jbellis@apache.org To: commits@cassandra.apache.org X-Mailer: ASF-Git Admin Mailer Subject: [1/2] git commit: Merge branch 'cassandra-1.1.' into trunk Message-Id: <20120523211216.27A0B1785E@tyr.zones.apache.org> Date: Wed, 23 May 2012 21:12:16 +0000 (UTC) Updated Branches: refs/heads/trunk cc112ae30 -> bc783baab Merge branch 'cassandra-1.1.' into trunk Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/bc783baa Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/bc783baa Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/bc783baa Branch: refs/heads/trunk Commit: bc783baab505fd317897f372c86d40b2102329a9 Parents: cc112ae 512d97f Author: Jonathan Ellis Authored: Wed May 23 16:11:49 2012 -0500 Committer: Jonathan Ellis Committed: Wed May 23 16:11:49 2012 -0500 ---------------------------------------------------------------------- .../cassandra/db/compaction/CompactionInfo.java | 8 ++++---- .../cassandra/db/compaction/CompactionManager.java | 6 +++--- .../cassandra/db/compaction/CompactionTask.java | 2 +- .../cassandra/db/index/SecondaryIndexBuilder.java | 2 +- 4 files changed, 9 insertions(+), 9 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/cassandra/blob/bc783baa/src/java/org/apache/cassandra/db/compaction/CompactionInfo.java ---------------------------------------------------------------------- diff --cc src/java/org/apache/cassandra/db/compaction/CompactionInfo.java index 594b639,937557f..acd8fcb --- a/src/java/org/apache/cassandra/db/compaction/CompactionInfo.java +++ b/src/java/org/apache/cassandra/db/compaction/CompactionInfo.java @@@ -103,36 -102,17 +103,36 @@@ public final class CompactionInfo imple public static abstract class Holder { - private volatile boolean isStopped = false; + private volatile boolean stopRequested = false; public abstract CompactionInfo getCompactionInfo(); + double load = StorageService.instance.getLoad(); + boolean reportedSeverity = false; public void stop() { - isStopped = true; + stopRequested = true; } - public boolean isStopped() + public boolean isStopRequested() { - return isStopped; + return stopRequested; } + /** + * report event on the size of the compaction. + */ + public void started() + { + reportedSeverity = StorageService.instance.reportSeverity(getCompactionInfo().getTotalBytes()/load); + } + + /** + * remove the event complete + */ + public void finished() + { + if (reportedSeverity) + StorageService.instance.reportSeverity(-(getCompactionInfo().getTotalBytes()/load)); + reportedSeverity = false; + } } } http://git-wip-us.apache.org/repos/asf/cassandra/blob/bc783baa/src/java/org/apache/cassandra/db/compaction/CompactionManager.java ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/cassandra/blob/bc783baa/src/java/org/apache/cassandra/db/compaction/CompactionTask.java ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/cassandra/blob/bc783baa/src/java/org/apache/cassandra/db/index/SecondaryIndexBuilder.java ---------------------------------------------------------------------- diff --cc src/java/org/apache/cassandra/db/index/SecondaryIndexBuilder.java index dfe1a56,5cdd26a..a434fa8 --- a/src/java/org/apache/cassandra/db/index/SecondaryIndexBuilder.java +++ b/src/java/org/apache/cassandra/db/index/SecondaryIndexBuilder.java @@@ -59,9 -59,9 +59,9 @@@ public class SecondaryIndexBuilder exte { while (iter.hasNext()) { - if (isStopped()) + if (isStopRequested()) throw new CompactionInterruptedException(getCompactionInfo()); - DecoratedKey key = iter.next(); + DecoratedKey key = iter.next(); Table.indexRow(key, cfs, columns); }