79 MACHINES_FILENAME = '.machines'
252                  machines,  argument
280         @param machines: A list of hostnames of the machines to use for the job.
281         @param machine_dict_list: A list of dicts for each of the machines above
313                 machines, where each host is a host that the test would be run
335         self.machines = machines
371                 'hostname': ','.join(machines),
513         machines, job, ssh_user, ssh_port, ssh_pass, ssh_verbosity_flag,
516         namespace = {'machines' : self.machine_dict_list,
527         """Cleanup machines.
532         if not self.machines:
533             raise error.AutoservError('No machines specified to cleanup')
543         """Verify machines are all ssh-able.
548         if not self.machines:
549             raise error.AutoservError('No machines specified to verify')
559         """Reset machines by first cleanup then verify each machine.
564         if not self.machines:
565             raise error.AutoservError('No machines specified to reset.')
575         """Repair machines.
580         if not self.machines:
581             raise error.AutoservError('No machines specified to repair')
630     def _make_parallel_wrapper(self, function, machines, log):  argument
632         # machines could be a list of dictionaries, e.g.,
637         # To compare the machinese to self.machines, which is a list of machine
638         # hostname, we need to convert machines back to a list of hostnames.
639         if (machines and isinstance(machines, list)
640             and isinstance(machines[0], dict)):
641             machines = [m['hostname'] for m in machines]
642         if len(machines) > 1 and log:
657     def parallel_simple(self, function, machines, log=True, timeout=None,  argument
665         @param machines: A list of machine names to be passed one per subcommand
676         wrapper = self._make_parallel_wrapper(function, machines, log)
678                 wrapper, machines,
683     def parallel_on_machines(self, function, machines, timeout=None):  argument
686         @param machines: A list of machines to call function(machine) on.
689         @returns A list of machines on which function(machine) returned
692         results = self.parallel_simple(function, machines, timeout=timeout,
695         for result, machine in zip(results, machines):
705             msg = 'No valid machines found for test %s.' % skipped_test
800         machines = self.machines
855                                     'autotest packages on %s', machines)
920             if machines and (collect_crashdumps or collect_crashinfo):
971         self.parallel_simple(serial, self.machines)
990             self.parallel_simple(serial, self.machines)
1486         if len(self.machines) > 1:
1487             machines_text = '\n'.join(self.machines) + '\n'
1571         When multiple machines are used in a job, change the hostname to
1582         if len(self.machines) > 1:
1583             # Search through machines for first machine with a platform.
1584             for host in self.machines: