diff --git a/server/events.go b/server/events.go index a2f6c570646..ff940571a00 100644 --- a/server/events.go +++ b/server/events.go @@ -960,7 +960,7 @@ func (s *Server) sendStatsz(subj string) { s.sendInternalMsg(subj, _EMPTY_, &m.Server, &m) } -// Limit updates to the heartbeat interval, max one second. +// Limit updates to the heartbeat interval, max one second by default. func (s *Server) limitStatsz(subj string) bool { s.mu.Lock() defer s.mu.Unlock() diff --git a/server/jetstream_helpers_test.go b/server/jetstream_helpers_test.go index 3d63b0b5e37..da2814e1452 100644 --- a/server/jetstream_helpers_test.go +++ b/server/jetstream_helpers_test.go @@ -44,7 +44,7 @@ func init() { lostQuorumCheck = 4 * hbInterval // For statz and jetstream placement speedups as well. - statszRateLimit = time.Millisecond * 100 + statszRateLimit = 0 } // Used to setup clusters of clusters for tests.