We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent a13501a commit 7884dd6Copy full SHA for 7884dd6
crates/corro-agent/src/broadcast/mod.rs
@@ -728,7 +728,7 @@ async fn handle_broadcasts(
728
debug!("queueing for re-send");
729
idle_pendings.push(Box::pin(async move {
730
// slow our send pace if we've been previously rate limited
731
- let sleep_ms_base = if prev_rate_limited { 1000 } else { 250 };
+ let sleep_ms_base = if prev_rate_limited { 500 } else { 100 };
732
// send with increasing latency as we've already sent the updates out
733
tokio::time::sleep(Duration::from_millis(
734
sleep_ms_base * send_count as u64,
0 commit comments