mirror of
https://github.com/element-hq/synapse
synced 2024-09-12 02:25:10 +00:00
Don't block waiting on waking up all the listeners when sending an event.
This commit is contained in:
parent
b677ff6692
commit
c2c9471cba
1 changed files with 10 additions and 1 deletions
|
@ -142,7 +142,16 @@ class BaseHandler(object):
|
||||||
"Failed to get destination from event %s", s.event_id
|
"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(
|
yield federation_handler.handle_new_event(
|
||||||
event, destinations=destinations,
|
event, destinations=destinations,
|
||||||
|
|
Loading…
Reference in a new issue