Browse Source

improvement: stop prev event fetching if too many events fail

merge-requests/159/head
Timo Kösters 4 years ago committed by Jonas Zohren
parent
commit
828611c0e4
  1. 5
      src/server_server.rs

5
src/server_server.rs

@ -1084,7 +1084,11 @@ pub(crate) async fn handle_incoming_pdu<'a>( @@ -1084,7 +1084,11 @@ pub(crate) async fn handle_incoming_pdu<'a>(
})
.map_err(|_| "Error sorting prev events".to_owned())?;
let mut errors = 0;
for prev_id in dbg!(sorted) {
if errors >= 5 {
break;
}
if let Some((pdu, json)) = eventid_info.remove(&prev_id) {
let start_time = Instant::now();
let event_id = pdu.event_id.clone();
@ -1099,6 +1103,7 @@ pub(crate) async fn handle_incoming_pdu<'a>( @@ -1099,6 +1103,7 @@ pub(crate) async fn handle_incoming_pdu<'a>(
)
.await
{
errors += 1;
warn!("Prev event {} failed: {}", event_id, e);
}
let elapsed = start_time.elapsed();

Loading…
Cancel
Save