diff --git a/federationsender/statistics/statistics.go b/federationsender/statistics/statistics.go index 0621ec497..f08fe1ce1 100644 --- a/federationsender/statistics/statistics.go +++ b/federationsender/statistics/statistics.go @@ -134,7 +134,7 @@ func (s *ServerStatistics) BackoffIfRequired(backingOff atomic.Bool, interrupt < // Work out how long we should be backing off for. duration := time.Second * time.Duration(math.Exp2(float64(count))) - logrus.Debugf("Backing off %q for %s", s.serverName, duration) + logrus.Warnf("Backing off %q for %s", s.serverName, duration) // Wait for either an interruption or for the backoff to // complete. @@ -144,10 +144,6 @@ func (s *ServerStatistics) BackoffIfRequired(backingOff atomic.Bool, interrupt < case <-time.After(duration): } - // Drain the interrupt queue - helps with tests. - for range interrupt { - } - return duration }