fix: diffcompensation on reload and tidy up (#316)

Eyevinn · Oct 25, 2024 · b511e37 · b511e37
1 parent f5c2e34
commit b511e37
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 5 deletions.
diff --git a/engine/session.js b/engine/session.js
@@ -1524,7 +1524,7 @@ class Session {
             await this._sessionState.remove("nextVod");
             this.leaderIsSettingNextVod = false;
             await this._playheadState.set("diffCompensation", this.diffCompensation, isLeader);
-            debug(`[${this._sessionId}]: sharing durrent vods diffCompensation=${this.diffCompensation}`);
+            debug(`[${this._sessionId}]: sharing current vods diffCompensation=${this.diffCompensation}`);
             this.produceEvent({
               type: 'NOW_PLAYING',
               data: {
@@ -1574,8 +1574,8 @@ class Session {
       case SessionState.VOD_RELOAD_INIT:
         try {
           debug(`[${this._sessionId}]: state=VOD_RELOAD_INIT`);
-          if (this.diffCompensation !== 0) {
-            this.diffCompensation = 0;
+          if (this.diffCompensation <= 0) {
+            this.diffCompensation = 0.1;
           }
           if (isLeader) {
             const startTS = Date.now();

diff --git a/engine/session_live.js b/engine/session_live.js
@@ -2157,7 +2157,7 @@ class SessionLive {
   }
 
   _pushToQueue(seg, liveTargetBandwidth, logName) {
-    const liveSegURIs = this.liveSegQueue[liveTargetBandwidth].filter((seg) => seg.uri).map((seg) => seg.uri);
+    const liveSegURIs = this.liveSegQueue[liveTargetBandwidth].filter((seg) => seg.uri).map((seg) => seg.uri).slice(-2);
     if (seg.uri && liveSegURIs.includes(seg.uri)) {
       debug(`[${this.sessionId}]: ${logName}: Found duplicate live segment. Skip push! (${liveTargetBandwidth})`);
     } else {
@@ -2168,7 +2168,7 @@ class SessionLive {
   }
 
   _pushToQueueAudio(seg, liveTargetAudiotrack, logName) {
-    const liveSegURIs = this.liveSegQueueAudio[liveTargetAudiotrack].filter((seg) => seg.uri).map((seg) => seg.uri);
+    const liveSegURIs = this.liveSegQueueAudio[liveTargetAudiotrack].filter((seg) => seg.uri).map((seg) => seg.uri).slice(-2);
     if (seg.uri && liveSegURIs.includes(seg.uri)) {
       debug(`[${this.sessionId}]: ${logName}: Found duplicate live segment. Skip push! track -> (${liveTargetAudiotrack})`);
     } else {