[jboss-cvs] JBossAS SVN: r81134 - trunk/tomcat/src/main/org/jboss/web/tomcat/statistics.

[jboss-cvs-commits at lists.jboss.org]

Author: bstansberry at jboss.com
Date: 2008-11-16 10:22:23 -0500 (Sun, 16 Nov 2008)
New Revision: 81134

Modified:
   trunk/tomcat/src/main/org/jboss/web/tomcat/statistics/ReplicationStatistics.java
Log:
Fix generics, tweak concurrency level

Modified: trunk/tomcat/src/main/org/jboss/web/tomcat/statistics/ReplicationStatistics.java
===================================================================
--- trunk/tomcat/src/main/org/jboss/web/tomcat/statistics/ReplicationStatistics.java	2008-11-16 15:17:17 UTC (rev 81133)
+++ trunk/tomcat/src/main/org/jboss/web/tomcat/statistics/ReplicationStatistics.java	2008-11-16 15:22:23 UTC (rev 81134)
@@ -73,23 +73,19 @@
 
    public ReplicationStatistics()
    {
-      ctxStats = new ConcurrentHashMap<String, TimeStatistic>();
+      ctxStats = new ConcurrentHashMap<String, TimeStatistic>(256, 0.75f, 32);
    }
 
    public void updatePassivationStats(String ctx, long elapsed)
    {
-      TimeStatistic stat = (TimeStatistic) ctxStats.get(ctx);
-      if( stat == null )
-      {
-         stat = new TimeStatistic();
-         ctxStats.put(ctx, stat);
-      }
+      TimeStatistic stat = getTimeStatistic(ctx);
       stat.totalPassivationTime += elapsed;
       if( stat.minPassivationTime > elapsed )
          stat.minPassivationTime = elapsed;
       if( stat.maxPassivationTime < elapsed )
          stat.maxPassivationTime = elapsed;
    }
+   
    /** Update the TimeStatistic for the given ctx. This does not synchronize
     * on the TimeStatistic so the results are an approximate values.
     *
@@ -98,12 +94,7 @@
     */
    public void updateReplicationStats(String ctx, long elapsed)
    {
-      TimeStatistic stat = (TimeStatistic) ctxStats.get(ctx);
-      if( stat == null )
-      {
-         stat = new TimeStatistic();
-         ctxStats.put(ctx, stat);
-      }
+      TimeStatistic stat = getTimeStatistic(ctx);
       stat.replicationCount ++;
       stat.totalReplicationlTime += elapsed;
       if( stat.minReplicationTime > elapsed )
@@ -111,14 +102,10 @@
       if( stat.maxReplicationTime < elapsed )
          stat.maxReplicationTime = elapsed;
    }
+   
    public void updateLoadStats(String ctx, long elapsed)
    {
-      TimeStatistic stat = (TimeStatistic) ctxStats.get(ctx);
-      if( stat == null )
-      {
-         stat = new TimeStatistic();
-         ctxStats.put(ctx, stat);
-      }
+      TimeStatistic stat = getTimeStatistic(ctx);
       stat.loadCount ++;
       stat.totalLoadlTime += elapsed;
       if( stat.minLoadTime > elapsed )
@@ -195,4 +182,15 @@
       return tmp.toString();
    }
 
+   private TimeStatistic getTimeStatistic(String ctx)
+   {
+      TimeStatistic stat = (TimeStatistic) ctxStats.get(ctx);
+      if( stat == null )
+      {
+         stat = new TimeStatistic();
+         ctxStats.put(ctx, stat);
+      }
+      return stat;
+   }
+
 }