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

Update comments

Browse source
This commit is contained in:
Neil Alexander 2020-07-07 15:55:26 +01:00
parent b152ee7c04
commit c072071801
1 changed files with 4 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
federationsender/queue/destinationqueue.go
View file

@ -276,10 +276,10 @@ func (oq *destinationQueue) backgroundSend() {
}
}
// If something else has come along since we sent the previous
// transactions then we want the next loop iteration to skip the
// wait and not go to sleep. In which case, if there isn't a
// wake-up message already, send one.
// If something else has come along while we were busy sending
// the previous transaction then we don't want the next loop
// iteration to sleep. Send a message if someone else hasn't
// already sent a wake-up.
if oq.pendingPDUs.Load() > 0 {
select {
case oq.notifyPDUs <- true: