Commit37ad03f

committed

Block on sending stat updates

1 parent99d7d1a commit37ad03fCopy full SHA for 37ad03f

File tree

-5

lines changed

-5

lines changed

Lines changed: 2 additions & 5 deletions

Original file line number	Diff line number	Diff line change
`@@ -1272,14 +1272,11 @@ func (a *agent) startReportingConnectionStats(ctx context.Context) {`
`1272`	`1272`	`a.logger.Info(ctx,"skipping stat because nothing changed")`
`1273`	`1273`	`return`
`1274`	`1274`	`}`
	`1275`	`+a.latestStat.Store(stats)`
`1275`	`1276`
`1276`	`1277`	`select {`
`1277`	`1278`	`casea.connStatsChan<-stats:`
`1278`		`-// Only store the latest stat when it's successfully sent!`
`1279`		`-// Otherwise, it should be sent again on the next iteration.`
`1280`		`-a.latestStat.Store(stats)`
`1281`		`-default:`
`1282`		`-a.logger.Warn(ctx,"network stat dropped")`
	`1279`	`+case<-a.closed:`
`1283`	`1280`	`}`
`1284`	`1281`	`}`
`1285`	`1282`

Comments

(0)