Add WaitForCondition() and use it in ExtensionTestNotificationObserver.

chrome/browser/extensions/extension_test_notification_observer.cc

 // Copyright 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 "chrome/browser/extensions/extension_test_notification_observer.h"
 
 #include "chrome/browser/extensions/extension_process_manager.h"
 #include "chrome/browser/extensions/extension_service.h"
 #include "chrome/browser/extensions/extension_system.h"
 #include "chrome/browser/profiles/profile_manager.h"
 #include "chrome/browser/ui/browser.h"
 #include "chrome/browser/ui/browser_window.h"
 #include "chrome/common/extensions/extension.h"
 #include "content/public/browser/notification_registrar.h"
 #include "content/public/browser/notification_service.h"
 #include "content/public/browser/render_view_host.h"
 #include "content/public/test/test_utils.h"
 
 using extensions::Extension;
 
 namespace {
 
+class ConditionRunLoop {
+ public:
+  typedef base::Callback<bool(void)> ConditionCallback;
+
+  explicit ConditionRunLoop(const ConditionCallback& callback);
+
+  void Wait();
+
+  void Check();
+
+ private:
+  base::RunLoop run_loop_;

[Avi (use Gerrit), 2013/10/23 19:21:53]

MessageLoopRunner is probably a better choice.

+  ConditionCallback condition_callback_;
+};
+
+ConditionRunLoop::ConditionRunLoop(const ConditionCallback& callback)
+    : condition_callback_(callback) {}
+
+void ConditionRunLoop::Wait() {
+  if (condition_callback_.Run())
+    return;
+
+  run_loop_.Run();
+}
+
+void ConditionRunLoop::Check() {
+  if (condition_callback_.Run())
+    run_loop_.Quit();
+}
+
 bool HasExtensionPageActionCountReachedTarget(LocationBarTesting* location_bar,
                                               int target_page_action_count) {
   VLOG(1) << "Number of page actions: " << location_bar->PageActionCount();
   return location_bar->PageActionCount() == target_page_action_count;
 }
 
 bool HasExtensionPageActionVisibilityReachedTarget(
     LocationBarTesting* location_bar,
     int target_visible_page_action_count) {
   VLOG(1) << "Number of visible page actions: "
           << location_bar->PageActionVisibleCount();
   return location_bar->PageActionVisibleCount() ==
          target_visible_page_action_count;
 }
 
+class NotificationCallbackRunner : public content::NotificationObserver {
+ public:
+  NotificationCallbackRunner(int type,
+                             const content::NotificationSource& source,
+                             const base::Closure& callback);
+
+ private:
+  // content::NotificationObserver
+  virtual void Observe(int type,
+                       const content::NotificationSource& source,
+                       const content::NotificationDetails& details) OVERRIDE;
+
+  content::NotificationRegistrar notification_registrar_;
+  base::Closure callback_;
+};
+
+NotificationCallbackRunner::NotificationCallbackRunner(
+    int type,
+    const content::NotificationSource& source,
+    const base::Closure& callback)
+    : callback_(callback) {
+  notification_registrar_.Add(this, type, source);
+}
+
+void NotificationCallbackRunner::Observe(
+    int type,
+    const content::NotificationSource& source,
+    const content::NotificationDetails& details) {
+  callback_.Run();
+}
+
+void WaitForConditionWithNotification(
+    const base::Callback<bool(void)>& condition,
+    int type,
+    const content::NotificationSource& source) {
+  ConditionRunLoop run_loop(condition);
+  NotificationCallbackRunner callback_runner(
+      type,
+      source,
+      base::Bind(&ConditionRunLoop::Check, base::Unretained(&run_loop)));
+  run_loop.Wait();
+}
+
+void WaitForConditionWithNotification(
+    const base::Callback<bool(void)>& condition,
+    int type) {
+  WaitForConditionWithNotification(
+      condition, type, content::NotificationService::AllSources());
+}
+
 }  // namespace
 
 ExtensionTestNotificationObserver::ExtensionTestNotificationObserver(
     Browser* browser)
     : browser_(browser),
       profile_(NULL),
       extension_installs_observed_(0),
       extension_load_errors_observed_(0),
       crx_installers_done_observed_(0) {
 }
