55ec69dc51
This change applies clang-tidy's modernize-use-auto [1] in /content/browser. This change does not rewrite new and cast expressions. Reproduction steps: - run clang-tidy's modernize-use-auto - run git cl format - manually remove unused typedefs due to -Wunused-local-typedef error [1] https://clang.llvm.org/extra/clang-tidy/checks/modernize-use-auto.html This CL was uploaded by git cl split. R=boliu@chromium.org, mkwst@chromium.org Bug: 890902 Change-Id: I06146497aa7a8cba7516eb17497ca33454141b2a Reviewed-on: https://chromium-review.googlesource.com/c/1257909 Reviewed-by: Daniel Cheng <dcheng@chromium.org> Reviewed-by: Mike West <mkwst@chromium.org> Reviewed-by: Bo <boliu@chromium.org> Commit-Queue: Jan Wilken Dörrie <jdoerrie@chromium.org> Cr-Commit-Position: refs/heads/master@{#597544}
75 lines
2.2 KiB
C++
75 lines
2.2 KiB
C++
// 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 "content/browser/startup_task_runner.h"
|
|
|
|
#include "base/bind.h"
|
|
#include "base/location.h"
|
|
|
|
namespace content {
|
|
|
|
StartupTaskRunner::StartupTaskRunner(
|
|
base::OnceCallback<void(int)> startup_complete_callback,
|
|
scoped_refptr<base::SingleThreadTaskRunner> proxy)
|
|
: startup_complete_callback_(std::move(startup_complete_callback)),
|
|
proxy_(proxy) {}
|
|
|
|
StartupTaskRunner::~StartupTaskRunner() {}
|
|
|
|
void StartupTaskRunner::AddTask(StartupTask callback) {
|
|
task_list_.push_back(callback);
|
|
}
|
|
|
|
void StartupTaskRunner::StartRunningTasksAsync() {
|
|
DCHECK(proxy_.get());
|
|
int result = 0;
|
|
if (task_list_.empty()) {
|
|
if (!startup_complete_callback_.is_null()) {
|
|
std::move(startup_complete_callback_).Run(result);
|
|
}
|
|
} else {
|
|
const base::Closure next_task =
|
|
base::Bind(&StartupTaskRunner::WrappedTask, base::Unretained(this));
|
|
proxy_->PostNonNestableTask(FROM_HERE, next_task);
|
|
}
|
|
}
|
|
|
|
void StartupTaskRunner::RunAllTasksNow() {
|
|
int result = 0;
|
|
for (auto it = task_list_.begin(); it != task_list_.end(); it++) {
|
|
result = it->Run();
|
|
if (result > 0) break;
|
|
}
|
|
task_list_.clear();
|
|
if (!startup_complete_callback_.is_null()) {
|
|
std::move(startup_complete_callback_).Run(result);
|
|
}
|
|
}
|
|
|
|
void StartupTaskRunner::WrappedTask() {
|
|
if (task_list_.empty()) {
|
|
// This will happen if the remaining tasks have been run synchronously since
|
|
// the WrappedTask was created. Any callback will already have been called,
|
|
// so there is nothing to do
|
|
return;
|
|
}
|
|
int result = task_list_.front().Run();
|
|
task_list_.pop_front();
|
|
if (result > 0) {
|
|
// Stop now and throw away the remaining tasks
|
|
task_list_.clear();
|
|
}
|
|
if (task_list_.empty()) {
|
|
if (!startup_complete_callback_.is_null()) {
|
|
std::move(startup_complete_callback_).Run(result);
|
|
}
|
|
} else {
|
|
const base::Closure next_task =
|
|
base::Bind(&StartupTaskRunner::WrappedTask, base::Unretained(this));
|
|
proxy_->PostNonNestableTask(FROM_HERE, next_task);
|
|
}
|
|
}
|
|
|
|
} // namespace content
|