You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by ag...@apache.org on 2017/08/01 09:25:51 UTC
[08/47] ignite git commit: IGNITE-5174: list only server nodes for
specified topology version
IGNITE-5174: list only server nodes for specified topology version
Fixes #2312
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/586a96ea
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/586a96ea
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/586a96ea
Branch: refs/heads/master
Commit: 586a96eaf4570f4f2020041cfef07550025421d8
Parents: 50c5b1d
Author: Evgeny Stanilovskiy <es...@gridgain.com>
Authored: Wed Jul 26 18:49:41 2017 +0300
Committer: dpavlov <dp...@gridgain.com>
Committed: Wed Jul 26 18:49:41 2017 +0300
----------------------------------------------------------------------
.../internal/managers/discovery/GridDiscoveryManager.java | 10 ++++++++++
1 file changed, 10 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/586a96ea/modules/core/src/main/java/org/apache/ignite/internal/managers/discovery/GridDiscoveryManager.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/managers/discovery/GridDiscoveryManager.java b/modules/core/src/main/java/org/apache/ignite/internal/managers/discovery/GridDiscoveryManager.java
index 9f5bd3f..7ad058d 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/managers/discovery/GridDiscoveryManager.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/managers/discovery/GridDiscoveryManager.java
@@ -1974,6 +1974,16 @@ public class GridDiscoveryManager extends GridManagerAdapter<DiscoverySpi> {
return snapshots.get(topVer);
}
+ /**
+ * Gets server nodes topology by specified version from snapshots history storage.
+ *
+ * @param topVer Topology version.
+ * @return Server topology nodes or {@code null} if there are no nodes for passed in version.
+ */
+ @Nullable public Collection<ClusterNode> serverTopologyNodes(long topVer) {
+ return F.view(topology(topVer), F.not(FILTER_CLI));
+ }
+
/** @return All daemon nodes in topology. */
public Collection<ClusterNode> daemonNodes() {
return discoCache().daemonNodes();