Add max_bulk_resend parameter for multiplayer server networking

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,
     }
 }
 

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);