diff --git a/server.go b/server.go index b0c2350f..900e6d62 100644 --- a/server.go +++ b/server.go @@ -1298,7 +1298,7 @@ func (s *server) Start() error { // NOTE: This function is safe for concurrent access. func (s *server) Stop() error { s.stop.Do(func() { - atomic.LoadInt32(&s.stopping) + atomic.StoreInt32(&s.stopping, 1) close(s.quit)