Use MessageLoopProxy for network message loop.

remoting/protocol/connection_to_host.h

 // 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.
 
 #ifndef REMOTING_PROTOCOL_CONNECTION_TO_HOST_H_
 #define REMOTING_PROTOCOL_CONNECTION_TO_HOST_H_
 
 #include <string>
 
 #include "base/memory/ref_counted.h"
 #include "base/memory/scoped_ptr.h"
 #include "base/task.h"
 #include "remoting/jingle_glue/signal_strategy.h"
 #include "remoting/proto/internal.pb.h"
 #include "remoting/protocol/connection_to_host.h"
 #include "remoting/protocol/message_reader.h"
 #include "remoting/protocol/session.h"
 #include "remoting/protocol/session_manager.h"
 
-class MessageLoop;
+namespace base {
+class MessageLoopProxy;
+}  // namespace base
 
 namespace talk_base {
 class NetworkManager;
 class PacketSocketFactory;
 }  // namespace talk_base
 
 namespace remoting {
 
 class JingleThread;
 class HostResolverFactory;
@@ skipping 36 matching lines @@
     virtual void OnConnectionClosed(ConnectionToHost* conn) = 0;
 
     // Called when the network connection has failed.
     virtual void OnConnectionFailed(ConnectionToHost* conn) = 0;
   };
 
   // Takes ownership of |network_manager| and |socket_factory|. Both
   // |network_manager| and |socket_factory| may be set to NULL.
   //
   // TODO(sergeyu): Constructor shouldn't need thread here.
-  ConnectionToHost(MessageLoop* network_message_loop,
+  ConnectionToHost(base::MessageLoopProxy* network_message_loop,
                    talk_base::NetworkManager* network_manager,
                    talk_base::PacketSocketFactory* socket_factory,
                    HostResolverFactory* host_resolver_factory,
                    PortAllocatorSessionFactory* session_factory,
                    bool allow_nat_traversal);
   virtual ~ConnectionToHost();
 
   virtual void Connect(scoped_refptr<XmppProxy> xmpp_proxy,
                        const std::string& your_jid,
                        const std::string& host_jid,
@@ skipping 42 matching lines @@
   void NotifyIfChannelsReady();
 
   // Callback for |video_reader_|.
   void OnVideoPacket(VideoPacket* packet);
 
   void CloseOnError();
 
   // Stops writing in the channels.
   void CloseChannels();
 
-  MessageLoop* message_loop_;
+  scoped_refptr<base::MessageLoopProxy> message_loop_;
   scoped_ptr<talk_base::NetworkManager> network_manager_;
   scoped_ptr<talk_base::PacketSocketFactory> socket_factory_;
   scoped_ptr<HostResolverFactory> host_resolver_factory_;
   scoped_ptr<PortAllocatorSessionFactory> port_allocator_session_factory_;
   bool allow_nat_traversal_;
 
   std::string host_jid_;
   std::string host_public_key_;
   std::string access_code_;
 
@@ skipping 27 matching lines @@
  private:
   DISALLOW_COPY_AND_ASSIGN(ConnectionToHost);
 };
 
 }  // namespace protocol
 }  // namespace remoting
 
 DISABLE_RUNNABLE_METHOD_REFCOUNT(remoting::protocol::ConnectionToHost);
 
 #endif  // REMOTING_PROTOCOL_CONNECTION_TO_HOST_H_