commit a5ac1231f6d1dc20ad8ca097764e8658da6c0a33
author Guillaume Nodet <gnodet@apache.org> Fri Dec 10 16:08:20 2010 +0000
committer Guillaume Nodet <gnodet@apache.org> Fri Dec 10 16:08:20 2010 +0000
tree 3355f62216fc5085df76fc5fcc2aff0aa0275f28
parent f18b493cd11e00478751787b84733359e8fe6cad

[FELIX-2723] When the execution of a closure with pipes is interrupted, pipes should be interrupted too

git-svn-id: https://svn.apache.org/repos/asf/felix/trunk@1044415 13f79535-47bb-0310-9956-ffa450edef68

gogo/runtime/src/main/java/org/apache/felix/gogo/runtime/Closure.java

diff --git a/gogo/runtime/src/main/java/org/apache/felix/gogo/runtime/Closure.java b/gogo/runtime/src/main/java/org/apache/felix/gogo/runtime/Closure.java
index 3b82874..f99a4b0 100644
--- a/gogo/runtime/src/main/java/org/apache/felix/gogo/runtime/Closure.java
+++ b/gogo/runtime/src/main/java/org/apache/felix/gogo/runtime/Closure.java
@@ -188,9 +188,20 @@
                 {
                     pipe.start();
                 }
-                for (Pipe pipe : pipes)
+                try
                 {
-                    pipe.join();
+                    for (Pipe pipe : pipes)
+                    {
+                        pipe.join();
+                    }
+                }
+                catch (InterruptedException e)
+                {
+                    for (Pipe pipe : pipes)
+                    {
+                        pipe.interrupt();
+                    }
+                    throw e;
                 }
             }