Lines Matching full:machines
76 MACHINES_FILENAME = '.machines'
100 @param workdir: A directory where any on-disk files related to the machines
238 def __init__(self, control, args, resultdir, label, user, machines,
280 attributes will apply to all machines.
301 self.machines = machines
325 'hostname' : ','.join(machines),
343 and len(machines) <= 1)
366 self.machines, self.resultdir, self.in_lab, host_attributes,
505 machines, job, ssh_user, ssh_port, ssh_pass, ssh_verbosity_flag,
508 namespace = {'machines' : self.machine_dict_list,
519 """Cleanup machines.
524 if not self.machines:
525 raise error.AutoservError('No machines specified to cleanup')
535 """Verify machines are all ssh-able.
540 if not self.machines:
541 raise error.AutoservError('No machines specified to verify')
551 """Reset machines by first cleanup then verify each machine.
556 if not self.machines:
557 raise error.AutoservError('No machines specified to reset.')
567 """Repair machines.
572 if not self.machines:
573 raise error.AutoservError('No machines specified to repair')
622 def _make_parallel_wrapper(self, function, machines, log):
624 # machines could be a list of dictionaries, e.g.,
629 # To compare the machinese to self.machines, which is a list of machine
630 # hostname, we need to convert machines back to a list of hostnames.
633 if (machines and isinstance(machines, list)
634 and isinstance(machines[0], dict)):
635 machines = [m['hostname'] for m in machines]
636 is_forking = not (len(machines) == 1 and self.machines == machines)
642 self.machines = [machine]
650 elif len(machines) > 1 and log:
665 def parallel_simple(self, function, machines, log=True, timeout=None,
673 @param machines: A list of machine names to be passed one per subcommand
684 wrapper = self._make_parallel_wrapper(function, machines, log)
686 wrapper, machines,
691 def parallel_on_machines(self, function, machines, timeout=None):
694 @param machines: A list of machines to call function(machine) on.
697 @returns A list of machines on which function(machine) returned
700 results = self.parallel_simple(function, machines, timeout=timeout,
703 for result, machine in itertools.izip(results, machines):
713 msg = 'No valid machines found for test %s.' % skipped_test
809 machines = self.machines
845 if install_before and machines:
859 'autotest packages on %s', machines)
912 if machines and (collect_crashdumps or collect_crashinfo):
928 if install_after and machines:
1385 if len(self.machines) > 1:
1386 machines_text = '\n'.join(self.machines) + '\n'
1504 When multiple machines are used in a job, change the hostname to
1515 if len(self.machines) > 1:
1516 # Search through machines for first machine with a platform.
1517 for host in self.machines:
1587 @param workdir: A directory where any on-disk files related to the machines
