| Index: chrome/browser/android/offline_pages/evaluation/evaluation_test_scheduler.cc
|
| diff --git a/chrome/browser/android/offline_pages/evaluation/evaluation_test_scheduler.cc b/chrome/browser/android/offline_pages/evaluation/evaluation_test_scheduler.cc
|
| new file mode 100644
|
| index 0000000000000000000000000000000000000000..03eabe2c009a32681cfb69e136185ccbb1f37b4e
|
| --- /dev/null
|
| +++ b/chrome/browser/android/offline_pages/evaluation/evaluation_test_scheduler.cc
|
| @@ -0,0 +1,70 @@
|
| +// 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"
|
| +#include "chrome/browser/profiles/profile_manager.h"
|
| +#include "components/offline_pages/background/device_conditions.h"
|
| +#include "components/offline_pages/background/request_coordinator.h"
|
| +#include "net/base/network_change_notifier.h"
|
| +
|
| +namespace offline_pages {
|
| +
|
| +namespace android {
|
| +
|
| +namespace {
|
| +
|
| +void StartProcessing();
|
| +
|
| +void ProcessingDoneCallback(bool result) {
|
| + base::ThreadTaskRunnerHandle::Get()->PostTask(FROM_HERE,
|
| + base::Bind(&StartProcessing));
|
| +}
|
| +
|
| +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);
|
| + coordinator->StartProcessing(device_conditions,
|
| + base::Bind(&ProcessingDoneCallback));
|
| + }
|
| +}
|
| +
|
| +void StartProcessing() {
|
| + Profile* profile = ProfileManager::GetLastUsedProfile();
|
| + RequestCoordinator* coordinator =
|
| + RequestCoordinatorFactory::GetInstance()->GetForBrowserContext(profile);
|
| + coordinator->GetAllRequests(base::Bind(&GetAllRequestsDone));
|
| +}
|
| +
|
| +} // namespace
|
| +
|
| +void EvaluationTestScheduler::Schedule(
|
| + const TriggerConditions& trigger_conditions) {
|
| + base::ThreadTaskRunnerHandle::Get()->PostTask(FROM_HERE,
|
| + base::Bind(&StartProcessing));
|
| +}
|
| +
|
| +void EvaluationTestScheduler::BackupSchedule(
|
| + const TriggerConditions& trigger_conditions,
|
| + long delay_in_seconds) {}
|
| +
|
| +void EvaluationTestScheduler::Unschedule() {}
|
| +
|
| +void EvaluationTestScheduler::ImmediateScheduleCallback(bool result) {
|
| + base::ThreadTaskRunnerHandle::Get()->PostTask(FROM_HERE,
|
| + base::Bind(&StartProcessing));
|
| +}
|
| +
|
| +} // namespace android
|
| +} // namespace offline_pages
|
|
|