You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hc.apache.org by ol...@apache.org on 2011/07/11 15:45:56 UTC
svn commit: r1145174 -
/httpcomponents/httpasyncclient/trunk/httpasyncclient/src/main/java/org/apache/http/impl/nio/client/NHttpClientProtocolHandler.java
Author: olegk
Date: Mon Jul 11 13:45:55 2011
New Revision: 1145174
URL: http://svn.apache.org/viewvc?rev=1145174&view=rev
Log:
HTTPASYNC-4: DefaultHttpAsyncClient does not execute callbacks on timeout
Modified:
httpcomponents/httpasyncclient/trunk/httpasyncclient/src/main/java/org/apache/http/impl/nio/client/NHttpClientProtocolHandler.java
Modified: httpcomponents/httpasyncclient/trunk/httpasyncclient/src/main/java/org/apache/http/impl/nio/client/NHttpClientProtocolHandler.java
URL: http://svn.apache.org/viewvc/httpcomponents/httpasyncclient/trunk/httpasyncclient/src/main/java/org/apache/http/impl/nio/client/NHttpClientProtocolHandler.java?rev=1145174&r1=1145173&r2=1145174&view=diff
==============================================================================
--- httpcomponents/httpasyncclient/trunk/httpasyncclient/src/main/java/org/apache/http/impl/nio/client/NHttpClientProtocolHandler.java (original)
+++ httpcomponents/httpasyncclient/trunk/httpasyncclient/src/main/java/org/apache/http/impl/nio/client/NHttpClientProtocolHandler.java Mon Jul 11 13:45:55 2011
@@ -29,6 +29,7 @@ package org.apache.http.impl.nio.client;
import java.io.IOException;
import java.net.ProtocolException;
+import java.net.SocketTimeoutException;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
@@ -313,6 +314,7 @@ class NHttpClientProtocolHandler impleme
conn.requestOutput();
httpexchange.setRequestState(MessageState.BODY_STREAM);
} else {
+ handler.failed(new SocketTimeoutException());
if (conn.getStatus() == NHttpConnection.ACTIVE) {
conn.close();
if (conn.getStatus() == NHttpConnection.CLOSING) {