diff options
| author | Till <2353100+S7evinK@users.noreply.github.com> | 2022-08-05 07:20:34 +0200 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2022-08-05 07:20:34 +0200 |
| commit | 9a655cb5e7f8b96a0b02203e69d866dfb1a184e2 (patch) | |
| tree | f5fd291004ab7e0282e9c6a3d1864e67ff1c0daa | |
| parent | a2bed259dd765bd0b9781cd65594343d22c07986 (diff) | |
Only create a new destinationQueue if we don't have one (#2620)
| -rw-r--r-- | federationapi/queue/queue.go | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/federationapi/queue/queue.go b/federationapi/queue/queue.go index 4c25c4ce..88664fcf 100644 --- a/federationapi/queue/queue.go +++ b/federationapi/queue/queue.go @@ -158,7 +158,7 @@ func (oqs *OutgoingQueues) getQueue(destination gomatrixserverlib.ServerName) *d oqs.queuesMutex.Lock() defer oqs.queuesMutex.Unlock() oq, ok := oqs.queues[destination] - if !ok || oq != nil { + if !ok || oq == nil { destinationQueueTotal.Inc() oq = &destinationQueue{ queues: oqs, |