You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@cassandra.apache.org by jb...@apache.org on 2012/01/27 00:00:18 UTC
[3/7] git commit: Log active compactions in StatusLogger patch by
jbellis; reviewed by slebresne for CASSANDRA-3703
Log active compactions in StatusLogger
patch by jbellis; reviewed by slebresne for CASSANDRA-3703
Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo
Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/68d4e28d
Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/68d4e28d
Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/68d4e28d
Branch: refs/heads/trunk
Commit: 68d4e28d94a69bfa954a04c4e2fbdb75252db47b
Parents: b663210
Author: Jonathan Ellis <jb...@apache.org>
Authored: Thu Jan 26 16:58:47 2012 -0600
Committer: Jonathan Ellis <jb...@apache.org>
Committed: Thu Jan 26 16:58:47 2012 -0600
----------------------------------------------------------------------
CHANGES.txt | 1 +
.../org/apache/cassandra/utils/StatusLogger.java | 3 ++-
2 files changed, 3 insertions(+), 1 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/cassandra/blob/68d4e28d/CHANGES.txt
----------------------------------------------------------------------
diff --git a/CHANGES.txt b/CHANGES.txt
index 2c7db76..7faf97f 100644
--- a/CHANGES.txt
+++ b/CHANGES.txt
@@ -1,4 +1,5 @@
1.0.8
+ * Log active compactions in StatusLogger (CASSANDRA-3703)
* Compute more accurate compaction score per level (CASSANDRA-3790)
* Return InvalidRequest when using a keyspace that doesn't exist
(CASSANDRA-3764)
http://git-wip-us.apache.org/repos/asf/cassandra/blob/68d4e28d/src/java/org/apache/cassandra/utils/StatusLogger.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/utils/StatusLogger.java b/src/java/org/apache/cassandra/utils/StatusLogger.java
index 55453af..fa67b45 100644
--- a/src/java/org/apache/cassandra/utils/StatusLogger.java
+++ b/src/java/org/apache/cassandra/utils/StatusLogger.java
@@ -66,8 +66,9 @@ public class StatusLogger
poolName, threadPoolProxy.getActiveCount(), threadPoolProxy.getPendingTasks(), threadPoolProxy.getCurrentlyBlockedTasks()));
}
// one offs
+ CompactionManager cm = CompactionManager.instance;
logger.info(String.format("%-25s%10s%10s",
- "CompactionManager", "n/a", CompactionManager.instance.getPendingTasks()));
+ "CompactionManager", cm.getActiveCompactions(), cm.getPendingTasks()));
int pendingCommands = 0;
for (int n : MessagingService.instance().getCommandPendingTasks().values())
{