Fix TM2 offline validator to onResume metafailures
Project: http://git-wip-us.apache.org/repos/asf/incubator-trafficcontrol/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-trafficcontrol/commit/6abf64aa Tree: http://git-wip-us.apache.org/repos/asf/incubator-trafficcontrol/tree/6abf64aa Diff: http://git-wip-us.apache.org/repos/asf/incubator-trafficcontrol/diff/6abf64aa Branch: refs/heads/master Commit: 6abf64aa97f23640cdb659581f0d7e373fa50700 Parents: 667ed34 Author: Robert Butts <[email protected]> Authored: Fri Mar 3 12:29:06 2017 -0700 Committer: Dave Neuman <[email protected]> Committed: Wed Apr 12 15:43:31 2017 -0600 ---------------------------------------------------------------------- traffic_monitor_golang/traffic_monitor/tmcheck/tmcheck.go | 5 +++++ 1 file changed, 5 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-trafficcontrol/blob/6abf64aa/traffic_monitor_golang/traffic_monitor/tmcheck/tmcheck.go ---------------------------------------------------------------------- diff --git a/traffic_monitor_golang/traffic_monitor/tmcheck/tmcheck.go b/traffic_monitor_golang/traffic_monitor/tmcheck/tmcheck.go index fa2c533..819c1ab 100644 --- a/traffic_monitor_golang/traffic_monitor/tmcheck/tmcheck.go +++ b/traffic_monitor_golang/traffic_monitor/tmcheck/tmcheck.go @@ -227,11 +227,16 @@ func AllMonitorsCRStatesOfflineValidator( ) { invalid := map[enum.TrafficMonitorName]bool{} invalidStart := map[enum.TrafficMonitorName]time.Time{} + metaFail := false for { tmErrs, err := ValidateAllMonitorsOfflineStates(toClient, includeOffline) if err != nil { onErr("", fmt.Errorf("Error validating monitors: %v", err)) time.Sleep(interval) + metaFail = true + } else if metaFail { + onResumeSuccess("") + metaFail = false } for name, err := range tmErrs {
