diff --git a/src/api/server/send.rs b/src/api/server/send.rs index b2794a6e..cd563b18 100644 --- a/src/api/server/send.rs +++ b/src/api/server/send.rs @@ -167,7 +167,7 @@ async fn handle( .try_stream() .broad_and_then(|(room_id, pdus): (_, Vec<_>)| { let count = pdus.len(); - handle_room(services, client, origin, started, room_id, pdus.into_iter(), count, transaction_id) + handle_room(services, client, origin, started, room_id, pdus.into_iter(), count) .map_ok(Vec::into_iter) .map_ok(IterStream::try_stream) }) @@ -180,7 +180,7 @@ async fn handle( edus = pdu_start.saturating_duration_since(handle_start).as_micros(), pdus = results_start.saturating_duration_since(pdu_start).as_micros(), handle_room = handle_stop.saturating_duration_since(results_start).as_micros(), - transaction_id = ?transaction_id, + id = ?transaction_id, "handled incoming transaction", ); Ok(results) @@ -194,7 +194,6 @@ async fn handle_room( room_id: OwnedRoomId, pdus: impl Iterator + Send, count: usize, - transaction_id: &str, ) -> Result> { let _room_lock = services .rooms @@ -212,7 +211,6 @@ async fn handle_room( trace!( %room_id, %event_id, - transaction_id = ?transaction_id, pdu = n + 1, total = count, pdu_elapsed = ?pdu_start_time.elapsed(), @@ -229,12 +227,11 @@ async fn handle_room( info!( %room_id, %event_id, - transaction_id = ?transaction_id, pdu = n + 1, total = count, pdu_elapsed = ?pdu_start_time.elapsed(), txn_elapsed = ?txn_start_time.elapsed(), - "Finished handling PDU", + "Finished handling PDU {event_id}", ); n += 1;