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

remove mutex lock/unlock during sync iteration.

Browse source 
Signed-off-by: Jason Volk <jason@zemos.net>
This commit is contained in:
Jason Volk 2025-01-14 08:01:12 +00:00
parent bab40a3747
commit 819e35f81f
1 changed files with 0 additions and 17 deletions
Download patch file Download diff file Expand all files Collapse all files

17
src/api/client/sync/v3.rs
View file

@ -242,10 +242,6 @@ pub(crate) async fn build_sync_events(
.state_cache .state_cache
.rooms_invited(sender_user) .rooms_invited(sender_user)
.fold_default(|mut invited_rooms: BTreeMap<_, _>, (room_id, invite_state)| async move { .fold_default(|mut invited_rooms: BTreeMap<_, _>, (room_id, invite_state)| async move {
// Get and drop the lock to wait for remaining operations to finish
let insert_lock = services.rooms.timeline.mutex_insert.lock(&room_id).await;
drop(insert_lock);
let invite_count = services let invite_count = services
.rooms .rooms
.state_cache .state_cache
@ -271,10 +267,6 @@ pub(crate) async fn build_sync_events(
.state_cache .state_cache
.rooms_knocked(sender_user) .rooms_knocked(sender_user)
.fold_default(|mut knocked_rooms: BTreeMap<_, _>, (room_id, knock_state)| async move { .fold_default(|mut knocked_rooms: BTreeMap<_, _>, (room_id, knock_state)| async move {
// Get and drop the lock to wait for remaining operations to finish
let insert_lock = services.rooms.timeline.mutex_insert.lock(&room_id).await;
drop(insert_lock);
let knock_count = services let knock_count = services
.rooms .rooms
.state_cache .state_cache
@ -470,10 +462,6 @@ async fn handle_left_room(
full_state: bool, full_state: bool,
lazy_load_enabled: bool, lazy_load_enabled: bool,
) -> Result<Option<LeftRoom>> { ) -> Result<Option<LeftRoom>> {
// Get and drop the lock to wait for remaining operations to finish
let insert_lock = services.rooms.timeline.mutex_insert.lock(room_id).await;
drop(insert_lock);
let left_count = services let left_count = services
.rooms .rooms
.state_cache .state_cache
@ -627,11 +615,6 @@ async fn load_joined_room(
lazy_load_send_redundant: bool, lazy_load_send_redundant: bool,
full_state: bool, full_state: bool,
) -> Result<(JoinedRoom, HashSet<OwnedUserId>, HashSet<OwnedUserId>)> { ) -> Result<(JoinedRoom, HashSet<OwnedUserId>, HashSet<OwnedUserId>)> {
// Get and drop the lock to wait for remaining operations to finish
// This will make sure the we have all events until next_batch
let insert_lock = services.rooms.timeline.mutex_insert.lock(room_id).await;
drop(insert_lock);
let sincecount = PduCount::Normal(since); let sincecount = PduCount::Normal(since);
let next_batchcount = PduCount::Normal(next_batch); let next_batchcount = PduCount::Normal(next_batch);