[Offline Pages] Adding a network check in test scheduler.

chrome/browser/android/offline_pages/evaluation/evaluation_test_scheduler.cc

 // Copyright 2016 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/android/offline_pages/evaluation/evaluation_test_scheduler.h"
 
 #include "base/logging.h"
 #include "base/threading/thread_task_runner_handle.h"
 #include "chrome/browser/android/offline_pages/request_coordinator_factory.h"
 #include "chrome/browser/profiles/profile.h"
@@ skipping 19 matching lines @@
 }
 
 void GetAllRequestsDone(
     std::vector<std::unique_ptr<SavePageRequest>> requests) {
   if (requests.size() > 0) {
     Profile* profile = ProfileManager::GetLastUsedProfile();
     RequestCoordinator* coordinator =
         RequestCoordinatorFactory::GetInstance()->GetForBrowserContext(profile);
     // TODO(romax) Maybe get current real condition.
     DeviceConditions device_conditions(
-        true, 0, net::NetworkChangeNotifier::ConnectionType::CONNECTION_WIFI);
+        true, 0, net::NetworkChangeNotifier::GetConnectionType());
     coordinator->StartImmediateProcessing(device_conditions,
                                           base::Bind(&ProcessingDoneCallback));
   }
 }
 
 void StartProcessing() {
+  // If there's no network connection then try in 2 seconds.
+  if (net::NetworkChangeNotifier::GetConnectionType() ==
+      net::NetworkChangeNotifier::ConnectionType::CONNECTION_NONE) {
+    base::ThreadTaskRunnerHandle::Get()->PostDelayedTask(
+        FROM_HERE, base::Bind(&StartProcessing),
+        base::TimeDelta::FromSeconds(2));
+    return;
+  }
   Profile* profile = ProfileManager::GetLastUsedProfile();
   RequestCoordinator* coordinator =
       RequestCoordinatorFactory::GetInstance()->GetForBrowserContext(profile);
   coordinator->GetAllRequests(base::Bind(&GetAllRequestsDone));
 }
 
 }  // namespace
 
 void EvaluationTestScheduler::Schedule(
     const TriggerConditions& trigger_conditions) {
   Profile* profile = ProfileManager::GetLastUsedProfile();
   if (!coordinator_) {
     coordinator_ =
         RequestCoordinatorFactory::GetInstance()->GetForBrowserContext(profile);
     // It's not expected that the coordinator would be nullptr since this bridge
     // would only be used for testing scenario.
     DCHECK(coordinator_);
   }
   coordinator_->GetLogger()->RecordActivity(std::string(kLogTag) +
                                             " Start schedule!");
   base::ThreadTaskRunnerHandle::Get()->PostTask(FROM_HERE,
                                                 base::Bind(&StartProcessing));
 }
 
 void EvaluationTestScheduler::BackupSchedule(
     const TriggerConditions& trigger_conditions,
-    long delay_in_seconds) {}
+    long delay_in_seconds) {
+  // This method is not expected to be called in test harness. Adding a log in
+  // case we somehow get called here and need to implement the method.
+  coordinator_->GetLogger()->RecordActivity(std::string(kLogTag) +
+                                            " BackupSchedule called!");
+}
 
-void EvaluationTestScheduler::Unschedule() {}
+void EvaluationTestScheduler::Unschedule() {
+  // This method is not expected to be called in test harness. Adding a log in
+  // case we somehow get called here and need to implement the method.
+  coordinator_->GetLogger()->RecordActivity(std::string(kLogTag) +
+                                            " Unschedule called!");
+}
 
 void EvaluationTestScheduler::ImmediateScheduleCallback(bool result) {
   base::ThreadTaskRunnerHandle::Get()->PostTask(FROM_HERE,
                                                 base::Bind(&StartProcessing));
 }
 
 }  // namespace android
 }  // namespace offline_pages