diff options
| author | Patrick Cloke <clokep@users.noreply.github.com> | 2023-09-26 11:57:50 -0400 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2023-09-26 11:57:50 -0400 |
| commit | f84da3c32ec74cf054e2fd6d10618aa4997cffaa (patch) | |
| tree | 4c6dba941c45d8bd95049c9d24bd43e3c840a0ce /synapse/replication/tcp/client.py | |
| parent | Implement MSC4028: push all encrypted events. (#16361) (diff) | |
| download | synapse-f84da3c32ec74cf054e2fd6d10618aa4997cffaa.tar.xz | |
Add a cache around server ACL checking (#16360)
* Pre-compiles the server ACLs onto an object per room and invalidates them when new events come in. * Converts the server ACL checking into Rust.
Diffstat (limited to 'synapse/replication/tcp/client.py')
| -rw-r--r-- | synapse/replication/tcp/client.py | 6 |
1 files changed, 6 insertions, 0 deletions
diff --git a/synapse/replication/tcp/client.py b/synapse/replication/tcp/client.py index ca8a76f77c..1c7946522a 100644 --- a/synapse/replication/tcp/client.py +++ b/synapse/replication/tcp/client.py @@ -205,6 +205,12 @@ class ReplicationDataHandler: self.notifier.notify_user_joined_room( row.data.event_id, row.data.room_id ) + + # If this is a server ACL event, clear the cache in the storage controller. + if row.data.type == EventTypes.ServerACL: + self._state_storage_controller.get_server_acl_for_room.invalidate( + (row.data.room_id,) + ) elif stream_name == UnPartialStatedRoomStream.NAME: for row in rows: assert isinstance(row, UnPartialStatedRoomStreamRow) |