diff --git a/interfaces/utility/trackResults.go b/interfaces/utility/trackResults.go index cd766624d475141edbad94731f3a3da092e4bcfd..a02f1e0e4d2442b7a9979dd50dd93c2976d02fe6 100644 --- a/interfaces/utility/trackResults.go +++ b/interfaces/utility/trackResults.go @@ -8,6 +8,7 @@ package utility import ( + jww "github.com/spf13/jwalterweatherman" ds "gitlab.com/elixxir/comms/network/dataStructures" "gitlab.com/elixxir/primitives/states" ) @@ -22,6 +23,7 @@ func TrackResults(resultsCh chan ds.EventReturn, numResults int) (bool, int, int if er.TimedOut { numTimeOut++ } else if states.Round(er.RoundInfo.State) == states.FAILED { + jww.ERROR.Printf("RoundInfo FAILED: %+v", er.RoundInfo) numRoundFail++ } } diff --git a/network/health/tracker.go b/network/health/tracker.go index 1cc4be54ef3e0ddb444a50a6a00570885ddcf659..8be8c05ff98b7a37f9fad79e3b6572c846bf9f61 100644 --- a/network/health/tracker.go +++ b/network/health/tracker.go @@ -177,6 +177,9 @@ func (t *Tracker) start(stop *stoppable.Single) { return case heartbeat = <-t.heartbeat: + // FIXME: There's no transition to unhealthy here + // and there needs to be after some number of bad + // polls if healthy(heartbeat) { t.setHealth(true) }