Convert WMPI state management to level-triggered.

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 "base/bind.h"
 #include "base/bind_helpers.h"
 #include "base/logging.h"
 #include "base/macros.h"
 #include "base/memory/ref_counted.h"
 #include "base/memory/scoped_ptr.h"
@@ skipping 18 matching lines @@
 class PipelineControllerTest : public ::testing::Test {
  public:
   PipelineControllerTest()
       : pipeline_controller_(&pipeline_,
                              base::Bind(&PipelineControllerTest::CreateRenderer,
                                         base::Unretained(this)),
                              base::Bind(&PipelineControllerTest::OnSeeked,
                                         base::Unretained(this)),
                              base::Bind(&PipelineControllerTest::OnSuspended,
                                         base::Unretained(this)),
-                             base::Bind(&PipelineControllerTest::OnResumed,
-                                        base::Unretained(this)),
                              base::Bind(&PipelineControllerTest::OnError,
                                         base::Unretained(this))) {}
 
   ~PipelineControllerTest() override {}
 
   PipelineStatusCB StartPipeline(bool is_streaming, bool is_static) {
     EXPECT_FALSE(pipeline_controller_.IsStable());
     PipelineStatusCB start_cb;
     EXPECT_CALL(pipeline_, Start(_, _, _, _, _, _, _, _, _, _))
         .WillOnce(SaveArg<4>(&start_cb));
@@ skipping 26 matching lines @@
     return seek_cb;
   }
 
   PipelineStatusCB SuspendPipeline() {
     EXPECT_TRUE(pipeline_controller_.IsStable());
     PipelineStatusCB suspend_cb;
     EXPECT_CALL(pipeline_, Suspend(_)).WillOnce(SaveArg<0>(&suspend_cb));
     pipeline_controller_.Suspend();
     Mock::VerifyAndClear(&pipeline_);
     EXPECT_FALSE(pipeline_controller_.IsStable());
-    EXPECT_FALSE(pipeline_controller_.IsSuspended());
+    EXPECT_FALSE(pipeline_controller_.IsPipelineSuspended());
     return suspend_cb;
   }
 
   PipelineStatusCB ResumePipeline() {
-    EXPECT_TRUE(pipeline_controller_.IsSuspended());
+    EXPECT_TRUE(pipeline_controller_.IsPipelineSuspended());
     PipelineStatusCB resume_cb;
     EXPECT_CALL(pipeline_, Resume(_, _, _))
         .WillOnce(
             DoAll(SaveArg<1>(&last_resume_time_), SaveArg<2>(&resume_cb)));
     EXPECT_CALL(pipeline_, GetMediaTime())
         .WillRepeatedly(Return(base::TimeDelta()));
     pipeline_controller_.Resume();
     Mock::VerifyAndClear(&pipeline_);
     EXPECT_FALSE(pipeline_controller_.IsStable());
-    EXPECT_FALSE(pipeline_controller_.IsSuspended());
+    EXPECT_FALSE(pipeline_controller_.IsPipelineSuspended());
     return resume_cb;
   }
 
   void Complete(const PipelineStatusCB& cb) {
     cb.Run(PIPELINE_OK);
     message_loop_.RunUntilIdle();
   }
 
  protected:
   scoped_ptr<Renderer> CreateRenderer() { return scoped_ptr<Renderer>(); }
 
   void OnSeeked(bool time_updated) {
     was_seeked_ = true;
     last_seeked_time_updated_ = time_updated;
   }
 
   void OnSuspended() { was_suspended_ = true; }
 
-  void OnResumed() { was_resumed_ = true; }
-
   void OnError(PipelineStatus status) { NOTREACHED(); }
 
   base::MessageLoop message_loop_;
 
   NiceMock<MockDemuxer> demuxer_;
   StrictMock<MockPipeline> pipeline_;
   PipelineController pipeline_controller_;
 
   bool was_seeked_ = false;
   bool last_seeked_time_updated_ = false;
   bool was_suspended_ = false;
-  bool was_resumed_ = false;
   base::TimeDelta last_resume_time_;
 
   DISALLOW_COPY_AND_ASSIGN(PipelineControllerTest);
 };
 
 TEST_F(PipelineControllerTest, Startup) {
   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_FALSE(was_resumed_);
   EXPECT_TRUE(pipeline_controller_.IsStable());
 }
 
 TEST_F(PipelineControllerTest, SuspendResume) {
   Complete(StartPipeline());
   EXPECT_TRUE(was_seeked_);
   was_seeked_ = false;
 
   Complete(SuspendPipeline());
   EXPECT_TRUE(was_suspended_);
-  EXPECT_FALSE(was_resumed_);
   EXPECT_FALSE(pipeline_controller_.IsStable());
 
   Complete(ResumePipeline());
-  EXPECT_TRUE(was_resumed_);
   EXPECT_TRUE(pipeline_controller_.IsStable());
 
   // |was_seeked_| should not be affected by Suspend()/Resume() at all.
   EXPECT_FALSE(was_seeked_);
 }
 
 TEST_F(PipelineControllerTest, Seek) {
   // Normal seeking should not result in a cancel.
   EXPECT_CALL(demuxer_, CancelPendingSeek(_)).Times(0);
 
@@ skipping 13 matching lines @@
 
 TEST_F(PipelineControllerTest, SuspendResumeTime) {
   Complete(StartPipeline());
   Complete(SuspendPipeline());
 
   base::TimeDelta seek_time = base::TimeDelta::FromSeconds(5);
   pipeline_controller_.Seek(seek_time, true);
   message_loop_.RunUntilIdle();
 
   Complete(ResumePipeline());
-  EXPECT_TRUE(was_resumed_);
   EXPECT_EQ(seek_time, last_resume_time_);
 }
 
 TEST_F(PipelineControllerTest, SuspendResumeTime_WithStreamingData) {
   Complete(StartPipeline_WithStreamingData());
   Complete(SuspendPipeline());
 
   base::TimeDelta seek_time = base::TimeDelta::FromSeconds(5);
   pipeline_controller_.Seek(seek_time, true);
   message_loop_.RunUntilIdle();
 
   Complete(ResumePipeline());
-  EXPECT_TRUE(was_resumed_);
   EXPECT_EQ(base::TimeDelta(), last_resume_time_);
 }
 
 TEST_F(PipelineControllerTest, SeekAborted) {
   Complete(StartPipeline());
 
   // Create a first pending seek.
   base::TimeDelta seek_time_1 = base::TimeDelta::FromSeconds(5);
   EXPECT_CALL(demuxer_, StartWaitingForSeek(seek_time_1));
   PipelineStatusCB seek_cb_1 = SeekPipeline(seek_time_1);
@@ skipping 95 matching lines @@
   // Request a seek to the same time again.
   pipeline_controller_.Seek(seek_time, true);
   message_loop_.RunUntilIdle();
 
   // Expect the second seek to trigger when the first seek completes.
   EXPECT_CALL(pipeline_, Seek(seek_time, _));
   Complete(seek_cb_1);
 }
 
 }  // namespace media