mirror of
https://github.com/livekit/livekit.git
synced 2026-10-23 13:02:53 +00:00
Log RTT as seen by congestion controller (#3354)
This commit is contained in:
1 parent
7a7e312424
commit
0c28e432a3
3 files changed
+6
No files matched your search
@@ -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()
|
||||
}
|
||||
|
||||
@@ -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
|
||||
|
||||
@@ -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
|
||||
|
||||
Reference in new issue
Block a user