WIP attempt to replace StartWorker/StopWorker IPCs with a new mojo EmbeddedWorker service.

content/browser/geofencing/geofencing_manager_unittest.cc

 // Copyright 2014 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/callback.h"
 #include "base/message_loop/message_loop.h"
 #include "content/browser/geofencing/geofencing_manager.h"
 #include "content/browser/geofencing/geofencing_service.h"
 #include "content/browser/service_worker/embedded_worker_test_helper.h"
 #include "content/browser/service_worker/service_worker_context_wrapper.h"
 #include "content/public/test/test_browser_thread_bundle.h"
 #include "content/public/test/test_utils.h"
 #include "testing/gmock/include/gmock/gmock.h"
 #include "testing/gtest/include/gtest/gtest.h"
 #include "third_party/WebKit/public/platform/WebCircularGeofencingRegion.h"
 
 using blink::WebCircularGeofencingRegion;
 typedef std::map<std::string, WebCircularGeofencingRegion> RegionMap;
 
 namespace {
 
-static const int kRenderProcessId = 99;
 static const char* kTestRegionId = "region-id";
 static const int64 kTestGeofencingRegistrationId = 42;
 static const int64 kTestGeofencingRegistrationId2 = 43;
 
 bool RegionsMatch(const WebCircularGeofencingRegion& expected,
                   const WebCircularGeofencingRegion& arg) {
   return testing::Matches(expected.latitude)(arg.latitude) &&
          testing::Matches(expected.longitude)(arg.longitude) &&
          testing::Matches(expected.radius)(arg.radius);
 }
@@ skipping 48 matching lines @@
     CHECK(was_called_);
     return result_;
   }
 
  private:
   bool was_called_;
   GeofencingStatus result_;
   scoped_refptr<MessageLoopRunner> runner_;
 };
 
-void SaveResponseCallback(bool* called,
-                          int64* store_registration_id,
+void SaveResponseCallback(int64* store_registration_id,
+                          const scoped_refptr<MessageLoopRunner> runner,
                           ServiceWorkerStatusCode status,
                           const std::string& status_message,
                           int64 registration_id) {
   EXPECT_EQ(SERVICE_WORKER_OK, status) << ServiceWorkerStatusToString(status);
-  *called = true;
   *store_registration_id = registration_id;
+  runner->Quit();
 }
 
 ServiceWorkerContextCore::RegistrationCallback MakeRegisteredCallback(
-    bool* called,
-    int64* store_registration_id) {
-  return base::Bind(&SaveResponseCallback, called, store_registration_id);
+    int64* store_registration_id,
+    const scoped_refptr<MessageLoopRunner>& runner) {
+  return base::Bind(&SaveResponseCallback, store_registration_id, runner);
 }
 
 void CallCompletedCallback(bool* called, ServiceWorkerStatusCode) {
   *called = true;
 }
 
 ServiceWorkerContextCore::UnregistrationCallback MakeUnregisteredCallback(
     bool* called) {
   return base::Bind(&CallCompletedCallback, called);
 }
 
 class GeofencingManagerTest : public testing::Test {
  public:
   GeofencingManagerTest() : service_(nullptr) {
     test_region_.latitude = 37.421999;
     test_region_.longitude = -122.084015;
     test_region_.radius = 100;
     expected_regions_[kTestRegionId] = test_region_;
   }
 
   void SetUp() override {
-    helper_.reset(
-        new EmbeddedWorkerTestHelper(base::FilePath(), kRenderProcessId));
+    helper_.reset(new EmbeddedWorkerTestHelper(base::FilePath()));
     service_ = new TestGeofencingService();
     manager_ = new GeofencingManager(helper_->context_wrapper());
     manager_->SetServiceForTesting(service_);
     manager_->Init();
 
     worker1_ = RegisterServiceWorker("1");
     worker2_ = RegisterServiceWorker("2");
   }
 
   void TearDown() override {
     worker1_ = nullptr;
     worker2_ = nullptr;
     manager_ = nullptr;
     delete service_;
     service_ = nullptr;
     helper_.reset();
   }
 
   void SetHasProviderForTests() { service_->SetIsServiceAvailable(true); }
 
   scoped_refptr<ServiceWorkerRegistration> RegisterServiceWorker(
       const std::string& name) {
     GURL pattern("http://www.example.com/" + name);
     GURL script_url("http://www.example.com/service_worker.js");
     int64 registration_id = kInvalidServiceWorkerRegistrationId;
-    bool called = false;
+    scoped_refptr<MessageLoopRunner> runner(new MessageLoopRunner);
     helper_->context()->RegisterServiceWorker(
         pattern, script_url, nullptr,
-        MakeRegisteredCallback(&called, &registration_id));
+        MakeRegisteredCallback(&registration_id, runner));
 
-    EXPECT_FALSE(called);
-    base::RunLoop().RunUntilIdle();
-    EXPECT_TRUE(called);
+    runner->Run();
     scoped_refptr<ServiceWorkerRegistration> worker(
         new ServiceWorkerRegistration(pattern, registration_id,
                                       helper_->context()->AsWeakPtr()));
     // ServiceWorkerRegistration posts a notification task on construction.
     base::RunLoop().RunUntilIdle();
     return worker;
   }
 
   void UnregisterServiceWorker(
       const scoped_refptr<ServiceWorkerRegistration>& registration) {
@@ skipping 337 matching lines @@
                 GEOFENCING_STATUS_OK, kTestGeofencingRegistrationId));
   VerifyRegions(worker1_->id(), expected_regions_);
 
   EXPECT_CALL(*service_, UnregisterRegion(kTestGeofencingRegistrationId));
 
   manager_->SetMockProvider(GeofencingMockState::SERVICE_AVAILABLE);
   VerifyRegions(worker1_->id(), RegionMap());
 }
 
 }  // namespace content