ipc: Use base::MessageLoop.

ipc/sync_socket_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 "base/sync_socket.h"
 
 #include <stdio.h>
 #include <string>
 #include <sstream>
 
@@ skipping 78 matching lines @@
     base::SyncSocket sync_socket(handle);
     EXPECT_EQ(sync_socket.Send(kHelloString, kHelloStringLength),
               kHelloStringLength);
     IPC::Message* msg = new MsgClassResponse(kHelloString);
     EXPECT_TRUE(chan_->Send(msg));
   }
 
   // When the client responds, it sends back a shutdown message,
   // which causes the message loop to exit.
   void OnMsgClassShutdown() {
-    MessageLoop::current()->Quit();
+    base::MessageLoop::current()->Quit();
   }
 
   IPC::Channel* chan_;
 
   DISALLOW_COPY_AND_ASSIGN(SyncSocketServerListener);
 };
 
 // Runs the fuzzing server child mode. Returns when the preset number of
 // messages have been received.
 MULTIPROCESS_IPC_TEST_CLIENT_MAIN(SyncSocketServerClient) {
-  MessageLoopForIO main_message_loop;
+  base::MessageLoopForIO main_message_loop;
   SyncSocketServerListener listener;
   IPC::Channel channel(IPCTestBase::GetChannelName("SyncSocketServerClient"),
                        IPC::Channel::MODE_CLIENT,
                        &listener);
   EXPECT_TRUE(channel.Connect());
   listener.Init(&channel);
-  MessageLoop::current()->Run();
+  base::MessageLoop::current()->Run();
   return 0;
 }
 
 // The SyncSocket client listener only processes one sort of message,
 // a response from the server.
 class SyncSocketClientListener : public IPC::Listener {
  public:
   SyncSocketClientListener() {
   }
 
@@ skipping 19 matching lines @@
     // We rely on the order of sync_socket.Send() and chan_->Send() in
     // the SyncSocketServerListener object.
     EXPECT_EQ(kHelloStringLength, socket_->Peek());
     char buf[kHelloStringLength];
     socket_->Receive(static_cast<void*>(buf), kHelloStringLength);
     EXPECT_EQ(strcmp(str.c_str(), buf), 0);
     // After receiving from the socket there should be no bytes left.
     EXPECT_EQ(0U, socket_->Peek());
     IPC::Message* msg = new MsgClassShutdown();
     EXPECT_TRUE(chan_->Send(msg));
-    MessageLoop::current()->Quit();
+    base::MessageLoop::current()->Quit();
   }
 
   base::SyncSocket* socket_;
   IPC::Channel* chan_;
 
   DISALLOW_COPY_AND_ASSIGN(SyncSocketClientListener);
 };
 
 class SyncSocketTest : public IPCTestBase {
 };
@@ skipping 23 matching lines @@
   // Set up a message to pass the handle to the server.
   IPC::Message* msg = new MsgClassSetHandle(target_handle);
 #else
   target_handle = pair[1].handle();
   // Set up a message to pass the handle to the server.
   base::FileDescriptor filedesc(target_handle, false);
   IPC::Message* msg = new MsgClassSetHandle(filedesc);
 #endif  // defined(OS_WIN)
   EXPECT_TRUE(sender()->Send(msg));
   // Use the current thread as the I/O thread.
-  MessageLoop::current()->Run();
+  base::MessageLoop::current()->Run();
   // Shut down.
   pair[0].Close();
   pair[1].Close();
   EXPECT_TRUE(WaitForClientShutdown());
   DestroyChannel();
 }
 
 // A blocking read operation that will block the thread until it receives
 // |length| bytes of packets or Shutdown() is called on another thread.
 static void BlockingRead(base::SyncSocket* socket, char* buf,
@@ skipping 88 matching lines @@
 
   // Read from another socket to free some space for a new write.
   char hello[kHelloStringLength] = {0};
   pair[1].Receive(&hello[0], sizeof(hello));
 
   // Should be able to write more data to the buffer now.
   EXPECT_EQ(kHelloStringLength, pair[0].Send(kHelloString, kHelloStringLength));
 }
 
 }  // namespace