X-Git-Url: http://git.onelab.eu/?a=blobdiff_plain;f=planetstack%2Fopenstack%2Fobserver.py;h=fbacb67c831129ecfff409fa6c304c3167f0276f;hb=43c3a775661098220309c758a0c689e2c6d576d3;hp=9e83f5b886eac24b110e5014aba85f2cfabf1d29;hpb=5c0c4557d76b3f1cec59dfe67a4e519137804170;p=plstackapi.git diff --git a/planetstack/openstack/observer.py b/planetstack/openstack/observer.py index 9e83f5b..fbacb67 100644 --- a/planetstack/openstack/observer.py +++ b/planetstack/openstack/observer.py @@ -8,7 +8,7 @@ from collections import defaultdict from core.models import * from django.db.models import F, Q from openstack.manager import OpenStackManager -from util.logger import Logger, logging +from util.logger import Logger, logging, logger #from timeout import timeout @@ -27,6 +27,7 @@ class OpenStackObserver: self.event_cond.release() def wake_up(self): + logger.info('Wake up routine called. Event cond %r'%self.event_cond) self.event_cond.acquire() self.event_cond.notify() self.event_cond.release() @@ -36,16 +37,18 @@ class OpenStackObserver: return while True: try: + logger.info('Observer run loop') #self.sync_roles() + logger.info('Calling sync tenants') self.sync_tenants() self.sync_users() self.sync_user_tenant_roles() self.sync_slivers() self.sync_sliver_ips() + logger.info('Calling sync external routes') self.sync_external_routes() - - self.wait_for_event(timeout=30) - + self.wait_for_event(timeout=300) + logger.info('Observer woken up') except: traceback.print_exc()