switch from channel to simple sleepingClusterChecks global map

xorpaul · Jan 9, 2020 · bb0b756 · bb0b756
1 parent cbb511d
commit bb0b756
Showing 1 changed file with 5 additions and 4 deletions.
diff --git a/v1.go b/v1.go
@@ -165,10 +165,11 @@ func restartHandlerV1(w http.ResponseWriter, r *http.Request) {
 				res.Message = result.Reason
 				res.Goahead = true
 				triggerRebootGoaheadActions(request.Fqdn, res.FoundCluster, request.Uptime, clusterLogger)
-				clusterLogger.Debug("Activating cluster checker for " + request.Fqdn + " inside cluster " + res.FoundCluster)
-				select {
-				case checkCluster <- clusterCheck{clusterSettings[c], request.Fqdn, rid, res.FoundCluster}:
-				default:
+				clusterLogger.Info("Activating cluster checker for " + request.Fqdn + " inside cluster " + res.FoundCluster)
+				mutex.Lock()
+				if _, ok := sleepingClusterChecks[res.RequestingFqdn]; !ok {
+					sleepingClusterChecks[request.Fqdn] = clusterCheck{clusterSettings[c], request.Fqdn, rid, res.FoundCluster}
+					mutex.Unlock()
 				}
 			} else {
 				res.Message = result.Reason