mirrors/dendrite
1
0
Fork 0
mirror of https://github.com/matrix-org/dendrite.git synced 2025-12-20 21:33:19 -06:00
Code Issues Packages Projects Releases Wiki Activity

Fix destination queue

Browse source
This commit is contained in:
Neil Alexander 2020-08-07 17:18:12 +01:00
parent 0b38141c76
commit f3d71c7a72
No known key found for this signature in database
GPG key ID: A02A2019A2BB0944
1 changed files with 1 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
federationsender/queue/destinationqueue.go
View file

@ -262,7 +262,7 @@ func (oq *destinationQueue) backgroundSend() {
// If we are backing off this server then wait for the
// backoff duration to complete first, or until explicitly
// told to retry.
oq.statistics.NextBackoff(oq.backingOff, oq.interruptBackoff)
oq.statistics.BackoffIfRequired(oq.backingOff, oq.interruptBackoff)
// If we have pending PDUs or EDUs then construct a transaction.
if pendingPDUs || pendingEDUs {