Commit930c467

committed

chore: nodeUpdater logging

1 parentf86f281 commit930c467Copy full SHA for 930c467

File tree

-0

lines changed

-0

lines changed

Lines changed: 4 additions & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -137,6 +137,7 @@ func (c *configMaps) configLoop() {`
`137`	`137`	`c.Wait()`
`138`	`138`	`}`
`139`	`139`	`ifc.closing {`
	`140`	`+c.logger.Debug(context.Background(),"closing configMaps configLoop")`
`140`	`141`	`return`
`141`	`142`	`}`
`142`	`143`	`// queue up the reconfiguration actions we will take while we have`
`@@ -146,19 +147,22 @@ func (c *configMaps) configLoop() {`
`146`	`147`	`ifc.derpMapDirty {`
`147`	`148`	`derpMap:=c.derpMapLocked()`
`148`	`149`	`actions=append(actions,func() {`
	`150`	`+c.logger.Debug(context.Background(),"updating engine DERP map",slog.F("derp_map",derpMap))`
`149`	`151`	`c.engine.SetDERPMap(derpMap)`
`150`	`152`	`})`
`151`	`153`	`}`
`152`	`154`	`ifc.netmapDirty {`
`153`	`155`	`nm:=c.netMapLocked()`
`154`	`156`	`actions=append(actions,func() {`
	`157`	`+c.logger.Debug(context.Background(),"updating engine network map",slog.F("network_map",nm))`
`155`	`158`	`c.engine.SetNetworkMap(nm)`
`156`	`159`	`c.reconfig(nm)`
`157`	`160`	`})`
`158`	`161`	`}`
`159`	`162`	`ifc.filterDirty {`
`160`	`163`	`f:=c.filterLocked()`
`161`	`164`	`actions=append(actions,func() {`
	`165`	`+c.logger.Debug(context.Background(),"updating engine filter",slog.F("filter",f))`
`162`	`166`	`c.engine.SetFilter(f)`
`163`	`167`	`})`
`164`	`168`	`}`

Lines changed: 4 additions & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -52,6 +52,7 @@ func (u *nodeUpdater) updateLoop() {`
`52`	`52`	`u.Wait()`
`53`	`53`	`}`
`54`	`54`	`ifu.closing {`
	`55`	`+u.logger.Debug(context.Background(),"closing nodeUpdater updateLoop")`
`55`	`56`	`return`
`56`	`57`	`}`
`57`	`58`	`node:=u.nodeLocked()`
`@@ -68,6 +69,7 @@ func (u *nodeUpdater) updateLoop() {`
`68`	`69`	`}`
`69`	`70`
`70`	`71`	`u.L.Unlock()`
	`72`	`+u.logger.Debug(context.Background(),"calling nodeUpdater callback",slog.F("node",node))`
`71`	`73`	`u.callback(node)`
`72`	`74`	`u.L.Lock()`
`73`	`75`	`}`
`@@ -126,6 +128,8 @@ func (u nodeUpdater) setNetInfo(ni tailcfg.NetInfo) {`
`126`	`128`	`ifu.preferredDERP!=ni.PreferredDERP {`
`127`	`129`	`dirty=true`
`128`	`130`	`u.preferredDERP=ni.PreferredDERP`
	`131`	`+u.logger.Debug(context.Background(),"new preferred DERP",`
	`132`	`+slog.F("preferred_derp",u.preferredDERP))`
`129`	`133`	`}`
`130`	`134`	`if!maps.Equal(u.derpLatency,ni.DERPLatency) {`
`131`	`135`	`dirty=true`

Comments

(0)