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 <[email protected]> Authored: Wed Jul 26 18:49:41 2017 +0300 Committer: dpavlov <[email protected]> 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();
