feat(CMCD): Add support to rtp parameter

demo/config.js

@@ -311,6 +311,8 @@ shakaDemo.Config = class {
         .addBoolInput_('Enabled', 'cmcd.enabled')
         .addTextInput_('Session ID', 'cmcd.sessionId')
         .addTextInput_('Content ID', 'cmcd.contentId')
+        .addNumberInput_('RTP safety Factor', 'cmcd.rtpSafetyFactor',
+            /* canBeDecimal= */ true)
         .addBoolInput_('Use Headers', 'cmcd.useHeaders');
   }
 

externs/shaka/player.js

@@ -1510,7 +1510,8 @@ shaka.extern.AdvancedAbrConfiguration;
  *   enabled: boolean,
  *   useHeaders: boolean,
  *   sessionId: string,
- *   contentId: string
+ *   contentId: string,
+ *   rtpSafetyFactor: number
  * }}
  *
  * @description
@@ -1533,6 +1534,9 @@ shaka.extern.AdvancedAbrConfiguration;
  *   characters. This value is consistent across multiple different sessions and
  *   devices and is defined and updated at the discretion of the service
  *   provider.
+ * @property {number} rtpSafetyFactor
+ *   RTP safety factor.
+ *   Defaults to <code>5</code>.
  * @exportDoc
  */
 shaka.extern.CmcdConfiguration;

lib/util/cmcd_manager.js

@@ -11,6 +11,8 @@ goog.require('shaka.log');
 goog.require('shaka.net.NetworkingEngine');
 goog.require('shaka.util.ArrayUtils');
 
+goog.requireType('shaka.media.SegmentReference');
+
 /**
  * @summary
  * A CmcdManager maintains CMCD state as well as a collection of utility
@@ -235,6 +237,10 @@ shaka.util.CmcdManager = class {
               }
             }
           }
+          const rtp = this.calculateRtp_(stream, segment);
+          if (!isNaN(rtp)) {
+            data.rtp = rtp;
+          }
         }
       }
 
@@ -373,8 +379,6 @@ shaka.util.CmcdManager = class {
       data.su = this.buffering_;
     }
 
-    // TODO: Implement rtp
-
     if (useHeaders) {
       const headers = shaka.util.CmcdManager.toHeaders(data);
       if (!Object.keys(headers).length) {
@@ -554,6 +558,33 @@ shaka.util.CmcdManager = class {
     return toPath.join('/');
   }
 
+  /**
+   * Calculate requested maximun throughput
+   *
+   * @param {shaka.extern.Stream} stream
+   * @param {shaka.media.SegmentReference} segment
+   * @return {number}
+   * @private
+   */
+  calculateRtp_(stream, segment) {
+    const playbackRate = this.playerInterface_.getPlaybackRate() || 1;
+    const currentBufferLevel =
+        this.getRemainingBufferLength_(stream.type) || 500;
+    const bandwidth = stream.bandwidth;
+    if (!bandwidth) {
+      return NaN;
+    }
+    const segmentDuration = segment.endTime - segment.startTime;
+    // Calculate file size in kilobits
+    const segmentSize = bandwidth * segmentDuration / 1000;
+    // Calculate time available to load file in seconds
+    const timeToLoad = (currentBufferLevel / playbackRate) / 1000;
+    // Calculate the exact bandwidth required
+    const minBandwidth = segmentSize / timeToLoad;
+    // Include a safety buffer
+    return minBandwidth * this.config_.rtpSafetyFactor;
+  }
+
   /**
    * Get the stream format
    *

lib/util/player_configuration.js

@@ -322,6 +322,7 @@ shaka.util.PlayerConfiguration = class {
       enabled: false,
       sessionId: '',
       contentId: '',
+      rtpSafetyFactor: 5,
       useHeaders: false,
     };
 

test/util/cmcd_manager_unit.js

@@ -125,6 +125,7 @@ describe('CmcdManager', () => {
       enabled: false,
       sessionId: '',
       contentId: 'testing',
+      rtpSafetyFactor: 5,
       useHeaders: false,
     };