Michael Blow has submitted this change and it was merged. ( https://asterix-gerrit.ics.uci.edu/3340 )
Change subject: [NO ISSUE][*DB][CLUS] Add API to return all known nodes atomically ...................................................................... [NO ISSUE][*DB][CLUS] Add API to return all known nodes atomically Change-Id: Ie6bb64e331666ef44b07034d430ba2ee563bba82 Reviewed-on: https://asterix-gerrit.ics.uci.edu/3340 Reviewed-by: Murtadha Hubail <[email protected]> Tested-by: Jenkins <[email protected]> --- M asterixdb/asterix-common/src/main/java/org/apache/asterix/common/cluster/IClusterStateManager.java M asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/utils/ClusterStateManager.java 2 files changed, 12 insertions(+), 0 deletions(-) Approvals: Murtadha Hubail: Looks good to me, approved Jenkins: Verified Objections: Jenkins: Violations found diff --git a/asterixdb/asterix-common/src/main/java/org/apache/asterix/common/cluster/IClusterStateManager.java b/asterixdb/asterix-common/src/main/java/org/apache/asterix/common/cluster/IClusterStateManager.java index d0d039d..0e62851 100644 --- a/asterixdb/asterix-common/src/main/java/org/apache/asterix/common/cluster/IClusterStateManager.java +++ b/asterixdb/asterix-common/src/main/java/org/apache/asterix/common/cluster/IClusterStateManager.java @@ -144,6 +144,11 @@ Set<String> getFailedNodes(); /** + * @return the set of cluster nodes + */ + Set<String> getNodes(); + + /** * Returns the IO devices configured for a Node Controller * * @param nodeId diff --git a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/utils/ClusterStateManager.java b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/utils/ClusterStateManager.java index 720b089..16a479e 100644 --- a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/utils/ClusterStateManager.java +++ b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/utils/ClusterStateManager.java @@ -256,6 +256,13 @@ } @Override + public synchronized Set<String> getNodes() { + Set<String> nodes = new HashSet<>(participantNodes); + nodes.addAll(failedNodes); + return nodes; + } + + @Override public synchronized Set<String> getParticipantNodes(boolean excludePendingRemoval) { final Set<String> participantNodesCopy = getParticipantNodes(); if (excludePendingRemoval) { -- To view, visit https://asterix-gerrit.ics.uci.edu/3340 To unsubscribe, visit https://asterix-gerrit.ics.uci.edu/settings Gerrit-Project: asterixdb Gerrit-Branch: stabilization-f69489 Gerrit-MessageType: merged Gerrit-Change-Id: Ie6bb64e331666ef44b07034d430ba2ee563bba82 Gerrit-Change-Number: 3340 Gerrit-PatchSet: 2 Gerrit-Owner: Michael Blow <[email protected]> Gerrit-Reviewer: Anon. E. Moose (1000171) Gerrit-Reviewer: Jenkins <[email protected]> Gerrit-Reviewer: Michael Blow <[email protected]> Gerrit-Reviewer: Murtadha Hubail <[email protected]> Gerrit-Reviewer: Till Westmann <[email protected]>
