You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@synapse.apache.org by in...@apache.org on 2009/03/19 12:11:19 UTC

svn commit: r755921 - in /synapse/trunk/java/modules/core/src/main/java/org/apache/synapse: aspects/statistics/view/PerUserViewStrategy.java aspects/statistics/view/SystemViewStrategy.java mediators/base/SequenceMediator.java

Author: indika
Date: Thu Mar 19 11:11:18 2009
New Revision: 755921

URL: http://svn.apache.org/viewvc?rev=755921&view=rev
Log:
avoid update out flow stat for endpoint

Modified:
    synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/aspects/statistics/view/PerUserViewStrategy.java
    synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/aspects/statistics/view/SystemViewStrategy.java
    synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/mediators/base/SequenceMediator.java

Modified: synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/aspects/statistics/view/PerUserViewStrategy.java
URL: http://svn.apache.org/viewvc/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/aspects/statistics/view/PerUserViewStrategy.java?rev=755921&r1=755920&r2=755921&view=diff
==============================================================================
--- synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/aspects/statistics/view/PerUserViewStrategy.java (original)
+++ synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/aspects/statistics/view/PerUserViewStrategy.java Thu Mar 19 11:11:18 2009
@@ -163,8 +163,10 @@
         if (view != null) {
             strategy.updateInFlowStatistics(id, type,
                     view.getInStatistics());
-            strategy.updateOutFlowStatistics(id, type,
-                    view.getOutStatistics());
+            if (type != ComponentType.ENDPOINT) {
+                strategy.updateOutFlowStatistics(id, type,
+                        view.getOutStatistics());
+            }
         }
     }
 

Modified: synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/aspects/statistics/view/SystemViewStrategy.java
URL: http://svn.apache.org/viewvc/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/aspects/statistics/view/SystemViewStrategy.java?rev=755921&r1=755920&r2=755921&view=diff
==============================================================================
--- synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/aspects/statistics/view/SystemViewStrategy.java (original)
+++ synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/aspects/statistics/view/SystemViewStrategy.java Thu Mar 19 11:11:18 2009
@@ -108,8 +108,10 @@
         if (view != null) {
             strategy.updateInFlowStatistics(id, type,
                     view.getInStatistics());
-            strategy.updateOutFlowStatistics(id, type,
-                    view.getOutStatistics());
+            if (type != ComponentType.ENDPOINT) {
+                strategy.updateOutFlowStatistics(id, type,
+                        view.getOutStatistics());
+            }
         }
     }
 

Modified: synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/mediators/base/SequenceMediator.java
URL: http://svn.apache.org/viewvc/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/mediators/base/SequenceMediator.java?rev=755921&r1=755920&r2=755921&view=diff
==============================================================================
--- synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/mediators/base/SequenceMediator.java (original)
+++ synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/mediators/base/SequenceMediator.java Thu Mar 19 11:11:18 2009
@@ -71,12 +71,14 @@
         SynapseLog synLog = getLog(synCtx);
 
         if (isStatisticsEnable()) {
-            StatisticsReporter.reportForComponent(synCtx, getAspectConfiguration(), ComponentType.SEQUENCE);
+            StatisticsReporter.reportForComponent(synCtx,
+                    getAspectConfiguration(), ComponentType.SEQUENCE);
         }
 
         if (synLog.isTraceOrDebugEnabled()) {
             synLog.traceOrDebug("Start : Sequence "
-                    + (name == null ? (key == null ? "<anonymous" : "key=<" + key) : "<" + name) + ">");
+                    + (name == null ? (key == null ? "<anonymous" : "key=<" + key) : "<"
+                    + name) + ">");
 
             if (synLog.isTraceTraceEnabled()) {
                 synLog.traceTrace("Message : " + synCtx.getEnvelope());