From 0db43497d802cfba078c54a3093a56afc19e071a Mon Sep 17 00:00:00 2001 From: "NG (Graham)" Date: Sat, 24 Jan 2026 18:36:29 -0500 Subject: [PATCH] Add max_bulk_resend parameter for multiplayer server networking --- rc_core/src/persist/multiplayer.rs | 2 ++ rc_multiplayer/src/main.rs | 3 ++- 2 files changed, 4 insertions(+), 1 deletion(-) diff --git a/rc_core/src/persist/multiplayer.rs b/rc_core/src/persist/multiplayer.rs index e671674..e612ea1 100644 --- a/rc_core/src/persist/multiplayer.rs +++ b/rc_core/src/persist/multiplayer.rs @@ -70,6 +70,7 @@ pub struct NetworkConf { pub resend_delay_rtt_mult: f64, pub network_peer_update_interval: i32, pub max_delay_for_disconnect_ms: i32, + pub max_bulk_resend: u8, } pub(super) fn default_net_conf() -> NetworkConf { @@ -90,6 +91,7 @@ pub(super) fn default_net_conf() -> NetworkConf { resend_delay_rtt_mult: 0.5, network_peer_update_interval: 1, max_delay_for_disconnect_ms: 5000, + max_bulk_resend: 2, } } diff --git a/rc_multiplayer/src/main.rs b/rc_multiplayer/src/main.rs index c534f69..1abba0c 100644 --- a/rc_multiplayer/src/main.rs +++ b/rc_multiplayer/src/main.rs @@ -42,8 +42,9 @@ async fn main() -> std::io::Result<()> { let mtu = oj_rc_core::ConfigProvider::<()>::network_config(&init_ctx.config).max_packet_size; let dos_protection = oj_rc_core::ConfigProvider::<()>::server_config(&init_ctx.config).dos_protect; + let max_bulk_resend = oj_rc_core::ConfigProvider::<()>::network_config(&init_ctx.config).max_bulk_resend; let event_handler = events::handler(&init_ctx).await; - let server = literustlib_server::Server::new(event_handler, (args.ip, args.port), mtu, dos_protection).await.expect("Bad server"); + let server = literustlib_server::Server::new(event_handler, (args.ip, args.port), mtu, dos_protection, max_bulk_resend as usize).await.expect("Bad server"); let start_time = chrono::Utc::now(); START_TIMESTAMP_S.store(start_time.timestamp(), std::sync::atomic::Ordering::Relaxed);