| commit | f5ccf50f4695a8557983abcfa8b1ad989ed8822a | [log] [tgz] |
|---|---|---|
| author | Michael Blow <michael.blow@couchbase.com> | Thu Apr 11 10:53:13 2019 -0400 |
| committer | Michael Blow <mblow@apache.org> | Fri Apr 12 02:03:25 2019 +0000 |
| tree | 2bac2460adfc2b074dd4c6c02a3987d4df9ad27b | |
| parent | c3ea16c8278111d10dee4d0a01d0a2cd08a81af0 [diff] |
[NO ISSUE][*DB][CLUS] Add failed nodes API to ClusterStateManager Change-Id: I1b56b29c38f0bbfe54b30ee5781770e90404c528 Reviewed-on: https://asterix-gerrit.ics.uci.edu/3335 Tested-by: Jenkins <jenkins@fulliautomatix.ics.uci.edu> Integration-Tests: Jenkins <jenkins@fulliautomatix.ics.uci.edu> Reviewed-by: Till Westmann <tillw@apache.org>
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 5e99eec..d0d039d 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
@@ -139,6 +139,11 @@ Set<String> getParticipantNodes(); /** + * @return the set of currently failed nodes + */ + Set<String> getFailedNodes(); + + /** * 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 8d3187b..720b089 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
@@ -251,6 +251,11 @@ } @Override + public synchronized Set<String> getFailedNodes() { + return new HashSet<>(failedNodes); + } + + @Override public synchronized Set<String> getParticipantNodes(boolean excludePendingRemoval) { final Set<String> participantNodesCopy = getParticipantNodes(); if (excludePendingRemoval) {