Index: trunk/src/tools/gn/scheduler.cc |
=================================================================== |
--- trunk/src/tools/gn/scheduler.cc (revision 214322) |
+++ trunk/src/tools/gn/scheduler.cc (working copy) |
@@ -1,130 +0,0 @@ |
-// Copyright (c) 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 "tools/gn/scheduler.h" |
- |
-#include "base/bind.h" |
-#include "tools/gn/ninja_target_writer.h" |
-#include "tools/gn/standard_out.h" |
- |
-Scheduler* g_scheduler = NULL; |
- |
-Scheduler::Scheduler() |
- : pool_(new base::SequencedWorkerPool(32, "worker_")), |
- input_file_manager_(new InputFileManager), |
- verbose_logging_(false), |
- work_count_(0), |
- is_failed_(false) { |
- g_scheduler = this; |
-} |
- |
-Scheduler::~Scheduler() { |
- g_scheduler = NULL; |
-} |
- |
-bool Scheduler::Run() { |
- runner_.Run(); |
- pool_->Shutdown(); |
- return !is_failed(); |
-} |
- |
-void Scheduler::Log(const std::string& verb, const std::string& msg) { |
- if (base::MessageLoop::current() == &main_loop_) { |
- LogOnMainThread(verb, msg); |
- } else { |
- // The run loop always joins on the sub threads, so the lifetime of this |
- // object outlives the invocations of this function, hence "unretained". |
- main_loop_.PostTask(FROM_HERE, |
- base::Bind(&Scheduler::LogOnMainThread, |
- base::Unretained(this), verb, msg)); |
- } |
-} |
- |
-void Scheduler::FailWithError(const Err& err) { |
- DCHECK(err.has_error()); |
- { |
- base::AutoLock lock(lock_); |
- |
- if (is_failed_) |
- return; // Ignore errors once we see one. |
- is_failed_ = true; |
- } |
- |
- if (base::MessageLoop::current() == &main_loop_) { |
- FailWithErrorOnMainThread(err); |
- } else { |
- // The run loop always joins on the sub threads, so the lifetime of this |
- // object outlives the invocations of this function, hence "unretained". |
- main_loop_.PostTask(FROM_HERE, |
- base::Bind(&Scheduler::FailWithErrorOnMainThread, |
- base::Unretained(this), err)); |
- } |
-} |
- |
-void Scheduler::ScheduleWork(const base::Closure& work) { |
- IncrementWorkCount(); |
- pool_->PostWorkerTaskWithShutdownBehavior( |
- FROM_HERE, base::Bind(&Scheduler::DoWork, |
- base::Unretained(this), work), |
- base::SequencedWorkerPool::BLOCK_SHUTDOWN); |
-} |
- |
-void Scheduler::ScheduleTargetFileWrite(const Target* target) { |
- pool_->PostWorkerTaskWithShutdownBehavior( |
- FROM_HERE, base::Bind(&Scheduler::DoTargetFileWrite, |
- base::Unretained(this), target), |
- base::SequencedWorkerPool::BLOCK_SHUTDOWN); |
-} |
- |
-void Scheduler::AddGenDependency(const SourceFile& source_file) { |
- base::AutoLock lock(lock_); |
- gen_dependencies_.push_back(source_file); |
-} |
- |
-std::vector<SourceFile> Scheduler::GetGenDependencies() const { |
- base::AutoLock lock(lock_); |
- return gen_dependencies_; |
-} |
- |
-void Scheduler::IncrementWorkCount() { |
- base::AtomicRefCountInc(&work_count_); |
-} |
- |
-void Scheduler::DecrementWorkCount() { |
- if (!base::AtomicRefCountDec(&work_count_)) { |
- if (base::MessageLoop::current() == &main_loop_) { |
- OnComplete(); |
- } else { |
- main_loop_.PostTask(FROM_HERE, |
- base::Bind(&Scheduler::OnComplete, |
- base::Unretained(this))); |
- } |
- } |
-} |
- |
-void Scheduler::LogOnMainThread(const std::string& verb, |
- const std::string& msg) { |
- OutputString(verb, DECORATION_YELLOW); |
- OutputString(" " + msg + "\n"); |
-} |
- |
-void Scheduler::FailWithErrorOnMainThread(const Err& err) { |
- err.PrintToStdout(); |
- runner_.Quit(); |
-} |
- |
-void Scheduler::DoTargetFileWrite(const Target* target) { |
- NinjaTargetWriter::RunAndWriteFile(target); |
-} |
- |
-void Scheduler::DoWork(const base::Closure& closure) { |
- closure.Run(); |
- DecrementWorkCount(); |
-} |
- |
-void Scheduler::OnComplete() { |
- // Should be called on the main thread. |
- DCHECK(base::MessageLoop::current() == main_loop()); |
- runner_.Quit(); |
-} |