diff options
author | Richard van der Hoff <1389908+richvdh@users.noreply.github.com> | 2020-10-29 11:48:39 +0000 |
---|---|---|
committer | GitHub <noreply@github.com> | 2020-10-29 11:48:39 +0000 |
commit | 56f0ee78a9c95844289ae71169f18f443ea2df6c (patch) | |
tree | 23818c8c3eb4c65b026b219e18a8b093cfa48bfd /synapse/handlers/room_member.py | |
parent | Support generating structured logs in addition to standard logs. (#8607) (diff) | |
download | synapse-56f0ee78a9c95844289ae71169f18f443ea2df6c.tar.xz |
Optimise createRoom with multiple invites (#8559)
By not dropping the membership lock between invites, we can stop joins from grabbing the lock when we're half-done and slowing the whole thing down.
Diffstat (limited to 'synapse/handlers/room_member.py')
-rw-r--r-- | synapse/handlers/room_member.py | 8 |
1 files changed, 6 insertions, 2 deletions
diff --git a/synapse/handlers/room_member.py b/synapse/handlers/room_member.py index ec784030e9..7cd858b7db 100644 --- a/synapse/handlers/room_member.py +++ b/synapse/handlers/room_member.py @@ -307,7 +307,7 @@ class RoomMemberHandler(metaclass=abc.ABCMeta): key = (room_id,) with (await self.member_linearizer.queue(key)): - result = await self._update_membership( + result = await self.update_membership_locked( requester, target, room_id, @@ -322,7 +322,7 @@ class RoomMemberHandler(metaclass=abc.ABCMeta): return result - async def _update_membership( + async def update_membership_locked( self, requester: Requester, target: UserID, @@ -335,6 +335,10 @@ class RoomMemberHandler(metaclass=abc.ABCMeta): content: Optional[dict] = None, require_consent: bool = True, ) -> Tuple[str, int]: + """Helper for update_membership. + + Assumes that the membership linearizer is already held for the room. + """ content_specified = bool(content) if content is None: content = {} |