svn commit: r941596 - in /synapse/trunk/java/modules/transports/core/nhttp/src/main/java/org/apache/synapse/transport/nhttp/debug: ClientConnectionDebug.java ServerConnectionDebug.java

[hiranya]

Author: hiranya
Date: Thu May  6 07:36:34 2010
New Revision: 941596

URL: http://svn.apache.org/viewvc?rev=941596&view=rev
Log:
Fixing SYNAPSE-642


Modified:
    
synapse/trunk/java/modules/transports/core/nhttp/src/main/java/org/apache/synapse/transport/nhttp/debug/ClientConnectionDebug.java
    
synapse/trunk/java/modules/transports/core/nhttp/src/main/java/org/apache/synapse/transport/nhttp/debug/ServerConnectionDebug.java

Modified: 
synapse/trunk/java/modules/transports/core/nhttp/src/main/java/org/apache/synapse/transport/nhttp/debug/ClientConnectionDebug.java
URL: 
http://svn.apache.org/viewvc/synapse/trunk/java/modules/transports/core/nhttp/src/main/java/org/apache/synapse/transport/nhttp/debug/ClientConnectionDebug.java?rev=941596&r1=941595&r2=941596&view=diff
==============================================================================
--- 
synapse/trunk/java/modules/transports/core/nhttp/src/main/java/org/apache/synapse/transport/nhttp/debug/ClientConnectionDebug.java
 (original)
+++ 
synapse/trunk/java/modules/transports/core/nhttp/src/main/java/org/apache/synapse/transport/nhttp/debug/ClientConnectionDebug.java
 Thu May  6 07:36:34 2010
@@ -19,7 +19,6 @@
 
 package org.apache.synapse.transport.nhttp.debug;
 
-import org.apache.http.Header;
 import org.apache.http.HttpRequest;
 import org.apache.http.RequestLine;
 import org.apache.http.nio.NHttpClientConnection;
@@ -43,7 +42,7 @@ public class ClientConnectionDebug exten
 
     private long requestCompletionTime;
     private long responseStartTime;
-    private long responseCompletionTime;
+    private long responseCompletionTime = -1;
     private String responseLine;
 
     private ServerConnectionDebug serverConnectionDebug;
@@ -131,7 +130,8 @@ public class ClientConnectionDebug exten
 
         
sb.append("S2E-Resp-Start").append(keyValueSeparator).append(format(responseStartTime));
         sb.append(fieldSeparator);
-        
sb.append("S2E-Resp-End").append(keyValueSeparator).append(format(responseCompletionTime));
+        
sb.append("S2E-Resp-End").append(keyValueSeparator).append(responseCompletionTime
 != -1 ?
+                format(responseCompletionTime) : "NOT-COMPLETED");
         sb.append(statementSeparator);
 
         
sb.append("S2E-Resp-Status").append(keyValueSeparator).append(responseLine);

Modified: 
synapse/trunk/java/modules/transports/core/nhttp/src/main/java/org/apache/synapse/transport/nhttp/debug/ServerConnectionDebug.java
URL: 
http://svn.apache.org/viewvc/synapse/trunk/java/modules/transports/core/nhttp/src/main/java/org/apache/synapse/transport/nhttp/debug/ServerConnectionDebug.java?rev=941596&r1=941595&r2=941596&view=diff
==============================================================================
--- 
synapse/trunk/java/modules/transports/core/nhttp/src/main/java/org/apache/synapse/transport/nhttp/debug/ServerConnectionDebug.java
 (original)
+++ 
synapse/trunk/java/modules/transports/core/nhttp/src/main/java/org/apache/synapse/transport/nhttp/debug/ServerConnectionDebug.java
 Thu May  6 07:36:34 2010
@@ -19,7 +19,6 @@
 
 package org.apache.synapse.transport.nhttp.debug;
 
-import org.apache.http.Header;
 import org.apache.http.HttpInetConnection;
 import org.apache.http.HttpRequest;
 import org.apache.http.RequestLine;
@@ -132,11 +131,21 @@ public class ServerConnectionDebug exten
 
         
sb.append("Total-Time").append(keyValueSeparator).append(totalTime).append("ms");
         if (clientConnectionDebug != null) {
-            long svcTime = clientConnectionDebug.getResponseCompletionTime() - 
clientConnectionDebug.getLastRequestStartTime();
             sb.append(fieldSeparator);
-            
sb.append("Svc-Time").append(keyValueSeparator).append(svcTime).append("ms");
-            sb.append(fieldSeparator);
-            sb.append("ESB-Time").append(keyValueSeparator).append(totalTime - 
svcTime).append("ms");
+
+            if (clientConnectionDebug.getResponseCompletionTime() != -1) {
+                long svcTime = 
clientConnectionDebug.getResponseCompletionTime() -
+                        clientConnectionDebug.getLastRequestStartTime();
+                
sb.append("Svc-Time").append(keyValueSeparator).append(svcTime).append("ms");
+                sb.append(fieldSeparator);
+                sb.append("ESB-Time").append(keyValueSeparator).
+                        append(totalTime - svcTime).append("ms");
+                
+            } else {
+                
sb.append("Svc-Time").append(keyValueSeparator).append("UNDETERMINED");
+                sb.append(fieldSeparator);
+                
sb.append("ESB-Time").append(keyValueSeparator).append("UNDETERMINED");
+            }
         }
 
         return sb.toString();