Merge remote branch 'cros/upstream' into master

client/tests/kvm/kvm_scheduler.py

 import os, select
 import kvm_utils, kvm_vm, kvm_subprocess
 
 
 class scheduler:
     """
     A scheduler that manages several parallel test execution pipelines on a
     single host.
     """
 
@@ skipping 56 matching lines @@
                 test_iterations = int(test.get("iterations", 1))
                 status = run_test_func("kvm", params=test,
                                        tag=test.get("shortname"),
                                        iterations=test_iterations)
                 w.write("done %s %s\n" % (test_index, status))
                 w.write("ready\n")
 
             # The scheduler wants this worker to free its used resources
             elif cmd[0] == "cleanup":
                 env_filename = os.path.join(self.bindir, self_dict["env"])
-                env = kvm_utils.load_env(env_filename, {})
+                env = kvm_utils.Env(env_filename)
                 for obj in env.values():
                     if isinstance(obj, kvm_vm.VM):
                         obj.destroy()
-                    elif isinstance(obj, kvm_subprocess.kvm_spawn):
+                    elif isinstance(obj, kvm_subprocess.Spawn):
                         obj.close()
-                kvm_utils.dump_env(env, env_filename)
+                env.save()
                 w.write("cleanup_done\n")
                 w.write("ready\n")
 
             # There's no more work for this worker
             elif cmd[0] == "terminate":
                 break
 
 
     def scheduler(self):
         """
@@ skipping 127 matching lines @@
                     self.s2w_w[worker].write("cleanup\n")
                     idle_workers.remove(worker)
                     closing_workers.append(worker)
 
             # If there are no more new tests to run, terminate the workers and
             # the scheduler
             if len(idle_workers) == self.num_workers:
                 for worker in idle_workers:
                     self.s2w_w[worker].write("terminate\n")
                 break