199   def __init__(self, name, command, output, events,  argument
218     self.command = command
258         logging.info("Restarting process %s", "".join(str(self.command)))
269           self.process = pexpect.spawn(" ".join(self.command), timeout=None)
272           self.process = subprocess.Popen(self.command, stdout=subprocess.PIPE)
418         command = [
421         command.extend(["%s:S" % tag for tag in config.tag_to_suppress])
424         command = [
432           name, command, os.path.join(
443       command = shlex.split(
444           daemon_process.command % self.cmd_string_replacements)
452       process_logger = ProcessLogger(name, command, output, events,
633   def AsyncCommand(self, command, log_output=False):  argument
635         lambda: self.__AsyncCommand(command, log_output=log_output))
637   def __AsyncCommand(self, command, log_output=False):  argument
638     result = self.Command(command).strip()
646   def Command(self, command):  argument
648     if command[0] in {"bugreport", "root", "wait-for-device", "shell",
651           ["adb", "-s", self.serial_number] + command)
652     elif command[0] == "DUMPSYS":
653       self.CaptureDumpsys(command[1])
655     elif command[0] == "pull":
658             ["adb", "-s", self.serial_number, "shell", "ls", command[1]]
666                                    command[2] % self.cmd_string_replacements)
678       return subprocess.check_output(command)
729 def RunAsyncCommand(devices, command):  argument
732     device.AsyncCommand(command)
849     for command in self.setup_commands:
850       logging.info("Running command %s", command)
855             shlex.split(command % device.cmd_string_replacements),
896         if step.command:
897           logging.info("Running command %s", step.command)
902                 shlex.split(step.command % device.cmd_string_replacements),