MirrorHub/synapse
0
0
Fork 1
mirror of https://mau.dev/maunium/synapse.git synced 2024-12-14 16:23:52 +01:00
Code Issues Projects Releases Wiki Activity

Speed up persisting redacted events (#10756)

Browse source
This commit is contained in:
Erik Johnston 2021-09-06 10:14:07 +01:00 committed by GitHub
parent 1ca70fd312
commit 2ca0d64854
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
2 changed files with 12 additions and 11 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

1
changelog.d/10756.misc Normal file
View file

@ -0,0 +1 @@
Minor speed ups when joining large rooms over federation.

18
synapse/storage/databases/main/events.py
View file

@ -1385,18 +1385,18 @@ class PersistEventsStore:
# If we're persisting an unredacted event we go and ensure # If we're persisting an unredacted event we go and ensure
# that we mark any redactions that reference this event as # that we mark any redactions that reference this event as
# requiring censoring. # requiring censoring.
sql = "UPDATE redactions SET have_censored = ? WHERE redacts = ?" unredacted_events = [
txn.execute_batch( event.event_id
sql,
(
(
False,
event.event_id,
)
for event, _ in events_and_contexts for event, _ in events_and_contexts
if not event.internal_metadata.is_redacted() if not event.internal_metadata.is_redacted()
), ]
sql = "UPDATE redactions SET have_censored = ? WHERE "
clause, args = make_in_list_sql_clause(
self.database_engine,
"redacts",
unredacted_events,
) )
txn.execute(sql + clause, [False] + args)
state_events_and_contexts = [ state_events_and_contexts = [
ec for ec in events_and_contexts if ec[0].is_state() ec for ec in events_and_contexts if ec[0].is_state()