Use MessageLoopProxy for network message loop.

remoting/client/client_context.cc

 // Copyright (c) 2010 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/client/client_context.h"
 
+#include "base/bind.h"
+#include "base/synchronization/waitable_event.h"
+
 namespace remoting {
 
+namespace {
+void InitializeMessageLoopProxy(
+    scoped_refptr<base::MessageLoopProxy>* proxy,
+    base::WaitableEvent* done) {
+  *proxy = base::MessageLoopProxy::CreateForCurrentThread();
+  done->Signal();
+}
+
+}  // namespace
+
 ClientContext::ClientContext()
     : main_thread_("ChromotingClientMainThread"),
       decode_thread_("ChromotingClientDecodeThread"),
       network_thread_("ChromotingClientNetworkThread") {
 }
 
 ClientContext::~ClientContext() {
 }
 
 void ClientContext::Start() {
   // Start all the threads.
   main_thread_.Start();
   decode_thread_.Start();
   network_thread_.StartWithOptions(
       base::Thread::Options(MessageLoop::TYPE_IO, 0));
+
+  // Initialize |network_message_loop_| on the network thread.
+  base::WaitableEvent proxy_event(true, false);
+  network_thread_.message_loop()->PostTask(FROM_HERE, base::Bind(
+      &InitializeMessageLoopProxy, &network_message_loop_, &proxy_event));

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

Is there a reason we can't just call message_loop_proxy() on |network_thread_|
here?

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

I didn't know about Thread::message_loop_proxy(). WIll fix it. Thanks!

+  proxy_event.Wait();
 }
 
 void ClientContext::Stop() {
   // Stop all the threads.
   network_thread_.Stop();
   decode_thread_.Stop();
   main_thread_.Stop();
 }
 
 MessageLoop* ClientContext::main_message_loop() {
   return main_thread_.message_loop();
 }
 
 MessageLoop* ClientContext::decode_message_loop() {
   return decode_thread_.message_loop();
 }
 
-MessageLoop* ClientContext::network_message_loop() {
-  return network_thread_.message_loop();
+base::MessageLoopProxy* ClientContext::network_message_loop() {
+  return network_message_loop_;
 }
 
 }  // namespace remoting