diff --git a/clients/client-core/src/client/real_messages_control/real_traffic_stream.rs b/clients/client-core/src/client/real_messages_control/real_traffic_stream.rs index ea01ada91a..fe8c8cd6de 100644 --- a/clients/client-core/src/client/real_messages_control/real_traffic_stream.rs +++ b/clients/client-core/src/client/real_messages_control/real_traffic_stream.rs @@ -138,15 +138,15 @@ impl SendingDelayController { // As soon as we're above a basic threshold, increase multiplier. But not too often as we // need to give time to give the channel a chance to clear. - if used_slots > 4 && now - self.time_when_changed > Duration::from_millis(500) { + if used_slots > 3 && now - self.time_when_changed > Duration::from_millis(300) { self.increase_delay_multiplier(); self.time_when_changed = now; } // If running smoothly without any backpressure detected, lower the delay multiplier, but // not too fast! - if now - self.time_when_backpressure_detected > Duration::from_secs(2) - && now - self.time_when_changed > Duration::from_secs(2) + if now - self.time_when_backpressure_detected > Duration::from_secs(1) + && now - self.time_when_changed > Duration::from_secs(1) { self.decrease_delay_multiplier(); self.time_when_changed = now; @@ -246,7 +246,7 @@ where ack_key, sent_notifier, next_delay: None, - sending_rate_controller: SendingDelayController::new(1, 5), + sending_rate_controller: SendingDelayController::new(1, 6), mix_tx, real_receiver, our_full_destination,