set discard asap

slandelle · slandelle · commit c9b3cb286d9d · 2015-11-17T22:21:59.000+01:00
diff --git a/client/src/main/java/org/asynchttpclient/netty/channel/ChannelManager.java b/client/src/main/java/org/asynchttpclient/netty/channel/ChannelManager.java
@@ -367,8 +367,8 @@ public void operationComplete(io.netty.util.concurrent.Future<?> future) throws
     public void closeChannel(Channel channel) {
 
         LOGGER.debug("Closing Channel {} ", channel);
-        removeAll(channel);
         Channels.setDiscard(channel);
+        removeAll(channel);
         Channels.silentlyCloseChannel(channel);
         openChannels.remove(channel);
     }

Original file line number	Diff line number	Diff line change
`@@ -367,8 +367,8 @@ public void operationComplete(io.netty.util.concurrent.Future<?> future) throws`
`367`	`367`	`public void closeChannel(Channel channel) {`
`368`	`368`
`369`	`369`	`LOGGER.debug("Closing Channel {} ", channel);`
`370`		`- removeAll(channel);`
`371`	`370`	`Channels.setDiscard(channel);`
	`371`	`+ removeAll(channel);`
`372`	`372`	`Channels.silentlyCloseChannel(channel);`
`373`	`373`	`openChannels.remove(channel);`
`374`	`374`	`}`