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 2016/08/13 15:30:27 UTC
svn commit: r1756278 - in /httpcomponents/httpclient/trunk/httpclient5/src/main/java/org/apache/hc/client5/http/impl/io: CPool.java PoolingHttpClientConnectionManager.java

Author: olegk
Date: Sat Aug 13 15:30:27 2016
New Revision: 1756278

URL: http://svn.apache.org/viewvc?rev=1756278&view=rev
Log:
HTTPCLIENT-1760: added protected methods to enumerate leased and available connections to PoolingHttpClientConnectionManager

Modified:
    httpcomponents/httpclient/trunk/httpclient5/src/main/java/org/apache/hc/client5/http/impl/io/CPool.java
    httpcomponents/httpclient/trunk/httpclient5/src/main/java/org/apache/hc/client5/http/impl/io/PoolingHttpClientConnectionManager.java

Modified: httpcomponents/httpclient/trunk/httpclient5/src/main/java/org/apache/hc/client5/http/impl/io/CPool.java
URL: http://svn.apache.org/viewvc/httpcomponents/httpclient/trunk/httpclient5/src/main/java/org/apache/hc/client5/http/impl/io/CPool.java?rev=1756278&r1=1756277&r2=1756278&view=diff
==============================================================================
--- httpcomponents/httpclient/trunk/httpclient5/src/main/java/org/apache/hc/client5/http/impl/io/CPool.java (original)
+++ httpcomponents/httpclient/trunk/httpclient5/src/main/java/org/apache/hc/client5/http/impl/io/CPool.java Sat Aug 13 15:30:27 2016
@@ -34,6 +34,7 @@ import org.apache.commons.logging.LogFac
 import org.apache.hc.client5.http.HttpRoute;
 import org.apache.hc.client5.http.io.ManagedHttpClientConnection;
 import org.apache.hc.core5.annotation.ThreadSafe;
+import org.apache.hc.core5.pool.PoolEntryCallback;
 import org.apache.hc.core5.pool.io.AbstractConnPool;
 import org.apache.hc.core5.pool.io.ConnFactory;
 
@@ -69,4 +70,14 @@ class CPool extends AbstractConnPool<Htt
         return !entry.getConnection().isStale();
     }
 
+    @Override
+    protected void enumAvailable(final PoolEntryCallback<HttpRoute, ManagedHttpClientConnection> callback) {
+        super.enumAvailable(callback);
+    }
+
+    @Override
+    protected void enumLeased(final PoolEntryCallback<HttpRoute, ManagedHttpClientConnection> callback) {
+        super.enumLeased(callback);
+    }
+
 }

Modified: httpcomponents/httpclient/trunk/httpclient5/src/main/java/org/apache/hc/client5/http/impl/io/PoolingHttpClientConnectionManager.java
URL: http://svn.apache.org/viewvc/httpcomponents/httpclient/trunk/httpclient5/src/main/java/org/apache/hc/client5/http/impl/io/PoolingHttpClientConnectionManager.java?rev=1756278&r1=1756277&r2=1756278&view=diff
==============================================================================
--- httpcomponents/httpclient/trunk/httpclient5/src/main/java/org/apache/hc/client5/http/impl/io/PoolingHttpClientConnectionManager.java (original)
+++ httpcomponents/httpclient/trunk/httpclient5/src/main/java/org/apache/hc/client5/http/impl/io/PoolingHttpClientConnectionManager.java Sat Aug 13 15:30:27 2016
@@ -62,6 +62,7 @@ import org.apache.hc.core5.http.config.S
 import org.apache.hc.core5.http.io.HttpClientConnection;
 import org.apache.hc.core5.http.protocol.HttpContext;
 import org.apache.hc.core5.pool.ConnPoolControl;
+import org.apache.hc.core5.pool.PoolEntryCallback;
 import org.apache.hc.core5.pool.PoolStats;
 import org.apache.hc.core5.pool.io.ConnFactory;
 import org.apache.hc.core5.util.Args;
@@ -419,6 +420,14 @@ public class PoolingHttpClientConnection
         this.pool.closeExpired();
     }
 
+    protected void enumAvailable(final PoolEntryCallback<HttpRoute, ManagedHttpClientConnection> callback) {
+        this.pool.enumAvailable(callback);
+    }
+
+    protected void enumLeased(final PoolEntryCallback<HttpRoute, ManagedHttpClientConnection> callback) {
+        this.pool.enumLeased(callback);
+    }
+
     @Override
     public int getMaxTotal() {
         return this.pool.getMaxTotal();