From a854e3aa18ccb9314b5ea1113ce932981c74c805 Mon Sep 17 00:00:00 2001 From: Neil Alexander Date: Tue, 22 Sep 2020 14:53:36 +0100 Subject: [PATCH] Fix backoff bug --- federationsender/queue/destinationqueue.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/federationsender/queue/destinationqueue.go b/federationsender/queue/destinationqueue.go index 57612908..12a04d4b 100644 --- a/federationsender/queue/destinationqueue.go +++ b/federationsender/queue/destinationqueue.go @@ -239,7 +239,7 @@ func (oq *destinationQueue) backgroundSend() { log.Warnf("Blacklisting %q due to exceeding backoff threshold", oq.destination) return } - if until != nil { + if until != nil && until.After(time.Now()) { // We haven't backed off yet, so wait for the suggested amount of // time. duration := time.Until(*until)