Add MessageLoopProxy::current

base/message_loop_proxy_impl.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 "base/message_loop_proxy_impl.h"
 #include "base/threading/thread_restrictions.h"
 
 namespace base {
 
 MessageLoopProxyImpl::~MessageLoopProxyImpl() {
-  AutoLock lock(message_loop_lock_);
-  // If the target message loop still exists, the d'tor WILL execute on the
-  // target loop.
-  if (target_message_loop_) {
-    DCHECK(MessageLoop::current() == target_message_loop_);
-    MessageLoop::current()->RemoveDestructionObserver(this);
-  }
 }
 
   // MessageLoopProxy implementation
 bool MessageLoopProxyImpl::PostTask(const tracked_objects::Location& from_here,
                                     Task* task) {
   return PostTaskHelper(from_here, task, 0, true);
 }
 
 bool MessageLoopProxyImpl::PostDelayedTask(
     const tracked_objects::Location& from_here, Task* task, int64 delay_ms) {
@@ skipping 67 matching lines @@
       target_message_loop_->DeleteSoon(FROM_HERE, this);
       delete_later = true;
     }
   }
   if (!delete_later)
     delete this;
 }
 
 MessageLoopProxyImpl::MessageLoopProxyImpl()
     : target_message_loop_(MessageLoop::current()) {
-  target_message_loop_->AddDestructionObserver(this);
 }
 
 bool MessageLoopProxyImpl::PostTaskHelper(
     const tracked_objects::Location& from_here, Task* task, int64 delay_ms,
     bool nestable) {
   bool ret = false;
   {
     AutoLock lock(message_loop_lock_);
     if (target_message_loop_) {
       if (nestable) {
@@ skipping 20 matching lines @@
     } else {
       target_message_loop_->PostNonNestableDelayedTask(from_here, task,
                                                        delay_ms);
     }
     return true;
   }
   return false;
 }
 
 scoped_refptr<MessageLoopProxy>
-MessageLoopProxy::CreateForCurrentThread() {
-  scoped_refptr<MessageLoopProxy> ret(new MessageLoopProxyImpl());
-  return ret;
+MessageLoopProxy::current() {
+  MessageLoop* cur_loop = MessageLoop::current();
+  if (!cur_loop)
+    return NULL;
+  return cur_loop->message_loop_proxy();
 }
 
 }  // namespace base