You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@trafficcontrol.apache.org by ne...@apache.org on 2017/04/12 21:43:57 UTC
[07/13] incubator-trafficcontrol git commit: Fix TM2 offline
validator to onResume metafailures
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 <ro...@gmail.com>
Authored: Fri Mar 3 12:29:06 2017 -0700
Committer: Dave Neuman <ne...@apache.org>
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 {