corresponding change in CaptureVideoDecoder and RTCVideoDecoder due to pull model used in medi...

content/renderer/media/rtc_video_decoder_unittest.cc

 // Copyright (c) 2011 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 "content/renderer/media/rtc_video_decoder.h"
 
 #include <deque>
 
 #include "base/bind.h"
 #include "base/memory/singleton.h"
@@ skipping 96 matching lines @@
 class RTCVideoDecoderTest : public testing::Test {
  protected:
   static const int kWidth;
   static const int kHeight;
   static const char* kUrl;
   static const PipelineStatistics kStatistics;
 
   RTCVideoDecoderTest() {
     decoder_ = new RTCVideoDecoder(&message_loop_, kUrl);
     renderer_ = new MockVideoRenderer();
+    read_cb_ = base::Bind(&RTCVideoDecoderTest::FrameReady,
+                          base::Unretained(this));
 
     DCHECK(decoder_);
 
     // Inject mocks and prepare a demuxer stream.
     decoder_->set_host(&host_);
 
     EXPECT_CALL(stats_callback_object_, OnStatistics(_))
         .Times(AnyNumber());
   }
 
@@ skipping 15 matching lines @@
   }
 
   MOCK_METHOD1(FrameReady, void(scoped_refptr<media::VideoFrame>));
 
   // Fixture members.
   scoped_refptr<RTCVideoDecoder> decoder_;
   scoped_refptr<MockVideoRenderer> renderer_;
   MockStatisticsCallback stats_callback_object_;
   StrictMock<MockFilterHost> host_;
   MessageLoop message_loop_;
+  media::VideoDecoder::ReadCB read_cb_;
 
  private:
   DISALLOW_COPY_AND_ASSIGN(RTCVideoDecoderTest);
 };
 
 const int RTCVideoDecoderTest::kWidth = 176;
 const int RTCVideoDecoderTest::kHeight = 144;
 const char* RTCVideoDecoderTest::kUrl = "media://remote/0";
 const PipelineStatistics RTCVideoDecoderTest::kStatistics;
 
@@ skipping 11 matching lines @@
 
   InitializeDecoderSuccessfully();
 
   // Expect seek and verify the results.
   decoder_->Seek(kZero, NewExpectedStatusCB(PIPELINE_OK));
 
   message_loop_.RunAllPending();
   EXPECT_EQ(RTCVideoDecoder::kNormal, decoder_->state_);
 }
 
+TEST_F(RTCVideoDecoderTest, DoFlush) {
+  const base::TimeDelta kZero;
+
+  InitializeDecoderSuccessfully();
+
+  EXPECT_CALL(*this, FrameReady(_));
+  decoder_->Read(read_cb_);
+  decoder_->Pause(media::NewExpectedClosure());
+  decoder_->Flush(media::NewExpectedClosure());
+
+  message_loop_.RunAllPending();
+  EXPECT_EQ(RTCVideoDecoder::kPaused, decoder_->state_);
+}
+
 TEST_F(RTCVideoDecoderTest, DoRenderFrame) {
   const base::TimeDelta kZero;
   EXPECT_CALL(host_, GetTime()).WillRepeatedly(Return(base::TimeDelta()));
 
   InitializeDecoderSuccessfully();
 
   NullVideoFrame video_frame;
 
   for (size_t i = 0; i < Limits::kMaxVideoFrames; ++i) {
     decoder_->RenderFrame(&video_frame);
@@ skipping 14 matching lines @@
   EXPECT_CALL(host_,
               SetNaturalVideoSize(new_natural_size)).WillRepeatedly(Return());
 
   decoder_->SetSize(new_width, new_height, new_reserved);
 
   EXPECT_EQ(new_width, decoder_->natural_size().width());
   EXPECT_EQ(new_height, decoder_->natural_size().height());
 
   message_loop_.RunAllPending();
 }