gogrlx/nats-server
1
0
Fork 0
mirror of https://github.com/gogrlx/nats-server.git synced 2026-04-16 19:14:41 -07:00
Code Issues Packages Projects Releases Wiki Activity

Fix a data race.

Browse Source 
Signed-off-by: Derek Collison <derek@nats.io>
This commit is contained in:
Derek Collison
2021-05-20 07:08:47 -07:00
parent 8b50094fde
commit 4bde91e9bd
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
server/stream.go
View File

@@ -1499,7 +1499,7 @@ func (mset *stream) setupMirrorConsumer() error {
respCh := make(chan *JSApiConsumerCreateResponse, 1)
reply := infoReplySubject()
crSub, _ := mset.subscribeInternal(reply, func(sub *subscription, c *client, subject, reply string, rmsg []byte) {
mset.unsubscribe(sub)
mset.unsubscribeUnlocked(sub)
_, msg := c.msgParts(rmsg)
var ccr JSApiConsumerCreateResponse
@@ -1569,7 +1569,7 @@ func (mset *stream) setupMirrorConsumer() error {
}
mset.setMirrorErr(ccr.Error)
case <-time.After(10 * time.Second):
mset.unsubscribe(crSub)
mset.unsubscribeUnlocked(crSub)
return
}
}()