"Fossies" - the Fresh Open Source Software Archive  

Source code changes of the file "zaqar/storage/mongodb/topics.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).

topics.py  (zaqar-9.0.0):topics.py  (zaqar-10.0.0)
skipping to change at line 149 skipping to change at line 149
threshold = now - window threshold = now - window
query['c.t'] = {'$lt': threshold} query['c.t'] = {'$lt': threshold}
while True: while True:
try: try:
doc = self._collection.find_one_and_update( doc = self._collection.find_one_and_update(
query, update, return_document=ReturnDocument.AFTER, query, update, return_document=ReturnDocument.AFTER,
projection={'c.v': 1, '_id': 0}) projection={'c.v': 1, '_id': 0})
break break
except pymongo.errors.AutoReconnect as ex: except pymongo.errors.AutoReconnect:
LOG.exception(ex) LOG.exception('Auto reconnect failure')
if doc is None: if doc is None:
if window is None: if window is None:
# NOTE(kgriffs): Since we did not filter by a time window, # NOTE(kgriffs): Since we did not filter by a time window,
# the topic should have been found and updated. Perhaps # the topic should have been found and updated. Perhaps
# the topic has been deleted? # the topic has been deleted?
message = _(u'Failed to increment the message ' message = _(u'Failed to increment the message '
u'counter for topic %(name)s and ' u'counter for topic %(name)s and '
u'project %(project)s') u'project %(project)s')
message %= dict(name=name, project=project) message %= dict(name=name, project=project)
 End of changes. 1 change blocks. 
2 lines changed or deleted 2 lines changed or added

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