Change-Id: I911fdeeb25bc1112cd38eaa96c34f47a7bf49060
Signed-off-by: Konstantin Ananyev <konstantin.ananyev@intel.com>
static inline uint32_t
calc_rx_wnd(const struct tle_tcp_stream *s, uint32_t scale)
{
- return s->rx.q->prod.mask << scale;
+ uint32_t wnd;
+
+ /* peer doesn't support WSCALE option, wnd size is limited to 64K */
+ if (scale == TCP_WSCALE_NONE) {
+ wnd = s->rx.q->prod.mask << TCP_WSCALE_DEFAULT;
+ return RTE_MIN(wnd, (uint32_t)UINT16_MAX);
+ } else
+ return s->rx.q->prod.mask << scale;
}
/* empty stream's receive queue */
s->tcb.rcv.irs = si->seq;
s->tcb.rcv.nxt = si->seq + 1;
+ /* if peer doesn't support WSCALE opt, recalculate RCV.WND */
+ s->tcb.rcv.wscale = (so.wscale == TCP_WSCALE_NONE) ?
+ TCP_WSCALE_NONE : TCP_WSCALE_DEFAULT;
+ s->tcb.rcv.wnd = calc_rx_wnd(s, s->tcb.rcv.wscale);
+
/* calculate initial rto */
rto_estimate(&s->tcb, ts - s->tcb.snd.ts);