Allow multiple concurrent Decode() requests in VideoDecoder interface.

media/filters/fake_video_decoder.cc

 // Copyright 2013 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/fake_video_decoder.h"
 
 #include "base/bind.h"
 #include "base/callback_helpers.h"
 #include "base/location.h"
 #include "base/message_loop/message_loop_proxy.h"
@@ skipping 53 matching lines @@
   if (buffer->end_of_stream() && decoded_frames_.empty()) {
     decode_cb_.RunOrHold(kOk, VideoFrame::CreateEOSFrame());
     return;
   }
 
   if (!buffer->end_of_stream()) {
     DCHECK(VerifyFakeVideoBufferForTest(buffer, current_config_));
     scoped_refptr<VideoFrame> video_frame = VideoFrame::CreateColorFrame(
         current_config_.coded_size(), 0, 0, 0, buffer->timestamp());
     decoded_frames_.push_back(video_frame);
+    LOG(ERROR) << "Queue " << decoded_frames_.size();

[Ami GONE FROM CHROMIUM, 2014/04/16 01:00:00]

drop?

[Sergey Ulanov, 2014/04/16 01:44:14]

Done.

 
     if (decoded_frames_.size() <= static_cast<size_t>(decoding_delay_)) {
       decode_cb_.RunOrHold(kNotEnoughData, scoped_refptr<VideoFrame>());
       return;
     }
   }
 
   scoped_refptr<VideoFrame> frame = decoded_frames_.front();
   decoded_frames_.pop_front();
+  LOG(ERROR) << "Queue " << decoded_frames_.size();

[Ami GONE FROM CHROMIUM, 2014/04/16 01:00:00]

drop?

[Sergey Ulanov, 2014/04/16 01:44:14]

Done.

   decode_cb_.RunOrHold(kOk, frame);
 }
 
 void FakeVideoDecoder::Reset(const base::Closure& closure) {
   DCHECK(task_runner_->BelongsToCurrentThread());
   DCHECK(reset_cb_.IsNull());
   reset_cb_.SetCallback(BindToCurrentLoop(closure));
 
   // Defer the reset if a decode is pending.
   if (!decode_cb_.IsNull())
@@ skipping 15 matching lines @@
   decoded_frames_.clear();
   state_ = UNINITIALIZED;
 }
 
 scoped_refptr<VideoFrame> FakeVideoDecoder::GetDecodeOutput() {
   DCHECK(task_runner_->BelongsToCurrentThread());
   if (!supports_get_decode_output_ || decoded_frames_.empty())
     return NULL;
   scoped_refptr<VideoFrame> out = decoded_frames_.front();
   decoded_frames_.pop_front();
+  LOG(ERROR) << "Queue " << decoded_frames_.size();

[Ami GONE FROM CHROMIUM, 2014/04/16 01:00:00]

drop?

[Sergey Ulanov, 2014/04/16 01:44:14]

Done.

   return out;
 }
 
 void FakeVideoDecoder::HoldNextInit() {
   DCHECK(task_runner_->BelongsToCurrentThread());
   init_cb_.HoldCallback();
 }
 
 void FakeVideoDecoder::HoldNextDecode() {
   DCHECK(task_runner_->BelongsToCurrentThread());
@@ skipping 40 matching lines @@
     int buffer_size,
     const DecodeCB& decode_cb,
     Status status,
     const scoped_refptr<VideoFrame>& video_frame) {
   if (status == kOk || status == kNotEnoughData)
     total_bytes_decoded_ += buffer_size;
   decode_cb.Run(status, video_frame);
 }
 
 }  // namespace media