From 95de74739e56c33c6c664ff780fe63a7887fa2b7 Mon Sep 17 00:00:00 2001 From: Derek Collison Date: Sun, 6 Mar 2022 16:58:24 -0800 Subject: [PATCH] fix Signed-off-by: Derek Collison --- server/consumer.go | 2 +- server/stream.go | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/server/consumer.go b/server/consumer.go index 91866d5135b..b3b99eb092f 100644 --- a/server/consumer.go +++ b/server/consumer.go @@ -752,11 +752,11 @@ func (o *consumer) checkQueueInterest() { // clears our node if we have one. When we scale down to 1. func (o *consumer) clearNode() { o.mu.Lock() + defer o.mu.Unlock() if o.node != nil { o.node.Delete() o.node = nil } - defer o.mu.Unlock() } // Lock should be held. diff --git a/server/stream.go b/server/stream.go index c2f708ddfa7..c5cd88a9d0b 100644 --- a/server/stream.go +++ b/server/stream.go @@ -3240,7 +3240,7 @@ func (mset *stream) internalLoop() { c.flushClients(0) outq.recycle(&pms) case <-msgs.ch: - // This can possible change now so needs to be checked here. + // This can possibly change now so needs to be checked here. mset.mu.RLock() isClustered := mset.node != nil mset.mu.RUnlock()