Lines Matching full:process
62 class Process(CustomEquals):
77 return super(Process, self).__repr__() + '<%s>' % self
99 process = None
108 return self.process and not self.exit_status
112 process = None
158 # about a drone hitting process limit is sent.
167 # holds Process objects
187 # has been sent about the drone hitting process limit.
324 def _get_drone_for_process(self, process):
325 return self._drones[process.hostname]
330 assert pidfile_contents.process is not None
331 return self._get_drone_for_process(pidfile_contents.process)
377 contents.process = Process(drone.hostname, pid)
398 process = Process(drone.hostname, int(process_info['pid']),
400 self._process_set.add(process)
423 on_this_drone = (contents.process
424 and contents.process.hostname == drone.hostname)
446 message = ('Drone %s is hitting %s of process limit.' %
452 body = ('Active processes/Process limit: %d/%d (%s)' %
487 with drone process information.
492 # 'autoserv_processes': (autoserv process info from ps),
493 # 'all_processes': (all process info from ps),
494 # 'parse_processes': (parse process infor from ps),
511 # {pidfile_id: pidfile_contents(Process(drone, pid),
516 # the agent notices that its process has exited, it unregisters the
579 Returns a set of Process objects for orphaned processes only.
581 return set(process for process in self._process_set
582 if process.ppid == 1)
585 def kill_process(self, process):
587 Kill the given process.
589 logging.info('killing %s', process)
590 drone = self._get_drone_for_process(process)
591 drone.queue_call('kill_process', process)
607 @param username: login of user to run a process. may be None.
718 @param pidfile_name: name of the pidfile this process will write
724 already-executed process; the new process will execute on the
725 same drone as the previous process.
727 process.
816 def is_process_running(self, process):
818 Check if the given process is in the running process list.
820 if process in self._process_set:
823 drone_pid = process.hostname, process.pid
825 logging.error('Process %s found, but not an autoserv process. '
826 'Is %s', process, self._all_processes[drone_pid])
851 def _copy_results_helper(self, process, source_path, destination_path,
853 logging.debug('_copy_results_helper. process
855 process, source_path, destination_path,
860 source_drone = self._get_drone_for_process(process)
869 def copy_to_results_repository(self, process, source_path,
872 Copy results from the given process at source_path to destination_path
877 self._copy_results_helper(process, source_path, destination_path,
881 def copy_results_on_drone(self, process, source_path, destination_path):
885 self._copy_results_helper(process, source_path, destination_path)
898 When the process for the results directory is executed, the given file
914 running the given Process. Otherwise, the file will be written to the
