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

Break if no txn is sent

Browse source
This commit is contained in:
Kegan Dougal 2020-07-07 14:30:57 +01:00
parent 51a7f4bb7c
commit 9035e169b7
1 changed files with 2 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
federationsender/queue/destinationqueue.go
View file

@ -250,6 +250,8 @@ func (oq *destinationQueue) backgroundSend() {
oq.statistics.Success() oq.statistics.Success()
// Clean up the in-memory buffers. // Clean up the in-memory buffers.
oq.cleanPendingEDUs() oq.cleanPendingEDUs()
} else {
break
} }
} }