"Fossies" - the Fresh Open Source Software Archive  

Source code changes of the file "zaqar/bootstrap.py" between
zaqar-9.0.0.tar.gz and zaqar-10.0.0.tar.gz

About: OpenStack Zaqar is a multi-tenant cloud messaging and notification service for web and mobile developers.
The "Ussuri" series (latest release).

bootstrap.py  (zaqar-9.0.0):bootstrap.py  (zaqar-10.0.0)
skipping to change at line 97 skipping to change at line 97
return storage_utils.load_storage_driver(self.conf, self.cache, return storage_utils.load_storage_driver(self.conf, self.cache,
control_mode=True) control_mode=True)
@decorators.lazy_property(write=False) @decorators.lazy_property(write=False)
def cache(self): def cache(self):
LOG.debug(u'Loading proxy cache driver') LOG.debug(u'Loading proxy cache driver')
try: try:
oslo_cache.register_config(self.conf) oslo_cache.register_config(self.conf)
return oslo_cache.get_cache(self.conf) return oslo_cache.get_cache(self.conf)
except RuntimeError as exc: except RuntimeError as exc:
LOG.exception(exc) LOG.exception('Error loading proxy cache.')
raise errors.InvalidDriver(exc) raise errors.InvalidDriver(exc)
@decorators.lazy_property(write=False) @decorators.lazy_property(write=False)
def transport(self): def transport(self):
transport_name = self.driver_conf.transport transport_name = self.driver_conf.transport
LOG.debug(u'Loading transport driver: %s', transport_name) LOG.debug(u'Loading transport driver: %s', transport_name)
if transport_name == consts.TRANSPORT_WEBSOCKET: if transport_name == consts.TRANSPORT_WEBSOCKET:
args = [self.conf, self.api, self.cache] args = [self.conf, self.api, self.cache]
else: else:
skipping to change at line 122 skipping to change at line 122
self.control, self.control,
] ]
try: try:
mgr = driver.DriverManager('zaqar.transport', mgr = driver.DriverManager('zaqar.transport',
transport_name, transport_name,
invoke_on_load=True, invoke_on_load=True,
invoke_args=args) invoke_args=args)
return mgr.driver return mgr.driver
except RuntimeError as exc: except RuntimeError as exc:
LOG.exception(exc) LOG.exception(u'Failed to load transport driver zaqar.transport.'
LOG.error(u'Failed to load transport driver zaqar.transport.' u'%(driver)s with args %(args)s',
u'%(driver)s with args %(args)s', {'driver': transport_name, 'args': args})
{'driver': transport_name, 'args': args})
raise errors.InvalidDriver(exc) raise errors.InvalidDriver(exc)
def run(self): def run(self):
self.transport.listen() self.transport.listen()
 End of changes. 2 change blocks. 
5 lines changed or deleted 4 lines changed or added

Home  |  About  |  Features  |  All  |  Newest  |  Dox  |  Diffs  |  RSS Feeds  |  Screenshots  |  Comments  |  Imprint  |  Privacy  |  HTTP(S)