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

Rename destination queue variable for correctness

Browse source
This commit is contained in:
Devon Hudson 2023-01-19 10:10:39 -07:00
parent a5da7301fd
commit e1c50b78bd
No known key found for this signature in database
GPG key ID: CD06B18E77F6A628
1 changed files with 2 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
federationapi/queue/destinationqueue.go
View file

@ -371,7 +371,7 @@ func (oq *destinationQueue) backgroundSend() {
// If we have pending PDUs or EDUs then construct a transaction. // If we have pending PDUs or EDUs then construct a transaction.
// Try sending the next transaction and see what happens. // Try sending the next transaction and see what happens.
terr, relaySuccess := oq.nextTransaction(toSendPDUs, toSendEDUs) terr, sendMethod := oq.nextTransaction(toSendPDUs, toSendEDUs)
if terr != nil { if terr != nil {
// We failed to send the transaction. Mark it as a failure. // We failed to send the transaction. Mark it as a failure.
_, blacklisted := oq.statistics.Failure() _, blacklisted := oq.statistics.Failure()
@ -388,7 +388,7 @@ func (oq *destinationQueue) backgroundSend() {
return return
} }
} else { } else {
oq.handleTransactionSuccess(pduCount, eduCount, relaySuccess) oq.handleTransactionSuccess(pduCount, eduCount, sendMethod)
} }
} }
} }