Skip to content

Commit 65d3abc

Browse files
author
Stephane Landelle
committed
Minor clean up after PR AsyncHttpClient#214
1 parent 05ae8da commit 65d3abc

File tree

1 file changed

+0
-3
lines changed

1 file changed

+0
-3
lines changed

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

Lines changed: 0 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -347,7 +347,6 @@ public ChannelPipeline getPipeline() throws Exception {
347347
}
348348

349349
private Channel lookupInCache(URI uri, ConnectionPoolKeyStrategy connectionPoolKeyStrategy) {
350-
351350
final Channel channel = connectionsPool.poll(connectionPoolKeyStrategy.getKey(uri));
352351

353352
if (channel != null) {
@@ -1273,7 +1272,6 @@ private Realm ntlmProxyChallenge(List<String> wwwAuth,
12731272
private void drainChannel(final ChannelHandlerContext ctx, final NettyResponseFuture<?> future, final boolean keepAlive, final URI uri) {
12741273
ctx.setAttachment(new AsyncCallable(future) {
12751274
public Object call() throws Exception {
1276-
// TODO POOL
12771275
if (keepAlive && ctx.getChannel().isReadable() && connectionsPool.offer(future.getConnectionPoolKeyStrategy().getKey(uri), ctx.getChannel())) {
12781276
return null;
12791277
}
@@ -1470,7 +1468,6 @@ private void finishUpdate(final NettyResponseFuture<?> future, final ChannelHand
14701468
if (lastValidChunk && future.getKeepAlive()) {
14711469
drainChannel(ctx, future, future.getKeepAlive(), future.getURI());
14721470
} else {
1473-
// TODO POOL
14741471
if (future.getKeepAlive() && ctx.getChannel().isReadable() &&
14751472
connectionsPool.offer(future.getConnectionPoolKeyStrategy().getKey(future.getURI()), ctx.getChannel())) {
14761473
markAsDone(future, ctx);

0 commit comments

Comments
 (0)