Move bvt suite into test harness.

au_test_harness/parallel_test_job.py

 # Copyright (c) 2011 The Chromium OS Authors. All rights reserved.
 # Use of this source code is governed by a BSD-style license that can be
 # found in the LICENSE file.
 
 """Module containing methods/classes related to running parallel test jobs."""
 
 import multiprocessing
 import sys
 import time
 
@@ skipping 46 matching lines @@
     def GetCurrentActiveCount():
       """Returns the (number of active jobs, first active job)."""
       active_count = 0
       active_job = None
       for parallel_job in parallel_jobs:
         if parallel_job.is_alive():
           active_count += 1
           if not active_job:
             active_job = parallel_job
 
-      return (active_count, parallel_job)
+      return (active_count, active_job)

[dgarrett, 2011/04/14 00:08:17]

This looks like a valid, but separate change. Doesn't need another change list,
but I'd put it in the description.

 
     start_time = time.time()
     while (time.time() - start_time) < cls.MAX_TIMEOUT_SECONDS:
       (active_count, active_job) = GetCurrentActiveCount()
       if active_count == 0:
         return
       else:
         print >> sys.stderr, (
             'Process Pool Active: Waiting on %d/%d jobs to complete' %
             (active_count, len(parallel_jobs)))
@@ skipping 58 matching lines @@
     output_array.append(output)
 
   # We use a semaphore to ensure we don't run more jobs than required.
   # After each parallel_job finishes, it releases (increments semaphore).
   for next_parallel_job in parallel_jobs:
     job_start_semaphore.acquire(block=True)
     next_parallel_job.start()
 
   ParallelJob.WaitUntilJobsComplete(parallel_jobs)
   return [output.get() for output in output_array]