Upstream RunBlockingPoolTask().

chrome/browser/chromeos/drive/test_util.cc

Index: chrome/browser/chromeos/drive/test_util.cc
diff --git a/chrome/browser/chromeos/drive/test_util.cc b/chrome/browser/chromeos/drive/test_util.cc
index a4c31f70fffadbd31447ce6376316286eb9b0d1e..682f62d56c1a9f3d009ea989d7d3c868eb22be71 100644
--- a/chrome/browser/chromeos/drive/test_util.cc
+++ b/chrome/browser/chromeos/drive/test_util.cc
@@ -4,59 +4,14 @@
 
 #include "chrome/browser/chromeos/drive/test_util.h"
 
-#include <string>
-
-#include "base/message_loop/message_loop.h"
 #include "base/prefs/pref_registry_simple.h"
 #include "base/prefs/testing_pref_service.h"
-#include "base/run_loop.h"
-#include "base/threading/sequenced_worker_pool.h"
 #include "chrome/browser/chromeos/drive/drive.pb.h"
 #include "chrome/common/pref_names.h"
-#include "content/public/browser/browser_thread.h"
 
 namespace drive {
-
 namespace test_util {
 
-namespace {
-
-// This class is used to monitor if any task is posted to a message loop.
-class TaskObserver : public base::MessageLoop::TaskObserver {
- public:
-  TaskObserver() : posted_(false) {}
-  virtual ~TaskObserver() {}
-
-  // MessageLoop::TaskObserver overrides.
-  virtual void WillProcessTask(const base::PendingTask& pending_task) OVERRIDE {
-  }
-  virtual void DidProcessTask(const base::PendingTask& pending_task) OVERRIDE {
-    posted_ = true;
-  }
-
-  // Returns true if any task was posted.
-  bool posted() const { return posted_; }
-
- private:
-  bool posted_;
-  DISALLOW_COPY_AND_ASSIGN(TaskObserver);
-};
-
-}  // namespace
-
-void RunBlockingPoolTask() {
-  while (true) {
-    content::BrowserThread::GetBlockingPool()->FlushForTesting();
-
-    TaskObserver task_observer;
-    base::MessageLoop::current()->AddTaskObserver(&task_observer);
-    base::RunLoop().RunUntilIdle();
-    base::MessageLoop::current()->RemoveTaskObserver(&task_observer);
-    if (!task_observer.posted())
-      break;
-  }
-}
-
 void RegisterDrivePrefs(PrefRegistrySimple* pref_registry) {
   pref_registry->RegisterBooleanPref(
       prefs::kDisableDrive,