fhanik 2004/06/08 13:23:55 Modified: modules/cluster/src/share/org/apache/catalina/cluster/tcp ReplicationValve.java Log: Improved the performance message, now the user sees the average request time and the average clustering overhead time Revision Changes Path 1.13 +11 -6 jakarta-tomcat-catalina/modules/cluster/src/share/org/apache/catalina/cluster/tcp/ReplicationValve.java Index: ReplicationValve.java =================================================================== RCS file: /home/cvs/jakarta-tomcat-catalina/modules/cluster/src/share/org/apache/catalina/cluster/tcp/ReplicationValve.java,v retrieving revision 1.12 retrieving revision 1.13 diff -u -r1.12 -r1.13 --- ReplicationValve.java 7 Apr 2004 20:43:55 -0000 1.12 +++ ReplicationValve.java 8 Jun 2004 20:23:55 -0000 1.13 @@ -101,15 +101,19 @@ // --------------------------------------------------------- Public Methods + protected static long totalRequestTime=0; protected static long totalSendTime=0; protected static long nrOfRequests =0; protected static long lastSendTime =0; - protected static synchronized void addClusterSendTime(long time) { - totalSendTime+=time; + + protected static synchronized void addClusterSendTime(long requestTime, long clusterTime) { + totalSendTime+=clusterTime; + totalRequestTime+=requestTime; nrOfRequests++; if ( (nrOfRequests % 100) == 0 ) { - log.info("Average cluster serialize/send time="+(totalSendTime/nrOfRequests)+" ms for "+ - nrOfRequests+" requests ("+totalSendTime+"ms)."); + log.info("Average request time="+(totalRequestTime/nrOfRequests)+" ms for "+ + "Cluster overhead time="+(totalSendTime/nrOfRequests)+" ms for "+ + nrOfRequests+" requests (Request="+totalRequestTime+"ms Cluster="+totalSendTime+"ms)."); lastSendTime=System.currentTimeMillis(); }//end if } @@ -131,6 +135,7 @@ ValveContext context) throws IOException, ServletException { + long totalstart = System.currentTimeMillis(); //this happens before the request //long _debugstart = System.currentTimeMillis(); context.invokeNext(request, response); @@ -201,7 +206,7 @@ cluster.send(msg); long stop = System.currentTimeMillis(); - addClusterSendTime(stop-start); + addClusterSendTime(stop-totalstart,stop-start); }catch (Exception x) {
--------------------------------------------------------------------- To unsubscribe, e-mail: [EMAIL PROTECTED] For additional commands, e-mail: [EMAIL PROTECTED]