astelm/telemt
1
0
Fork 0
mirror of https://github.com/telemt/telemt.git synced 2026-04-17 18:44:10 +03:00
Code Issues Packages Projects Releases Wiki Activity

Update scheduler.rs

Browse Source
This commit is contained in:
Alexey
2026-04-17 11:20:58 +03:00
parent 44485a545e
commit 191ca35076
1 changed files with 2 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
src/transport/middle_proxy/fairness/scheduler.rs
View File

@@ -390,9 +390,8 @@ impl WorkerFairnessState {
flow.queue.push_front(candidate.frame); flow.queue.push_front(candidate.frame);
flow.fairness.pending_bytes = flow.fairness.pending_bytes =
flow.fairness.pending_bytes.saturating_add(frame_bytes); flow.fairness.pending_bytes.saturating_add(frame_bytes);
if flow.fairness.queue_started_at.is_none() { flow.fairness.queue_started_at =
flow.fairness.queue_started_at = Some(now); flow.queue.front().map(|front| front.enqueued_at);
}
self.total_queued_bytes = self.total_queued_bytes.saturating_add(frame_bytes); self.total_queued_bytes = self.total_queued_bytes.saturating_add(frame_bytes);
self.bucket_queued_bytes[flow.fairness.bucket_id] = self.bucket_queued_bytes self.bucket_queued_bytes[flow.fairness.bucket_id] = self.bucket_queued_bytes
[flow.fairness.bucket_id] [flow.fairness.bucket_id]