Skip to content

Commit ea4cb3b

Browse files
[FIXED] Consumer/JS deadlock
Signed-off-by: Maurice van Veen <[email protected]>
1 parent 4be6af1 commit ea4cb3b

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

server/consumer.go

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1866,10 +1866,10 @@ func (o *consumer) deleteNotActive() {
18661866
if o.srv != nil {
18671867
qch = o.srv.quitCh
18681868
}
1869-
if o.js != nil {
1870-
cqch = o.js.clusterQuitC()
1871-
}
18721869
o.mu.Unlock()
1870+
if js != nil {
1871+
cqch = js.clusterQuitC()
1872+
}
18731873

18741874
// Useful for pprof.
18751875
setGoRoutineLabels(pprofLabels{

0 commit comments

Comments
 (0)