From 19f80580a390320a473a96e3ce70a680b8306456 Mon Sep 17 00:00:00 2001
From: Artem Anisimov <aanisimov@inbox.ru>
Date: Wed, 6 Nov 2019 13:53:23 +0300
Subject: [PATCH] feat(transport): Enable TCP_NODELAY.

The combination of the Nagle algorithm on a client, and delayed ack on a server
can introduce up to 200ms latency if a small gRPC messages is sent with multiple
writes.

Enable TCP_NODELAY to make sure that neither client, nor server buffer their
messages for too long when exchaning small requests.
---
 tonic/src/transport/server.rs            | 3 ++-
 tonic/src/transport/service/connector.rs | 2 ++
 2 files changed, 4 insertions(+), 1 deletion(-)

diff --git a/tonic/src/transport/server.rs b/tonic/src/transport/server.rs
index 886a74b7e..9d1da6076 100644
--- a/tonic/src/transport/server.rs
+++ b/tonic/src/transport/server.rs
@@ -427,7 +427,8 @@ struct TcpIncoming {
 
 impl TcpIncoming {
     fn bind(addr: SocketAddr) -> Result<Self, crate::Error> {
-        let inner = conn::AddrIncoming::bind(&addr).map_err(Box::new)?;
+        let mut inner = conn::AddrIncoming::bind(&addr).map_err(Box::new)?;
+        inner.set_nodelay(true);
 
         Ok(Self { inner })
     }
diff --git a/tonic/src/transport/service/connector.rs b/tonic/src/transport/service/connector.rs
index 908c5b7aa..c02d17367 100644
--- a/tonic/src/transport/service/connector.rs
+++ b/tonic/src/transport/service/connector.rs
@@ -13,6 +13,7 @@ use tower_service::Service;
 pub(crate) fn connector() -> HttpConnector {
     let mut http = HttpConnector::new();
     http.enforce_http(false);
+    http.set_nodelay(true);
     http
 }
 
@@ -32,6 +33,7 @@ impl Connector {
     pub(crate) fn new(tls: Option<TlsConnector>) -> Self {
         let mut http = HttpConnector::new();
         http.enforce_http(false);
+        http.set_nodelay(true);
 
         Self { http, tls }
     }