ZOOKEEPER-XXXX: Restore interrupt status in quorum catch blocks

zookeeper-server/src/main/java/org/apache/zookeeper/server/quorum/FastLeaderElection.java

@@ -467,6 +467,7 @@ public void run() {
                             }
                         }
                     } catch (InterruptedException e) {
+                        Thread.currentThread().interrupt();
                         LOG.warn("Interrupted Exception while waiting for new message", e);
                     }
                 }

zookeeper-server/src/main/java/org/apache/zookeeper/server/quorum/Learner.java

@@ -332,6 +332,7 @@ protected void connectToLeader(MultipleAddresses multiAddr, String hostname) thr
         try {
             latch.await();
         } catch (InterruptedException e) {
+            Thread.currentThread().interrupt();
             LOG.warn("Interrupted while trying to connect to Leader", e);
         } finally {
             executor.shutdown();
@@ -340,6 +341,7 @@ protected void connectToLeader(MultipleAddresses multiAddr, String hostname) thr
                     LOG.error("not all the LeaderConnector terminated properly");
                 }
             } catch (InterruptedException ie) {
+                Thread.currentThread().interrupt();
                 LOG.error("Interrupted while terminating LeaderConnector executor.", ie);
             }
         }

zookeeper-server/src/main/java/org/apache/zookeeper/server/quorum/LearnerHandler.java

@@ -1047,6 +1047,7 @@ public void shutdown() {
             queuedPackets.clear();
             queuedPackets.put(proposalOfDeath);
         } catch (InterruptedException e) {
+            Thread.currentThread().interrupt();
             LOG.warn("Ignoring unexpected exception", e);
         }
 

zookeeper-server/src/main/java/org/apache/zookeeper/server/quorum/Observer.java

@@ -258,6 +258,7 @@ private static void waitForReconnectDelayHelper(long delayValueMs) {
             try {
                 Thread.sleep(randomDelay);
             } catch (InterruptedException e) {
+                Thread.currentThread().interrupt();
                 LOG.warn("Interrupted while waiting", e);
             }
         }

zookeeper-server/src/main/java/org/apache/zookeeper/server/quorum/QuorumCnxManager.java

@@ -819,6 +819,7 @@ public void halt() {
         try {
             listener.join();
         } catch (InterruptedException ex) {
+            Thread.currentThread().interrupt();
             LOG.warn("Got interrupted before joining the listener", ex);
         }
         softHalt();
@@ -1106,6 +1107,7 @@ private void acceptConnections() {
                         } catch (IOException ie) {
                             LOG.error("Error closing server socket", ie);
                         } catch (InterruptedException ie) {
+                            Thread.currentThread().interrupt();
                             LOG.error("Interrupted while sleeping. Ignoring exception", ie);
                         }
                         closeSocket(client);
@@ -1282,6 +1284,7 @@ public void run() {
                             send(b);
                         }
                     } catch (InterruptedException e) {
+                        Thread.currentThread().interrupt();
                         LOG.warn("Interrupted while waiting for message on queue", e);
                     }
                 }

zookeeper-server/src/main/java/org/apache/zookeeper/server/quorum/QuorumPeerMain.java

@@ -231,6 +231,7 @@ public void runFromConfig(QuorumPeerConfig config) throws IOException, AdminServ
             ZKAuditProvider.addZKStartStopAuditLog();
             quorumPeer.join();
         } catch (InterruptedException e) {
+            Thread.currentThread().interrupt();
             // warn, but generally this is ok
             LOG.warn("Quorum Peer interrupted", e);
         } finally {