Diagnostics calculate drift (#263)

* Diagnostics calculate drift * Diagnostics calculate drift - 1
kaltura · Sep 27, 2016 · 664eb87 · 664eb87
1 parent 4bcf918
commit 664eb87
Show file tree

Hide file tree

Showing 3 changed files with 17 additions and 3 deletions.
diff --git a/lib/playlistGenerator/ConcatSource.js b/lib/playlistGenerator/ConcatSource.js
@@ -389,8 +389,8 @@ var checkClipStartTime = function(fileInfo){
 // check for gaps, reorder etc.
 ConcatSource.prototype.checkDiscontinuity = function (fileInfo,track) {
     var that = this;
-
     var firstDTS,discontinuity = false;
+    let diagDrift = {  deltaPts : 0, deltaClock : 0 , refPts : 0, refEncoderDts : 0};
 
     track.firstDTS =  Math.ceil(track.firstDTS);
 
@@ -439,7 +439,14 @@ ConcatSource.prototype.checkDiscontinuity = function (fileInfo,track) {
                 }
                 firstDTS = that.inner.refPTS + dtsDistance(track.firstEncoderDTS, that.inner.refEncoderDTS,track.wrapEncoderDTS);
             }
-
+            // Fill drift information for diagnostics purposes
+            diagDrift['deltaPts'] = track.firstDTS - that.inner.refPTS;
+            diagDrift['deltaClock'] = track.firstEncoderDTS - that.inner.refEncoderDTS;
+            diagDrift['refPts'] = that.inner.refPTS;
+            diagDrift['refEncoderDts'] = that.inner.refEncoderDTS;
+
+            that.emit(playlistUtils.ClipEvents.diagnosticsInfo, that, diagDrift);
+
             checkOverlap.call(that,firstDTS,lastDTS);
 
             if (timestampDiff < playlistConfig.maxChunkGapSize )  {

diff --git a/lib/playlistGenerator/PlaylistGenerator.js b/lib/playlistGenerator/PlaylistGenerator.js
@@ -59,6 +59,8 @@ function PlaylistGenerator (entryObject) {
     setPlayList.call(that,new Playlist(that.loggerInfo));
     that.gapsCounter = 0;
     that.reorderCounter = 0;
+
+    that.driftInfo = {};
 }
 
 util.inherits(PlaylistGenerator,EventEmitter);
@@ -404,6 +406,9 @@ PlaylistGenerator.prototype.handleEvent = function (type,arg) {
         case playlistUtils.ClipEvents.modified:
             that.isDirty = true;
             break;
+        case playlistUtils.ClipEvents.diagnosticsInfo:
+            that.driftInfo = arguments[2];
+            break;
         case playlistUtils.ClipEvents.diagnosticsAlert:
             that.emit('diagnosticsAlert', arguments[2]);
             break;
@@ -413,10 +418,11 @@ PlaylistGenerator.prototype.handleEvent = function (type,arg) {
 // JSON.stringify callback
 PlaylistGenerator.prototype.toJSON = function () {
     var that = this;
-    var diag = {};//that.getDiagnostics();
+    var diag = {};
     diag.playlistPath = that.playlistPath;
     diag.gapsCounter = that.gapsCounter;
     diag.config = that.playListLimits;
+    diag.drift = that.driftInfo;
     return diag;
 };
 

diff --git a/lib/playlistGenerator/playlistGen-utils.js b/lib/playlistGenerator/playlistGen-utils.js
@@ -115,6 +115,7 @@ module.exports.ClipEvents = {
     // param 2 : object returned at humanReadablePass
     humanReadablePass: 'humanReadablePass',
     item_disposed: 'item_disposed',
+    diagnosticsInfo: 'diagnosticsInfo',
     diagnosticsAlert: 'diagnosticsAlert'
 };