diff --git a/dragonfly-client-storage/src/server/quic.rs b/dragonfly-client-storage/src/server/quic.rs index 083428f6..f585d809 100644 --- a/dragonfly-client-storage/src/server/quic.rs +++ b/dragonfly-client-storage/src/server/quic.rs @@ -25,7 +25,8 @@ use dragonfly_client_util::{ id_generator::IDGenerator, shutdown, tls::generate_simple_self_signed_certs, }; use leaky_bucket::RateLimiter; -use quinn::{congestion::BbrConfig, AckFrequencyConfig, Endpoint, ServerConfig, TransportConfig}; +// use quinn::{congestion::BbrConfig, AckFrequencyConfig, Endpoint, ServerConfig, TransportConfig}; +use quinn::{AckFrequencyConfig, Endpoint, ServerConfig, TransportConfig}; use std::net::SocketAddr; use std::sync::Arc; use tokio::io::{copy, AsyncRead}; @@ -89,7 +90,7 @@ impl QUICServer { })?; let mut transport = TransportConfig::default(); - transport.congestion_controller_factory(Arc::new(BbrConfig::default())); + // transport.congestion_controller_factory(Arc::new(BbrConfig::default())); transport.keep_alive_interval(Some(super::DEFAULT_KEEPALIVE_INTERVAL)); transport.max_idle_timeout(Some(super::DEFAULT_MAX_IDLE_TIMEOUT.try_into().unwrap())); transport.ack_frequency_config(Some(AckFrequencyConfig::default())); diff --git a/dragonfly-client-storage/src/server/tcp.rs b/dragonfly-client-storage/src/server/tcp.rs index 586d1b95..d0083d21 100644 --- a/dragonfly-client-storage/src/server/tcp.rs +++ b/dragonfly-client-storage/src/server/tcp.rs @@ -97,14 +97,15 @@ impl TCPServer { socket.set_tcp_keepalive( &TcpKeepalive::new().with_interval(super::DEFAULT_KEEPALIVE_INTERVAL), )?; - #[cfg(target_os = "linux")] - { - use tracing::warn; - if let Err(err) = socket.set_tcp_congestion("bbr".as_bytes()) { - warn!("failed to set tcp congestion: {}", err); - } - info!("set tcp congestion to bbr"); - } + // #[cfg(target_os = "linux")] + // { + // use tracing::warn; + // if let Err(err) = socket.set_tcp_congestion("bbr".as_bytes()) { + // warn!("failed to set tcp congestion: {}", err); + // } else { + // info!("set tcp congestion to bbr"); + // } + // } socket.bind(&self.addr.into())?; socket.listen(1024)?;