1 files changed, 47 insertions, 0 deletions
diff --git a/chrome/browser/chrome_thread.cc b/chrome/browser/chrome_thread.cc
index 300c2f6..6421a79 100644
--- a/chrome/browser/chrome_thread.cc
+++ b/chrome/browser/chrome_thread.cc
@@ -5,6 +5,7 @@
 #include "chrome/browser/chrome_thread.h"
 
 #include "base/message_loop.h"
+#include "base/message_loop_proxy.h"
 
 // Friendly names for the well-known threads.
 static const char* chrome_thread_names[ChromeThread::ID_COUNT] = {
@@ -19,6 +20,44 @@ static const char* chrome_thread_names[ChromeThread::ID_COUNT] = {
 #endif
 };
 
+// An implementation of MessageLoopProxy to be used in conjunction
+// with ChromeThread.
+class ChromeThreadMessageLoopProxy : public MessageLoopProxy {
+ public:
+  explicit ChromeThreadMessageLoopProxy(ChromeThread::ID identifier)
+      : id_(identifier) {
+  }
+
+  // MessageLoopProxy implementation.
+  virtual bool PostTask(const tracked_objects::Location& from_here,
+                        Task* task) {
+    return ChromeThread::PostTask(id_, from_here, task);
+  }
+
+  virtual bool PostDelayedTask(const tracked_objects::Location& from_here,
+                               Task* task, int64 delay_ms) {
+    return ChromeThread::PostDelayedTask(id_, from_here, task, delay_ms);
+  }
+
+  virtual bool PostNonNestableTask(const tracked_objects::Location& from_here,
+                                   Task* task) {
+    return ChromeThread::PostNonNestableTask(id_, from_here, task);
+  }
+
+  virtual bool PostNonNestableDelayedTask(
+      const tracked_objects::Location& from_here,
+      Task* task,
+      int64 delay_ms) {
+    return ChromeThread::PostNonNestableDelayedTask(id_, from_here, task,
+                                                    delay_ms);
+  }
+
+ private:
+  ChromeThread::ID id_;
+  DISALLOW_COPY_AND_ASSIGN(ChromeThreadMessageLoopProxy);
+};
+
+
 Lock ChromeThread::lock_;
 
 ChromeThread* ChromeThread::chrome_threads_[ID_COUNT];
@@ -122,6 +161,14 @@ bool ChromeThread::GetCurrentThreadIdentifier(ID* identifier) {
 }
 
 // static
+scoped_refptr<MessageLoopProxy> ChromeThread::GetMessageLoopProxyForThread(
+    ID identifier) {
+  scoped_refptr<MessageLoopProxy> proxy =
+      new ChromeThreadMessageLoopProxy(identifier);
+  return proxy;
+}
+
+// static
 bool ChromeThread::PostTaskHelper(
     ID identifier,
     const tracked_objects::Location& from_here,