Hi,
There is an implementation problem in
*AbstractIOSessionPool.getSessionInternal()*
Wrong pattern (starting line 190 in httpcore5-5.1.1) :
if (poolEntry.sessionFuture == null) {
*poolEntry.sessionFuture =* connectSession(
namedEndpoint,
connectTimeout,
new FutureCallback<IOSession>() {
...
@Override
public void failed(final Exception ex) {
synchronized (poolEntry) {
poolEntry.session = null;
*poolEntry.sessionFuture = null;*
...
}
}
...
});
In case of a synchronous failure during connectSession (for example :
UnknownHostException), the sessionFuture cleanup in the failed()
callback (line 216) is executed _before_ poolEntry.sessionFuture is
assigned with the return value of connectSession (line 191)
Thus, after the failure, a cancelled future is assigned to
poolEntry.sessionFuture and never cleaned up !
This result in a stalled entry in the pool because the /if
(poolEntry.sessionFuture == null)/ condition will no longer return true.
*Quick Reproducer*
H2AsyncClientBuilder httpClientBuilder =
HttpAsyncClients.customHttp2()
.setDefaultRequestConfig(RequestConfig.custom()
.setConnectTimeout(5000,
TimeUnit.MILLISECONDS)
.setResponseTimeout(5000,
TimeUnit.MILLISECONDS)
.build())
.setH2Config(H2Config.custom()
.setPushEnabled(false)
.build());
CloseableHttpAsyncClient client = httpClientBuilder.build();
client.start();
for(int n=1;n<=2;n++)
{
System.out.println("Try #"+n);
HttpHost targetHost = new HttpHost(URIScheme.HTTPS.getId(),
"invalidhost-gfhsgfxyzd.com", 443);
SimpleHttpRequest request = new SimpleHttpRequest("GET",
targetHost, "/");
Future<SimpleHttpResponse> responseFuture =
client.execute(request, null);
try
{
responseFuture.get(); // HANGS FOREVER at Try #2
}
catch (ExecutionException e)
{
e.printStackTrace();
}
}
*Quick Fix*
Cleaning the sessionFuture immediately after connectSession() returns in
case its already done fixes the issue :
(Line 234)
+ if (poolEntry.sessionFuture != null && poolEntry.sessionFuture.isDone())
+ poolEntry.sessionFuture = null;
--
Overkiz Logo <http://www.overkiz.com> *Sylvain POGNANT*
Lead Architect
[email protected] <maito:[email protected]>
Immeuble Variation A | Allée de la Mandallaz
74370 METZ-TESSY | France
www.overkiz.com <http://www.overkiz.com>
Overkiz Footer <http://www.overkiz.com>
This message and any attachments are confidential and intended solely
for the addressees. Any unauthorized use or disclosure, either whole or
partial is prohibited. E-mails are susceptible to alteration. OVERKIZ
shall not be liable for the message if altered, changed or falsified. If
you are not the intended recipient of this message, please delete it and
notify the sender.
Please think of the environment before printing this email.
