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

Don't reset counters before successful outgoing federation request on incoming federation request

Browse source
This commit is contained in:
Neil Alexander 2020-06-04 09:05:33 +01:00
parent e21d7d4baf
commit 2de19af21d
1 changed files with 0 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

1
federationsender/queue/destinationqueue.go
View file

@ -59,7 +59,6 @@ func (oq *destinationQueue) retry() {
// and then skip ahead a lot which feels non-ideal but equally we can't persist thousands of events // and then skip ahead a lot which feels non-ideal but equally we can't persist thousands of events
// in-memory to maybe-send it one day. Ideally we would just shove these pending events in a database // in-memory to maybe-send it one day. Ideally we would just shove these pending events in a database
// so we can send a lot of events. // so we can send a lot of events.
oq.statistics.Success()
// if we were backing off, swap to not backing off and interrupt the select. // if we were backing off, swap to not backing off and interrupt the select.
// We need to use an atomic bool here to prevent multiple calls to retry() blocking on the channel // We need to use an atomic bool here to prevent multiple calls to retry() blocking on the channel
// as it is unbuffered. // as it is unbuffered.