sendnrw/netbird
2
0
Fork 0
mirror of https://github.com/netbirdio/netbird.git synced 2026-05-04 08:06:37 +00:00
Code Issues Packages Projects Releases Wiki Activity

Merge remote-tracking branch 'origin/fix/lost-peer-status-event' into apply-routes-early

Browse Source
This commit is contained in:
Viktor Liu
2025-06-02 19:42:58 +02:00
parent db9facf9cb aa2662a2bb
commit a29b28390b
3 changed files with 77 additions and 27 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
client/internal/routemanager/client/client.go
View File

@@ -223,19 +223,17 @@ func (w *Watcher) getBestRouteFromStatuses(routePeerStatuses map[route.ID]router
}
func (w *Watcher) watchPeerStatusChanges(ctx context.Context, peerKey string, peerStateUpdate chan struct{}, closer chan struct{}) {
subscription := w.statusRecorder.SubscribeToPeerStateChanges(ctx, peerKey)
defer w.statusRecorder.UnsubscribePeerStateChanges(subscription)
for {
select {
case <-ctx.Done():
return
case <-closer:
return
case <-w.statusRecorder.GetPeerStateChangeNotifier(peerKey):
state, err := w.statusRecorder.GetPeer(peerKey)
if err != nil {
continue
}
case <-subscription.Events():
peerStateUpdate <- struct{}{}
log.Debugf("triggered route state update for Peer %s, state: %s", peerKey, state.ConnStatus)
log.Debugf("triggered route state update for Peer: %s", peerKey)
}
}
}