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) {