Matrix-Mirrors/synapse-product
1
0
Fork 0
mirror of https://git.anonymousland.org/anonymousland/synapse-product.git synced 2024-10-01 08:25:44 -04:00
Code Issues Packages Projects Releases Wiki Activity

Handle a potential race in the notifier when calling get_events_for which resulted in an uncaught KeyError

Browse Source
This commit is contained in:
Erik Johnston 2014-08-13 17:13:26 +01:00
parent 6904952ec4
commit 6df83555cc
1 changed files with 7 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
synapse/api/notifier.py
View File

@ -166,9 +166,13 @@ class Notifier(object):
""" """
logger.debug("%s is listening for events.", user_id) logger.debug("%s is listening for events.", user_id)
if len(self.stored_event_listeners[user_id][stream_id]["chunk"]) > 0: try:
streams = self.stored_event_listeners[user_id][stream_id]["chunk"]
if streams:
logger.debug("%s returning existing chunk.", user_id) logger.debug("%s returning existing chunk.", user_id)
return self.stored_event_listeners[user_id][stream_id] return streams
except KeyError:
return None
reactor.callLater( reactor.callLater(
(timeout / 1000.0), self._timeout, user_id, stream_id (timeout / 1000.0), self._timeout, user_id, stream_id