diff options
| author |   Konstantin Ananyev <konstantin.ananyev@intel.com> | 2021-05-13 15:26:50 +0000 |
|---|---|---|
| committer | Konstantin Ananyev <konstantin.ananyev@intel.com> | 2021-05-13 17:32:55 +0000 |
| commit | e0d62f616439955946d24ad83d49552da24afd5d (patch) | |
| tree | 6a0b3cb971cb2857da3c7b5111bc64d2b0ac1b60 /lib/libtle_l4p/syncookie.h | |
| parent | 10ae544444cfafc4367d9c1f39f332b6206772bf (diff) | |
l4p/tcp: introduce tle_tcp_stream_establish() API
tle_tcp_stream_establish() allows to create streams in established
connection state.
Signed-off-by: Konstantin Ananyev <konstantin.ananyev@intel.com>
Change-Id: Ib302c4d7f229144d2624279f973f00041fb611b2
Diffstat (limited to 'lib/libtle_l4p/syncookie.h')
| -rw-r--r-- | lib/libtle_l4p/syncookie.h | 49 |
1 files changed, 30 insertions, 19 deletions
diff --git a/lib/libtle_l4p/syncookie.h b/lib/libtle_l4p/syncookie.h index 61bfce4..6d4372d 100644 --- a/lib/libtle_l4p/syncookie.h +++ b/lib/libtle_l4p/syncookie.h @@ -178,41 +178,52 @@ sync_check_ack(const union pkt_info *pi, uint32_t seq, uint32_t ack, } static inline void -sync_fill_tcb(struct tcb *tcb, const union seg_info *si, const union tsopt *to) +fill_tcb_rcv(struct tcb *tcb, uint32_t seq, uint32_t wscale, + const union tle_tcp_tsopt *to) { - uint32_t ack, mss, seq, wscale; - - seq = si->seq; - tcb->rcv.nxt = seq; tcb->rcv.irs = seq - 1; - tcb->snd.wu.wl1 = seq; - - ack = si->ack; + tcb->rcv.ts = to->val; + tcb->rcv.wscale = (wscale == TCP_WSCALE_NONE) ? + TCP_WSCALE_NONE : TCP_WSCALE_DEFAULT; +} +static inline void +fill_tcb_snd(struct tcb *tcb, uint32_t seq, uint32_t ack, uint32_t mss, + uint32_t wnd, uint32_t wscale, const union tle_tcp_tsopt *to) +{ tcb->snd.nxt = ack; tcb->snd.una = ack; tcb->snd.iss = ack - 1; tcb->snd.rcvr = ack - 1; - tcb->snd.wu.wl2 = ack; - mss = si->mss; + tcb->snd.wu.wl1 = seq; + tcb->snd.wu.wl2 = ack; tcb->snd.mss = mss; - tcb->so.mss = mss; - tcb->snd.ts = to->ecr; - tcb->rcv.ts = to->val; - tcb->so.ts.raw = to->raw; + tcb->snd.wscale = wscale; + tcb->snd.wnd = wnd << wscale; +} + +static inline void +sync_fill_tcb(struct tcb *tcb, const union seg_info *si, + const union tle_tcp_tsopt *to) +{ + uint32_t ack, mss, seq, wscale; + + seq = si->seq; + ack = si->ack; + mss = si->mss; wscale = to->ecr & SYNC_TMS_WSCALE_MASK; - tcb->snd.wscale = wscale; - tcb->snd.wnd = si->wnd << wscale; - tcb->so.wscale = wscale; + fill_tcb_snd(tcb, seq, ack, mss, si->wnd, wscale, to); + fill_tcb_rcv(tcb, seq, wscale, to); - tcb->rcv.wscale = (wscale == TCP_WSCALE_NONE) ? - TCP_WSCALE_NONE : TCP_WSCALE_DEFAULT; + tcb->so.mss = mss; + tcb->so.ts.raw = to->raw; + tcb->so.wscale = wscale; } #ifdef __cplusplus |