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 2017/09/04 08:20:05 UTC
[3/3] httpcomponents-core git commit: Added #getRoutes method to
ConnPoolControl interface
Added #getRoutes method to ConnPoolControl interface
Project: http://git-wip-us.apache.org/repos/asf/httpcomponents-core/repo
Commit: http://git-wip-us.apache.org/repos/asf/httpcomponents-core/commit/572fd170
Tree: http://git-wip-us.apache.org/repos/asf/httpcomponents-core/tree/572fd170
Diff: http://git-wip-us.apache.org/repos/asf/httpcomponents-core/diff/572fd170
Branch: refs/heads/master
Commit: 572fd170016a27d0893bc19a9fe7d202706d62fa
Parents: 59bff65
Author: Oleg Kalnichevski <ol...@apache.org>
Authored: Mon Sep 4 10:17:56 2017 +0200
Committer: Oleg Kalnichevski <ol...@apache.org>
Committed: Mon Sep 4 10:17:56 2017 +0200
----------------------------------------------------------------------
.../hc/core5/http/impl/bootstrap/HttpAsyncRequester.java | 6 ++++++
.../org/apache/hc/core5/http/impl/bootstrap/HttpRequester.java | 6 ++++++
.../main/java/org/apache/hc/core5/pool/ConnPoolControl.java | 4 ++++
.../src/main/java/org/apache/hc/core5/pool/LaxConnPool.java | 1 +
.../src/main/java/org/apache/hc/core5/pool/StrictConnPool.java | 1 +
5 files changed, 18 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/httpcomponents-core/blob/572fd170/httpcore5/src/main/java/org/apache/hc/core5/http/impl/bootstrap/HttpAsyncRequester.java
----------------------------------------------------------------------
diff --git a/httpcore5/src/main/java/org/apache/hc/core5/http/impl/bootstrap/HttpAsyncRequester.java b/httpcore5/src/main/java/org/apache/hc/core5/http/impl/bootstrap/HttpAsyncRequester.java
index 8c37d31..5c63611 100644
--- a/httpcore5/src/main/java/org/apache/hc/core5/http/impl/bootstrap/HttpAsyncRequester.java
+++ b/httpcore5/src/main/java/org/apache/hc/core5/http/impl/bootstrap/HttpAsyncRequester.java
@@ -30,6 +30,7 @@ package org.apache.hc.core5.http.impl.bootstrap;
import java.io.IOException;
import java.nio.ByteBuffer;
import java.util.List;
+import java.util.Set;
import java.util.concurrent.Future;
import java.util.concurrent.atomic.AtomicReference;
@@ -150,6 +151,11 @@ public class HttpAsyncRequester extends AsyncRequester implements ConnPoolContro
connPool.closeExpired();
}
+ @Override
+ public Set<HttpHost> getRoutes() {
+ return connPool.getRoutes();
+ }
+
public Future<AsyncClientEndpoint> connect(
final HttpHost host,
final TimeValue timeout,
http://git-wip-us.apache.org/repos/asf/httpcomponents-core/blob/572fd170/httpcore5/src/main/java/org/apache/hc/core5/http/impl/bootstrap/HttpRequester.java
----------------------------------------------------------------------
diff --git a/httpcore5/src/main/java/org/apache/hc/core5/http/impl/bootstrap/HttpRequester.java b/httpcore5/src/main/java/org/apache/hc/core5/http/impl/bootstrap/HttpRequester.java
index 0b8c3ce..b6489d6 100644
--- a/httpcore5/src/main/java/org/apache/hc/core5/http/impl/bootstrap/HttpRequester.java
+++ b/httpcore5/src/main/java/org/apache/hc/core5/http/impl/bootstrap/HttpRequester.java
@@ -32,6 +32,7 @@ import java.io.InterruptedIOException;
import java.io.OutputStream;
import java.net.InetSocketAddress;
import java.net.Socket;
+import java.util.Set;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.Future;
import java.util.concurrent.TimeoutException;
@@ -151,6 +152,11 @@ public class HttpRequester implements ConnPoolControl<HttpHost>, GracefullyClose
connPool.closeExpired();
}
+ @Override
+ public Set<HttpHost> getRoutes() {
+ return connPool.getRoutes();
+ }
+
public ClassicHttpResponse execute(
final HttpClientConnection connection,
final ClassicHttpRequest request,
http://git-wip-us.apache.org/repos/asf/httpcomponents-core/blob/572fd170/httpcore5/src/main/java/org/apache/hc/core5/pool/ConnPoolControl.java
----------------------------------------------------------------------
diff --git a/httpcore5/src/main/java/org/apache/hc/core5/pool/ConnPoolControl.java b/httpcore5/src/main/java/org/apache/hc/core5/pool/ConnPoolControl.java
index ac83c39..00019a1 100644
--- a/httpcore5/src/main/java/org/apache/hc/core5/pool/ConnPoolControl.java
+++ b/httpcore5/src/main/java/org/apache/hc/core5/pool/ConnPoolControl.java
@@ -26,6 +26,8 @@
*/
package org.apache.hc.core5.pool;
+import java.util.Set;
+
import org.apache.hc.core5.util.TimeValue;
/**
@@ -55,4 +57,6 @@ public interface ConnPoolControl<T> extends ConnPoolStats<T> {
void closeExpired();
+ Set<T> getRoutes();
+
}
http://git-wip-us.apache.org/repos/asf/httpcomponents-core/blob/572fd170/httpcore5/src/main/java/org/apache/hc/core5/pool/LaxConnPool.java
----------------------------------------------------------------------
diff --git a/httpcore5/src/main/java/org/apache/hc/core5/pool/LaxConnPool.java b/httpcore5/src/main/java/org/apache/hc/core5/pool/LaxConnPool.java
index 06e2b9f..12347e2 100644
--- a/httpcore5/src/main/java/org/apache/hc/core5/pool/LaxConnPool.java
+++ b/httpcore5/src/main/java/org/apache/hc/core5/pool/LaxConnPool.java
@@ -234,6 +234,7 @@ public class LaxConnPool<T, C extends GracefullyCloseable> implements ManagedCon
routePool.getMax());
}
+ @Override
public Set<T> getRoutes() {
return new HashSet<>(routeToPool.keySet());
}
http://git-wip-us.apache.org/repos/asf/httpcomponents-core/blob/572fd170/httpcore5/src/main/java/org/apache/hc/core5/pool/StrictConnPool.java
----------------------------------------------------------------------
diff --git a/httpcore5/src/main/java/org/apache/hc/core5/pool/StrictConnPool.java b/httpcore5/src/main/java/org/apache/hc/core5/pool/StrictConnPool.java
index 8fc9ed0..a776747 100644
--- a/httpcore5/src/main/java/org/apache/hc/core5/pool/StrictConnPool.java
+++ b/httpcore5/src/main/java/org/apache/hc/core5/pool/StrictConnPool.java
@@ -507,6 +507,7 @@ public class StrictConnPool<T, C extends GracefullyCloseable> implements Managed
*
* @since 4.4
*/
+ @Override
public Set<T> getRoutes() {
this.lock.lock();
try {