199   def __init__(self, name, command, output, events,  argument
218     self.command = command
257         logging.info("Restarting process %s", "".join(str(self.command)))
268           self.process = pexpect.spawn(" ".join(self.command), timeout=None)
271           self.process = subprocess.Popen(self.command, stdout=subprocess.PIPE)
409         command = [
412         command.extend(["%s:S" % tag for tag in config.tag_to_suppress])
415         command = [
423           name, command, os.path.join(
434       command = shlex.split(
435           daemon_process.command % self.cmd_string_replacements)
443       process_logger = ProcessLogger(name, command, output, events,
624   def AsyncCommand(self, command, log_output=False):  argument
626         lambda: self.__AsyncCommand(command, log_output=log_output))
628   def __AsyncCommand(self, command, log_output=False):  argument
629     result = self.Command(command).strip()
634   def Command(self, command):  argument
636     if command[0] in {"bugreport", "root", "wait-for-device", "shell",
639           ["adb", "-s", self.serial_number] + command)
640     elif command[0] == "DUMPSYS":
641       self.CaptureDumpsys(command[1])
643     elif command[0] == "pull":
646             ["adb", "-s", self.serial_number, "shell", "ls", command[1]]
654                                    command[2] % self.cmd_string_replacements)
666       return subprocess.check_output(command)
717 def RunAsyncCommand(devices, command):  argument
720     device.AsyncCommand(command)
837     for command in self.setup_commands:
838       logging.info("Running command %s", command)
843             shlex.split(command % device.cmd_string_replacements),
884         if step.command:
885           logging.info("Running command %s", step.command)
890                 shlex.split(step.command % device.cmd_string_replacements),