try try fix madsim

Signed-off-by: Bugen Zhao <[email protected]>

Cargo.toml

@@ -129,7 +129,7 @@ rdkafka = { package = "madsim-rdkafka", version = "0.4.1", features = [
 ] }
 hashbrown = { version = "0.14", features = ["ahash", "inline-more", "nightly"] }
 criterion = { version = "0.5", features = ["async_futures"] }
-tonic = { package = "madsim-tonic", version = "0.5" }
+tonic = { package = "madsim-tonic", version = "0.5", git = "https://github.com/BugenZhao/madsim", rev = "20afe23b9a8c953cc111cc1f9d31f5da825ab8b9" }
 tonic-build = { package = "madsim-tonic-build", version = "0.5" }
 otlp-embedded = { git = "https://github.com/risingwavelabs/otlp-embedded", rev = "e6cd165b9bc85783b42c106e99186b86b73e3507" }
 prost = { version = "0.13" }

src/common/metrics/src/monitor/connection.rs

@@ -329,6 +329,7 @@ where
 
 // Compatibility implementation for hyper 0.14 ecosystem.
 // Should be the same as those with imports from `http::Uri` and `hyper_util::client::legacy`.
+// TODO(http-bump): remove this after there is no more dependency on hyper 0.14.
 mod compat {
     use http_02::Uri;
     use hyper_014::client::connect::{Connected, Connection};

src/compute/src/rpc/service/monitor_service.rs

@@ -390,7 +390,6 @@ pub mod grpc_middleware {
     use either::Either;
     use futures::Future;
     use tonic::body::BoxBody;
-    use tonic::server::NamedService;
     use tower::{Layer, Service};
 
     /// Manages the await-trees of `gRPC` requests that are currently served by the compute node.
@@ -478,7 +477,8 @@ pub mod grpc_middleware {
         }
     }
 
-    impl<S: NamedService> NamedService for AwaitTreeMiddleware<S> {
+    #[cfg(not(madsim))]
+    impl<S: tonic::server::NamedService> tonic::server::NamedService for AwaitTreeMiddleware<S> {
         const NAME: &'static str = S::NAME;
     }
 }

src/rpc_client/src/tracing.rs

@@ -28,6 +28,7 @@ pub struct TracingInjectChannel {
     inner: tonic::transport::Channel,
 }
 
+#[cfg(not(madsim))]
 impl Service<http::Request<BoxBody>> for TracingInjectChannel {
     type Error = tonic::transport::Error;
     type Response = http::Response<BoxBody>;