This CL updates the parallel job library in the au test harness to be more robust.

au_test_harness/au_worker.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 that contains the interface for au_test_harness workers.
 
 An au test harnss worker is a class that contains the logic for performing
 and validating updates on a target.  This should be subclassed to handle
 various types of target.  Types of targets include VM's, real devices, etc.
 """
@@ skipping 214 matching lines @@
     """
     cros_lib.Info('Output from VerifyImage():')
     print >> sys.stderr, output
     sys.stderr.flush()
     percent_passed = self._ParseGenerateTestReportOutput(output)
     cros_lib.Info('Percent passed: %d vs. Percent required: %d' % (
         percent_passed, percent_required_to_pass))
     unittest.assertTrue(percent_passed >= percent_required_to_pass)
     return percent_passed
 
-  def InitializeResultsDirectory(self):
-    """Called by a test to initialize a results directory for this worker."""
-    # Use the name of the test.
+  def Initialize(self, port):
+    """Initializes test specific variables for each test.
+
+    Each test needs to specify a unique ssh port.
+
+    Args:
+      port:  Unique port for ssh access.
+    """
+    # Initialize port vars.
+    self._ssh_port = port
+    self._kvm_pid_file = '/tmp/kvm.%d' % port
+
+    # Initialize test results directory.
     test_name = inspect.stack()[1][3]
     self.results_directory = os.path.join(self.test_results_root, test_name)
     self.results_count = 0
 
   def GetNextResultsPath(self, label):
     """Returns a path for the results directory for this label.
 
     Prefixes directory returned for worker with time called i.e. 1_label,
     2_label, etc.  The directory returned is outside the chroot so if passing
     to an script that is called with enther_chroot, make sure to use
@@ skipping 15 matching lines @@
     lines = output.split('\n')
 
     for line in lines:
       if line.startswith("Total PASS:"):
         # FORMAT: ^TOTAL PASS: num_passed/num_total (percent%)$
         percent_passed = line.split()[3].strip('()%')
         cros_lib.Info('Percent of tests passed %s' % percent_passed)
         break
 
     return int(percent_passed)