sendnrw/netbird
2
0
Fork 0
mirror of https://github.com/netbirdio/netbird.git synced 2026-08-26 09:31:30 +02:00
Code Issues Packages Projects Releases Wiki Activity

use 1 min ticker interval

Browse Source 
Signed-off-by: Dmitri Dolguikh <dmitri.external@netbird.io>
This commit is contained in:
Dmitri Dolguikh
2026-08-20 16:34:06 +02:00
parent a1254da9a7
commit 98b8373db7
1 changed files with 5 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
management/internals/shared/grpc/server.go
View File

@@ -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