diff options
Diffstat (limited to 'python/pgq/ticker.py')
-rw-r--r-- | python/pgq/ticker.py | 52 |
1 files changed, 0 insertions, 52 deletions
diff --git a/python/pgq/ticker.py b/python/pgq/ticker.py deleted file mode 100644 index e623b9cb..00000000 --- a/python/pgq/ticker.py +++ /dev/null @@ -1,52 +0,0 @@ -"""PgQ ticker. - -It will also launch maintenance job. -""" - -import time, threading -import skytools - -from pgq.maint import MaintenanceJob - -__all__ = ['SmallTicker'] - -class SmallTicker(skytools.DBScript): - """Ticker that periodically calls pgq.ticker().""" - tick_count = 0 - maint_thread = None - - def __init__(self, args): - skytools.DBScript.__init__(self, 'pgqadm', args) - - self.ticker_log_time = 0 - self.ticker_log_delay = 5*60 - - def reload(self): - skytools.DBScript.reload(self) - self.ticker_log_delay = self.cf.getfloat("ticker_log_delay", 5*60) - - def startup(self): - if self.maint_thread: - return - - # launch maint thread - self.maint_thread = MaintenanceJob(self, [self.cf.filename]) - t = threading.Thread(name = 'maint_thread', - target = self.maint_thread.run) - t.setDaemon(1) - t.start() - - def work(self): - db = self.get_database("db", autocommit = 1) - cx = db.cursor() - - # run ticker - cx.execute("select pgq.ticker()") - self.tick_count += cx.fetchone()[0] - - cur_time = time.time() - if cur_time > self.ticker_log_time + self.ticker_log_delay: - self.ticker_log_time = cur_time - self.stat_increase('ticks', self.tick_count) - self.tick_count = 0 - |