|
|
@ -628,19 +628,20 @@ pub async fn send_transaction_message_route<'a>(
|
|
|
|
};
|
|
|
|
};
|
|
|
|
|
|
|
|
|
|
|
|
let start_time = Instant::now();
|
|
|
|
let start_time = Instant::now();
|
|
|
|
if let Err(e) = handle_incoming_pdu(
|
|
|
|
resolved_map.insert(
|
|
|
|
&body.origin,
|
|
|
|
event_id.clone(),
|
|
|
|
&event_id,
|
|
|
|
handle_incoming_pdu(
|
|
|
|
value,
|
|
|
|
&body.origin,
|
|
|
|
true,
|
|
|
|
&event_id,
|
|
|
|
&db,
|
|
|
|
value,
|
|
|
|
&pub_key_map,
|
|
|
|
true,
|
|
|
|
&mut auth_cache,
|
|
|
|
&db,
|
|
|
|
)
|
|
|
|
&pub_key_map,
|
|
|
|
.await
|
|
|
|
&mut auth_cache,
|
|
|
|
{
|
|
|
|
)
|
|
|
|
resolved_map.insert(event_id.clone(), Err(e));
|
|
|
|
.await
|
|
|
|
}
|
|
|
|
.map(|_| ()),
|
|
|
|
|
|
|
|
);
|
|
|
|
|
|
|
|
|
|
|
|
let elapsed = start_time.elapsed();
|
|
|
|
let elapsed = start_time.elapsed();
|
|
|
|
if elapsed > Duration::from_secs(1) {
|
|
|
|
if elapsed > Duration::from_secs(1) {
|
|
|
|