summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorOla Aunrønning <olaa@verizonmedia.com>2021-01-04 17:31:51 +0100
committerGitHub <noreply@github.com>2021-01-04 17:31:51 +0100
commit3c220d12e1c6991fc62f6e157a623d78af17a8cd (patch)
tree8aa833c59ee4697629836297375c1307a025dd8f
parent5613779dc559920120f93cf9358d62cad0ddde1e (diff)
parent5e2a1979667be67d7d70d2a79153bf48c37d8a77 (diff)
Merge pull request #15898 from vespa-engine/olaa/always-update-is-master-metric
Always set 'is-master' metric. Remove 'master-change'
-rw-r--r--clustercontroller-core/src/main/java/com/yahoo/vespa/clustercontroller/core/FleetController.java3
-rw-r--r--clustercontroller-core/src/main/java/com/yahoo/vespa/clustercontroller/core/MetricUpdater.java10
2 files changed, 3 insertions, 10 deletions
diff --git a/clustercontroller-core/src/main/java/com/yahoo/vespa/clustercontroller/core/FleetController.java b/clustercontroller-core/src/main/java/com/yahoo/vespa/clustercontroller/core/FleetController.java
index 9c9e1042c79..d29b2387db3 100644
--- a/clustercontroller-core/src/main/java/com/yahoo/vespa/clustercontroller/core/FleetController.java
+++ b/clustercontroller-core/src/main/java/com/yahoo/vespa/clustercontroller/core/FleetController.java
@@ -1002,7 +1002,6 @@ public class FleetController implements NodeStateOrHostInfoChangeHandler, NodeAd
boolean didWork = false;
if (masterElectionHandler.isMaster()) {
if ( ! isMaster) {
- metricUpdater.becameMaster();
// If we just became master, restore state from ZooKeeper
stateChangeHandler.setStateChangedFlag();
systemStateBroadcaster.resetBroadcastedClusterStateBundle();
@@ -1032,12 +1031,12 @@ public class FleetController implements NodeStateOrHostInfoChangeHandler, NodeAd
if (isMaster) {
eventLog.add(new ClusterEvent(ClusterEvent.Type.MASTER_ELECTION, "This node is no longer fleetcontroller master.", timer.getCurrentTimeInMillis()));
firstAllowedStateBroadcast = Long.MAX_VALUE;
- metricUpdater.noLongerMaster();
failAllVersionDependentTasks();
}
wantedStateChanged = false;
isMaster = false;
}
+ metricUpdater.updateMasterState(isMaster);
return didWork;
}
diff --git a/clustercontroller-core/src/main/java/com/yahoo/vespa/clustercontroller/core/MetricUpdater.java b/clustercontroller-core/src/main/java/com/yahoo/vespa/clustercontroller/core/MetricUpdater.java
index bc66980db75..650f7756bf9 100644
--- a/clustercontroller-core/src/main/java/com/yahoo/vespa/clustercontroller/core/MetricUpdater.java
+++ b/clustercontroller-core/src/main/java/com/yahoo/vespa/clustercontroller/core/MetricUpdater.java
@@ -75,14 +75,8 @@ public class MetricUpdater {
metricReporter.set("agreed-master-votes", maxCount);
}
- public void becameMaster() {
- metricReporter.set("is-master", 1);
- metricReporter.add("master-change", 1);
- }
-
- public void noLongerMaster() {
- metricReporter.set("is-master", 0);
- metricReporter.add("master-change", 1);
+ public void updateMasterState(boolean isMaster) {
+ metricReporter.set("is-master", isMaster ? 1 : 0);
}
public void addTickTime(long millis, boolean didWork) {