From: Ryujiro Shibuya <ryujiro.shibuya@owmobility.com>
Date: Wed, 24 Jun 2020 07:36:14 +0000 (+0100)
Subject: tcp: avoid rcv wnd more than RX fifo can enqueue
X-Git-Tag: v21.01-rc0~234
X-Git-Url: https://gerrit.fd.io/r/gitweb?a=commitdiff_plain;h=cc1085647b2ae36e6c086d65b4e81b9f1cf9fc9a;p=vpp.git

tcp: avoid rcv wnd more than RX fifo can enqueue

Type: fix

Signed-off-by: Ryujiro Shibuya <ryujiro.shibuya@owmobility.com>
Signed-off-by: Florin Coras <fcoras@cisco.com>
Change-Id: Ie358b731f8ecb1fcaebd6e79f5ce5c10802c2814
---

diff --git a/src/vnet/tcp/tcp_output.c b/src/vnet/tcp/tcp_output.c
index afc652029c8..3b1bbacbbe6 100644
--- a/src/vnet/tcp/tcp_output.c
+++ b/src/vnet/tcp/tcp_output.c
@@ -120,6 +120,11 @@ tcp_update_rcv_wnd (tcp_connection_t * tc)
    * Figure out how much space we have available
    */
   available_space = transport_max_rx_enqueue (&tc->connection);
+
+  /* Make sure we have a multiple of 1 << rcv_wscale. We round down to
+   * avoid advertising a window larger than what can be buffered */
+  available_space = round_down_pow2 (available_space, 1 << tc->rcv_wscale);
+
   if (PREDICT_FALSE (available_space < tc->rcv_opts.mss))
     {
       tc->rcv_wnd = 0;
@@ -135,7 +140,7 @@ tcp_update_rcv_wnd (tcp_connection_t * tc)
   /* Bad. Thou shalt not shrink */
   if (PREDICT_FALSE ((i32) available_space < observed_wnd))
     {
-      wnd = clib_max (observed_wnd, 0);
+      wnd = round_pow2 (clib_max (observed_wnd, 0), 1 << tc->rcv_wscale);
       TCP_EVT (TCP_EVT_RCV_WND_SHRUNK, tc, observed_wnd, available_space);
     }
   else
@@ -143,12 +148,6 @@ tcp_update_rcv_wnd (tcp_connection_t * tc)
       wnd = available_space;
     }
 
-  /* Make sure we have a multiple of 1 << rcv_wscale. We round up to
-   * avoid advertising a window less than mss which could happen if
-   * 1 << rcv_wscale < mss */
-  if (wnd && tc->rcv_wscale)
-    wnd = round_pow2 (wnd, 1 << tc->rcv_wscale);
-
   tc->rcv_wnd = clib_min (wnd, TCP_WND_MAX << tc->rcv_wscale);
 }
 
diff --git a/src/vppinfra/clib.h b/src/vppinfra/clib.h
index 6961d100a75..be21cad604b 100644
--- a/src/vppinfra/clib.h
+++ b/src/vppinfra/clib.h
@@ -253,6 +253,12 @@ is_pow2 (uword x)
   return 0 == (x & (x - 1));
 }
 
+always_inline uword
+round_down_pow2 (uword x, uword pow2)
+{
+  return (x) & ~(pow2 - 1);
+}
+
 always_inline uword
 round_pow2 (uword x, uword pow2)
 {