Use SequencedWorkerPoolOwner in ParallelTestLauncher.

base/test/parallel_test_launcher.cc

 // 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 "base/test/parallel_test_launcher.h"
 
 #if defined(OS_POSIX)
 #include <fcntl.h>
 #include <sys/stat.h>
 #include <sys/types.h>
 #endif
 
 #if defined(OS_WIN)
 #include <windows.h>
 #endif
 
 #include "base/bind.h"
 #include "base/command_line.h"
 #include "base/file_util.h"
 #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"
 #endif
 
 namespace base {
 
 namespace {
 
 // Maximum time of no output after which we print list of processes still
@@ skipping 85 matching lines @@
 }
 
 }  // namespace
 
 ParallelTestLauncher::ParallelTestLauncher(size_t jobs)
     : timer_(FROM_HERE,
              TimeDelta::FromSeconds(kOutputTimeoutSeconds),
              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();
 }
 
 ParallelTestLauncher::~ParallelTestLauncher() {
   DCHECK(thread_checker_.CalledOnValidThread());
 
-  worker_pool_->Shutdown();
+  worker_pool_owner_->pool()->Shutdown();
 }
 
 void ParallelTestLauncher::LaunchChildGTestProcess(
     const CommandLine& command_line,
     const std::string& wrapper,
     base::TimeDelta timeout,
     const LaunchChildGTestProcessCallback& callback) {
   DCHECK(thread_checker_.CalledOnValidThread());
 
   // Record the exact command line used to launch the child.
   CommandLine new_command_line(
       PrepareCommandLineForGTest(command_line, wrapper));
   launch_sequence_number_++;
   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,
            timeout,
            MessageLoopProxy::current(),
            Bind(&ParallelTestLauncher::OnLaunchTestProcessFinished,
                 Unretained(this),
                 launch_sequence_number_,
                 callback)));
 }
@@ skipping 29 matching lines @@
 #endif
   }
 
   fflush(stdout);
 
   // Arm the timer again - otherwise it would fire only once.
   timer_.Reset();
 }
 
 }  // namespace base