MSE: Start letting SourceBuffer begin to do initialization segment received algorithm

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 71 matching lines @@
 SourceBuffer::SourceBuffer(PassOwnPtr<WebSourceBuffer> webSourceBuffer, MediaSource* source, GenericEventQueue* asyncEventQueue)
     : ActiveDOMObject(source->executionContext())
     , m_webSourceBuffer(webSourceBuffer)
     , m_source(source)
     , m_asyncEventQueue(asyncEventQueue)
     , m_mode(segmentsKeyword())
     , m_updating(false)
     , m_timestampOffset(0)
     , m_appendWindowStart(0)
     , m_appendWindowEnd(std::numeric_limits<double>::infinity())
+    , m_firstInitializationSegmentReceived(false)
     , m_pendingAppendDataOffset(0)
     , m_appendBufferAsyncPartRunner(this, &SourceBuffer::appendBufferAsyncPart)
     , m_pendingRemoveStart(-1)
     , m_pendingRemoveEnd(-1)
     , m_removeAsyncPartRunner(this, &SourceBuffer::removeAsyncPart)
     , m_streamMaxSizeValid(false)
     , m_streamMaxSize(0)
     , m_appendStreamAsyncPartRunner(this, &SourceBuffer::appendStreamAsyncPart)
 {
     ASSERT(m_webSourceBuffer);
     ASSERT(m_source);
+    m_webSourceBuffer->setClient(this);
 }
 
 SourceBuffer::~SourceBuffer()
 {
     // Oilpan: a SourceBuffer might be finalized without having been
     // explicitly removed first, hence the asserts below will not
     // hold.
 #if !ENABLE(OILPAN)
     ASSERT(isRemoved());
     ASSERT(!m_loader);
     ASSERT(!m_stream);
+    ASSERT(!m_webSourceBuffer);
 #endif
 }
 
 const AtomicString& SourceBuffer::segmentsKeyword()
 {
     DEFINE_STATIC_LOCAL(const AtomicString, segments, ("segments", AtomicString::ConstructFromLiteral));
     return segments;
 }
 
 const AtomicString& SourceBuffer::sequenceKeyword()
@@ skipping 288 matching lines @@
         return;
 
     abortIfUpdating();
 
     m_webSourceBuffer->removedFromMediaSource();
     m_webSourceBuffer.clear();
     m_source = nullptr;
     m_asyncEventQueue = 0;
 }
 
+void SourceBuffer::initializationSegmentReceived()
+{
+    ASSERT(m_source);
+    ASSERT(m_updating);
+
+    // https://dvcs.w3.org/hg/html-media/raw-file/tip/media-source/media-source.html#sourcebuffer-init-segment-received
+    // FIXME: Make steps 1-7 synchronous with this call.
+    // FIXME: Augment the interface to this method to implement compliant steps 4-7 here.
+    // Step 3 (if the first initialization segment received flag is true) is
+    // implemented by caller.
+
+    if (!m_firstInitializationSegmentReceived) {
+        // 5. If active track flag equals true, then run the following steps:
+        // 5.1. Add this SourceBuffer to activeSourceBuffers.
+        // 5.2. Queue a task to fire a simple event named addsourcebuffer at
+        // activesourcebuffers.
+        m_source->setSourceBufferActive(this);
+
+        // 6. Set first initialization segment received flag to true.
+        m_firstInitializationSegmentReceived = true;
+    }
+}
+
 bool SourceBuffer::hasPendingActivity() const
 {
     return m_source;
 }
 
 void SourceBuffer::suspend()
 {
     m_appendBufferAsyncPartRunner.suspend();
     m_removeAsyncPartRunner.suspend();
     m_appendStreamAsyncPartRunner.suspend();
@@ skipping 285 matching lines @@
 }
 
 void SourceBuffer::trace(Visitor* visitor)
 {
     visitor->trace(m_source);
     visitor->trace(m_stream);
     EventTargetWithInlineData::trace(visitor);
 }
 
 } // namespace blink