From 98b8373db7d509d694a32dbf378148a3378eaa01 Mon Sep 17 00:00:00 2001 From: Dmitri Dolguikh Date: Thu, 20 Aug 2026 16:34:06 +0200 Subject: [PATCH] use 1 min ticker interval Signed-off-by: Dmitri Dolguikh --- management/internals/shared/grpc/server.go | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/management/internals/shared/grpc/server.go b/management/internals/shared/grpc/server.go index d27c61b35..76a07c9e1 100644 --- a/management/internals/shared/grpc/server.go +++ b/management/internals/shared/grpc/server.go @@ -423,7 +423,9 @@ func (s *Server) handleUpdates(ctx context.Context, accountID string, peerKey wg // Create a debouncer for this peer connection debouncer := NewUpdateDebouncer(1000 * time.Millisecond) defer debouncer.Stop() - ticker := time.NewTicker(1 * time.Second) + + tickerInterval := 1 * time.Minute + ticker := time.NewTicker(tickerInterval) for { select { @@ -449,6 +451,7 @@ func (s *Server) handleUpdates(ctx context.Context, accountID string, peerKey wg } } + ticker.Reset(tickerInterval) if err := s.accountManager.RefreshPeerLastSeen(ctx, accountID, peer.ID); err != nil { log.WithContext(ctx).Debugf("error updating peer's last seen timestamp %s: %v", peerKey.String(), err) return err @@ -468,6 +471,7 @@ func (s *Server) handleUpdates(ctx context.Context, accountID string, peerKey wg } } + ticker.Reset(tickerInterval) if err := s.accountManager.RefreshPeerLastSeen(ctx, accountID, peer.ID); err != nil { log.WithContext(ctx).Debugf("error updating peer's last seen timestamp %s: %v", peerKey.String(), err) return err