diff --git a/pkg/sfu/streamallocator/probe_controller.go b/pkg/sfu/streamallocator/probe_controller.go index c57d74e2e..42f44be94 100644 --- a/pkg/sfu/streamallocator/probe_controller.go +++ b/pkg/sfu/streamallocator/probe_controller.go @@ -137,6 +137,7 @@ func (p *ProbeController) Reset() { p.pci = ccutils.ProbeClusterInfoInvalid p.probeInterval = p.params.Config.BaseInterval p.probeDuration = p.params.Config.MinDuration + p.nextProbeEarliestAt = mono.Now() } func (p *ProbeController) UpdateRTT(rtt float64) {