Skip to content

Commit 5461d8c

Browse files
committed
Group network path scheduling helpers
1 parent aecda3c commit 5461d8c

2 files changed

Lines changed: 8 additions & 8 deletions

File tree

comp/networkpath/npcollector/impl/baseline.go

Lines changed: 0 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -68,11 +68,3 @@ func addBaselinePath(selected []baselineCandidate, path common.Pathtest, signals
6868
bytes: signals.Bytes,
6969
})
7070
}
71-
72-
func (s *npCollectorImpl) scheduleBaselinePaths(selected []baselineCandidate) {
73-
for i := range selected {
74-
if err := s.scheduleOne(&selected[i].path); err != nil {
75-
s.logger.Errorf("Error scheduling baseline pathtest: %s", err)
76-
}
77-
}
78-
}

comp/networkpath/npcollector/impl/npcollector.go

Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -351,6 +351,14 @@ func (s *npCollectorImpl) scheduleStandardNetworkPathTest(pathtest common.Pathte
351351
return s.scheduleOne(&pathtest)
352352
}
353353

354+
func (s *npCollectorImpl) scheduleBaselinePaths(selected []baselineCandidate) {
355+
for i := range selected {
356+
if err := s.scheduleOne(&selected[i].path); err != nil {
357+
s.logger.Errorf("Error scheduling baseline pathtest: %s", err)
358+
}
359+
}
360+
}
361+
354362
// scheduleOne schedules pathtests.
355363
// It shouldn't block, if the input channel is full, an error is returned.
356364
func (s *npCollectorImpl) scheduleOne(pathtest *common.Pathtest) error {

0 commit comments

Comments
 (0)