Use MessageLoopProxy for network message loop.

remoting/host/chromoting_host_context.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 "remoting/host/chromoting_host_context.h"
 
 #include <string>
 
 #include "base/bind.h"
+#include "base/synchronization/waitable_event.h"
 #include "base/threading/thread.h"
 #include "remoting/jingle_glue/jingle_thread.h"
 
 namespace remoting {
 
+namespace {
+void InitializeMessageLoopProxy(
+    scoped_refptr<base::MessageLoopProxy>* proxy,
+    base::WaitableEvent* done) {
+  *proxy = base::MessageLoopProxy::CreateForCurrentThread();
+  done->Signal();
+}
+}  // namespace
+
 ChromotingHostContext::ChromotingHostContext()
     : main_thread_("ChromotingMainThread"),
       encode_thread_("ChromotingEncodeThread"),
       desktop_thread_("ChromotingDesktopThread") {
 }
 
 ChromotingHostContext::~ChromotingHostContext() {
 }
 
 void ChromotingHostContext::Start() {
   // Start all the threads.
   main_thread_.Start();
   encode_thread_.Start();
   jingle_thread_.Start();
   desktop_thread_.Start();
+
+  // Initialize |network_message_loop_| on the network thread.
+  base::WaitableEvent proxy_event(true, false);
+  jingle_thread_.message_loop()->PostTask(FROM_HERE, base::Bind(
+      &InitializeMessageLoopProxy, &network_message_loop_, &proxy_event));
+  proxy_event.Wait();

[Wez, 2011/08/12 21:11:20]

Again, use message_loop_proxy() here?

[Sergey Ulanov, 2011/08/12 21:24:18]

Added message_loop_proxy() in JingleThread.

 }
 
 void ChromotingHostContext::Stop() {
   // Stop all the threads.
   jingle_thread_.Stop();
   encode_thread_.Stop();
   main_thread_.Stop();
   desktop_thread_.Stop();
 }
 
 JingleThread* ChromotingHostContext::jingle_thread() {
   return &jingle_thread_;
 }
 
 MessageLoop* ChromotingHostContext::main_message_loop() {
   return main_thread_.message_loop();
 }
 
 MessageLoop* ChromotingHostContext::encode_message_loop() {
   return encode_thread_.message_loop();
 }
 
-MessageLoop* ChromotingHostContext::network_message_loop() {
-  return jingle_thread_.message_loop();
+base::MessageLoopProxy* ChromotingHostContext::network_message_loop() {
+  return network_message_loop_;
 }
 
 MessageLoop* ChromotingHostContext::desktop_message_loop() {
   return desktop_thread_.message_loop();
 }
 
 void ChromotingHostContext::SetUITaskPostFunction(
     const UIThreadPostTaskFunction& poster) {
   ui_poster_ = poster;
   ui_main_thread_id_ = base::PlatformThread::CurrentId();
@@ skipping 14 matching lines @@
   main_message_loop()->PostDelayedTask(from_here, base::Bind(
       &ChromotingHostContext::PostTaskToUIThread, base::Unretained(this),
       from_here, task), delay_ms);
 }
 
 bool ChromotingHostContext::IsUIThread() const {
   return ui_main_thread_id_ == base::PlatformThread::CurrentId();
 }
 
 }  // namespace remoting