You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@synapse.apache.org by as...@apache.org on 2009/03/24 08:02:32 UTC
svn commit: r757675 -
/synapse/trunk/java/modules/transports/src/main/java/org/apache/synapse/transport/nhttp/ServerHandler.java
Author: asankha
Date: Tue Mar 24 07:02:31 2009
New Revision: 757675
URL: http://svn.apache.org/viewvc?rev=757675&view=rev
Log:
fix SYNAPSE-452
Modified:
synapse/trunk/java/modules/transports/src/main/java/org/apache/synapse/transport/nhttp/ServerHandler.java
Modified: synapse/trunk/java/modules/transports/src/main/java/org/apache/synapse/transport/nhttp/ServerHandler.java
URL: http://svn.apache.org/viewvc/synapse/trunk/java/modules/transports/src/main/java/org/apache/synapse/transport/nhttp/ServerHandler.java?rev=757675&r1=757674&r2=757675&view=diff
==============================================================================
--- synapse/trunk/java/modules/transports/src/main/java/org/apache/synapse/transport/nhttp/ServerHandler.java (original)
+++ synapse/trunk/java/modules/transports/src/main/java/org/apache/synapse/transport/nhttp/ServerHandler.java Tue Mar 24 07:02:31 2009
@@ -220,6 +220,7 @@
} else if (!connStrategy.keepAlive(response, context)) {
conn.close();
} else {
+ conn.resetOutput();
conn.requestInput();
}
}
@@ -241,6 +242,7 @@
*/
public void commitResponseHideExceptions(final NHttpServerConnection conn, final HttpResponse response) {
try {
+ conn.suspendInput();
httpProcessor.process(response, conn.getContext());
conn.submitResponse(response);
} catch (HttpException e) {
@@ -261,6 +263,7 @@
public void commitResponse(final NHttpServerConnection conn,
final HttpResponse response) throws IOException, HttpException {
try {
+ conn.suspendInput();
httpProcessor.process(response, conn.getContext());
conn.submitResponse(response);
} catch (HttpException e) {