MCPcopy
hub / github.com/tailscale/tailscale / changeDeltaWatcher

Function changeDeltaWatcher

cmd/tailscaled/debug.go:131–150  ·  view source on GitHub ↗
(ec *eventbus.Client, ctx context.Context, dump func(st *netmon.State))

Source from the content-addressed store, hash-verified

129}
130
131func changeDeltaWatcher(ec *eventbus.Client, ctx context.Context, dump func(st *netmon.State)) func(*eventbus.Client) {
132 changeSub := eventbus.Subscribe[netmon.ChangeDelta](ec)
133 return func(ec *eventbus.Client) {
134 for {
135 select {
136 case <-ctx.Done():
137 return
138 case <-ec.Done():
139 return
140 case delta := <-changeSub.Events():
141 if !delta.RebindLikelyRequired {
142 log.Printf("Network monitor fired; not a significant change")
143 return
144 }
145 log.Printf("Network monitor fired. New state:")
146 dump(delta.CurrentState())
147 }
148 }
149 }
150}
151
152func getURL(ctx context.Context, urlStr string) error {
153 if urlStr == "login" {

Callers 1

runMonitorFunction · 0.85

Calls 4

PrintfMethod · 0.80
DoneMethod · 0.65
EventsMethod · 0.45
CurrentStateMethod · 0.45

Tested by

no test coverage detected

Used in the wild real call sites across dependent graphs

searching dependent graphs…