Lines Matching defs:Process
69 class Process(CustomEquals):
84 return super(Process, self).__repr__() + '<%s>' % self
106 process = None
115 return self.process and not self.exit_status
119 process = None
165 # about a drone hitting process limit is sent.
174 # holds Process objects
346 def _get_drone_for_process(self, process):
347 return self._drones[process.hostname]
352 if pidfile_contents.process is None:
354 return self._get_drone_for_process(pidfile_contents.process)
399 contents.process = Process(drone.hostname, pid)
420 process = Process(drone.hostname, int(process_info['pid']),
422 self._process_set.add(process)
445 on_this_drone = (contents.process
446 and contents.process.hostname == drone.hostname)
499 with drone process information.
504 # 'autoserv_processes': (autoserv process info from ps),
505 # 'all_processes': (all process info from ps),
506 # 'parse_processes': (parse process infor from ps),
524 # {pidfile_id: pidfile_contents(Process(drone, pid),
529 # the agent notices that its process has exited, it unregisters the
590 Returns a set of Process objects for orphaned processes only.
592 return set(process for process in self._process_set
593 if process.ppid == 1)
596 def kill_process(self, process):
598 Kill the given process.
600 logging.info('killing %s', process)
601 drone = self._get_drone_for_process(process)
602 drone.queue_kill_process(process)
618 @param username: login of user to run a process. may be None.
749 @param pidfile_name: name of the pidfile this process will write
755 already-executed process; the new process will execute on the
756 same drone as the previous process.
758 process.
847 def is_process_running(self, process):
849 Check if the given process is in the running process list.
851 if process in self._process_set:
854 drone_pid = process.hostname, process.pid
856 logging.error('Process %s found, but not an autoserv process. '
857 'Is %s', process, self._all_processes[drone_pid])
882 def _copy_results_helper(self, process, source_path, destination_path,
884 logging.debug('_copy_results_helper. process: %s, source_path: %s, '
886 process, source_path, destination_path,
891 source_drone = self._get_drone_for_process(process)
900 def copy_to_results_repository(self, process, source_path,
903 Copy results from the given process at source_path to destination_path
928 self._copy_results_helper(process, source_path, destination_path,
931 def _copy_to_results_repository(self, process, source_path,
934 Copy results from the given process at source_path to destination_path
939 self._copy_results_helper(process, source_path, destination_path,
943 def copy_results_on_drone(self, process, source_path, destination_path):
947 self._copy_results_helper(process, source_path, destination_path)
960 When the process for the results directory is executed, the given file
976 running the given Process. Otherwise, the file will be written to the
