Skip to content

Commit d49b86d

Browse files
author
Stephane Landelle
committed
Don't enable idleConnectionTimeout when it's equal to requestTimeoutInMs
1 parent 8877ef4 commit d49b86d

File tree

2 files changed

+3
-3
lines changed

2 files changed

+3
-3
lines changed

src/main/java/com/ning/http/client/providers/netty/NettyAsyncHttpProvider.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -606,7 +606,7 @@ public void operationComplete(ChannelFuture cf) {
606606
}
607607

608608
int idleConnectionTimeoutInMs = config.getIdleConnectionTimeoutInMs();
609-
if (idleConnectionTimeoutInMs != -1 && idleConnectionTimeoutInMs < requestTimeoutInMs) {
609+
if (idleConnectionTimeoutInMs != -1 && idleConnectionTimeoutInMs <= requestTimeoutInMs) {
610610
// no need for a idleConnectionTimeout that's less than the requestTimeoutInMs
611611
Timeout idleConnectionTimeout = newTimeoutInMs(new IdleConnectionTimeoutTimerTask(future, this, timeoutsHolder,
612612
requestTimeoutInMs, idleConnectionTimeoutInMs), idleConnectionTimeoutInMs);
@@ -1496,6 +1496,7 @@ private void markAsDone(final NettyResponseFuture<?> future, final ChannelHandle
14961496
log.debug(t.getMessage(), t);
14971497
}
14981498

1499+
// FIXME why isReadable and not isConnected
14991500
if (!future.getKeepAlive() || !ctx.getChannel().isReadable()) {
15001501
closeChannel(ctx);
15011502
}

src/main/java/com/ning/http/client/providers/netty/NettyResponseFuture.java

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -307,10 +307,9 @@ V getContent() throws ExecutionException {
307307
}
308308

309309
public final void done() {
310+
cancelTimeouts();
310311

311312
try {
312-
cancelTimeouts();
313-
314313
if (exEx.get() != null) {
315314
return;
316315
}

0 commit comments

Comments
 (0)