Refactor ChildProcess and related classes to create a framework outside of br...

chrome/common/socket_stream_dispatcher.cc

 // Copyright (c) 2009 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 "chrome/common/socket_stream_dispatcher.h"
 
 #include <vector>
 
 #include "base/id_map.h"
 #include "base/ref_counted.h"
-#include "chrome/common/child_thread.h"
+#include "base/mp/mp_child_thread.h"
 #include "chrome/common/render_messages.h"
 #include "chrome/common/net/socket_stream.h"
 #include "googleurl/src/gurl.h"
 #include "webkit/glue/websocketstreamhandle_bridge.h"
 #include "webkit/glue/websocketstreamhandle_delegate.h"
 
 // IPCWebSocketStreamHandleBridge is owned by each SocketStreamHandle.
 // It communicates with the main browser process via SocketStreamDispatcher.
 class IPCWebSocketStreamHandleBridge
     : public webkit_glue::WebSocketStreamHandleBridge {
  public:
   IPCWebSocketStreamHandleBridge(
-      ChildThread* child_thread,
+      base::MpChildThread* child_thread,
       WebKit::WebSocketStreamHandle* handle,
       webkit_glue::WebSocketStreamHandleDelegate* delegate)
       : socket_id_(chrome_common_net::kNoSocketId),
         child_thread_(child_thread),
         handle_(handle),
         delegate_(delegate) {}
 
   // Returns the handle having given id or NULL if there is no such handle.
   static IPCWebSocketStreamHandleBridge* FromSocketId(int id);
 
   // webkit_glue::WebSocketStreamHandleBridge methods.
   virtual void Connect(const GURL& url);
   virtual bool Send(const std::vector<char>& data);
   virtual void Close();
 
   // Called by SocketStreamDispatcher.
   void OnConnected(int max_amount_send_allowed);
   void OnSentData(int amount_sent);
   void OnReceivedData(const std::vector<char>& data);
   void OnClosed();
 
  private:
   virtual ~IPCWebSocketStreamHandleBridge();
 
   void DoConnect(const GURL& url);
   int socket_id_;
 
-  ChildThread* child_thread_;
+  base::MpChildThread* child_thread_;
   WebKit::WebSocketStreamHandle* handle_;
   webkit_glue::WebSocketStreamHandleDelegate* delegate_;
 
   static IDMap<IPCWebSocketStreamHandleBridge> all_bridges;
 };
 
 IDMap<IPCWebSocketStreamHandleBridge>
 IPCWebSocketStreamHandleBridge::all_bridges;
 
 /* static */
@@ skipping 89 matching lines @@
 
 SocketStreamDispatcher::SocketStreamDispatcher() {
 }
 
 /* static */
 webkit_glue::WebSocketStreamHandleBridge*
 SocketStreamDispatcher::CreateBridge(
     WebKit::WebSocketStreamHandle* handle,
     webkit_glue::WebSocketStreamHandleDelegate* delegate) {
   return new IPCWebSocketStreamHandleBridge(
-      ChildThread::current(), handle, delegate);
+    base::MpChildThread::current(), handle, delegate);
 }
 
 bool SocketStreamDispatcher::OnMessageReceived(const IPC::Message& msg) {
   bool handled = true;
   IPC_BEGIN_MESSAGE_MAP(SocketStreamDispatcher, msg)
     IPC_MESSAGE_HANDLER(ViewMsg_SocketStream_Connected, OnConnected)
     IPC_MESSAGE_HANDLER(ViewMsg_SocketStream_SentData, OnSentData)
     IPC_MESSAGE_HANDLER(ViewMsg_SocketStream_ReceivedData, OnReceivedData)
     IPC_MESSAGE_HANDLER(ViewMsg_SocketStream_Closed, OnClosed)
     IPC_MESSAGE_UNHANDLED(handled = false)
@@ skipping 33 matching lines @@
 }
 
 void SocketStreamDispatcher::OnClosed(int socket_id) {
   IPCWebSocketStreamHandleBridge* bridge =
       IPCWebSocketStreamHandleBridge::FromSocketId(socket_id);
   if (bridge)
     bridge->OnClosed();
   else
     DLOG(ERROR) << "No SocketStreamHandleBridge for socket_id=" << socket_id;
 }