Commit31e7249

Stephane Landelle

committed

When debug is enabled, Netty ConnectListener erroneously consumes a retry token,closeAsyncHttpClient#436

1 parent16550ec commit31e7249Copy full SHA for 31e7249

File tree

-2

lines changed

-2

lines changed

Lines changed: 4 additions & 2 deletions

Original file line number	Diff line number	Diff line change
`@@ -33,6 +33,7 @@`
`33`	`33`	`importorg.slf4j.LoggerFactory;`
`34`	`34`
`35`	`35`	`importjavax.net.ssl.HostnameVerifier;`
	`36`	`+`
`36`	`37`	`importjava.io.IOException;`
`37`	`38`	`importjava.net.ConnectException;`
`38`	`39`	`importjava.net.InetSocketAddress;`
`@@ -85,8 +86,9 @@ public final void operationComplete(ChannelFuture f) throws Exception {`
`85`	`86`	`}else {`
`86`	`87`	`Throwablecause =f.getCause();`
`87`	`88`
`88`		`-logger.debug("Trying to recover a dead cached channel {} with a retry value of {} ",f.getChannel(),future.canRetry());`
`89`		`-if (future.canRetry() &&cause !=null && (NettyAsyncHttpProvider.abortOnDisconnectException(cause)`
	`89`	`+booleancanRetry =future.canRetry();`
	`90`	`+logger.debug("Trying to recover a dead cached channel {} with a retry value of {} ",f.getChannel(),canRetry);`
	`91`	`+if (canRetry &&cause !=null && (NettyAsyncHttpProvider.abortOnDisconnectException(cause)`
`90`	`92`	`\|\|causeinstanceofClosedChannelException`
`91`	`93`	`\|\|future.getState() !=NettyResponseFuture.STATE.NEW)) {`
`92`	`94`

Comments

(0)