disable GSO (Generic Segmentation Offload) for all outgoing QUIC-conn…

…ects (#200) should fix #199 Co-authored-by: GroovieGermanikus <groovie@mango.markets>
blockworks-foundation · Sep 18, 2023 · 79ef230 · 79ef230
1 parent 433550d
commit 79ef230
Show file tree

Hide file tree

Showing 5 changed files with 67 additions and 17 deletions.
diff --git a/Cargo.lock b/Cargo.lock
diff --git a/Cargo.toml b/Cargo.toml
@@ -50,7 +50,7 @@ prometheus = "0.13.3"
 lazy_static = "1.4.0"
 dotenv = "0.15.0"
 async-channel = "1.8.0"
-quinn = "0.9.3"
+quinn = { git = "https://github.com/grooviegermanikus/quinn.git", branch = "0.9.4-manually-disable-gso", version = "0.9.4" }
 rustls = { version = "=0.20.8", default-features = false }
 solana-lite-rpc-services = {path = "services", version="0.2.3"}
 solana-lite-rpc-core = {path = "core", version="0.2.3"}

diff --git a/core/src/quic_connection_utils.rs b/core/src/quic_connection_utils.rs
@@ -61,6 +61,7 @@ impl QuicConnectionUtils {
         let timeout = IdleTimeout::try_from(Duration::from_secs(1)).unwrap();
         transport_config.max_idle_timeout(Some(timeout));
         transport_config.keep_alive_interval(Some(Duration::from_millis(500)));
+        transport_config.enable_segmentation_offload(false);
         config.transport_config(Arc::new(transport_config));
 
         endpoint.set_default_client_config(config);

diff --git a/quic-forward-proxy/src/outbound/tx_forward.rs b/quic-forward-proxy/src/outbound/tx_forward.rs
@@ -309,6 +309,7 @@ fn create_tpu_client_endpoint(
     let timeout = IdleTimeout::try_from(QUIC_MAX_TIMEOUT).unwrap();
     transport_config.max_idle_timeout(Some(timeout));
     transport_config.keep_alive_interval(Some(Duration::from_millis(500)));
+    transport_config.enable_segmentation_offload(false);
 
     config.transport_config(Arc::new(transport_config));
 

diff --git a/services/src/tpu_utils/quic_proxy_connection_manager.rs b/services/src/tpu_utils/quic_proxy_connection_manager.rs
@@ -136,6 +136,7 @@ impl QuicProxyConnectionManager {
         let timeout = Duration::from_secs(10).try_into().unwrap();
         transport_config.max_idle_timeout(Some(timeout));
         transport_config.keep_alive_interval(Some(Duration::from_millis(500)));
+        transport_config.enable_segmentation_offload(false);
 
         config.transport_config(Arc::new(transport_config));
         endpoint.set_default_client_config(config);