hadoop-common-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From lium...@apache.org
Subject hadoop git commit: HADOOP-14214. DomainSocketWatcher::add()/delete() should not self interrupt while looping await(). Contributed by Mingliang Liu
Date Thu, 23 Mar 2017 20:42:07 GMT
Repository: hadoop
Updated Branches:
  refs/heads/branch-2.8 5e794c74e -> 47d3c29e3


HADOOP-14214. DomainSocketWatcher::add()/delete() should not self interrupt while looping
await(). Contributed by Mingliang Liu

(cherry picked from commit d35e79abc2fee7153a6168e6088f100de59d8c81)


Project: http://git-wip-us.apache.org/repos/asf/hadoop/repo
Commit: http://git-wip-us.apache.org/repos/asf/hadoop/commit/47d3c29e
Tree: http://git-wip-us.apache.org/repos/asf/hadoop/tree/47d3c29e
Diff: http://git-wip-us.apache.org/repos/asf/hadoop/diff/47d3c29e

Branch: refs/heads/branch-2.8
Commit: 47d3c29e300e0d43ce4a26807432c9c0361e172e
Parents: 5e794c7
Author: Mingliang Liu <liuml07@apache.org>
Authored: Thu Mar 23 11:33:06 2017 -0700
Committer: Mingliang Liu <liuml07@apache.org>
Committed: Thu Mar 23 13:39:42 2017 -0700

----------------------------------------------------------------------
 .../org/apache/hadoop/net/unix/DomainSocketWatcher.java | 12 ++----------
 1 file changed, 2 insertions(+), 10 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/hadoop/blob/47d3c29e/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/net/unix/DomainSocketWatcher.java
----------------------------------------------------------------------
diff --git a/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/net/unix/DomainSocketWatcher.java
b/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/net/unix/DomainSocketWatcher.java
index ad2fbfb..e1bcf7e 100644
--- a/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/net/unix/DomainSocketWatcher.java
+++ b/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/net/unix/DomainSocketWatcher.java
@@ -321,11 +321,7 @@ public final class DomainSocketWatcher implements Closeable {
       toAdd.add(entry);
       kick();
       while (true) {
-        try {
-          processedCond.await();
-        } catch (InterruptedException e) {
-          Thread.currentThread().interrupt();
-        }
+        processedCond.awaitUninterruptibly();
         if (!toAdd.contains(entry)) {
           break;
         }
@@ -347,11 +343,7 @@ public final class DomainSocketWatcher implements Closeable {
       toRemove.put(sock.fd, sock);
       kick();
       while (true) {
-        try {
-          processedCond.await();
-        } catch (InterruptedException e) {
-          Thread.currentThread().interrupt();
-        }
+        processedCond.awaitUninterruptibly();
         if (!toRemove.containsKey(sock.fd)) {
           break;
         }


---------------------------------------------------------------------
To unsubscribe, e-mail: common-commits-unsubscribe@hadoop.apache.org
For additional commands, e-mail: common-commits-help@hadoop.apache.org


Mime
View raw message