magmaus3/continuwuity
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

cork around send_join response processing

Browse source 
Signed-off-by: Jason Volk <jason@zemos.net>
This commit is contained in:
Jason Volk 2024-11-09 02:42:09 +00:00
parent 10be301646
commit 14fce38403
1 changed files with 4 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

4
src/api/client/membership.rs
View file

@ -877,6 +877,7 @@ async fn join_room_by_id_helper_remote(
.await; .await;
info!("Going through send_join response room_state"); info!("Going through send_join response room_state");
let cork = services.db.cork_and_flush();
let mut state = HashMap::new(); let mut state = HashMap::new();
for result in send_join_response.room_state.state.iter().map(|pdu| { for result in send_join_response.room_state.state.iter().map(|pdu| {
services services
@ -902,8 +903,10 @@ async fn join_room_by_id_helper_remote(
state.insert(shortstatekey, pdu.event_id.clone()); state.insert(shortstatekey, pdu.event_id.clone());
} }
} }
drop(cork);
info!("Going through send_join response auth_chain"); info!("Going through send_join response auth_chain");
let cork = services.db.cork_and_flush();
for result in send_join_response.room_state.auth_chain.iter().map(|pdu| { for result in send_join_response.room_state.auth_chain.iter().map(|pdu| {
services services
.server_keys .server_keys
@ -915,6 +918,7 @@ async fn join_room_by_id_helper_remote(
services.rooms.outlier.add_pdu_outlier(&event_id, &value); services.rooms.outlier.add_pdu_outlier(&event_id, &value);
} }
drop(cork);
debug!("Running send_join auth check"); debug!("Running send_join auth check");
let fetch_state = &state; let fetch_state = &state;