ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sboi...@apache.org
Subject ignite git commit: zk
Date Thu, 30 Nov 2017 14:03:32 GMT
Repository: ignite
Updated Branches:
  refs/heads/ignite-zk c167640ee -> 4405bb1cb


zk


Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/4405bb1c
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/4405bb1c
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/4405bb1c

Branch: refs/heads/ignite-zk
Commit: 4405bb1cbeae62e11650a7cb650eb2980b490ed0
Parents: c167640
Author: sboikov <sboikov@gridgain.com>
Authored: Thu Nov 30 17:02:40 2017 +0300
Committer: sboikov <sboikov@gridgain.com>
Committed: Thu Nov 30 17:02:40 2017 +0300

----------------------------------------------------------------------
 .../spi/discovery/zk/internal/ZookeeperDiscoveryImpl.java    | 8 +++-----
 1 file changed, 3 insertions(+), 5 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/ignite/blob/4405bb1c/modules/core/src/main/java/org/apache/ignite/spi/discovery/zk/internal/ZookeeperDiscoveryImpl.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/spi/discovery/zk/internal/ZookeeperDiscoveryImpl.java
b/modules/core/src/main/java/org/apache/ignite/spi/discovery/zk/internal/ZookeeperDiscoveryImpl.java
index 38f9cbf..5e806eb 100644
--- a/modules/core/src/main/java/org/apache/ignite/spi/discovery/zk/internal/ZookeeperDiscoveryImpl.java
+++ b/modules/core/src/main/java/org/apache/ignite/spi/discovery/zk/internal/ZookeeperDiscoveryImpl.java
@@ -211,10 +211,9 @@ public class ZookeeperDiscoveryImpl {
      * @return Ping result.
      */
     public boolean pingNode(UUID nodeId) {
-        while (!busyLock.enterBusy())
-            checkState();
-
         // TODO ZK
+        checkState();
+
         return node(nodeId) != null;
     }
 
@@ -312,8 +311,7 @@ public class ZookeeperDiscoveryImpl {
      * @return Remote nodes.
      */
     public Collection<ClusterNode> remoteNodes() {
-        while (!busyLock.enterBusy())
-            checkState();
+        checkState();
 
         return state.top.remoteNodes();
     }


Mime
View raw message