Mercurial > repos > guerler > springsuite

comparison planemo/lib/python3.7/site-packages/galaxy/util/monitors.py @ 1:56ad4e20f292 draft

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
"planemo upload commit 6eee67778febed82ddd413c3ca40b3183a3898f1"
author guerler
date Fri, 31 Jul 2020 00:32:28 -0400
parents
children
comparison
equal deleted inserted replaced
0:d30785e31577 1:56ad4e20f292
1 from __future__ import absolute_import
2
3 import logging
4 import threading
5
6 from .sleeper import Sleeper
7 from .web_compat import register_postfork_function
8
9 log = logging.getLogger(__name__)
10
11 DEFAULT_MONITOR_THREAD_JOIN_TIMEOUT = 5
12
13
14 class Monitors(object):
15
16 def _init_monitor_thread(self, name, target_name=None, target=None, start=False, config=None):
17 self.monitor_join_sleep = getattr(config, "monitor_thread_join_timeout", DEFAULT_MONITOR_THREAD_JOIN_TIMEOUT)
18 self.monitor_join = self.monitor_join_sleep > 0
19 self.monitor_running = True
20
21 if target is not None:
22 assert target_name is None
23 monitor_func = target
24 else:
25 target_name = target_name or "monitor"
26 monitor_func = getattr(self, target_name)
27 self.sleeper = Sleeper()
28 self.monitor_thread = threading.Thread(name=name, target=monitor_func)
29 self.monitor_thread.setDaemon(True)
30 self._start = start
31 register_postfork_function(self.start_monitoring)
32
33 def _init_noop_monitor(self):
34 self.sleeper = None
35 self.monitor_join = False
36
37 def start_monitoring(self):
38 if self._start:
39 self.monitor_thread.start()
40
41 def stop_monitoring(self):
42 self.monitor_running = False
43
44 def _monitor_sleep(self, sleep_amount):
45 self.sleeper.sleep(sleep_amount)
46
47 def shutdown_monitor(self):
48 self.stop_monitoring()
49 if self.sleeper is not None:
50 self.sleeper.wake()
51 if self.monitor_join:
52 log.debug("Joining monitor thread")
53 self.monitor_thread.join(self.monitor_join_sleep)