blockworks-foundation
/
quic_geyser_plugin
mirror of https://github.com/blockworks-foundation/quic_geyser_plugin.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

changing congestion control algorithm and pacing

This commit is contained in:
godmodegalactus 2024-05-29 14:15:40 +02:00
parent 1db88d168d
commit 26be1bc5be
No known key found for this signature in database
GPG Key ID: 22DA4A30887FDA3C
3 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
common/src/quic/configure_client.rs
View File

@ -27,9 +27,8 @@ pub fn configure_client(
config.set_initial_max_streams_bidi(maximum_concurrent_streams); config.set_initial_max_streams_bidi(maximum_concurrent_streams);
config.set_initial_max_streams_uni(maximum_concurrent_streams); config.set_initial_max_streams_uni(maximum_concurrent_streams);
config.set_disable_active_migration(true); config.set_disable_active_migration(true);
config.set_cc_algorithm(quiche::CongestionControlAlgorithm::CUBIC); config.set_cc_algorithm(quiche::CongestionControlAlgorithm::BBR2);
config.set_max_ack_delay(maximum_ack_delay); config.set_max_ack_delay(maximum_ack_delay);
config.set_ack_delay_exponent(ack_exponent); config.set_ack_delay_exponent(ack_exponent);
config.enable_pacing(false);
Ok(config) Ok(config)
} }

3
common/src/quic/configure_server.rs
View File

@ -43,9 +43,10 @@ pub fn configure_server(quic_parameter: QuicParameters) -> anyhow::Result<quiche
config.set_disable_active_migration(true); config.set_disable_active_migration(true);
config.set_max_connection_window(128 * 1024 * 1024); // 128 Mbs config.set_max_connection_window(128 * 1024 * 1024); // 128 Mbs
config.enable_early_data(); config.enable_early_data();
config.set_cc_algorithm(quiche::CongestionControlAlgorithm::CUBIC); config.set_cc_algorithm(quiche::CongestionControlAlgorithm::BBR2);
config.set_active_connection_id_limit(max_number_of_connections); config.set_active_connection_id_limit(max_number_of_connections);
config.set_max_ack_delay(maximum_ack_delay); config.set_max_ack_delay(maximum_ack_delay);
config.set_ack_delay_exponent(ack_exponent); config.set_ack_delay_exponent(ack_exponent);
config.enable_pacing(false);
Ok(config) Ok(config)
} }

2
common/src/quic/quiche_client_loop.rs
View File

@ -194,7 +194,7 @@ pub fn create_quiche_client_thread(
} }
} }
Ok(None) => { Ok(None) => {
// do nothing / continue reading other streams // do nothing / continue
} }
Err(e) => { Err(e) => {
log::error!("Error recieving message : {e}"); log::error!("Error recieving message : {e}");