Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(2552)

Unified Diff: base/test/parallel_test_launcher.cc

Issue 23754019: Use SequencedWorkerPoolOwner in ParallelTestLauncher. (Closed) Base URL: svn://svn.chromium.org/chrome/trunk/src
Patch Set: Created 7 years, 3 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View side-by-side diff with in-line comments
Download patch
« no previous file with comments | « base/test/parallel_test_launcher.h ('k') | no next file » | no next file with comments »
Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
Index: base/test/parallel_test_launcher.cc
diff --git a/base/test/parallel_test_launcher.cc b/base/test/parallel_test_launcher.cc
index c01a78371250beb86fdb4301485943e621beb1a2..cbcac9a0019c093914c9d716748eb962d8d1e84f 100644
--- a/base/test/parallel_test_launcher.cc
+++ b/base/test/parallel_test_launcher.cc
@@ -20,8 +20,9 @@
#include "base/location.h"
#include "base/message_loop/message_loop_proxy.h"
#include "base/process/launch.h"
+#include "base/run_loop.h"
#include "base/test/test_launcher.h"
-#include "base/threading/sequenced_worker_pool.h"
+#include "base/test/sequenced_worker_pool_owner.h"
#if defined(OS_WIN)
#include "base/win/scoped_handle.h"
@@ -127,7 +128,8 @@ ParallelTestLauncher::ParallelTestLauncher(size_t jobs)
this,
&ParallelTestLauncher::OnOutputTimeout),
launch_sequence_number_(0),
- worker_pool_(new SequencedWorkerPool(jobs, "parallel_test_launcher")) {
+ worker_pool_owner_(
+ new SequencedWorkerPoolOwner(jobs, "parallel_test_launcher")) {
// Start the watchdog timer.
timer_.Reset();
}
@@ -135,7 +137,7 @@ ParallelTestLauncher::ParallelTestLauncher(size_t jobs)
ParallelTestLauncher::~ParallelTestLauncher() {
DCHECK(thread_checker_.CalledOnValidThread());
- worker_pool_->Shutdown();
+ worker_pool_owner_->pool()->Shutdown();
}
void ParallelTestLauncher::LaunchChildGTestProcess(
@@ -152,7 +154,7 @@ void ParallelTestLauncher::LaunchChildGTestProcess(
running_processes_map_.insert(
std::make_pair(launch_sequence_number_, new_command_line));
- worker_pool_->PostWorkerTask(
+ worker_pool_owner_->pool()->PostWorkerTask(
FROM_HERE,
Bind(&DoLaunchChildTestProcess,
new_command_line,
« no previous file with comments | « base/test/parallel_test_launcher.h ('k') | no next file » | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698