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

Close channels

Browse source
This commit is contained in:
Neil Alexander 2021-02-17 13:22:09 +00:00
parent c6c5c553dd
commit c2e92d0237
No known key found for this signature in database
GPG key ID: A02A2019A2BB0944
1 changed files with 2 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
federationsender/queue/queue.go
View file

@ -183,6 +183,8 @@ func (oqs *OutgoingQueues) clearQueue(destination gomatrixserverlib.ServerName)
case oq.backingOff.Load(): case oq.backingOff.Load():
return return
} }
close(oq.notify)
close(oq.interruptBackoff)
delete(oqs.queues, destination) delete(oqs.queues, destination)
destinationQueueTotal.Dec() destinationQueueTotal.Dec()
} }