Lines Matching refs:pidfile_id
328 def _get_drone_for_pidfile_id(self, pidfile_id):
329 pidfile_contents = self.get_pidfile_contents(pidfile_id)
336 for pidfile_id, info in self._registered_pidfile_info.items():
338 logging.warning('dropping leaked pidfile %s', pidfile_id)
339 self.unregister_pidfile(pidfile_id)
392 pidfile_id = PidfileId(pidfile_path)
394 store_in_dict[pidfile_id] = contents
421 for pidfile_id, contents in self._pidfiles.iteritems():
426 info = self._registered_pidfile_info[pidfile_id]
467 pidfile_paths = [pidfile_id.path
468 for pidfile_id in self._registered_pidfile_info]
511 # {pidfile_id: pidfile_contents(Process(drone, pid),
513 # In handle agents, each agent knows its pidfile_id, and uses this
765 pidfile_id = PidfileId(pidfile_path)
766 self.register_pidfile(pidfile_id)
767 self._registered_pidfile_info[pidfile_id].num_processes = num_processes
768 return pidfile_id
776 def register_pidfile(self, pidfile_id):
781 if pidfile_id not in self._registered_pidfile_info:
782 logging.info('monitoring pidfile %s', pidfile_id)
783 self._registered_pidfile_info[pidfile_id] = _PidfileInfo()
784 self._reset_pidfile_age(pidfile_id)
787 def _reset_pidfile_age(self, pidfile_id):
788 if pidfile_id in self._registered_pidfile_info:
789 self._registered_pidfile_info[pidfile_id].age = 0
792 def unregister_pidfile(self, pidfile_id):
793 if pidfile_id in self._registered_pidfile_info:
794 logging.info('forgetting pidfile %s', pidfile_id)
795 del self._registered_pidfile_info[pidfile_id]
798 def declare_process_count(self, pidfile_id, num_processes):
799 self._registered_pidfile_info[pidfile_id].num_processes = num_processes
802 def get_pidfile_contents(self, pidfile_id, use_second_read=False):
804 Retrieve a PidfileContents object for the given pidfile_id. If
808 self._reset_pidfile_age(pidfile_id)
813 return pidfile_map.get(pidfile_id, PidfileContents())
