Catching InterruptedException now interrupts the caller thread again (h…

…ttps://issues.redhat.com/browse/JGRP-2835)
belaban · Oct 2, 2024 · 67969f6 · 67969f6
1 parent eee37b8
commit 67969f6
Showing 1 changed file with 9 additions and 1 deletion.
diff --git a/src/org/jgroups/protocols/TransferQueueBundler.java b/src/org/jgroups/protocols/TransferQueueBundler.java
@@ -81,7 +81,12 @@ public synchronized void stop() {
         if(tmp != null) {
             tmp.interrupt();
             if(tmp.isAlive()) {
-                try {tmp.join(500);} catch(InterruptedException e) {}
+                try {
+                    tmp.join(500);
+                }
+                catch(InterruptedException e) {
+                    Thread.currentThread().interrupt();
+                }
             }
         }
         drain();
@@ -127,6 +132,9 @@ public void run() {
                     num_sends_because_no_msgs++;
                 }
             }
+            catch(InterruptedException iex) {
+                Thread.currentThread().interrupt();
+            }
             catch(Throwable t) {
                 log.trace("%s: failed sending message: %s", transport.addr(), t);
             }