web-threads: Create a single instance of WebThread for each blink thread.

content/child/webthread_impl.cc

Index: content/child/webthread_impl.cc
diff --git a/content/child/webthread_impl.cc b/content/child/webthread_impl.cc
index 8a1d7cdda63ad1126ae2161f0ca5b592dd02b01d..572e5890bb53409078ac70da898081855c491450 100644
--- a/content/child/webthread_impl.cc
+++ b/content/child/webthread_impl.cc
@@ -9,7 +9,6 @@
 
 #include "base/bind.h"
 #include "base/bind_helpers.h"
-#include "base/message_loop/message_loop.h"
 #include "base/pending_task.h"
 #include "base/threading/platform_thread.h"
 #include "third_party/WebKit/public/platform/WebTraceLocation.h"
@@ -119,12 +118,14 @@ void WebThreadBase::postDelayedTask(const blink::WebTraceLocation& web_location,
 
 void WebThreadBase::enterRunLoop() {

[kinuko, 2015/02/27 09:54:27]

Is this now used only for unit tests? If so I'd just add NOTREACHED() here and
remove MessageLoop virtual method from this interface.

[Sami, 2015/02/27 17:23:08]

There are a handful of tests on the Blink side which call this too. Perhaps it
would be worth renaming this to enterRunLoopForTesting() or something?

[sadrul, 2015/03/01 10:21:38]

I have filed http://crbug.com/462927 to remove enterRunLoop/exitRunLoop from
WebThread interface (also some related cleanup:
https://codereview.chromium.org/962053003/). Would it make sense to leave this
as is for now and do that cleanup separately?

   CHECK(isCurrentThread());
+  CHECK(MessageLoop());
   CHECK(!MessageLoop()->is_running());  // We don't support nesting.
   MessageLoop()->Run();
 }
 
 void WebThreadBase::exitRunLoop() {
   CHECK(isCurrentThread());
+  CHECK(MessageLoop());
   CHECK(MessageLoop()->is_running());
   MessageLoop()->Quit();
 }
@@ -147,33 +148,11 @@ WebThreadImpl::~WebThreadImpl() {
 }
 
 base::MessageLoop* WebThreadImpl::MessageLoop() const {
-  return thread_->message_loop();
+  return nullptr;
 }
 
 base::SingleThreadTaskRunner* WebThreadImpl::TaskRunner() const {
   return thread_->message_loop_proxy().get();
 }
 
-WebThreadImplForMessageLoop::WebThreadImplForMessageLoop(
-    scoped_refptr<base::SingleThreadTaskRunner> owning_thread_task_runner)
-    : owning_thread_task_runner_(owning_thread_task_runner),
-      thread_id_(base::PlatformThread::CurrentId()) {
-}
-
-blink::PlatformThreadId WebThreadImplForMessageLoop::threadId() const {
-  return thread_id_;
-}
-
-WebThreadImplForMessageLoop::~WebThreadImplForMessageLoop() {
-}
-
-base::MessageLoop* WebThreadImplForMessageLoop::MessageLoop() const {
-  DCHECK(isCurrentThread());
-  return base::MessageLoop::current();
-}
-
-base::SingleThreadTaskRunner* WebThreadImplForMessageLoop::TaskRunner() const {
-  return owning_thread_task_runner_.get();
-}
-
 }  // namespace content