diff --git a/server/filestore.go b/server/filestore.go index 4e615238..93260e0a 100644 --- a/server/filestore.go +++ b/server/filestore.go @@ -6836,7 +6836,7 @@ var dios chan struct{} // golang.org's semaphore seemed a bit heavy. func init() { // Based on Go max threads of 10k, limit ourselves to a max of 1k blocking IO calls. - const nIO = 1024 + const nIO = 4 dios = make(chan struct{}, nIO) // Fill it up to start. for i := 0; i < nIO; i++ { diff --git a/server/jetstream.go b/server/jetstream.go index fd7926f0..3c8c0623 100644 --- a/server/jetstream.go +++ b/server/jetstream.go @@ -853,9 +853,9 @@ func (s *Server) signalPullConsumers() { // Shutdown jetstream for this server. func (s *Server) shutdownJetStream() { - s.mu.Lock() + s.mu.RLock() js := s.js - s.mu.Unlock() + s.mu.RUnlock() if js == nil { return