Don't close channels when clearing queue (we might race and panic, when the GC will still clean it up for us anyway)

main
Neil Alexander 2021-02-18 09:26:40 +00:00
parent 2fdc318f2c
commit 4c0103a2d5
No known key found for this signature in database
GPG Key ID: A02A2019A2BB0944
1 changed files with 1 additions and 3 deletions

View File

@ -154,7 +154,7 @@ func (oqs *OutgoingQueues) getQueue(destination gomatrixserverlib.ServerName) *d
oqs.queuesMutex.Lock()
defer oqs.queuesMutex.Unlock()
oq, ok := oqs.queues[destination]
if !ok {
if !ok && oq != nil {
destinationQueueTotal.Inc()
oq = &destinationQueue{
queues: oqs,
@ -178,8 +178,6 @@ func (oqs *OutgoingQueues) clearQueue(oq *destinationQueue) {
oqs.queuesMutex.Lock()
defer oqs.queuesMutex.Unlock()
close(oq.notify)
close(oq.interruptBackoff)
delete(oqs.queues, oq.destination)
destinationQueueTotal.Dec()
}