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

fix linter issues

Browse Source 
Signed-off-by: Dmitri Dolguikh <dmitri.external@netbird.io>
This commit is contained in:
Dmitri Dolguikh
2026-08-20 16:23:12 +02:00
parent cf4b9f8333
commit 218febdf79
1 changed files with 12 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -449,7 +449,10 @@ func (s *Server) handleUpdates(ctx context.Context, accountID string, peerKey wg
}
}
s.accountManager.RefreshPeerLastSeen(ctx, accountID, peer.ID)
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
}
// Timer expired - quiet period reached, send pending updates if any
case <-debouncer.TimerChannel():
@@ -465,10 +468,16 @@ func (s *Server) handleUpdates(ctx context.Context, accountID string, peerKey wg
}
}
s.accountManager.RefreshPeerLastSeen(ctx, accountID, peer.ID)
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
}
case <-ticker.C:
s.accountManager.RefreshPeerLastSeen(ctx, accountID, peer.ID)
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
}
// condition when client <-> server connection has been terminated
case <-srv.Context().Done():