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

Add comments to dest queue relay server sending

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

5
federationapi/queue/destinationqueue.go
View file

@ -419,14 +419,19 @@ func (oq *destinationQueue) nextTransaction(
if userErr != nil { if userErr != nil {
return userErr, sendMethod return userErr, sendMethod
} }
// Attempt sending to each known relay server.
for _, relayServer := range relayServers { for _, relayServer := range relayServers {
_, relayErr := oq.client.P2PSendTransactionToRelay(ctx, *userID, t, relayServer) _, relayErr := oq.client.P2PSendTransactionToRelay(ctx, *userID, t, relayServer)
if relayErr != nil { if relayErr != nil {
err = relayErr err = relayErr
} else { } else {
// If sending to one of the relay servers succeeds, consider the send successful.
relaySuccess = true relaySuccess = true
} }
} }
// Clear the error if sending to any of the relay servers succeeded.
if relaySuccess { if relaySuccess {
err = nil err = nil
} }