Commit90f619d

committed

fixup

1 parent91f8009 commit90f619dCopy full SHA for 90f619d

File tree

-4

lines changed

-4

lines changed

Lines changed: 4 additions & 4 deletions

Original file line number	Diff line number	Diff line change
`@@ -607,24 +607,24 @@ func (u *updater) netStatusLoop() {`
`607`	`607`	`case<-u.ctx.Done():`
`608`	`608`	`return`
`609`	`609`	`case<-ticker.C:`
`610`		`-u.recordLatency()`
	`610`	`+u.recordLatencies()`
`611`	`611`	`u.sendAgentUpdate()`
`612`	`612`	`}`
`613`	`613`	`}`
`614`	`614`	`}`
`615`	`615`
`616`		`-func (u*updater)recordLatency() {`
	`616`	`+func (u*updater)recordLatencies() {`
`617`	`617`	`varagentsIDsToPing []uuid.UUID`
`618`	`618`	`u.mu.Lock()`
`619`	`619`	`for_,agent:=rangeu.agents {`
`620`	`620`	`agentsIDsToPing=append(agentsIDsToPing,agent.ID)`
`621`	`621`	`}`
`622`	`622`	`u.mu.Unlock()`
`623`	`623`
`624`		`-pingCtx,cancelFunc:=context.WithTimeout(u.ctx,5*time.Second)`
`625`		`-defercancelFunc()`
`626`	`624`	`for_,agentID:=rangeagentsIDsToPing {`
`627`	`625`	`gofunc() {`
	`626`	`+pingCtx,cancelFunc:=context.WithTimeout(u.ctx,5*time.Second)`
	`627`	`+defercancelFunc()`
`628`	`628`	`pingDur,didP2p,pingResult,err:=u.conn.Ping(pingCtx,agentID)`
`629`	`629`	`iferr!=nil {`
`630`	`630`	`u.logger.Warn(u.ctx,"failed to ping agent",slog.F("agent_id",agentID),slog.Error(err))`

Comments

(0)