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/cassandra-1.0 Commit: 68d4e28d94a69bfa954a04c4e2fbdb75252db47b Parents: b663210 Author: Jonathan Ellis <[email protected]> Authored: Thu Jan 26 16:58:47 2012 -0600 Committer: Jonathan Ellis <[email protected]> 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()) {
