diff options
| author | Neil Alexander <neilalexander@users.noreply.github.com> | 2020-09-22 14:53:36 +0100 |
|---|---|---|
| committer | Neil Alexander <neilalexander@users.noreply.github.com> | 2020-09-22 14:53:36 +0100 |
| commit | a854e3aa18ccb9314b5ea1113ce932981c74c805 (patch) | |
| tree | fc8882d627ff41645b0ba079fa3f8d3dc1e62b13 /federationsender | |
| parent | a14b29b52617c06a548145a18b4d7cee6e529b79 (diff) | |
Fix backoff bug
Diffstat (limited to 'federationsender')
| -rw-r--r-- | federationsender/queue/destinationqueue.go | 2 |
1 files changed, 1 insertions, 1 deletions
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) |