MSE: Experimental support for new abort and duration behavior

third_party/WebKit/Source/modules/mediasource/SourceBuffer.cpp

 /*
  * Copyright (C) 2013 Google Inc. All rights reserved.
  *
  * Redistribution and use in source and binary forms, with or without
  * modification, are permitted provided that the following conditions are
  * met:
  *
  *     * Redistributions of source code must retain the above copyright
  * notice, this list of conditions and the following disclaimer.
  *     * Redistributions in binary form must reproduce the above
@@ skipping 21 matching lines @@
 
 #include "bindings/core/v8/ExceptionMessages.h"
 #include "bindings/core/v8/ExceptionState.h"
 #include "core/dom/DOMArrayBuffer.h"
 #include "core/dom/DOMArrayBufferView.h"
 #include "core/dom/ExceptionCode.h"
 #include "core/dom/ExecutionContext.h"
 #include "core/events/Event.h"
 #include "core/events/GenericEventQueue.h"
 #include "core/fileapi/FileReaderLoader.h"
+#include "core/frame/Deprecation.h"
+#include "core/frame/UseCounter.h"
 #include "core/html/HTMLMediaElement.h"
 #include "core/html/MediaError.h"
 #include "core/html/TimeRanges.h"
 #include "core/html/track/AudioTrack.h"
 #include "core/html/track/AudioTrackList.h"
 #include "core/html/track/VideoTrack.h"
 #include "core/html/track/VideoTrackList.h"
 #include "core/streams/Stream.h"
 #include "modules/mediasource/MediaSource.h"
 #include "modules/mediasource/SourceBufferTrackBaseSupplement.h"
 #include "platform/Logging.h"
+#include "platform/RuntimeEnabledFeatures.h"
 #include "platform/TraceEvent.h"
 #include "public/platform/WebSourceBuffer.h"
 #include "wtf/MathExtras.h"
 #include <limits>
 #include <memory>
 #include <sstream>
 
 using blink::WebSourceBuffer;
 
 #define SBLOG DVLOG(3)
@@ skipping 276 matching lines @@
     SBLOG << __FUNCTION__ << " this=" << this << " maxSize=" << maxSize;
     m_streamMaxSizeValid = maxSize > 0;
     if (m_streamMaxSizeValid)
         m_streamMaxSize = maxSize;
     appendStreamInternal(stream, exceptionState);
 }
 
 void SourceBuffer::abort(ExceptionState& exceptionState)
 {
     SBLOG << __FUNCTION__ << " this=" << this;
-    // Section 3.2 abort() method steps.
-    // https://dvcs.w3.org/hg/html-media/raw-file/default/media-source/media-source.html#widl-SourceBuffer-abort-void
+    // http://w3c.github.io/media-source/#widl-SourceBuffer-abort-void
     // 1. If this object has been removed from the sourceBuffers attribute of the parent media source
     //    then throw an InvalidStateError exception and abort these steps.
     // 2. If the readyState attribute of the parent media source is not in the "open" state
     //    then throw an InvalidStateError exception and abort these steps.
     if (isRemoved()) {
         MediaSource::logAndThrowDOMException(exceptionState, InvalidStateError, "This SourceBuffer has been removed from the parent media source.");
         return;
     }
     if (!m_source->isOpen()) {
         MediaSource::logAndThrowDOMException(exceptionState, InvalidStateError, "The parent media source's readyState is not 'open'.");
         return;
     }
 
-    // 3. If the sourceBuffer.updating attribute equals true, then run the following steps: ...
+    // 3. If the range removal algorithm is running, then throw an
+    //    InvalidStateError exception and abort these steps.
+    if (m_pendingRemoveStart != -1) {
+        DCHECK(m_updating);
+        // Throwing the exception and aborting these steps is new behavior that
+        // is implemented behind the MediaSourceNewAbortAndDuration
+        // RuntimeEnabledFeature.
+        if (RuntimeEnabledFeatures::mediaSourceNewAbortAndDurationEnabled()) {
+            MediaSource::logAndThrowDOMException(exceptionState, InvalidStateError, "Aborting asynchronous remove() operation is disallowed.");
+            return;
+        }
+
+        Deprecation::countDeprecation(m_source->mediaElement()->document(), UseCounter::MediaSourceAbortRemove);
+        cancelRemove();
+    }
+
+    // 4. If the sourceBuffer.updating attribute equals true, then run the following steps: ...
     abortIfUpdating();
 
-    // 4. Run the reset parser state algorithm.
+    // 5. Run the reset parser state algorithm.
     m_webSourceBuffer->resetParserState();
 
-    // 5. Set appendWindowStart to 0.
+    // 6. Set appendWindowStart to 0.
     setAppendWindowStart(0, exceptionState);
 
-    // 6. Set appendWindowEnd to positive Infinity.
+    // 7. Set appendWindowEnd to positive Infinity.
     setAppendWindowEnd(std::numeric_limits<double>::infinity(), exceptionState);
 }
 
 void SourceBuffer::remove(double start, double end, ExceptionState& exceptionState)
 {
     SBLOG << __FUNCTION__ << " this=" << this << " start=" << start << " end=" << end;
 
     // Section 3.2 remove() method steps.
     // 1. If duration equals NaN, then throw an InvalidAccessError exception and abort these steps.
     // 2. If start is negative or greater than duration, then throw an InvalidAccessError exception and abort these steps.
@@ skipping 44 matching lines @@
     //    and abort these steps.
     // 2. If the updating attribute equals true, then throw an InvalidStateError
     //    exception and abort these steps.
     if (throwExceptionIfRemovedOrUpdating(isRemoved(), m_updating, exceptionState))
         return;
 
     // 3. Update the attribute to the new value.
     m_trackDefaults = trackDefaults;
 }
 
+void SourceBuffer::cancelRemove()
+{
+    DCHECK(m_updating);
+    DCHECK_NE(m_pendingRemoveStart, -1);
+    m_removeAsyncPartRunner->stop();
+    m_pendingRemoveStart = -1;
+    m_pendingRemoveEnd = -1;
+    m_updating = false;
+
+    if (!RuntimeEnabledFeatures::mediaSourceNewAbortAndDurationEnabled()) {
+        scheduleEvent(EventTypeNames::abort);
+        scheduleEvent(EventTypeNames::updateend);
+    }
+
+    TRACE_EVENT_ASYNC_END0("media", "SourceBuffer::remove", this);
+}
+
 void SourceBuffer::abortIfUpdating()
 {
-    // Section 3.2 abort() method step 3 substeps.
-    // https://dvcs.w3.org/hg/html-media/raw-file/default/media-source/media-source.html#widl-SourceBuffer-abort-void
+    // Section 3.2 abort() method step 4 substeps.
+    // http://w3c.github.io/media-source/#widl-SourceBuffer-abort-void
 
     if (!m_updating)
         return;
 
+    DCHECK_EQ(m_pendingRemoveStart, -1);
+
     const char* traceEventName = 0;
     if (!m_pendingAppendData.isEmpty()) {
         traceEventName = "SourceBuffer::appendBuffer";
     } else if (m_stream) {
         traceEventName = "SourceBuffer::appendStream";
-    } else if (m_pendingRemoveStart != -1) {
-        traceEventName = "SourceBuffer::remove";
     } else {
         NOTREACHED();
     }
 
-    // 3.1. Abort the buffer append and stream append loop algorithms if they are running.
+    // 4.1. Abort the buffer append and stream append loop algorithms if they are running.
     m_appendBufferAsyncPartRunner->stop();
     m_pendingAppendData.clear();
     m_pendingAppendDataOffset = 0;
 
-    m_removeAsyncPartRunner->stop();
-    m_pendingRemoveStart = -1;
-    m_pendingRemoveEnd = -1;
-
     m_appendStreamAsyncPartRunner->stop();
     clearAppendStreamState();
 
-    // 3.2. Set the updating attribute to false.
+    // 4.2. Set the updating attribute to false.
     m_updating = false;
 
-    // 3.3. Queue a task to fire a simple event named abort at this SourceBuffer object.
+    // 4.3. Queue a task to fire a simple event named abort at this SourceBuffer object.
     scheduleEvent(EventTypeNames::abort);
 
-    // 3.4. Queue a task to fire a simple event named updateend at this SourceBuffer object.
+    // 4.4. Queue a task to fire a simple event named updateend at this SourceBuffer object.
     scheduleEvent(EventTypeNames::updateend);
 
     TRACE_EVENT_ASYNC_END0("media", traceEventName, this);
 }
 
 void SourceBuffer::removedFromMediaSource()
 {
     if (isRemoved())
         return;
 
     SBLOG << __FUNCTION__ << " this=" << this;
-    abortIfUpdating();
+    if (m_pendingRemoveStart != -1) {
+        cancelRemove();
+    } else {
+        abortIfUpdating();
+    }
 
     if (RuntimeEnabledFeatures::audioVideoTracksEnabled()) {
         DCHECK(m_source);
         if (m_source->mediaElement()->audioTracks().length() > 0
             || m_source->mediaElement()->videoTracks().length() > 0) {
             removeMediaTracks();
         }
     }
 
     m_webSourceBuffer->removedFromMediaSource();
     m_webSourceBuffer.reset();
     m_source = nullptr;
     m_asyncEventQueue = nullptr;
 }
 
+double SourceBuffer::highestPresentationTimestamp()
+{
+    DCHECK(!isRemoved());
+
+    SBLOG << __FUNCTION__ << " this=" << this;

[chcunningham, 2016/06/29 21:19:24]

Do you need both SBLOGs? (here and 2 lines down)

[wolenetz, 2016/06/30 01:35:49]

Nope. I was being extra-verbose. I'll keep the latter.

+    double pts = m_webSourceBuffer->highestPresentationTimestamp();
+    SBLOG << __FUNCTION__ << " this=" << this << ", pts=" << pts;
+    return pts;
+}
+
 void SourceBuffer::removeMediaTracks()
 {
     DCHECK(RuntimeEnabledFeatures::audioVideoTracksEnabled());
     // Spec: http://w3c.github.io/media-source/#widl-MediaSource-removeSourceBuffer-void-SourceBuffer-sourceBuffer
     DCHECK(m_source);
 
     HTMLMediaElement* mediaElement = m_source->mediaElement();
     DCHECK(mediaElement);
     // 3. Let SourceBuffer audioTracks list equal the AudioTrackList object returned by sourceBuffer.audioTracks.
     // 4. If the SourceBuffer audioTracks list is not empty, then run the following steps:
@@ skipping 536 matching lines @@
     visitor->trace(m_removeAsyncPartRunner);
     visitor->trace(m_appendStreamAsyncPartRunner);
     visitor->trace(m_stream);
     visitor->trace(m_audioTracks);
     visitor->trace(m_videoTracks);
     EventTargetWithInlineData::trace(visitor);
     ActiveDOMObject::trace(visitor);
 }
 
 } // namespace blink