mirrors/dendrite
1
0
Fork 0
mirror of https://github.com/matrix-org/dendrite.git synced 2024-11-26 08:11:55 -06:00
Code Issues Packages Projects Releases Wiki Activity

Un-goroutine the goroutines

Browse source
This commit is contained in:
Neil Alexander 2020-07-09 12:22:41 +01:00
parent 478374e5d1
commit aee933f878
No known key found for this signature in database
GPG key ID: A02A2019A2BB0944
2 changed files with 1 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

1
federationsender/queue/destinationqueue.go
View file

@ -353,7 +353,6 @@ func (oq *destinationQueue) nextTransaction(
// If we didn't get anything from the database and there are no
// pending EDUs then there's nothing to do - stop here.
if len(pdus) == 0 && len(pendingEDUs) == 0 {
log.Warnf("Expected PDUs/EDUs for destination %q but got none", oq.destination)
return false, nil
}

2
federationsender/queue/queue.go
View file

@ -136,7 +136,7 @@ func (oqs *OutgoingQueues) SendEvent(
}
for _, destination := range destinations {
go oqs.getQueue(destination).sendEvent(nid)
oqs.getQueue(destination).sendEvent(nid)
}
return nil