summary refs log tree commit diff
path: root/synapse/handlers/_base.py
diff options
context:
space:
mode:
authorErik Johnston <erik@matrix.org>2015-03-16 13:16:37 +0000
committerErik Johnston <erik@matrix.org>2015-03-16 13:16:37 +0000
commitc2c9471cbab2795edaced4d89ed9ef80ef129afe (patch)
tree6fb666dbac7387b21fbbafa8922b3aebc8704721 /synapse/handlers/_base.py
parentadd ToC and fix typoe (diff)
downloadsynapse-c2c9471cbab2795edaced4d89ed9ef80ef129afe.tar.xz
Don't block waiting on waking up all the listeners when sending an event.
Diffstat (limited to 'synapse/handlers/_base.py')
-rw-r--r--synapse/handlers/_base.py11
1 files changed, 10 insertions, 1 deletions
diff --git a/synapse/handlers/_base.py b/synapse/handlers/_base.py
index 1773fa20aa..7f07f05215 100644
--- a/synapse/handlers/_base.py
+++ b/synapse/handlers/_base.py
@@ -142,7 +142,16 @@ class BaseHandler(object):
                     "Failed to get destination from event %s", s.event_id
                 )
 
-        yield self.notifier.on_new_room_event(event, extra_users=extra_users)
+        # Don't block waiting on waking up all the listeners.
+        d = self.notifier.on_new_room_event(event, extra_users=extra_users)
+
+        def log_failure(f):
+            logger.warn(
+                "Failed to notify about %s: %s",
+                event.event_id, f.value
+            )
+
+        d.addErrback(log_failure)
 
         yield federation_handler.handle_new_event(
             event, destinations=destinations,