[web-wasm] Fix incorrent chunk timestamps (#912)

software-mansion · Jan 8, 2025 · 21253b0 · 21253b0
1 parent 55cddb9
commit 21253b0
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git a/ts/@live-compositor/web-wasm/src/input/mp4/demuxer.ts b/ts/@live-compositor/web-wasm/src/input/mp4/demuxer.ts
@@ -78,15 +78,15 @@ export class MP4Demuxer {
     assert(this.samplesCount !== undefined);
 
     for (const sample of samples) {
-      const pts = (sample.cts * 1_000) / sample.timescale;
+      const pts = (sample.cts * 1_000_000) / sample.timescale;
       if (this.ptsOffset === undefined) {
         this.ptsOffset = -pts;
       }
 
       const chunk = new EncodedVideoChunk({
         type: sample.is_sync ? 'key' : 'delta',
         timestamp: pts + this.ptsOffset,
-        duration: (sample.duration * 1_000) / sample.timescale,
+        duration: (sample.duration * 1_000_000) / sample.timescale,
         data: sample.data,
       });
 

diff --git a/ts/@live-compositor/web-wasm/src/input/producer/decodingFrameProducer.ts b/ts/@live-compositor/web-wasm/src/input/producer/decodingFrameProducer.ts
@@ -137,10 +137,10 @@ export default class DecodingFrameProducer implements InputFrameProducer {
     assert(framerate);
 
     const frameDuration = framerateToDurationMs(framerate);
-    const targetPts = framePts + frameDuration * MAX_BUFFERING_SIZE;
+    const targetPtsUs = (framePts + frameDuration * MAX_BUFFERING_SIZE) * 1000;
 
     let chunk = this.source.peekChunk();
-    while (chunk && chunk.timestamp <= targetPts) {
+    while (chunk && chunk.timestamp <= targetPtsUs) {
       this.decoder.decode(chunk);
       this.source.nextChunk();
       chunk = this.source.peekChunk();