From f8e8ec013bad0afb010d8cfda3da63e36d37fea5 Mon Sep 17 00:00:00 2001
From: Erik Johnston <erik@matrix.org>
Date: Tue, 10 Apr 2018 14:00:24 +0100
Subject: [PATCH] Note why we're limiting concurrent event sends
---
synapse/handlers/message.py | 5 +++++
1 file changed, 5 insertions(+)
diff --git a/synapse/handlers/message.py b/synapse/handlers/message.py
index 1814b205da..54cd691f91 100644
--- a/synapse/handlers/message.py
+++ b/synapse/handlers/message.py
@@ -557,6 +557,11 @@ class EventCreationHandler(object):
See self.create_event and self.send_nonmember_event.
"""
+ # We limit the number of concurrent event sends in a room so that we
+ # don't fork the DAG too much. If we don't limit then we can end up in
+ # a situation where event persistence can't keep up, causing
+ # extremities to pile up, which in turn leads to state resolution
+ # taking longer.
with (yield self.limiter.queue(event_dict["room_id"])):
event, context = yield self.create_event(
requester,
--
GitLab