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

Clear more aggressively

Browse source
This commit is contained in:
Neil Alexander 2021-02-17 13:33:36 +00:00
parent 995694af7a
commit 6a5826cba4
No known key found for this signature in database
GPG key ID: A02A2019A2BB0944
1 changed files with 5 additions and 12 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

17
federationsender/queue/queue.go
View file

@ -174,19 +174,12 @@ func (oqs *OutgoingQueues) getQueue(destination gomatrixserverlib.ServerName) *d
func (oqs *OutgoingQueues) clearQueue(destination gomatrixserverlib.ServerName) { func (oqs *OutgoingQueues) clearQueue(destination gomatrixserverlib.ServerName) {
oqs.queuesMutex.Lock() oqs.queuesMutex.Lock()
defer oqs.queuesMutex.Unlock() defer oqs.queuesMutex.Unlock()
oq, ok := oqs.queues[destination] if oq, ok := oqs.queues[destination]; ok {
switch { close(oq.notify)
case !ok: close(oq.interruptBackoff)
return delete(oqs.queues, destination)
case oq.running.Load(): destinationQueueTotal.Dec()
return
case oq.backingOff.Load():
return
} }
close(oq.notify)
close(oq.interruptBackoff)
delete(oqs.queues, destination)
destinationQueueTotal.Dec()
} }
type ErrorFederationDisabled struct { type ErrorFederationDisabled struct {