ipc: Use base::MessageLoop.

ipc/ipc_channel_unittest.cc

 // Copyright (c) 2012 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)
 #include <windows.h>
 #endif
 
@@ skipping 47 matching lines @@
     EXPECT_TRUE(iter.ReadString(&big_string));
     EXPECT_EQ(kLongMessageStringNumBytes - 1, big_string.length());
 
     SendNextMessage();
     return true;
   }
 
   virtual void OnChannelError() OVERRIDE {
     // There is a race when closing the channel so the last message may be lost.
     EXPECT_LE(messages_left_, 1);
-    MessageLoop::current()->Quit();
+    base::MessageLoop::current()->Quit();
   }
 
   void Init(IPC::Sender* s) {
     sender_ = s;
   }
 
  protected:
   void SendNextMessage() {
     if (--messages_left_ <= 0)
-      MessageLoop::current()->Quit();
+      base::MessageLoop::current()->Quit();
     else
       Send(sender_, "Foo");
   }
 
  private:
   IPC::Sender* sender_;
   int messages_left_;
 };
 
 class IPCChannelTest : public IPCTestBase {
@@ skipping 37 matching lines @@
   // Set up IPC channel and start client.
   GenericChannelListener listener;
   CreateChannel(&listener);
   listener.Init(sender());
   ASSERT_TRUE(ConnectChannel());
   ASSERT_TRUE(StartClient());
 
   Send(sender(), "hello from parent");
 
   // Run message loop.
-  MessageLoop::current()->Run();
+  base::MessageLoop::current()->Run();
 
   // Close the channel so the client's OnChannelError() gets fired.
   channel()->Close();
 
   EXPECT_TRUE(WaitForClientShutdown());
   DestroyChannel();
 }
 
 // TODO(viettrungluu): Move to a separate IPCChannelWinTest.
 #if defined(OS_WIN)
@@ skipping 18 matching lines @@
   CloseHandle(pipe);  // The channel duplicates the handle.
   listener.Init(sender());
 
   // Connect to channel and start client.
   ASSERT_TRUE(ConnectChannel());
   ASSERT_TRUE(StartClient());
 
   Send(sender(), "hello from parent");
 
   // Run message loop.
-  MessageLoop::current()->Run();
+  base::MessageLoop::current()->Run();
 
   // Close the channel so the client's OnChannelError() gets fired.
   channel()->Close();
 
   EXPECT_TRUE(WaitForClientShutdown());
   DestroyChannel();
 }
 #endif  // defined (OS_WIN)
 
 TEST_F(IPCChannelTest, ChannelProxyTest) {
   Init("GenericClient");
 
   base::Thread thread("ChannelProxyTestServer");
   base::Thread::Options options;
-  options.message_loop_type = MessageLoop::TYPE_IO;
+  options.message_loop_type = base::MessageLoop::TYPE_IO;
   thread.StartWithOptions(options);
 
   // Set up IPC channel proxy.
   GenericChannelListener listener;
   CreateChannelProxy(&listener, thread.message_loop_proxy());
   listener.Init(sender());
 
   ASSERT_TRUE(StartClient());
 
   Send(sender(), "hello from parent");
 
   // Run message loop.
-  MessageLoop::current()->Run();
+  base::MessageLoop::current()->Run();
 
   EXPECT_TRUE(WaitForClientShutdown());
 
   // Destroy the channel proxy before shutting down the thread.
   DestroyChannelProxy();
   thread.Stop();
 }
 
 class ChannelListenerWithOnConnectedSend : public GenericChannelListener {
  public:
@@ skipping 19 matching lines @@
   // Set up IPC channel and start client.
   ChannelListenerWithOnConnectedSend listener;
   CreateChannel(&listener);
   listener.Init(sender());
   ASSERT_TRUE(ConnectChannel());
   ASSERT_TRUE(StartClient());
 
   Send(sender(), "hello from parent");
 
   // Run message loop.
-  MessageLoop::current()->Run();
+  base::MessageLoop::current()->Run();
 
   // Close the channel so the client's OnChannelError() gets fired.
   channel()->Close();
 
   EXPECT_TRUE(WaitForClientShutdown());
   DestroyChannel();
 }
 
 MULTIPROCESS_IPC_TEST_CLIENT_MAIN(GenericClient) {
-  MessageLoopForIO main_message_loop;
+  base::MessageLoopForIO main_message_loop;
   GenericChannelListener listener;
 
   // Set up IPC channel.
   IPC::Channel channel(IPCTestBase::GetChannelName("GenericClient"),
                        IPC::Channel::MODE_CLIENT,
                        &listener);
   CHECK(channel.Connect());
   listener.Init(&channel);
   Send(&channel, "hello from child");
 
-  MessageLoop::current()->Run();
+  base::MessageLoop::current()->Run();
   return 0;
 }
 
 }  // namespace