Notify HTMLMediaElement when media pipeline init has finished

media/filters/pipeline_controller_unittest.cc

 // Copyright 2016 The Chromium Authors. All rights reserved.
 // Use of this source code is governed by a BSD-style license that can be
 // found in the LICENSE file.
 
 #include "media/filters/pipeline_controller.h"
 
 #include <memory>
 
 #include "base/bind.h"
 #include "base/bind_helpers.h"
@@ skipping 17 matching lines @@
 using ::testing::StrictMock;
 
 namespace media {
 
 class PipelineControllerTest : public ::testing::Test, public Pipeline::Client {
  public:
   PipelineControllerTest()
       : pipeline_controller_(&pipeline_,
                              base::Bind(&PipelineControllerTest::CreateRenderer,
                                         base::Unretained(this)),
+                             base::Bind(&PipelineControllerTest::OnStartDone,
+                                        base::Unretained(this)),
                              base::Bind(&PipelineControllerTest::OnSeeked,
                                         base::Unretained(this)),
                              base::Bind(&PipelineControllerTest::OnSuspended,
                                         base::Unretained(this)),
                              base::Bind(&PipelineControllerTest::OnError,
-                                        base::Unretained(this))) {}
+                                        base::Unretained(this))) {
+    EXPECT_CALL(*this, OnError(_)).Times(0);
+  }
 
   ~PipelineControllerTest() override {}
 
   PipelineStatusCB StartPipeline(bool is_streaming, bool is_static) {
     EXPECT_FALSE(pipeline_controller_.IsStable());
+    EXPECT_CALL(*this, OnStartDone(_)).Times(1);
     PipelineStatusCB start_cb;
     EXPECT_CALL(pipeline_, Start(_, _, _, _)).WillOnce(SaveArg<3>(&start_cb));
     pipeline_controller_.Start(&demuxer_, this, is_streaming, is_static);
     Mock::VerifyAndClear(&pipeline_);
     EXPECT_FALSE(pipeline_controller_.IsStable());
     return start_cb;
   }
 
   PipelineStatusCB StartPipeline() { return StartPipeline(false, true); }
 
@@ skipping 51 matching lines @@
  protected:
   std::unique_ptr<Renderer> CreateRenderer() {
     return std::unique_ptr<Renderer>();
   }
 
   void OnSeeked(bool time_updated) {
     was_seeked_ = true;
     last_seeked_time_updated_ = time_updated;
   }
 
+  MOCK_METHOD1(OnStartDone, void(PipelineStatus status));
+
   void OnSuspended() { was_suspended_ = true; }
 
   // Pipeline::Client overrides
-  void OnError(PipelineStatus status) override { NOTREACHED(); }
+  MOCK_METHOD1(OnError, void(PipelineStatus status));
   void OnEnded() override {}
   void OnMetadata(PipelineMetadata metadata) override {}
   void OnBufferingStateChange(BufferingState state) override {}
   void OnDurationChange() override {}
   void OnAddTextTrack(const TextTrackConfig& config,
                       const AddTextTrackDoneCB& done_cb) override {}
   void OnWaitingForDecryptionKey() override {}
   void OnVideoNaturalSizeChange(const gfx::Size& size) override {}
   void OnVideoOpacityChange(bool opaque) override {}
 
@@ skipping 15 matching lines @@
   PipelineStatusCB start_cb = StartPipeline();
   EXPECT_FALSE(was_seeked_);
 
   Complete(start_cb);
   EXPECT_TRUE(was_seeked_);
   EXPECT_FALSE(last_seeked_time_updated_);
   EXPECT_FALSE(was_suspended_);
   EXPECT_TRUE(pipeline_controller_.IsStable());
 }
 
+TEST_F(PipelineControllerTest, StartupFailed) {
+  EXPECT_CALL(*this, OnError(PIPELINE_ERROR_INITIALIZATION_FAILED)).Times(1);
+  PipelineStatusCB start_cb = StartPipeline();
+  start_cb.Run(PIPELINE_ERROR_INITIALIZATION_FAILED);
+  base::RunLoop().RunUntilIdle();
+}
+
 TEST_F(PipelineControllerTest, SuspendResume) {
   Complete(StartPipeline());
   EXPECT_TRUE(was_seeked_);
   was_seeked_ = false;
 
   Complete(SuspendPipeline());
   EXPECT_TRUE(was_suspended_);
   EXPECT_FALSE(pipeline_controller_.IsStable());
 
   Complete(ResumePipeline());
@@ skipping 150 matching lines @@
   // Request a seek to the same time again.
   pipeline_controller_.Seek(seek_time, true);
   base::RunLoop().RunUntilIdle();
 
   // Expect the second seek to trigger when the first seek completes.
   EXPECT_CALL(pipeline_, Seek(seek_time, _));
   Complete(seek_cb_1);
 }
 
 }  // namespace media