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 2013/10/13 14:18:12 UTC
svn commit: r1531676 - in
/httpcomponents/httpasyncclient/trunk/httpasyncclient/src/main/java/org/apache/http/impl/nio:
client/MainClientExec.java conn/CPoolProxy.java
Author: olegk
Date: Sun Oct 13 12:18:12 2013
New Revision: 1531676
URL: http://svn.apache.org/r1531676
Log:
Added connection routing related logs
Modified:
httpcomponents/httpasyncclient/trunk/httpasyncclient/src/main/java/org/apache/http/impl/nio/client/MainClientExec.java
httpcomponents/httpasyncclient/trunk/httpasyncclient/src/main/java/org/apache/http/impl/nio/conn/CPoolProxy.java
Modified: httpcomponents/httpasyncclient/trunk/httpasyncclient/src/main/java/org/apache/http/impl/nio/client/MainClientExec.java
URL: http://svn.apache.org/viewvc/httpcomponents/httpasyncclient/trunk/httpasyncclient/src/main/java/org/apache/http/impl/nio/client/MainClientExec.java?rev=1531676&r1=1531675&r2=1531676&view=diff
==============================================================================
--- httpcomponents/httpasyncclient/trunk/httpasyncclient/src/main/java/org/apache/http/impl/nio/client/MainClientExec.java (original)
+++ httpcomponents/httpasyncclient/trunk/httpasyncclient/src/main/java/org/apache/http/impl/nio/client/MainClientExec.java Sun Oct 13 12:18:12 2013
@@ -163,10 +163,12 @@ class MainClientExec implements Internal
final HttpRoute route = state.getRoute();
final NHttpClientConnection managedConn = connManager.getConnection();
if (!state.isRouteEstablished() && state.getRouteTracker() == null) {
- this.log.debug("Start connection routing");
state.setRouteEstablished(this.connmgr.isRouteComplete(managedConn));
if (!state.isRouteEstablished()) {
+ this.log.debug("Start connection routing");
state.setRouteTracker(new RouteTracker(route));
+ } else {
+ this.log.debug("Connection route already established");
}
}
@@ -207,6 +209,7 @@ class MainClientExec implements Internal
this.connmgr.routeComplete(managedConn, route, localContext);
state.setRouteEstablished(true);
state.setRouteTracker(null);
+ this.log.debug("Connection route established");
break;
default:
throw new IllegalStateException("Unknown step indicator "
Modified: httpcomponents/httpasyncclient/trunk/httpasyncclient/src/main/java/org/apache/http/impl/nio/conn/CPoolProxy.java
URL: http://svn.apache.org/viewvc/httpcomponents/httpasyncclient/trunk/httpasyncclient/src/main/java/org/apache/http/impl/nio/conn/CPoolProxy.java?rev=1531676&r1=1531675&r2=1531676&view=diff
==============================================================================
--- httpcomponents/httpasyncclient/trunk/httpasyncclient/src/main/java/org/apache/http/impl/nio/conn/CPoolProxy.java (original)
+++ httpcomponents/httpasyncclient/trunk/httpasyncclient/src/main/java/org/apache/http/impl/nio/conn/CPoolProxy.java Sun Oct 13 12:18:12 2013
@@ -46,7 +46,6 @@ class CPoolProxy implements InvocationHa
private static final Method SHUTDOWN_METHOD;
private static final Method IS_OPEN_METHOD;
private static final Method IS_STALE_METHOD;
- private static final Method TO_STRING;
static {
try {
@@ -54,7 +53,6 @@ class CPoolProxy implements InvocationHa
SHUTDOWN_METHOD = HttpConnection.class.getMethod("shutdown");
IS_OPEN_METHOD = HttpConnection.class.getMethod("isOpen");
IS_STALE_METHOD = HttpConnection.class.getMethod("isStale");
- TO_STRING = Object.class.getMethod("toString");
} catch (final NoSuchMethodException ex) {
throw new Error(ex);
}
@@ -129,8 +127,6 @@ class CPoolProxy implements InvocationHa
return Boolean.valueOf(isOpen());
} else if (method.equals(IS_STALE_METHOD)) {
return Boolean.valueOf(isStale());
- } else if (method.equals(TO_STRING)) {
- return "Managed connection";
} else {
final NHttpClientConnection conn = getConnection();
if (conn == null) {