From b56535412882ea06155eb3faaaa2357c52a4279e Mon Sep 17 00:00:00 2001 From: Stephen Gran Date: Sun, 19 Jan 2014 20:02:28 +0000 Subject: [PATCH] better debugging Signed-off-by: Stephen Gran --- ud-replicated | 11 ++++++++--- 1 file changed, 8 insertions(+), 3 deletions(-) diff --git a/ud-replicated b/ud-replicated index 26f8695..1e19ef4 100755 --- a/ud-replicated +++ b/ud-replicated @@ -71,9 +71,14 @@ formatter = logging.Formatter(SFORMAT) syslog_handler.setFormatter(formatter) LOG.addHandler(syslog_handler) +last_run = 0 + def do_replicate(message): - last_update = time.time() - LOG.debug("Got message at %s" % last_update) + global last_run + last_update = int(time.time()) + LOG.debug("Got message at %s: %s" % (last_update, message['message'])) + if last_run > message.get('timestamp', 0): + return command = ['/usr/bin/ud-replicate'] if options.dryrun: @@ -89,7 +94,7 @@ def do_replicate(message): LOG.debug('%s finished with ret: 0' % ' '.join(command)) finally: os.environ['TERM'] = old_term - LOG.debug(message) + last_run = int(time.time()) def main(): conn = Connection(conf=mq_conf) -- 2.20.1