MssHandler: start MssFragmentInfoControllers on seeking, pause and at startup for start-over streams

Author: bbert

src/mss/MssHandler.js

@@ -113,53 +113,72 @@ function MssHandler(config) {
         return chunk;
     }
 
+    function startFragmentInfoControllers() {
+
+        let streamController = playbackController.getStreamController();
+        if (!streamController) {
+            return;
+        }
+
+        // Create MssFragmentInfoControllers for each StreamProcessor of active stream (only for audio, video or fragmentedText)
+        let processors = streamController.getActiveStreamProcessors();
+        processors.forEach(function (processor) {
+            if (processor.getType() === constants.VIDEO ||
+                processor.getType() === constants.AUDIO ||
+                processor.getType() === constants.FRAGMENTED_TEXT) {
+
+                // Check MssFragmentInfoController already registered to StreamProcessor
+                let i;
+                let alreadyRegistered = false;
+                let externalControllers = processor.getExternalControllers();
+                for (i = 0; i < externalControllers.length; i++) {
+                    if (externalControllers[i].controllerType &&
+                        externalControllers[i].controllerType === 'MssFragmentInfoController') {
+                        alreadyRegistered = true;
+                    }
+                }
+
+                if (!alreadyRegistered) {
+                    let fragmentInfoController = MssFragmentInfoController(context).create({
+                        streamProcessor: processor,
+                        eventBus: eventBus,
+                        metricsModel: metricsModel,
+                        playbackController: playbackController,
+                        baseURLController: config.baseURLController,
+                        ISOBoxer: config.ISOBoxer,
+                        debug: config.debug
+                    });
+                    fragmentInfoController.initialize();
+                    fragmentInfoController.start();
+                }
+            }
+        });
+    }
+
     function onSegmentMediaLoaded(e) {
         if (e.error) {
             return;
         }
         // Process moof to transcode it from MSS to DASH
         let streamProcessor = e.sender.getStreamProcessor();
         mssFragmentProcessor.processFragment(e, streamProcessor);
+
+        // Start MssFragmentInfoControllers in case of start-over streams
+        let streamInfo = streamProcessor.getStreamInfo();
+        if (!streamInfo.manifestInfo.isDynamic && streamInfo.manifestInfo.DVRWindowSize !== Infinity) {
+            startFragmentInfoControllers();
+        }
     }
 
-    function onPlaybackSeekAsked() {
+    function onPlaybackPaused() {
         if (playbackController.getIsDynamic() && playbackController.getTime() !== 0) {
+            startFragmentInfoControllers();
+        }
+    }
 
-            //create fragment info controllers for each stream processors of active stream (only for audio, video or fragmentedText)
-            let streamController = playbackController.getStreamController();
-            if (streamController) {
-                let processors = streamController.getActiveStreamProcessors();
-                processors.forEach(function (processor) {
-                    if (processor.getType() === constants.VIDEO ||
-                        processor.getType() === constants.AUDIO ||
-                        processor.getType() === constants.FRAGMENTED_TEXT) {
-
-                        // check that there is no fragment info controller registered to processor
-                        let i;
-                        let alreadyRegistered = false;
-                        let externalControllers = processor.getExternalControllers();
-                        for (i = 0; i < externalControllers.length; i++) {
-                            if (externalControllers[i].controllerType &&
-                                externalControllers[i].controllerType === 'MssFragmentInfoController') {
-                                alreadyRegistered = true;
-                            }
-                        }
-
-                        if (!alreadyRegistered) {
-                            let fragmentInfoController = MssFragmentInfoController(context).create({
-                                streamProcessor: processor,
-                                eventBus: eventBus,
-                                metricsModel: metricsModel,
-                                playbackController: playbackController,
-                                ISOBoxer: config.ISOBoxer,
-                                debug: config.debug
-                            });
-                            fragmentInfoController.initialize();
-                            fragmentInfoController.start();
-                        }
-                    }
-                });
-            }
+    function onPlaybackSeekAsked() {
+        if (playbackController.getIsDynamic() && playbackController.getTime() !== 0) {
+            startFragmentInfoControllers();
         }
     }
 
@@ -175,13 +194,15 @@ function MssHandler(config) {
 
     function registerEvents() {
         eventBus.on(events.INIT_REQUESTED, onInitializationRequested, instance, dashjs.FactoryMaker.getSingletonFactoryByName(eventBus.getClassName()).EVENT_PRIORITY_HIGH); /* jshint ignore:line */
+        eventBus.on(events.PLAYBACK_PAUSED, onPlaybackPaused, instance, dashjs.FactoryMaker.getSingletonFactoryByName(eventBus.getClassName()).EVENT_PRIORITY_HIGH); /* jshint ignore:line */
         eventBus.on(events.PLAYBACK_SEEK_ASKED, onPlaybackSeekAsked, instance, dashjs.FactoryMaker.getSingletonFactoryByName(eventBus.getClassName()).EVENT_PRIORITY_HIGH); /* jshint ignore:line */
         eventBus.on(events.FRAGMENT_LOADING_COMPLETED, onSegmentMediaLoaded, instance, dashjs.FactoryMaker.getSingletonFactoryByName(eventBus.getClassName()).EVENT_PRIORITY_HIGH); /* jshint ignore:line */
         eventBus.on(events.TTML_TO_PARSE, onTTMLPreProcess, instance);
     }
 
     function reset() {
         eventBus.off(events.INIT_REQUESTED, onInitializationRequested, this);
+        eventBus.off(events.PLAYBACK_PAUSED, onPlaybackPaused, this);
         eventBus.off(events.PLAYBACK_SEEK_ASKED, onPlaybackSeekAsked, this);
         eventBus.off(events.FRAGMENT_LOADING_COMPLETED, onSegmentMediaLoaded, this);
         eventBus.off(events.TTML_TO_PARSE, onTTMLPreProcess, this);