[1.8.x] + close the transaction, if connection is closed locally

Author: oleksiys

src/main/java/com/ning/http/client/providers/grizzly/FeedableBodyGenerator.java

@@ -1,5 +1,5 @@
 /*
- * Copyright (c) 2012-2014 Sonatype, Inc. All rights reserved.
+ * Copyright (c) 2012-2015 Sonatype, Inc. All rights reserved.
  *
  * This program is licensed to you under the Apache License Version 2.0,
  * and you may not use this file except in compliance with the Apache License Version 2.0.
@@ -38,6 +38,7 @@
 import static java.lang.Boolean.TRUE;
 import static java.util.concurrent.TimeUnit.MILLISECONDS;
 import static org.glassfish.grizzly.ssl.SSLUtils.getSSLEngine;
+import org.glassfish.grizzly.utils.Exceptions;
 import static org.glassfish.grizzly.utils.Exceptions.*;
 
 /**
@@ -215,6 +216,10 @@ private void flushOnSSLHandshakeComplete() throws IOException {
             public void onStart(Connection connection) {
             }
 
+            public void onFailure(Connection connection, Throwable t) {
+                connection.closeWithReason(Exceptions.makeIOException(t));
+            }
+
             public void onComplete(Connection connection) {
                 if (c.equals(connection)) {
                     filter.removeHandshakeListener(this);
@@ -225,10 +230,6 @@ public void onComplete(Connection connection) {
                     }
                 }
             }
-
-            public void onFailure(Connection connection, Throwable t) {
-                
-            }
         });
         filter.handshake(context.getConnection(),  null);
     }

src/main/java/com/ning/http/client/providers/grizzly/GrizzlyAsyncHttpProvider.java

@@ -1,5 +1,5 @@
 /*
- * Copyright (c) 2012-2014 Sonatype, Inc. All rights reserved.
+ * Copyright (c) 2012-2015 Sonatype, Inc. All rights reserved.
  *
  * This program is licensed to you under the Apache License Version 2.0,
  * and you may not use this file except in compliance with the Apache License Version 2.0.
@@ -658,6 +658,12 @@ public void onClosed(Closeable closeable, CloseType type) throws IOException {
                             new GracefulCloseEvent(HttpTransactionContext.this), null);
                 } else if (CloseType.REMOTELY.equals(type)) {
                     abort(REMOTELY_CLOSED_EXCEPTION);
+                } else {
+                    try {
+                        closeable.assertOpen();
+                    } catch (IOException ioe) {
+                        abort(ioe);
+                    }
                 }
             }
         };