Skip to content
This repository has been archived by the owner on Apr 26, 2024. It is now read-only.

Run _handle_queued_pdus as a background process #12041

Merged
merged 4 commits into from
Feb 22, 2022
Merged

Run _handle_queued_pdus as a background process #12041

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
4 commits
Select commit Hold shift + click to select a range
81f4ab7
run _handle_queued_pdus as a background process
richvdh Feb 18, 2022
6f1c90b
fix imports
richvdh Feb 21, 2022
7609dac
changelog
richvdh Feb 21, 2022
f668c48
Rename 12049.misc to 12041.misc
richvdh Feb 22, 2022
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
1 change: 1 addition & 0 deletions changelog.d/12041.misc
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -0,0 +1 @@
After joining a room, create a dedicated logcontext to process the queued events.
6 changes: 4 additions & 2 deletions synapse/handlers/federation.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -49,8 +49,8 @@
make_deferred_yieldable,
nested_logging_context,
preserve_fn,
run_in_background,
)
from synapse.metrics.background_process_metrics import run_as_background_process
from synapse.replication.http.federation import (
ReplicationCleanRoomRestServlet,
ReplicationStoreRoomOnOutlierMembershipRestServlet,
Expand Down Expand Up @@ -559,7 +559,9 @@ async def do_invite_join(
# lots of requests for missing prev_events which we do actually
# have. Hence we fire off the background task, but don't wait for it.

run_in_background(self._handle_queued_pdus, room_queue)
run_as_background_process(
"handle_queued_pdus", self._handle_queued_pdus, room_queue
)

async def do_knock(
self,
Expand Down