def run_command(self, argv, set_env=True, stdin_text=None,

                      log_stdout=True, raiseonerr=True,

          """Run the given command on this host

          Returns a Command instance. The command will have already run in the

          :param raiseonerr: If true, an exception will be raised if the command

                             does not exit with return code 0

          :param cwd: The working directory for the command

          """

          # Set working directory

          if cwd is None:

              cwd = self.test_dir

          self.log.info('MKDIR %s', path)

          self.sftp.mkdir(path)

          logger_name = self.get_next_command_logger_name()

          ssh = self._transport.open_channel('session')

          self.log.info('RUN %s', argv)

          return SSHCommand(ssh, argv, logger_name=logger_name,

                            log_stdout=log_stdout,

      def get_file(self, remotepath, localpath):

          self.log.debug('GET %s', remotepath)

  class SSHCommand(Command):

      """Command implementation for ParamikoTransport and OpenSSHTranspport"""

      def __init__(self, ssh, argv, logger_name, log_stdout=True,

          super(SSHCommand, self).__init__(argv, logger_name,

                                           log_stdout=log_stdout,

                                           get_logger=get_logger)

          self._ssh = ssh

          self.log.debug('RUN %s', argv)

          self._ssh.invoke_shell()

          def wrap_file(file, encoding):