GameCult/Odin
Watch
9
0
Fork
You've already forked Odin
 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Raise Muninn RUDP repair budget for LAN streams

Browse source
This commit is contained in:
Meta Vens 2026-06-19 18:53:50 +01:00
commit 07b366faa2
1 changed files with 10 additions and 10 deletions
Download patch file Download diff file Expand all files Collapse all files

20
crates/muninn-daemon/src/main.rs
View file

@ -68,11 +68,11 @@ const MUNINN_RUDP_MEDIA_RESEND_DELAY_MS: u64 = 5;
const MUNINN_RUDP_MEDIA_RECEIVER_ASSEMBLY_DEADLINE_MS: u64 = 1_200;
const MUNINN_RUDP_MEDIA_RECEIVER_GAP_WAIT_MS: u64 = 16;
const MUNINN_RUDP_MEDIA_REPAIR_CACHE_CHUNKS: usize = 16_384;
const MUNINN_RUDP_MEDIA_REPAIR_BURST_CHUNKS: usize = 512;
const MUNINN_RUDP_MEDIA_REPAIR_INITIAL_CHUNKS_PER_SECOND: usize = 512;
const MUNINN_RUDP_MEDIA_REPAIR_BURST_CHUNKS: usize = 1_024;
const MUNINN_RUDP_MEDIA_REPAIR_INITIAL_CHUNKS_PER_SECOND: usize = 1_024;
const MUNINN_RUDP_MEDIA_REPAIR_MIN_CHUNKS_PER_SECOND: usize = 8;
const MUNINN_RUDP_MEDIA_REPAIR_MAX_CHUNKS_PER_SECOND: usize = 4_096;
const MUNINN_RUDP_MEDIA_REPAIR_ADD_CHUNKS_PER_SECOND: usize = 256;
const MUNINN_RUDP_MEDIA_REPAIR_MAX_CHUNKS_PER_SECOND: usize = 6_144;
const MUNINN_RUDP_MEDIA_REPAIR_ADD_CHUNKS_PER_SECOND: usize = 512;
const MUNINN_RUDP_MEDIA_REPAIR_RECOVERY_INTERVAL_MS: u64 = 2_000;
const MUNINN_RUDP_MEDIA_SOCKET_BUFFER_BYTES: usize = 4 * 1024 * 1024;
const MUNINN_RUDP_MEDIA_SEND_PACE_EVERY_PAYLOADS: usize = 16;
@ -7248,13 +7248,13 @@ mod tests {
);
let start = budget.last_refill_at;
assert_eq!(budget.chunks_per_second(), 512);
assert_eq!(budget.take(512, start, 0), 512);
assert_eq!(budget.take(4_096, start + Duration::from_secs(1), 0), 512);
assert_eq!(budget.take(4_096, start + Duration::from_secs(3), 0), 512);
assert_eq!(budget.chunks_per_second(), 1_024);
assert_eq!(budget.take(1_024, start, 0), 1_024);
assert_eq!(budget.take(8_192, start + Duration::from_secs(1), 0), 1_024);
assert_eq!(budget.take(8_192, start + Duration::from_secs(3), 0), 1_024);
assert_eq!(budget.chunks_per_second(), 1_536);
assert_eq!(budget.take(512, start + Duration::from_secs(4), 1), 512);
assert_eq!(budget.chunks_per_second(), 768);
assert_eq!(budget.take(512, start + Duration::from_secs(4), 1), 384);
assert_eq!(budget.chunks_per_second(), 384);
}
#[test]