Cleanup the current source when loading a new one

If src() is called when a src is already loaded, make sure to abort any outstanding work and reset the state of the SourceBuffer. Switching sources after initial load occasionally caused weird audio and video artifacts because the underlying decoder was working from the old state.

@@ -54,31 +54,39 @@ videojs.Hls.prototype.src = function(src) {
     mediaSource,
     mediaSource,
     source;
     source;
 
 
-  if (src) {
-    this.src_ = src;
-
-    mediaSource = new videojs.MediaSource();
-    source = {
-      src: videojs.URL.createObjectURL(mediaSource),
-      type: "video/flv"
-    };
-    this.mediaSource = mediaSource;
-
-    this.segmentBuffer_ = [];
-    this.segmentParser_ = new videojs.Hls.SegmentParser();
-
-    // load the MediaSource into the player
-    this.mediaSource.addEventListener('sourceopen', videojs.bind(this, this.handleSourceOpen));
-
-    this.player().ready(function() {
-      // do nothing if the tech has been disposed already
-      // this can occur if someone sets the src in player.ready(), for instance
-      if (!tech.el()) {
-        return;
-      }
-      tech.el().vjs_src(source.src);
-    });
+  // do nothing if the src is falsey
+  if (!src) {
+    return;
   }
   }
+
+  // if there is already a source loaded, clean it up
+  if (this.src_) {
+    this.resetSrc_();
+  }
+
+  this.src_ = src;
+
+  mediaSource = new videojs.MediaSource();
+  source = {
+    src: videojs.URL.createObjectURL(mediaSource),
+    type: "video/flv"
+  };
+  this.mediaSource = mediaSource;
+
+  this.segmentBuffer_ = [];
+  this.segmentParser_ = new videojs.Hls.SegmentParser();
+
+  // load the MediaSource into the player
+  this.mediaSource.addEventListener('sourceopen', videojs.bind(this, this.handleSourceOpen));
+
+  this.player().ready(function() {
+    // do nothing if the tech has been disposed already
+    // this can occur if someone sets the src in player.ready(), for instance
+    if (!tech.el()) {
+      return;
+    }
+    tech.el().vjs_src(source.src);
+  });
 };
 };
 
 
 videojs.Hls.prototype.handleSourceOpen = function() {
 videojs.Hls.prototype.handleSourceOpen = function() {
@@ -231,16 +239,11 @@ videojs.Hls.prototype.updateDuration = function(playlist) {
 };
 };
 
 
 /**
 /**
- * Abort all outstanding work and cleanup.
+ * Clear all buffers and reset any state relevant to the current
+ * source. After this function is called, the tech should be in a
+ * state suitable for switching to a different video.
  */
  */
-videojs.Hls.prototype.dispose = function() {
-  var player = this.player();
-
-  // remove event handlers
-  player.off('timeupdate', this.fillBuffer);
-  player.off('timeupdate', this.drainBuffer);
-  player.off('waiting', this.drainBuffer);
-
+videojs.Hls.prototype.resetSrc_ = function() {
   if (this.segmentXhr_) {
   if (this.segmentXhr_) {
     this.segmentXhr_.onreadystatechange = null;
     this.segmentXhr_.onreadystatechange = null;
     this.segmentXhr_.abort();
     this.segmentXhr_.abort();
@@ -251,12 +254,28 @@ videojs.Hls.prototype.dispose = function() {
     keyXhr.abort();
     keyXhr.abort();
     keyXhr = null;
     keyXhr = null;
   }
   }
-  if (this.playlists) {
-    this.playlists.dispose();
-  }
   if (this.sourceBuffer) {
   if (this.sourceBuffer) {
     this.sourceBuffer.abort();
     this.sourceBuffer.abort();
   }
   }
+};
+
+/**
+ * Abort all outstanding work and cleanup.
+ */
+videojs.Hls.prototype.dispose = function() {
+  var player = this.player();
+
+  // remove event handlers
+  player.off('timeupdate', this.fillBuffer);
+  player.off('timeupdate', this.drainBuffer);
+  player.off('waiting', this.drainBuffer);
+
+  if (this.playlists) {
+    this.playlists.dispose();
+  }
+
+  this.resetSrc_();
+
   videojs.Flash.prototype.dispose.call(this);
   videojs.Flash.prototype.dispose.call(this);
 };
 };
 
 

@@ -293,7 +293,9 @@ test('recognizes domain-relative URLs', function() {
 });
 });
 
 
 test('re-initializes the tech for each source', function() {
 test('re-initializes the tech for each source', function() {
-  var firstPlaylists, secondPlaylists, firstMSE, secondMSE;
+  var firstPlaylists, secondPlaylists, firstMSE, secondMSE, aborts;
+
+  aborts = 0;
 
 
   player.src({
   player.src({
     src: 'manifest/master.m3u8',
     src: 'manifest/master.m3u8',
@@ -302,6 +304,11 @@ test('re-initializes the tech for each source', function() {
   openMediaSource(player);
   openMediaSource(player);
   firstPlaylists = player.hls.playlists;
   firstPlaylists = player.hls.playlists;
   firstMSE = player.hls.mediaSource;
   firstMSE = player.hls.mediaSource;
+  player.hls.sourceBuffer.abort = function() {
+    aborts++;
+  };
+  standardXHRResponse(requests.shift());
+  standardXHRResponse(requests.shift());
 
 
   player.src({
   player.src({
     src: 'manifest/master.m3u8',
     src: 'manifest/master.m3u8',
@@ -311,6 +318,8 @@ test('re-initializes the tech for each source', function() {
   secondPlaylists = player.hls.playlists;
   secondPlaylists = player.hls.playlists;
   secondMSE = player.hls.mediaSource;
   secondMSE = player.hls.mediaSource;
 
 
+  equal(1, aborts, 'aborted the old source buffer');
+  ok(requests[0].aborted, 'aborted the old segment request');
   notStrictEqual(firstPlaylists, secondPlaylists, 'the playlist object is not reused');
   notStrictEqual(firstPlaylists, secondPlaylists, 'the playlist object is not reused');
   notStrictEqual(firstMSE, secondMSE, 'the media source object is not reused');
   notStrictEqual(firstMSE, secondMSE, 'the media source object is not reused');
 });
 });