Index: media/audio/scoped_task_runner_observer.cc |
diff --git a/media/audio/scoped_loop_observer.cc b/media/audio/scoped_task_runner_observer.cc |
similarity index 61% |
rename from media/audio/scoped_loop_observer.cc |
rename to media/audio/scoped_task_runner_observer.cc |
index 01187ec8f991be37bad58a9cf648c7be72ed5786..9f4eac285111787071191ee23fca789c1e46769a 100644 |
--- a/media/audio/scoped_loop_observer.cc |
+++ b/media/audio/scoped_task_runner_observer.cc |
@@ -2,27 +2,28 @@ |
// Use of this source code is governed by a BSD-style license that can be |
// found in the LICENSE file. |
-#include "media/audio/scoped_loop_observer.h" |
+#include "media/audio/scoped_task_runner_observer.h" |
#include "base/bind.h" |
#include "base/synchronization/waitable_event.h" |
namespace media { |
-ScopedLoopObserver::ScopedLoopObserver( |
- const scoped_refptr<base::MessageLoopProxy>& loop) |
- : loop_(loop) { |
+ScopedTaskRunnerObserver::ScopedTaskRunnerObserver( |
+ const scoped_refptr<base::SingleThreadTaskRunner>& task_runner) |
+ : task_runner_(task_runner) { |
ObserveLoopDestruction(true, NULL); |
} |
-ScopedLoopObserver::~ScopedLoopObserver() { |
+ScopedTaskRunnerObserver::~ScopedTaskRunnerObserver() { |
ObserveLoopDestruction(false, NULL); |
} |
-void ScopedLoopObserver::ObserveLoopDestruction(bool enable, |
- base::WaitableEvent* done) { |
+void ScopedTaskRunnerObserver::ObserveLoopDestruction( |
+ bool enable, |
+ base::WaitableEvent* done) { |
// Note: |done| may be NULL. |
- if (loop_->BelongsToCurrentThread()) { |
+ if (task_runner_->BelongsToCurrentThread()) { |
base::MessageLoop* loop = base::MessageLoop::current(); |
if (enable) { |
loop->AddDestructionObserver(this); |
@@ -31,8 +32,8 @@ void ScopedLoopObserver::ObserveLoopDestruction(bool enable, |
} |
} else { |
base::WaitableEvent event(false, false); |
- if (loop_->PostTask(FROM_HERE, |
- base::Bind(&ScopedLoopObserver::ObserveLoopDestruction, |
+ if (task_runner_->PostTask(FROM_HERE, |
+ base::Bind(&ScopedTaskRunnerObserver::ObserveLoopDestruction, |
base::Unretained(this), enable, &event))) { |
event.Wait(); |
} else { |