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

Don't send empty transactions

Browse source
This commit is contained in:
Neil Alexander 2020-07-01 10:19:29 +01:00
parent cef07c4e4e
commit c4571c9cdd
1 changed files with 4 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
federationsender/queue/destinationqueue.go
View file

@ -322,6 +322,10 @@ func (oq *destinationQueue) nextTransaction(
return false, fmt.Errorf("oq.db.GetNextTransactionPDUs: %w", err) return false, fmt.Errorf("oq.db.GetNextTransactionPDUs: %w", err)
} }
if len(pdus) == 0 && len(pendingEDUs) == 0 {
return false, nil
}
if txid != "" { if txid != "" {
// The database supplied us with a transaction ID to use // The database supplied us with a transaction ID to use
// from a failed PDU so use that. // from a failed PDU so use that.