ddidderr/lanspread
1
0
Fork 0
Code Issues 6 Pull Requests Actions Packages Projects Releases Wiki Activity

fix(peer): preserve control capacity across origins

Browse Source 
Set the per-origin control-stream share to eight against the sixteen-slot global pool, preventing one observed host from occupying every decoded control task.

Test Plan:
- just test
- just clippy
- exact admission-limit regression
- git diff --check
This commit is contained in:
ddidderr
2026-09-12 13:22:51 +02:00
parent a5c3a21142
commit a687e0c2b8
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
crates/lanspread-peer/src/services/server.rs
+2 -2
View File
@@ -52,7 +52,7 @@ const MAX_GLOBAL_STREAM_INSTALL_TASKS: usize = 2;
/// One observed host may retain only this many established connection scopes. /// One observed host may retain only this many established connection scopes.
const MAX_ESTABLISHED_CONNECTIONS_PER_ORIGIN: usize = 8; const MAX_ESTABLISHED_CONNECTIONS_PER_ORIGIN: usize = 8;
/// Bounds decoded and undecoded control work across every connection from one IP. /// Bounds decoded and undecoded control work across every connection from one IP.
const MAX_CONTROL_STREAM_TASKS_PER_ORIGIN: usize = 16; const MAX_CONTROL_STREAM_TASKS_PER_ORIGIN: usize = 8;
/// Preserves bulk capacity for other LAN origins while allowing two full /// Preserves bulk capacity for other LAN origins while allowing two full
/// four-stream ordinary download windows from one host. /// four-stream ordinary download windows from one host.
const MAX_BULK_TRANSFER_TASKS_PER_ORIGIN: usize = 8; const MAX_BULK_TRANSFER_TASKS_PER_ORIGIN: usize = 8;
@@ -717,7 +717,7 @@ mod tests {
assert_eq!(MAX_GLOBAL_BULK_TRANSFER_TASKS, 48); assert_eq!(MAX_GLOBAL_BULK_TRANSFER_TASKS, 48);
assert_eq!(MAX_GLOBAL_STREAM_INSTALL_TASKS, 2); assert_eq!(MAX_GLOBAL_STREAM_INSTALL_TASKS, 2);
assert_eq!(MAX_ESTABLISHED_CONNECTIONS_PER_ORIGIN, 8); assert_eq!(MAX_ESTABLISHED_CONNECTIONS_PER_ORIGIN, 8);
assert_eq!(MAX_CONTROL_STREAM_TASKS_PER_ORIGIN, 16); assert_eq!(MAX_CONTROL_STREAM_TASKS_PER_ORIGIN, 8);
assert_eq!(MAX_BULK_TRANSFER_TASKS_PER_ORIGIN, 8); assert_eq!(MAX_BULK_TRANSFER_TASKS_PER_ORIGIN, 8);
assert_eq!(MAX_STREAM_INSTALL_TASKS_PER_ORIGIN, 1); assert_eq!(MAX_STREAM_INSTALL_TASKS_PER_ORIGIN, 1);
assert_eq!( assert_eq!(