You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hc.apache.org by ol...@apache.org on 2017/08/09 18:15:19 UTC

[10/10] httpcomponents-core git commit: BasicRequestProducer propagates failure to dataProducer

BasicRequestProducer propagates failure to dataProducer

Closes PR #48


Project: http://git-wip-us.apache.org/repos/asf/httpcomponents-core/repo
Commit: http://git-wip-us.apache.org/repos/asf/httpcomponents-core/commit/9d603d4d
Tree: http://git-wip-us.apache.org/repos/asf/httpcomponents-core/tree/9d603d4d
Diff: http://git-wip-us.apache.org/repos/asf/httpcomponents-core/diff/9d603d4d

Branch: refs/heads/master
Commit: 9d603d4d4b454facd2bcfe8a22cf7beef18c8002
Parents: 3fb67cb
Author: Carter Kozak <c4...@gmail.com>
Authored: Mon Aug 7 17:35:23 2017 -0400
Committer: Oleg Kalnichevski <ol...@apache.org>
Committed: Wed Aug 9 16:49:08 2017 +0200

----------------------------------------------------------------------
 .../org/apache/hc/core5/http/nio/BasicRequestProducer.java   | 8 +++++++-
 1 file changed, 7 insertions(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/httpcomponents-core/blob/9d603d4d/httpcore5/src/main/java/org/apache/hc/core5/http/nio/BasicRequestProducer.java
----------------------------------------------------------------------
diff --git a/httpcore5/src/main/java/org/apache/hc/core5/http/nio/BasicRequestProducer.java b/httpcore5/src/main/java/org/apache/hc/core5/http/nio/BasicRequestProducer.java
index c07d979..4e22f7a 100644
--- a/httpcore5/src/main/java/org/apache/hc/core5/http/nio/BasicRequestProducer.java
+++ b/httpcore5/src/main/java/org/apache/hc/core5/http/nio/BasicRequestProducer.java
@@ -79,7 +79,13 @@ public class BasicRequestProducer implements AsyncRequestProducer {
 
     @Override
     public void failed(final Exception cause) {
-        releaseResources();
+        try {
+            if (dataProducer != null) {
+                dataProducer.failed(cause);
+            }
+        } finally {
+            releaseResources();
+        }
     }
 
     @Override