()
| 584 | } |
| 585 | |
| 586 | func (u *updater) netStatusLoop() { |
| 587 | ticker := u.clock.NewTicker(netStatusInterval) |
| 588 | defer ticker.Stop() |
| 589 | defer close(u.netLoopDone) |
| 590 | for { |
| 591 | select { |
| 592 | case <-u.ctx.Done(): |
| 593 | return |
| 594 | case <-ticker.C: |
| 595 | u.recordLatencies() |
| 596 | u.sendAgentUpdate() |
| 597 | } |
| 598 | } |
| 599 | } |
| 600 | |
| 601 | func (u *updater) recordLatencies() { |
| 602 | var agentsIDsToPing []uuid.UUID |
no test coverage detected