@@ skipping 19 matching lines @@
   registrar.Add(
       this, notification_type, content::NotificationService::AllSources());
   content::WindowedNotificationObserver(
       notification_type, content::NotificationService::AllSources()).Wait();
 }
 
 bool ExtensionTestNotificationObserver::WaitForPageActionCountChangeTo(
     int count) {
   LocationBarTesting* location_bar =
       browser_->window()->GetLocationBar()->GetLocationBarForTesting();
-  if (!HasExtensionPageActionCountReachedTarget(location_bar, count)) {
-    content::WindowedNotificationObserver(
-        chrome::NOTIFICATION_EXTENSION_PAGE_ACTION_COUNT_CHANGED,
-        base::Bind(
-            &HasExtensionPageActionCountReachedTarget, location_bar, count))
-        .Wait();
-  }
-  return HasExtensionPageActionCountReachedTarget(location_bar, count);
+  WaitForConditionWithNotification(
+      base::Bind(
+          &HasExtensionPageActionCountReachedTarget, location_bar, count),
+      chrome::NOTIFICATION_EXTENSION_PAGE_ACTION_COUNT_CHANGED);
+  return true;
 }
 
 bool ExtensionTestNotificationObserver::WaitForPageActionVisibilityChangeTo(
     int count) {
   LocationBarTesting* location_bar =
       browser_->window()->GetLocationBar()->GetLocationBarForTesting();
-  if (!HasExtensionPageActionVisibilityReachedTarget(location_bar, count)) {
-    content::WindowedNotificationObserver(
-        chrome::NOTIFICATION_EXTENSION_PAGE_ACTION_VISIBILITY_CHANGED,
-        base::Bind(&HasExtensionPageActionVisibilityReachedTarget,
-                   location_bar,
-                   count)).Wait();
-  }
-  return HasExtensionPageActionVisibilityReachedTarget(location_bar, count);
+  WaitForConditionWithNotification(
+      base::Bind(
+          &HasExtensionPageActionVisibilityReachedTarget, location_bar, count),
+      chrome::NOTIFICATION_EXTENSION_PAGE_ACTION_VISIBILITY_CHANGED);
+  return true;
 }
 
 bool ExtensionTestNotificationObserver::WaitForExtensionViewsToLoad() {
   ExtensionProcessManager* manager =
-    extensions::ExtensionSystem::Get(GetProfile())->process_manager();
+      extensions::ExtensionSystem::Get(GetProfile())->process_manager();
   ExtensionProcessManager::ViewSet all_views = manager->GetAllViews();
   for (ExtensionProcessManager::ViewSet::const_iterator iter =
          all_views.begin();
        iter != all_views.end();) {
     if (!(*iter)->IsLoading()) {
       ++iter;
     } else {
       // Wait for all the extension render view hosts that exist to finish
       // loading.
       content::WindowedNotificationObserver observer(
           content::NOTIFICATION_LOAD_STOP,
           content::NotificationService::AllSources());
-      observer.AddNotificationType(
-                                   content::NOTIFICATION_WEB_CONTENTS_DESTROYED,
+      observer.AddNotificationType(content::NOTIFICATION_WEB_CONTENTS_DESTROYED,
                                    content::NotificationService::AllSources());
       observer.Wait();
 
       // Test activity may have modified the set of extension processes during
       // message processing, so re-start the iteration to catch added/removed
       // processes.
       all_views = manager->GetAllViews();
       iter = all_views.begin();
     }
   }
@@ skipping 97 matching lines @@
   case chrome::NOTIFICATION_EXTENSION_LOAD_ERROR:
     VLOG(1) << "Got EXTENSION_LOAD_ERROR notification.";
     ++extension_load_errors_observed_;
     break;
 
   default:
     NOTREACHED();
     break;
   }
 }