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 <[email protected]> Authored: Thu Nov 30 17:02:40 2017 +0300 Committer: sboikov <[email protected]> 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(); }
