tileradotorg/synapse
1
0
Fork 0
forked from MirrorHub/synapse
Code Pull requests Activity

Always cache 'event_to_prev_state_group' (#9950)

Browse source 
Fixes regression in send PDU times introduced in #9905.
This commit is contained in:
Erik Johnston 2021-05-07 14:54:09 +01:00 committed by GitHub
parent 765473567c
commit 6c84778549
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
2 changed files with 8 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

1
changelog.d/9950.feature Normal file
View file

@ -0,0 +1 @@
Improve performance of sending events for worker-based deployments using Redis.

13
synapse/handlers/message.py
View file

@ -1050,6 +1050,13 @@ class EventCreationHandler:
) )
if state_entry.state_group: if state_entry.state_group:
await self._external_cache.set(
"event_to_prev_state_group",
event.event_id,
state_entry.state_group,
expiry_ms=60 * 60 * 1000,
)
if state_entry.state_group in self._external_cache_joined_hosts_updates: if state_entry.state_group in self._external_cache_joined_hosts_updates:
return return
@ -1057,12 +1064,6 @@ class EventCreationHandler:
# Note that the expiry times must be larger than the expiry time in # Note that the expiry times must be larger than the expiry time in
# _external_cache_joined_hosts_updates. # _external_cache_joined_hosts_updates.
await self._external_cache.set(
"event_to_prev_state_group",
event.event_id,
state_entry.state_group,
expiry_ms=60 * 60 * 1000,
)
await self._external_cache.set( await self._external_cache.set(
"get_joined_hosts", "get_joined_hosts",
str(state_entry.state_group), str(state_entry.state_group),