diff --git a/pkg/sfu/bwe/remotebwe/probe_controller.go b/pkg/sfu/bwe/remotebwe/probe_controller.go index 52a9ff940..1efa3f655 100644 --- a/pkg/sfu/bwe/remotebwe/probe_controller.go +++ b/pkg/sfu/bwe/remotebwe/probe_controller.go @@ -114,6 +114,10 @@ func (p *probeController) UpdateRTT(rtt float64) { } } +func (p *probeController) GetRTT() float64 { + return p.rtt +} + func (p *probeController) CanProbe() bool { return p.state == probeControllerStateNone && p.ProbeRegulator.CanProbe() } diff --git a/pkg/sfu/bwe/remotebwe/remote_bwe.go b/pkg/sfu/bwe/remotebwe/remote_bwe.go index 226329e1d..30a9f70d1 100644 --- a/pkg/sfu/bwe/remotebwe/remote_bwe.go +++ b/pkg/sfu/bwe/remotebwe/remote_bwe.go @@ -316,6 +316,7 @@ func (r *RemoteBWE) ProbeClusterFinalize() (ccutils.ProbeSignal, int64, bool) { "channel", pco, "isSignalValid", pco.HasEnoughEstimateSamples(), "probeClusterInfo", pci, + "rtt", r.probeController.GetRTT(), ) probeSignal := ccutils.ProbeSignalNotCongesting diff --git a/pkg/sfu/bwe/sendsidebwe/congestion_detector.go b/pkg/sfu/bwe/sendsidebwe/congestion_detector.go index 2ccdf9185..567143b89 100644 --- a/pkg/sfu/bwe/sendsidebwe/congestion_detector.go +++ b/pkg/sfu/bwe/sendsidebwe/congestion_detector.go @@ -803,6 +803,7 @@ func (c *congestionDetector) ProbeClusterFinalize() (ccutils.ProbeSignal, int64, "probeClusterInfo", pci, "probePacketGroup", c.probePacketGroup, "congestionState", c.congestionState, + "rtt", c.rtt, ) // if congestion signal changed during probe, defer to that signal