From 7eb28f570953e924381059facaf6fcd59a14afc6 Mon Sep 17 00:00:00 2001 From: Derek Collison Date: Sun, 16 Jun 2024 18:25:04 -0700 Subject: [PATCH] Remove statszRateLimit by setting to 0 for tests, which emulates prior behavior. Signed-off-by: Derek Collison --- server/events.go | 2 +- server/jetstream_helpers_test.go | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/server/events.go b/server/events.go index a2f6c57064..ff940571a0 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 3d63b0b5e3..da2814e145 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.