Skip to content

Commit c0fb4c7

Browse files
author
Stephane Landelle
committed
Move debug log
1 parent adac464 commit c0fb4c7

File tree

2 files changed

+3
-6
lines changed

2 files changed

+3
-6
lines changed

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

Lines changed: 0 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -39,7 +39,6 @@
3939
import java.util.List;
4040
import java.util.Map.Entry;
4141
import java.util.concurrent.Callable;
42-
import java.util.concurrent.ExecutionException;
4342
import java.util.concurrent.ExecutorService;
4443
import java.util.concurrent.Executors;
4544
import java.util.concurrent.Future;
@@ -1324,11 +1323,6 @@ private void abort(NettyResponseFuture<?> future, Throwable t) {
13241323
openChannels.remove(channel);
13251324
}
13261325

1327-
if (!future.isCancelled() && !future.isDone()) {
1328-
log.debug("Aborting Future {}\n", future);
1329-
log.debug(t.getMessage(), t);
1330-
}
1331-
13321326
future.abort(t);
13331327
}
13341328

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

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -334,6 +334,9 @@ public final void abort(final Throwable t) {
334334
if (isDone.get() || isCancelled.get())
335335
return;
336336

337+
logger.debug("Aborting Future {}\n", this);
338+
logger.debug(t.getMessage(), t);
339+
337340
exEx.compareAndSet(null, new ExecutionException(t));
338341
if (!throwableCalled.getAndSet(true)) {
339342
try {

0 commit comments

Comments
 (0)