From 78c896b3b3127515478090c19447e27dc406427e Mon Sep 17 00:00:00 2001
From: Jianfeng Tan <henry.tjf@antfin.com>
Date: Mon, 18 Nov 2019 06:59:50 +0000
Subject: TLDKv2

Signed-off-by: Jianfeng Tan <henry.tjf@antfin.com>
Signed-off-by: Jielong Zhou <jielong.zjl@antfin.com>
Signed-off-by: Jian Zhang <wuzai.zj@antfin.com>
Signed-off-by: Chen Zhao <winters.zc@antfin.com>
Change-Id: I55c39de4c6cd30f991f35631eb507f770230f08e
---
 lib/libtle_l4p/tcp_rxq.h | 4 ++++
 1 file changed, 4 insertions(+)

(limited to 'lib/libtle_l4p/tcp_rxq.h')

diff --git a/lib/libtle_l4p/tcp_rxq.h b/lib/libtle_l4p/tcp_rxq.h
index 2351ee6..be092f9 100644
--- a/lib/libtle_l4p/tcp_rxq.h
+++ b/lib/libtle_l4p/tcp_rxq.h
@@ -17,6 +17,7 @@
 #define _TCP_RXQ_H_
 
 #include "tcp_ofo.h"
+#include "tcp_ctl.h"
 
 #ifdef __cplusplus
 extern "C" {
@@ -74,6 +75,7 @@ rx_ofo_reduce(struct tle_tcp_stream *s)
 
 	s->tcb.rcv.nxt = seq;
 	_ofo_remove(ofo, 0, i);
+
 	return n;
 }
 
@@ -133,6 +135,8 @@ rx_data_enqueue(struct tle_tcp_stream *s, uint32_t seq, uint32_t len,
 	}
 
 	n = rte_ring_count(s->rx.q);
+	/* update receive window with left recv buffer*/
+	s->tcb.rcv.wnd = calc_rx_wnd(s, s->tcb.rcv.wscale);
 	if (r != n) {
 		/* raise RX event */
 		if (s->rx.ev != NULL)
-- 
cgit 1.2.3-korg