network: use sui-http for running gRPC http server

MystenLabs · Jan 2, 2025 · b19b7af · b19b7af
1 parent c97668f
commit b19b7af
Show file tree

Hide file tree

Showing 5 changed files with 109 additions and 339 deletions.
diff --git a/Cargo.lock b/Cargo.lock
diff --git a/crates/mysten-network/Cargo.toml b/crates/mysten-network/Cargo.toml
@@ -33,3 +33,4 @@ tower.workspace = true
 tower-http.workspace = true
 pin-project-lite = "0.2.13"
 tracing.workspace = true
+sui-http.workspace = true
diff --git a/crates/mysten-network/src/config.rs b/crates/mysten-network/src/config.rs
@@ -12,7 +12,7 @@ use std::time::Duration;
 use tokio_rustls::rustls::ClientConfig;
 use tonic::transport::Channel;
 
-#[derive(Debug, Default, Deserialize, Serialize)]
+#[derive(Clone, Debug, Default, Deserialize, Serialize)]
 pub struct Config {
     /// Set the concurrency limit applied to on requests inbound per connection.
     pub concurrency_limit_per_connection: Option<usize>,
@@ -106,4 +106,15 @@ impl Config {
     ) -> Result<Channel> {
         connect_lazy_with_config(addr, tls_config, self)
     }
+
+    pub(crate) fn http_config(&self) -> sui_http::Config {
+        sui_http::Config::default()
+            .initial_stream_window_size(self.http2_initial_stream_window_size)
+            .initial_connection_window_size(self.http2_initial_connection_window_size)
+            .max_concurrent_streams(self.http2_max_concurrent_streams)
+            .http2_keepalive_timeout(self.http2_keepalive_timeout)
+            .http2_keepalive_interval(self.http2_keepalive_interval)
+            .tcp_keepalive(self.tcp_keepalive)
+            .tcp_nodelay(self.tcp_nodelay.unwrap_or_default())
+    }
 }