From dee5229f9b9fb7fe792dca5cc66f673f3eaece37 Mon Sep 17 00:00:00 2001 From: Derek Collison Date: Thu, 6 Apr 2023 10:37:31 -0700 Subject: [PATCH] Fix data race Signed-off-by: Derek Collison --- server/jetstream_api.go | 7 +++++++ 1 file changed, 7 insertions(+) diff --git a/server/jetstream_api.go b/server/jetstream_api.go index cfe06442..7a7ce2c1 100644 --- a/server/jetstream_api.go +++ b/server/jetstream_api.go @@ -890,10 +890,17 @@ func (s *Server) sendAPIErrResponse(ci *ClientInfo, acc *Account, subject, reply const errRespDelay = 500 * time.Millisecond func (s *Server) sendDelayedAPIErrResponse(ci *ClientInfo, acc *Account, subject, reply, request, response string, rg *raftGroup) { + js := s.getJetStream() + if js == nil { + return + } var quitCh <-chan struct{} + js.mu.RLock() if rg != nil && rg.node != nil { quitCh = rg.node.QuitC() } + js.mu.RUnlock() + s.startGoRoutine(func() { defer s.grWG.Done() select {