git-mirrors/continuwuity
1
0
Fork 0
mirror of https://forgejo.ellis.link/continuwuation/continuwuity.git synced 2025-09-11 07:33:01 +02:00
Code Issues Projects Releases Packages Wiki Activity

collect room lock timing ???

Browse source
This commit is contained in:
Jacob Taylor 2025-08-31 10:26:59 -07:00
commit eb37e0de77
1 changed files with 4 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

4
src/api/server/send.rs
View file

@ -196,12 +196,14 @@ async fn handle_room(
count: usize, count: usize,
transaction_id: &str, transaction_id: &str,
) -> Result<Vec<(OwnedEventId, Result)>> { ) -> Result<Vec<(OwnedEventId, Result)>> {
let room_lock_start = Instant::now();
let _room_lock = services let _room_lock = services
.rooms .rooms
.event_handler .event_handler
.mutex_federation .mutex_federation
.lock(&room_id) .lock(&room_id)
.await; .await;
let room_lock_end = Instant::now();
let room_id = &room_id; let room_id = &room_id;
let mut n = 0; let mut n = 0;
@ -215,6 +217,7 @@ async fn handle_room(
transaction_id = ?transaction_id, transaction_id = ?transaction_id,
pdu = n + 1, pdu = n + 1,
total = count, total = count,
room_lock_time = ?room_lock_end.saturating_duration_since(room_lock_start).as_micros(),
pdu_elapsed = ?pdu_start_time.elapsed(), pdu_elapsed = ?pdu_start_time.elapsed(),
txn_elapsed = ?txn_start_time.elapsed(), txn_elapsed = ?txn_start_time.elapsed(),
"Handling PDU", "Handling PDU",
@ -232,6 +235,7 @@ async fn handle_room(
transaction_id = ?transaction_id, transaction_id = ?transaction_id,
pdu = n + 1, pdu = n + 1,
total = count, total = count,
room_lock_time = ?room_lock_end.saturating_duration_since(room_lock_start).as_micros(),
pdu_elapsed = ?pdu_start_time.elapsed(), pdu_elapsed = ?pdu_start_time.elapsed(),
txn_elapsed = ?txn_start_time.elapsed(), txn_elapsed = ?txn_start_time.elapsed(),
"Finished handling PDU", "Finished handling PDU",