You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@synapse.apache.org by ve...@apache.org on 2008/12/23 20:01:58 UTC

svn commit: r729065 - in /synapse/trunk/java/modules/transports/src/main/java/org/apache/synapse/transport/nhttp: ClientHandler.java HttpCoreNIOSender.java

Author: veithen
Date: Tue Dec 23 11:01:58 2008
New Revision: 729065

URL: http://svn.apache.org/viewvc?rev=729065&view=rev
Log:
SYNAPSE-491: Added some log statements (to be removed later).

Modified:
    synapse/trunk/java/modules/transports/src/main/java/org/apache/synapse/transport/nhttp/ClientHandler.java
    synapse/trunk/java/modules/transports/src/main/java/org/apache/synapse/transport/nhttp/HttpCoreNIOSender.java

Modified: synapse/trunk/java/modules/transports/src/main/java/org/apache/synapse/transport/nhttp/ClientHandler.java
URL: http://svn.apache.org/viewvc/synapse/trunk/java/modules/transports/src/main/java/org/apache/synapse/transport/nhttp/ClientHandler.java?rev=729065&r1=729064&r2=729065&view=diff
==============================================================================
--- synapse/trunk/java/modules/transports/src/main/java/org/apache/synapse/transport/nhttp/ClientHandler.java (original)
+++ synapse/trunk/java/modules/transports/src/main/java/org/apache/synapse/transport/nhttp/ClientHandler.java Tue Dec 23 11:01:58 2008
@@ -486,6 +486,8 @@
 
         try {
             int bytesWritten = outBuf.produceContent(encoder);
+            // TODO: remove the log statement when SYNAPSE-491 has been solved
+            log.debug(">>> Before incrementBytesSent; bytesWritten=" + bytesWritten + "; completes = " + encoder.isCompleted());
             if (metrics != null && bytesWritten > 0) {
                 if (metrics.getLevel() == MetricsCollector.LEVEL_FULL) {
                     metrics.incrementBytesSent(getMessageContext(conn), bytesWritten);
@@ -493,6 +495,8 @@
                     metrics.incrementBytesSent(bytesWritten);
                 }
             }
+            // TODO: remove the log statement when SYNAPSE-491 has been solved
+            log.debug(">>> After incrementBytesSent");
 
         } catch (IOException e) {
             if (metrics != null) {

Modified: synapse/trunk/java/modules/transports/src/main/java/org/apache/synapse/transport/nhttp/HttpCoreNIOSender.java
URL: http://svn.apache.org/viewvc/synapse/trunk/java/modules/transports/src/main/java/org/apache/synapse/transport/nhttp/HttpCoreNIOSender.java?rev=729065&r1=729064&r2=729065&view=diff
==============================================================================
--- synapse/trunk/java/modules/transports/src/main/java/org/apache/synapse/transport/nhttp/HttpCoreNIOSender.java (original)
+++ synapse/trunk/java/modules/transports/src/main/java/org/apache/synapse/transport/nhttp/HttpCoreNIOSender.java Tue Dec 23 11:01:58 2008
@@ -335,6 +335,8 @@
 
             try {
                 axis2Req.streamMessageContents();
+                // TODO: remove the log statement when SYNAPSE-491 has been solved
+                log.debug(">>> Before incrementMessagesSent");
                 if (metrics != null) {
                     if (metrics.getLevel() == MetricsCollector.LEVEL_FULL) {
                         metrics.incrementMessagesSent(msgContext);
@@ -342,6 +344,8 @@
                         metrics.incrementMessagesSent();
                     }
                 }
+                // TODO: remove the log statement when SYNAPSE-491 has been solved
+                log.debug("<<< After incrementMessagesSent");
 
             } catch (AxisFault af) {
                 throw af;