Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(826)

Unified Diff: media/filters/fake_video_decoder.cc

Issue 65803002: Replace MessageLoopProxy with SingleThreadTaskRunner for media/filters/ + associated code. (Closed) Base URL: svn://svn.chromium.org/chrome/trunk/src
Patch Set: rebase Created 7 years ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View side-by-side diff with in-line comments
Download patch
« no previous file with comments | « media/filters/fake_video_decoder.h ('k') | media/filters/ffmpeg_audio_decoder.h » ('j') | no next file with comments »
Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
Index: media/filters/fake_video_decoder.cc
diff --git a/media/filters/fake_video_decoder.cc b/media/filters/fake_video_decoder.cc
index dbb16db0d9e1e9c1469034e2afd4e33cf7001ca1..3bd70616c85ef9b973edf0725e1b899af199db3b 100644
--- a/media/filters/fake_video_decoder.cc
+++ b/media/filters/fake_video_decoder.cc
@@ -14,7 +14,7 @@
namespace media {
FakeVideoDecoder::FakeVideoDecoder(int decoding_delay)
- : message_loop_(base::MessageLoopProxy::current()),
+ : task_runner_(base::MessageLoopProxy::current()),
weak_factory_(this),
decoding_delay_(decoding_delay),
state_(UNINITIALIZED),
@@ -28,7 +28,7 @@ FakeVideoDecoder::~FakeVideoDecoder() {
void FakeVideoDecoder::Initialize(const VideoDecoderConfig& config,
const PipelineStatusCB& status_cb) {
- DCHECK(message_loop_->BelongsToCurrentThread());
+ DCHECK(task_runner_->BelongsToCurrentThread());
DCHECK(config.IsValidConfig());
DCHECK(decode_cb_.IsNull()) << "No reinitialization during pending decode.";
DCHECK(reset_cb_.IsNull()) << "No reinitialization during pending reset.";
@@ -49,7 +49,7 @@ void FakeVideoDecoder::Initialize(const VideoDecoderConfig& config,
void FakeVideoDecoder::Decode(const scoped_refptr<DecoderBuffer>& buffer,
const DecodeCB& decode_cb) {
- DCHECK(message_loop_->BelongsToCurrentThread());
+ DCHECK(task_runner_->BelongsToCurrentThread());
DCHECK(decode_cb_.IsNull()) << "Overlapping decodes are not supported.";
DCHECK(reset_cb_.IsNull());
DCHECK_LE(decoded_frames_.size(), static_cast<size_t>(decoding_delay_));
@@ -81,7 +81,7 @@ void FakeVideoDecoder::Decode(const scoped_refptr<DecoderBuffer>& buffer,
}
void FakeVideoDecoder::Reset(const base::Closure& closure) {
- DCHECK(message_loop_->BelongsToCurrentThread());
+ DCHECK(task_runner_->BelongsToCurrentThread());
DCHECK(reset_cb_.IsNull());
reset_cb_.SetCallback(BindToCurrentLoop(closure));
@@ -93,7 +93,7 @@ void FakeVideoDecoder::Reset(const base::Closure& closure) {
}
void FakeVideoDecoder::Stop(const base::Closure& closure) {
- DCHECK(message_loop_->BelongsToCurrentThread());
+ DCHECK(task_runner_->BelongsToCurrentThread());
stop_cb_.SetCallback(BindToCurrentLoop(closure));
// Defer the stop if an init, a decode or a reset is pending.
@@ -104,27 +104,27 @@ void FakeVideoDecoder::Stop(const base::Closure& closure) {
}
void FakeVideoDecoder::HoldNextInit() {
- DCHECK(message_loop_->BelongsToCurrentThread());
+ DCHECK(task_runner_->BelongsToCurrentThread());
init_cb_.HoldCallback();
}
void FakeVideoDecoder::HoldNextRead() {
- DCHECK(message_loop_->BelongsToCurrentThread());
+ DCHECK(task_runner_->BelongsToCurrentThread());
decode_cb_.HoldCallback();
}
void FakeVideoDecoder::HoldNextReset() {
- DCHECK(message_loop_->BelongsToCurrentThread());
+ DCHECK(task_runner_->BelongsToCurrentThread());
reset_cb_.HoldCallback();
}
void FakeVideoDecoder::HoldNextStop() {
- DCHECK(message_loop_->BelongsToCurrentThread());
+ DCHECK(task_runner_->BelongsToCurrentThread());
stop_cb_.HoldCallback();
}
void FakeVideoDecoder::SatisfyInit() {
- DCHECK(message_loop_->BelongsToCurrentThread());
+ DCHECK(task_runner_->BelongsToCurrentThread());
DCHECK(decode_cb_.IsNull());
DCHECK(reset_cb_.IsNull());
@@ -135,7 +135,7 @@ void FakeVideoDecoder::SatisfyInit() {
}
void FakeVideoDecoder::SatisfyRead() {
- DCHECK(message_loop_->BelongsToCurrentThread());
+ DCHECK(task_runner_->BelongsToCurrentThread());
decode_cb_.RunHeldCallback();
if (!reset_cb_.IsNull())
@@ -146,7 +146,7 @@ void FakeVideoDecoder::SatisfyRead() {
}
void FakeVideoDecoder::SatisfyReset() {
- DCHECK(message_loop_->BelongsToCurrentThread());
+ DCHECK(task_runner_->BelongsToCurrentThread());
DCHECK(decode_cb_.IsNull());
reset_cb_.RunHeldCallback();
@@ -155,14 +155,14 @@ void FakeVideoDecoder::SatisfyReset() {
}
void FakeVideoDecoder::SatisfyStop() {
- DCHECK(message_loop_->BelongsToCurrentThread());
+ DCHECK(task_runner_->BelongsToCurrentThread());
DCHECK(decode_cb_.IsNull());
DCHECK(reset_cb_.IsNull());
stop_cb_.RunHeldCallback();
}
void FakeVideoDecoder::DoReset() {
- DCHECK(message_loop_->BelongsToCurrentThread());
+ DCHECK(task_runner_->BelongsToCurrentThread());
DCHECK(decode_cb_.IsNull());
DCHECK(!reset_cb_.IsNull());
@@ -171,7 +171,7 @@ void FakeVideoDecoder::DoReset() {
}
void FakeVideoDecoder::DoStop() {
- DCHECK(message_loop_->BelongsToCurrentThread());
+ DCHECK(task_runner_->BelongsToCurrentThread());
DCHECK(decode_cb_.IsNull());
DCHECK(reset_cb_.IsNull());
DCHECK(!stop_cb_.IsNull());
« no previous file with comments | « media/filters/fake_video_decoder.h ('k') | media/filters/ffmpeg_audio_decoder.h » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698