[Hyperic-hq-discuss] hq r14498 - in trunk/src/org/hyperic: hq/escalation/server/session hq/product/server/mbean util/stats

[<sc...@hy...>]

Author: scottmf
Date: 2010-04-13 11:38:04 -0700 (Tue, 13 Apr 2010)
New Revision: 14498
URL: http://svn.hyperic.org/?view=rev&root=Hyperic+HQ&revision=14498

Modified:
   trunk/src/org/hyperic/hq/escalation/server/session/EscalationRuntime.java
   trunk/src/org/hyperic/hq/product/server/mbean/ProductPluginDeployer.java
   trunk/src/org/hyperic/util/stats/ConcurrentStatsCollector.java
Log:
[HHQ-3899] added stat around executeState() in EscalationRuntime

Modified: trunk/src/org/hyperic/hq/escalation/server/session/EscalationRuntime.java
===================================================================
--- trunk/src/org/hyperic/hq/escalation/server/session/EscalationRuntime.java	2010-04-13 07:52:05 UTC (rev 14497)
+++ trunk/src/org/hyperic/hq/escalation/server/session/EscalationRuntime.java	2010-04-13 18:38:04 UTC (rev 14498)
@@ -46,6 +46,7 @@
 import org.hyperic.hq.application.HQApp;
 import org.hyperic.hq.application.TransactionListener;
 import org.hyperic.hq.escalation.shared.EscalationManagerLocal;
+import org.hyperic.util.stats.ConcurrentStatsCollector;
 
 /**
  * This class manages the runtime execution of escalation chains.  The
@@ -407,7 +408,11 @@
     private void runEscalation(Integer stateId) {
         final boolean debug = _log.isDebugEnabled();
         if (debug) _log.debug("Running escalation state [" + stateId + "]");
+        final long start = System.currentTimeMillis();
         _esclMan.executeState(stateId);
+        final long end = System.currentTimeMillis();
+        ConcurrentStatsCollector.getInstance().addStat(
+            (end-start), ConcurrentStatsCollector.ESCALATION_EXECUTE_STATE_TIME);
     }
     
     public static EscalationRuntime getInstance() {

Modified: trunk/src/org/hyperic/hq/product/server/mbean/ProductPluginDeployer.java
===================================================================
--- trunk/src/org/hyperic/hq/product/server/mbean/ProductPluginDeployer.java	2010-04-13 07:52:05 UTC (rev 14497)
+++ trunk/src/org/hyperic/hq/product/server/mbean/ProductPluginDeployer.java	2010-04-13 18:38:04 UTC (rev 14498)
@@ -284,6 +284,7 @@
             c.register(ConcurrentStatsCollector.FIRED_ALERT_TIME);
             c.register(ConcurrentStatsCollector.SCHEDULE_QUEUE_SIZE);
             c.register(ConcurrentStatsCollector.UNSCHEDULE_QUEUE_SIZE);
+            c.register(ConcurrentStatsCollector.ESCALATION_EXECUTE_STATE_TIME);
             c.startCollector();
         } catch (Exception e) {
             _log.error("Could not start Concurrent Stats Collector", e);

Modified: trunk/src/org/hyperic/util/stats/ConcurrentStatsCollector.java
===================================================================
--- trunk/src/org/hyperic/util/stats/ConcurrentStatsCollector.java	2010-04-13 07:52:05 UTC (rev 14497)
+++ trunk/src/org/hyperic/util/stats/ConcurrentStatsCollector.java	2010-04-13 18:38:04 UTC (rev 14498)
@@ -111,7 +111,8 @@
         TRIGGER_INIT_TIME            = "TRIGGER_INIT_TIME",
         FIRED_ALERT_TIME             = "FIRED_ALERT_TIME",
         SCHEDULE_QUEUE_SIZE          = "SCHEDULE_QUEUE_SIZE",
-        UNSCHEDULE_QUEUE_SIZE        = "UNSCHEDULE_QUEUE_SIZE";
+        UNSCHEDULE_QUEUE_SIZE        = "UNSCHEDULE_QUEUE_SIZE",
+        ESCALATION_EXECUTE_STATE_TIME = "ESCALATION_EXECUTE_STATE_TIME";
     // using tree due to ordering capabilities
     private final Map _statKeys = new TreeMap();
     private AtomicBoolean _hasStarted = new AtomicBoolean(false);