You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@synapse.apache.org by hi...@apache.org on 2010/05/06 09:36:35 UTC
svn commit: r941596 - in
/synapse/trunk/java/modules/transports/core/nhttp/src/main/java/org/apache/synapse/transport/nhttp/debug:
ClientConnectionDebug.java ServerConnectionDebug.java
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();