Mirrors/chatmail-core
1
0
Fork 0
mirror of https://github.com/chatmail/core.git synced 2026-05-06 06:46:35 +03:00
Code Issues Packages Projects Releases Wiki Activity

Disable Nagle's algorithm for TCP connections

Browse Source
This commit is contained in:
link2xt
2023-01-01 22:50:20 +00:00
parent 08af7419af
commit 9aaf5cf914
1 changed files with 8 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
src/net.rs
View File

@@ -7,7 +7,11 @@ use tokio::net::{TcpStream, ToSocketAddrs};
use tokio::time::timeout; use tokio::time::timeout;
use tokio_io_timeout::TimeoutStream; use tokio_io_timeout::TimeoutStream;
/// Returns a TCP connection with read/write timeouts set. /// Returns a TCP connection stream with read/write timeouts set
/// and Nagle's algorithm disabled with `TCP_NODELAY`.
///
/// `TCP_NODELAY` ensures writing to the stream always results in immediate sending of the packet
/// to the network, which is important to reduce the latency of interactive protocols such as IMAP.
pub(crate) async fn connect_tcp( pub(crate) async fn connect_tcp(
addr: impl ToSocketAddrs, addr: impl ToSocketAddrs,
timeout_val: Duration, timeout_val: Duration,
@@ -17,6 +21,9 @@ pub(crate) async fn connect_tcp(
.context("connection timeout")? .context("connection timeout")?
.context("connection failure")?; .context("connection failure")?;
// Disable Nagle's algorithm.
tcp_stream.set_nodelay(true)?;
let mut timeout_stream = TimeoutStream::new(tcp_stream); let mut timeout_stream = TimeoutStream::new(tcp_stream);
timeout_stream.set_write_timeout(Some(timeout_val)); timeout_stream.set_write_timeout(Some(timeout_val));
timeout_stream.set_read_timeout(Some(timeout_val)); timeout_stream.set_read_timeout(Some(timeout_val));