Plug some of the leaks in dbus_unittests.

dbus/object_manager_unittest.cc

 // Copyright (c) 2013 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 "dbus/object_manager.h"
 
 #include <string>
 #include <vector>
 
 #include "base/basictypes.h"
 #include "base/bind.h"
 #include "base/message_loop/message_loop.h"
+#include "base/run_loop.h"
 #include "base/threading/thread.h"
 #include "base/threading/thread_restrictions.h"
 #include "dbus/bus.h"
 #include "dbus/object_path.h"
 #include "dbus/object_proxy.h"
 #include "dbus/property.h"
 #include "dbus/test_service.h"
 #include "testing/gtest/include/gtest/gtest.h"
 
 namespace dbus {
@@ skipping 75 matching lines @@
 
     // Shut down the service.
     test_service_->ShutdownAndBlock();
 
     // Reset to the default.
     base::ThreadRestrictions::SetIOAllowed(true);
 
     // Stopping a thread is considered an IO operation, so do this after
     // allowing IO.
     test_service_->Stop();
+
+    base::RunLoop().RunUntilIdle();
   }
 
   void MethodCallback(Response* response) {
     method_callback_called_ = true;
     message_loop_.Quit();
   }
 
  protected:
   // Called when an object is added.
   virtual void ObjectAdded(const ObjectPath& object_path,
@@ skipping 15 matching lines @@
     updated_properties_.push_back(name);
     message_loop_.Quit();
   }
 
   static const size_t kExpectedObjects = 1;
   static const size_t kExpectedProperties = 4;
 
   void WaitForObject() {
     while (added_objects_.size() < kExpectedObjects ||
            updated_properties_.size() < kExpectedProperties)
-      message_loop_.Run();
+      base::RunLoop().Run();
     for (size_t i = 0; i < kExpectedObjects; ++i)
       added_objects_.erase(added_objects_.begin());
     for (size_t i = 0; i < kExpectedProperties; ++i)
       updated_properties_.erase(updated_properties_.begin());
   }
 
   void WaitForRemoveObject() {
     while (removed_objects_.size() < kExpectedObjects)
-      message_loop_.Run();
+      base::RunLoop().Run();
     for (size_t i = 0; i < kExpectedObjects; ++i)
       removed_objects_.erase(removed_objects_.begin());
   }
 
   void WaitForMethodCallback() {
-    message_loop_.Run();
+    base::RunLoop().Run();
     method_callback_called_ = false;
   }
 
   void PerformAction(const std::string& action, const ObjectPath& object_path) {
     ObjectProxy* object_proxy = bus_->GetObjectProxy(
         "org.chromium.TestService",
         ObjectPath("/org/chromium/TestObject"));
 
     MethodCall method_call("org.chromium.TestInterface", "PerformAction");
     MessageWriter writer(&method_call);
@@ skipping 175 matching lines @@
 TEST_F(ObjectManagerTest, OwnershipLostAndRegained) {
   PerformAction("Ownership", ObjectPath("/org/chromium/TestService"));
   WaitForRemoveObject();
   WaitForObject();
 
   std::vector<ObjectPath> object_paths = object_manager_->GetObjects();
   ASSERT_EQ(1U, object_paths.size());
 }
 
 }  // namespace dbus