| Index: base/message_loop/message_loop_task_runner.cc
|
| diff --git a/base/message_loop/message_loop_proxy_impl.cc b/base/message_loop/message_loop_task_runner.cc
|
| similarity index 62%
|
| rename from base/message_loop/message_loop_proxy_impl.cc
|
| rename to base/message_loop/message_loop_task_runner.cc
|
| index 580620d6bd5bf5a0f040dc85facdf4fbf9178b28..d553cfe7f8d43d698851606e187b2fe1430c5106 100644
|
| --- a/base/message_loop/message_loop_proxy_impl.cc
|
| +++ b/base/message_loop/message_loop_task_runner.cc
|
| @@ -2,29 +2,26 @@
|
| // Use of this source code is governed by a BSD-style license that can be
|
| // found in the LICENSE file.
|
|
|
| -#include "base/message_loop/message_loop_proxy_impl.h"
|
| +#include "base/message_loop/message_loop_task_runner.h"
|
|
|
| #include "base/location.h"
|
| #include "base/logging.h"
|
| #include "base/message_loop/incoming_task_queue.h"
|
| -#include "base/message_loop/message_loop.h"
|
|
|
| namespace base {
|
| namespace internal {
|
|
|
| -MessageLoopProxyImpl::MessageLoopProxyImpl(
|
| +MessageLoopTaskRunner::MessageLoopTaskRunner(
|
| scoped_refptr<IncomingTaskQueue> incoming_queue)
|
| - : incoming_queue_(incoming_queue),
|
| - valid_thread_id_(kInvalidThreadId) {
|
| -}
|
| + : incoming_queue_(incoming_queue), valid_thread_id_(kInvalidThreadId) {}
|
|
|
| -void MessageLoopProxyImpl::BindToCurrentThread() {
|
| +void MessageLoopTaskRunner::BindToCurrentThread() {
|
| AutoLock lock(valid_thread_id_lock_);
|
| DCHECK_EQ(kInvalidThreadId, valid_thread_id_);
|
| valid_thread_id_ = PlatformThread::CurrentId();
|
| }
|
|
|
| -bool MessageLoopProxyImpl::PostDelayedTask(
|
| +bool MessageLoopTaskRunner::PostDelayedTask(
|
| const tracked_objects::Location& from_here,
|
| const base::Closure& task,
|
| base::TimeDelta delay) {
|
| @@ -32,7 +29,7 @@ bool MessageLoopProxyImpl::PostDelayedTask(
|
| return incoming_queue_->AddToIncomingQueue(from_here, task, delay, true);
|
| }
|
|
|
| -bool MessageLoopProxyImpl::PostNonNestableDelayedTask(
|
| +bool MessageLoopTaskRunner::PostNonNestableDelayedTask(
|
| const tracked_objects::Location& from_here,
|
| const base::Closure& task,
|
| base::TimeDelta delay) {
|
| @@ -40,22 +37,13 @@ bool MessageLoopProxyImpl::PostNonNestableDelayedTask(
|
| return incoming_queue_->AddToIncomingQueue(from_here, task, delay, false);
|
| }
|
|
|
| -bool MessageLoopProxyImpl::RunsTasksOnCurrentThread() const {
|
| +bool MessageLoopTaskRunner::RunsTasksOnCurrentThread() const {
|
| AutoLock lock(valid_thread_id_lock_);
|
| return valid_thread_id_ == PlatformThread::CurrentId();
|
| }
|
|
|
| -MessageLoopProxyImpl::~MessageLoopProxyImpl() {
|
| -}
|
| +MessageLoopTaskRunner::~MessageLoopTaskRunner() {}
|
|
|
| } // namespace internal
|
|
|
| -scoped_refptr<MessageLoopProxy>
|
| -MessageLoopProxy::current() {
|
| - MessageLoop* cur_loop = MessageLoop::current();
|
| - if (!cur_loop)
|
| - return NULL;
|
| - return cur_loop->message_loop_proxy();
|
| -}
|
| -
|
| } // namespace base
|
|
|