File tree Expand file tree Collapse file tree 1 file changed +8
-12
lines changed
providers/netty/src/main/java/org/asynchttpclient/providers/netty/channel Expand file tree Collapse file tree 1 file changed +8
-12
lines changed Original file line number Diff line number Diff line change @@ -308,19 +308,15 @@ public void close() {
308
308
309
309
public void closeChannel (Channel channel ) {
310
310
311
- // The channel may have already been removed if a timeout occurred, and
312
- // this method may be called just after.
313
- if (channel != null ) {
314
- LOGGER .debug ("Closing Channel {} " , channel );
315
- try {
316
- removeAll (channel );
317
- Channels .setDiscard (channel );
318
- channel .close ();
319
- } catch (Throwable t ) {
320
- LOGGER .debug ("Error closing a connection" , t );
321
- }
322
- openChannels .remove (channel );
311
+ LOGGER .debug ("Closing Channel {} " , channel );
312
+ try {
313
+ removeAll (channel );
314
+ Channels .setDiscard (channel );
315
+ channel .close ();
316
+ } catch (Throwable t ) {
317
+ LOGGER .debug ("Error closing a connection" , t );
323
318
}
319
+ openChannels .remove (channel );
324
320
}
325
321
326
322
public void abortChannelPreemption (String poolKey ) {
You can’t perform that action at this time.
0 commit comments