Re-enable the listener test now that win32 is fixed

Author: jfarcand

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

@@ -315,24 +315,14 @@ protected final <T> void writeRequest(final Channel channel,
                                           final NettyResponseFuture<T> future,
                                           final HttpRequest nettyRequest) {
         try {
-
-            if (TransferCompletionHandler.class.isAssignableFrom(future.getAsyncHandler().getClass())) {
-
-                FluentCaseInsensitiveStringsMap h = new FluentCaseInsensitiveStringsMap();
-                for (String s : future.getNettyRequest().getHeaderNames()) {
-                    for (String header : future.getNettyRequest().getHeaders(s)) {
-                        h.add(s, header);
-                    }
-                }
-
-                TransferCompletionHandler.class.cast(future.getAsyncHandler()).transferAdapter(
-                        new NettyTransferAdapter(h, nettyRequest.getContent(), future.getRequest().getFile()));
-            }
-
             if (!channel.isOpen() || !channel.isConnected()) {
                 if (!remotelyClosed(channel, future)) {
                     abort(future, new ConnectException());
                     return;
+                } else {
+                    log.error("Channel is in close state {} and cannot be recovered", channel);
+                    abort(future, new ClosedChannelException());                    
+                    return;
                 }
             }
 
@@ -355,6 +345,20 @@ protected final <T> void writeRequest(final Channel channel,
                 }
             }
 
+
+            if (TransferCompletionHandler.class.isAssignableFrom(future.getAsyncHandler().getClass())) {
+
+                FluentCaseInsensitiveStringsMap h = new FluentCaseInsensitiveStringsMap();
+                for (String s : future.getNettyRequest().getHeaderNames()) {
+                    for (String header : future.getNettyRequest().getHeaders(s)) {
+                        h.add(s, header);
+                    }
+                }
+
+                TransferCompletionHandler.class.cast(future.getAsyncHandler()).transferAdapter(
+                        new NettyTransferAdapter(h, nettyRequest.getContent(), future.getRequest().getFile()));
+            }
+
             // Leave it to true.
             if (future.getAndSetWriteHeaders(true)) {
                 try {
@@ -1463,6 +1467,7 @@ public void exceptionCaught(ChannelHandlerContext ctx, ExceptionEvent e)
         } catch (Throwable t) {
             cause = t;
         }
+
         if (future != null) {
             try {
                 abort(future, cause);

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

@@ -221,6 +221,8 @@ V getContent() throws ExecutionException {
         }
 
         V update = content.get();
+        // No more retry
+        currentRetry.set(maxRetry);
         if (exEx.get() == null && !contentProcessed.getAndSet(true)) {
             try {
                 update = asyncHandler.onCompleted();

src/test/java/com/ning/http/client/async/TransferListenerTest.java

@@ -191,7 +191,7 @@ public void onThrowable(Throwable t) {
         c.close();
     }
 
-    @Test(groups = {"standalone", "default_provider"}, enabled = false)
+    @Test(groups = {"standalone", "default_provider"})
     public void basicPutBodyTest() throws Throwable {
         AsyncHttpClient c = new AsyncHttpClient();