From ceefa8d1509b741c3b10a1fc7f20c0b5939a7697 Mon Sep 17 00:00:00 2001 From: Raja Subramanian Date: Mon, 2 Dec 2024 11:37:02 +0530 Subject: [PATCH] Reset next probe time. (#3226) --- pkg/sfu/streamallocator/probe_controller.go | 1 + 1 file changed, 1 insertion(+) 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) {