Fix for data race

Signed-off-by: Derek Collison <derek@nats.io>
This commit is contained in:
Derek Collison
2021-01-29 18:12:57 -08:00
parent 8bd290c77a
commit 302ea010b7

View File

@@ -986,8 +986,10 @@ func (js *jetStream) monitorStream(mset *Stream, sa *streamAssignment) {
t := time.NewTicker(compactInterval)
defer t.Stop()
js.mu.RLock()
isLeader := cc.isStreamLeader(sa.Client.Account, sa.Config.Name)
isRestore := sa.Restore != nil
js.mu.RUnlock()
acc, err := s.LookupAccount(sa.Client.Account)
if err != nil {