GameCult/Ratatoskr-receiver
Watch
3
0
Fork
You've already forked Ratatoskr-receiver
 0
Code Issues Pull requests 1 Projects Releases Packages Wiki Activity Actions

Size the media receive buffer like the producer's send buffer

Browse source 
A 12 Mbps stream is about 2,300 datagrams a second; the OS default
receive buffer holds a few milliseconds of it, and every poll gap longer
than that is loss on a wire that lost nothing.

Co-Authored-By: Claude Fable 5.1 <noreply@anthropic.com>
This commit is contained in:
Meta Vens 2026-09-11 01:01:12 +02:00
commit 014e24f771
3 changed files with 12 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

1
Cargo.lock generated
View file

@ -615,6 +615,7 @@ dependencies = [
"cultmesh-rs",
"cultnet-rs",
"rmp-serde",
"socket2",
]
[[package]]

1
crates/ratatoskr-core/Cargo.toml
View file

@ -16,6 +16,7 @@ chrono = "0.4"
cultnet-rs = { git = "https://github.com/GameCult/CultLib.git", rev = "c84cb2e", package = "cultnet-rs" }
cultmesh-rs = { git = "https://github.com/GameCult/CultLib.git", rev = "c84cb2e", package = "cultmesh-rs" }
cultcache-rs = { git = "https://github.com/GameCult/CultLib.git", rev = "c84cb2e", package = "cultcache-rs" }
socket2 = "0.5"
[dev-dependencies]
rmp-serde = "1.3"

10
crates/ratatoskr-core/src/receiver.rs
View file

@ -30,6 +30,10 @@ use crate::video::{ExpiredFrame, VideoAssembler, VideoAssemblerOptions, VideoFra
/// takes it as a parameter so no consumer's name is baked into the contract.
pub const RATATOSKR_MEDIA_PRODUCER: &str = "ratatoskr";
/// Kernel receive buffer for the media socket. Matches the producer's send
/// buffer; the OS default is a few milliseconds of a 12 Mbps stream.
const RECEIVE_BUFFER_BYTES: usize = 16 * 1024 * 1024;
#[derive(Clone, Debug)]
pub struct ReceiverOptions {
/// The producer's advertised media endpoint, to dial.
@ -402,6 +406,12 @@ impl RatatoskrReceiver {
fn dial(producer: SocketAddr, runtime_id: &str, connection_id: u32) -> Result<CultNetRudpSocketTransportConnection> {
let bind = if producer.is_ipv4() { "0.0.0.0:0" } else { "[::]:0" };
let socket = UdpSocket::bind(bind).with_context(|| format!("binding a socket to dial {producer}"))?;
// A 12 Mbps stream is ~2,300 datagrams a second; the OS default receive
// buffer holds a few milliseconds of that, and every poll gap longer than
// it is loss on a wire that lost nothing. Sized like the producer's.
socket2::SockRef::from(&socket)
.set_recv_buffer_size(RECEIVE_BUFFER_BYTES)
.context("sizing the Ratatoskr media receive buffer")?;
socket
.set_nonblocking(true)
.context("setting the Ratatoskr media socket nonblocking")?;