Add PluginMessageLoopProxy and use it for Host plugin UI thread.

remoting/protocol/protocol_test_client.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 "build/build_config.h"
 
 #if !defined(OS_WIN)
 extern "C" {
 #include <unistd.h>
 }
 #endif  // !defined(OS_WIN)
 
 #include <iostream>
 #include <list>
 
 #include "base/at_exit.h"
 #include "base/bind.h"
 #include "base/command_line.h"
 #include "base/message_loop_proxy.h"
+#include "base/synchronization/waitable_event.h"
 #include "base/test/mock_chrome_application_mac.h"
 #include "base/time.h"
 #include "crypto/nss_util.h"
 #include "net/base/completion_callback.h"
 #include "net/base/io_buffer.h"
 #include "net/base/net_errors.h"
 #include "net/socket/socket.h"
 #include "remoting/base/constants.h"
 #include "remoting/jingle_glue/jingle_thread.h"
 #include "remoting/jingle_glue/xmpp_signal_strategy.h"
 #include "remoting/protocol/jingle_session_manager.h"
 
 namespace remoting {
 namespace protocol {
 
 namespace {
+
 const int kBufferSize = 4096;
 const char kDummyAuthToken[] = "";
+
+void InitializeMessageLoopProxy(
+    scoped_refptr<base::MessageLoopProxy>* proxy,
+    base::WaitableEvent* done) {
+  *proxy = base::MessageLoopProxy::CreateForCurrentThread();
+  done->Signal();
+}
+
 }  // namespace
 
 class ProtocolTestClient;
 
 class ProtocolTestConnection
     : public base::RefCountedThreadSafe<ProtocolTestConnection> {
  public:
   ProtocolTestConnection(ProtocolTestClient* client)
       : client_(client),
         message_loop_(MessageLoop::current()),
@@ skipping 164 matching lines @@
   }
 }
 
 void ProtocolTestClient::Run(const std::string& username,
                              const std::string& auth_token,
                              const std::string& auth_service,
                              const std::string& host_jid) {
   remoting::JingleThread jingle_thread;
   jingle_thread.Start();
 
+  scoped_refptr<base::MessageLoopProxy> network_message_loop;
+  base::WaitableEvent proxy_event(true, false);
+  jingle_thread.message_loop()->PostTask(FROM_HERE, base::Bind(
+      &InitializeMessageLoopProxy, &network_message_loop, &proxy_event));
+  proxy_event.Wait();
+
   signal_strategy_.reset(
       new XmppSignalStrategy(&jingle_thread, username, auth_token,
                              auth_service));
   signal_strategy_->Init(this);
-  session_manager_.reset(JingleSessionManager::CreateNotSandboxed(
-      jingle_thread.message_loop_proxy()));
+  session_manager_.reset(
+      JingleSessionManager::CreateNotSandboxed(network_message_loop));
 
   host_jid_ = host_jid;
 
   while (true) {
     std::string line;
     std::getline(std::cin, line);
 
     {
       base::AutoLock auto_lock(connections_lock_);
 
@@ skipping 121 matching lines @@
   std::string auth_service("oauth2");
   if (cmd_line->HasSwitch("auth_service"))
     auth_service = cmd_line->GetSwitchValueASCII("auth_service");
 
   scoped_refptr<ProtocolTestClient> client(new ProtocolTestClient());
 
   client->Run(username, auth_token, host_jid, auth_service);
 
   return 0;
 }