LogalDeveloper/owncast
LogalDeveloper/owncast
0
Fork 0
Code

Completely give up latency compensation when the latency seems too wrong

Browse Source
This commit is contained in:
Gabe Kangas 2022-05-12 14:00:52 -07:00
parent 19be55a637
commit d43e3d4e47
No known key found for this signature in database
GPG Key ID: 9A56337728BC81EA
1 changed files with 24 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

25
webroot/js/components/latencyCompensator.js
View File

@ -41,6 +41,7 @@ const MIN_LATENCY = 4 * 1000; // The absolute lowest we'll continue compensation
const MAX_LATENCY = 15 * 1000; // The absolute highest we'll allow a target latency to be before we start compensating.
const MAX_JUMP_LATENCY = 5 * 1000; // How much behind the max latency we need to be behind before we allow a jump.
const MAX_JUMP_FREQUENCY = 20 * 1000; // How often we'll allow a time jump.
const MAX_ACTIONABLE_LATENCY = 80 * 1000; // If latency is seen to be greater than this then something is wrong.
const STARTUP_WAIT_TIME = 10 * 1000; // The amount of time after we start up that we'll allow monitoring to occur.
class LatencyCompensator {
@ -169,6 +170,18 @@ class LatencyCompensator {
const now = new Date().getTime();
const latency = now - segmentTime;
// Since the calculation of latency is based on clock times, it's possible
// things can be reported incorrectly. So we use a sanity check here to
// simply bail if the latency is reported to so high we think the whole
// thing is wrong. We can't make decisions based on bad data, so give up.
// This can also occur if somebody pauses for a long time and hits play
// again but it's not really possible to know the difference between
// the two scenarios.
if (Math.abs(latency) > MAX_ACTIONABLE_LATENCY) {
this.timeout();
return;
}
if (latency > maxLatencyThreshold) {
// If the current latency exceeds the max jump amount then
// force jump into the future, skipping all the video in between.
@ -340,10 +353,19 @@ class LatencyCompensator {
handlePlaying() {
clearTimeout(this.bufferingTimer);
if (!this.enabled) {
return;
}
if (!this.shouldJumpToLive()) {
return;
}
// Seek to live immediately on starting playback to handle any long-pause
// scenarios or somebody starting far back from the live edge.
this.jumpingToLiveIgnoreBuffer = true;
this.player.liveTracker.seekToLiveEdge();
this.lastJumpOccurred = new Date();
}
handleEnded() {
@ -369,6 +391,7 @@ class LatencyCompensator {
this.disable();
return;
}
console.log('timeout due to buffering');
this.timeout();