mirror of
https://mau.dev/maunium/synapse.git
synced 2024-12-15 22:23:56 +01:00
Don't wait on federation_handler.handle_new_event
This commit is contained in:
parent
e845434028
commit
d5ff9effcf
1 changed files with 7 additions and 3 deletions
|
@ -139,7 +139,9 @@ class BaseHandler(object):
|
||||||
)
|
)
|
||||||
|
|
||||||
# Don't block waiting on waking up all the listeners.
|
# Don't block waiting on waking up all the listeners.
|
||||||
d = self.notifier.on_new_room_event(event, extra_users=extra_users)
|
notify_d = self.notifier.on_new_room_event(
|
||||||
|
event, extra_users=extra_users
|
||||||
|
)
|
||||||
|
|
||||||
def log_failure(f):
|
def log_failure(f):
|
||||||
logger.warn(
|
logger.warn(
|
||||||
|
@ -147,8 +149,10 @@ class BaseHandler(object):
|
||||||
event.event_id, f.value
|
event.event_id, f.value
|
||||||
)
|
)
|
||||||
|
|
||||||
d.addErrback(log_failure)
|
notify_d.addErrback(log_failure)
|
||||||
|
|
||||||
yield federation_handler.handle_new_event(
|
fed_d = federation_handler.handle_new_event(
|
||||||
event, destinations=destinations,
|
event, destinations=destinations,
|
||||||
)
|
)
|
||||||
|
|
||||||
|
fed_d.addErrback(log_failure)
|
||||||
|
|
Loading…
Reference in a new issue