Browse Source

added additional failover qualifieers

0xdcarns 2 years ago
parent
commit
e5ffe3114d
3 changed files with 5 additions and 3 deletions
  1. 1 1
      ee/initialize.go
  2. 1 1
      ee/logic/failover.go
  3. 3 1
      mq/handlers.go

+ 1 - 1
ee/initialize.go

@@ -28,11 +28,11 @@ func InitEE() {
 		}
 		// == End License Handling ==
 		AddLicenseHooks()
+		resetFailover()
 	})
 	logic.EnterpriseFailoverFunc = eelogic.SetFailover
 	logic.EnterpriseResetFailoverFunc = eelogic.ResetFailover
 	logic.EnterpriseResetAllPeersFailovers = eelogic.WipeAffectedFailoversOnly
-	resetFailover()
 }
 
 func setControllerLimits() {

+ 1 - 1
ee/logic/failover.go

@@ -100,11 +100,11 @@ func WipeAffectedFailoversOnly(nodeid, network string) error {
 	if err != nil {
 		return nil
 	}
+	WipeFailover(nodeid)
 
 	for i := range currentNetworkNodes {
 		currNodeID := currentNetworkNodes[i].ID
 		if currNodeID == nodeid {
-			WipeFailover(nodeid)
 			continue
 		}
 		currMetrics, err := logic.GetMetrics(currNodeID)

+ 3 - 1
mq/handlers.go

@@ -261,7 +261,9 @@ func updateNodeMetrics(currentNode *models.Node, newMetrics *models.Metrics) boo
 	for _, node := range nodes {
 		if !newMetrics.Connectivity[node.ID].Connected &&
 			len(newMetrics.Connectivity[node.ID].NodeName) > 0 &&
-			node.Connected == "yes" {
+			node.Connected == "yes" &&
+			len(node.FailoverNode) > 0 &&
+			node.Failover != "yes" {
 			newMetrics.FailoverPeers[node.ID] = node.FailoverNode
 		}
 	}