mirrors/tailscale
1
0
Fork 0
mirror of https://github.com/tailscale/tailscale.git synced 2025-09-21 05:31:36 +02:00
Code Issues Packages Projects Releases Wiki Activity

ipn/ipnlocal: shim in appc route subscriber plumbing

Browse Source 
Just log the events for now.

Change-Id: I20e18306e0362a13210dbc90707acddb788c10ea
This commit is contained in:
M. J. Fromberger 2025-09-12 13:39:39 -07:00
parent ccbf115875
commit 16808bf297
1 changed files with 21 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

33
ipn/ipnlocal/local.go
View File

@ -197,18 +197,21 @@ var (
// state machine generates events back out to zero or more components. // state machine generates events back out to zero or more components.
type LocalBackend struct { type LocalBackend struct {
// Elements that are thread-safe or constant after construction. // Elements that are thread-safe or constant after construction.
ctx context.Context // canceled by [LocalBackend.Shutdown] ctx context.Context // canceled by [LocalBackend.Shutdown]
ctxCancel context.CancelCauseFunc // cancels ctx ctxCancel context.CancelCauseFunc // cancels ctx
logf logger.Logf // general logging logf logger.Logf // general logging
keyLogf logger.Logf // for printing list of peers on change keyLogf logger.Logf // for printing list of peers on change
statsLogf logger.Logf // for printing peers stats on change statsLogf logger.Logf // for printing peers stats on change
sys *tsd.System sys *tsd.System
eventClient *eventbus.Client eventClient *eventbus.Client
clientVersionSub *eventbus.Subscriber[tailcfg.ClientVersion] clientVersionSub *eventbus.Subscriber[tailcfg.ClientVersion]
autoUpdateSub *eventbus.Subscriber[controlclient.AutoUpdate] autoUpdateSub *eventbus.Subscriber[controlclient.AutoUpdate]
healthChangeSub *eventbus.Subscriber[health.Change] healthChangeSub *eventbus.Subscriber[health.Change]
changeDeltaSub *eventbus.Subscriber[netmon.ChangeDelta] changeDeltaSub *eventbus.Subscriber[netmon.ChangeDelta]
subsDoneCh chan struct{} // closed when consumeEventbusTopics returns routeUpdateSub *eventbus.Subscriber[appc.RouteUpdate]
storeRoutesSub *eventbus.Subscriber[appc.RouteInfo]
subsDoneCh chan struct{} // closed when consumeEventbusTopics returns
health *health.Tracker // always non-nil health *health.Tracker // always non-nil
polc policyclient.Client // always non-nil polc policyclient.Client // always non-nil
metrics metrics metrics metrics
@ -545,6 +548,8 @@ func NewLocalBackend(logf logger.Logf, logID logid.PublicID, sys *tsd.System, lo
b.autoUpdateSub = eventbus.Subscribe[controlclient.AutoUpdate](b.eventClient) b.autoUpdateSub = eventbus.Subscribe[controlclient.AutoUpdate](b.eventClient)
b.healthChangeSub = eventbus.Subscribe[health.Change](b.eventClient) b.healthChangeSub = eventbus.Subscribe[health.Change](b.eventClient)
b.changeDeltaSub = eventbus.Subscribe[netmon.ChangeDelta](b.eventClient) b.changeDeltaSub = eventbus.Subscribe[netmon.ChangeDelta](b.eventClient)
b.routeUpdateSub = eventbus.Subscribe[appc.RouteUpdate](b.eventClient)
b.storeRoutesSub = eventbus.Subscribe[appc.RouteInfo](b.eventClient)
nb := newNodeBackend(ctx, b.sys.Bus.Get()) nb := newNodeBackend(ctx, b.sys.Bus.Get())
b.currentNodeAtomic.Store(nb) b.currentNodeAtomic.Store(nb)
nb.ready() nb.ready()
@ -635,6 +640,10 @@ func (b *LocalBackend) consumeEventbusTopics() {
b.onHealthChange(change) b.onHealthChange(change)
case changeDelta := <-b.changeDeltaSub.Events(): case changeDelta := <-b.changeDeltaSub.Events():
b.linkChange(&changeDelta) b.linkChange(&changeDelta)
case ru := <-b.routeUpdateSub.Events():
b.logf("TODO: received route update: %+v", ru)
case ri := <-b.storeRoutesSub.Events():
b.logf("TODO: received store routes: %+v", ri)
} }
} }
} }