mirror of
https://github.com/gogrlx/nats-server.git
synced 2026-04-17 11:24:44 -07:00
Merge pull request #2132 from wallyqs/oor-data-race
Fix for data race when disabling JS running out of resources
This commit is contained in:
@@ -493,8 +493,16 @@ func (s *Server) configAllJetStreamAccounts() error {
|
||||
// JetStreamEnabled reports if jetstream is enabled.
|
||||
func (s *Server) JetStreamEnabled() bool {
|
||||
s.mu.Lock()
|
||||
enabled := s.js != nil && !s.js.disabled
|
||||
js := s.js
|
||||
s.mu.Unlock()
|
||||
|
||||
var enabled bool
|
||||
if js != nil {
|
||||
js.mu.RLock()
|
||||
enabled = !js.disabled
|
||||
js.mu.RUnlock()
|
||||
}
|
||||
|
||||
return enabled
|
||||
}
|
||||
|
||||
|
||||
@@ -464,10 +464,22 @@ func (s *Server) startRaftNode(cfg *RaftConfig) (RaftNode, error) {
|
||||
|
||||
// outOfResources checks to see if we are out of resources.
|
||||
func (n *raft) outOfResources() bool {
|
||||
if !n.track || n.js == nil || n.js.disabled {
|
||||
n.RLock()
|
||||
js := n.js
|
||||
if !n.track || js == nil {
|
||||
n.RUnlock()
|
||||
return false
|
||||
}
|
||||
return n.js.limitsExceeded(n.wtype)
|
||||
n.RUnlock()
|
||||
|
||||
js.mu.RLock()
|
||||
jsDisabled := js.disabled
|
||||
js.mu.RUnlock()
|
||||
if jsDisabled {
|
||||
return false
|
||||
}
|
||||
|
||||
return js.limitsExceeded(n.wtype)
|
||||
}
|
||||
|
||||
// Maps node names back to server names.
|
||||
|
||||
Reference in New Issue
Block a user