Skip to content

Commit f4ff1ac

Browse files
committed
Stop treating queued-byte growth as active poll progress
1 parent 3513efd commit f4ff1ac

File tree

1 file changed

+1
-5
lines changed

1 file changed

+1
-5
lines changed

crates/slipstream-client/src/runtime.rs

Lines changed: 1 addition & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -291,7 +291,6 @@ pub async fn run_client(config: &ClientConfig<'_>) -> Result<i32, ClientError> {
291291
let mut active_poll_backoff_us = active_poll_base_us;
292292
let mut next_active_poll_at = current_time;
293293
let mut last_dns_responses_total = 0u64;
294-
let (mut last_enqueued_bytes_total, _) = unsafe { (*state_ptr).debug_snapshot() };
295294

296295
loop {
297296
let current_time = unsafe { picoquic_current_time() };
@@ -541,9 +540,7 @@ pub async fn run_client(config: &ClientConfig<'_>) -> Result<i32, ClientError> {
541540
let polls_sent_before = total_polls_sent(&resolvers);
542541
let mut scheduled_active_poll = false;
543542
let dns_responses_total = total_dns_responses(&resolvers);
544-
let (enqueued_bytes_total, _) = unsafe { (*state_ptr).debug_snapshot() };
545-
let has_useful_progress = dns_responses_total > last_dns_responses_total
546-
|| enqueued_bytes_total > last_enqueued_bytes_total;
543+
let has_useful_progress = dns_responses_total > last_dns_responses_total;
547544
if has_useful_progress {
548545
active_poll_backoff_us = active_poll_base_us;
549546
next_active_poll_at = now.saturating_add(active_poll_backoff_us);
@@ -569,7 +566,6 @@ pub async fn run_client(config: &ClientConfig<'_>) -> Result<i32, ClientError> {
569566
next_active_poll_at = now;
570567
}
571568
last_dns_responses_total = dns_responses_total;
572-
last_enqueued_bytes_total = enqueued_bytes_total;
573569
for resolver in resolvers.iter_mut() {
574570
if !refresh_resolver_path(cnx, resolver) {
575571
continue;

0 commit comments

Comments
 (0)