Apache
/
httpcomponents-client
mirror of https://github.com/apache/httpcomponents-client.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Method to check if the connection manager has been shut down and is closed or not.

This commit is contained in:
Arturo Bernal 2021-12-11 16:23:12 +01:00 committed by Oleg Kalnichevski
parent 4c464b2432
commit 6ba9b4acdc
3 changed files with 26 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
httpclient5/src/main/java/org/apache/hc/client5/http/impl/io/BasicHttpClientConnectionManager.java
View File

@ -299,7 +299,7 @@ public class BasicHttpClientConnectionManager implements HttpClientConnectionMan
} }
synchronized ManagedHttpClientConnection getConnection(final HttpRoute route, final Object state) throws IOException { synchronized ManagedHttpClientConnection getConnection(final HttpRoute route, final Object state) throws IOException {
Asserts.check(!this.closed.get(), "Connection manager has been shut down"); Asserts.check(!isClosed(), "Connection manager has been shut down");
if (LOG.isDebugEnabled()) { if (LOG.isDebugEnabled()) {
LOG.debug("{} Get connection for route {}", id, route); LOG.debug("{} Get connection for route {}", id, route);
} }
@ -336,7 +336,7 @@ public class BasicHttpClientConnectionManager implements HttpClientConnectionMan
if (LOG.isDebugEnabled()) { if (LOG.isDebugEnabled()) {
LOG.debug("{} Releasing connection {}", id, conn); LOG.debug("{} Releasing connection {}", id, conn);
} }
if (this.closed.get()) { if (isClosed()) {
return; return;
} }
try { try {
@ -345,7 +345,6 @@ public class BasicHttpClientConnectionManager implements HttpClientConnectionMan
} }
this.updated = System.currentTimeMillis(); this.updated = System.currentTimeMillis();
if (!this.conn.isOpen() && !this.conn.isConsistent()) { if (!this.conn.isOpen() && !this.conn.isConsistent()) {
this.conn = null;
this.route = null; this.route = null;
this.conn = null; this.conn = null;
this.expiry = Long.MAX_VALUE; this.expiry = Long.MAX_VALUE;
@ -427,7 +426,7 @@ public class BasicHttpClientConnectionManager implements HttpClientConnectionMan
} }
public synchronized void closeExpired() { public synchronized void closeExpired() {
if (this.closed.get()) { if (isClosed()) {
return; return;
} }
if (!this.leased) { if (!this.leased) {
@ -437,7 +436,7 @@ public class BasicHttpClientConnectionManager implements HttpClientConnectionMan
public synchronized void closeIdle(final TimeValue idleTime) { public synchronized void closeIdle(final TimeValue idleTime) {
Args.notNull(idleTime, "Idle time"); Args.notNull(idleTime, "Idle time");
if (this.closed.get()) { if (isClosed()) {
return; return;
} }
if (!this.leased) { if (!this.leased) {
@ -556,4 +555,15 @@ public class BasicHttpClientConnectionManager implements HttpClientConnectionMan
} }
/**
* Method that can be called to determine whether the connection manager has been shut down and
* is closed or not.
*
* @return {@code true} if the connection manager has been shut down and is closed, otherwise
* return {@code false}.
*/
boolean isClosed() {
return this.closed.get();
}
} }

1
httpclient5/src/main/java/org/apache/hc/client5/http/impl/io/PoolingHttpClientConnectionManager.java
View File

@ -686,5 +686,4 @@ public class PoolingHttpClientConnectionManager
} }
} }
} }

11
httpclient5/src/main/java/org/apache/hc/client5/http/impl/nio/PoolingAsyncClientConnectionManager.java
View File

@ -727,4 +727,15 @@ public class PoolingAsyncClientConnectionManager implements AsyncClientConnectio
} }
/**
* Method that can be called to determine whether the connection manager has been shut down and
* is closed or not.
*
* @return {@code true} if the connection manager has been shut down and is closed, otherwise
* return {@code false}.
*/
boolean isClosed() {
return this.closed.get();
}
} }