Lines Matching refs:data_seq
892 return mpext && mpext->data_seq + mpext->data_len == write_seq && in mptcp_skb_can_collapse_to()
908 df->data_seq + df->data_len == msk->write_seq; in mptcp_frag_can_collapse_to()
1062 if (after64(dfrag->data_seq + dfrag->data_len, snd_una)) in __mptcp_clean_una()
1078 if (dfrag && after64(snd_una, dfrag->data_seq)) { in __mptcp_clean_una()
1079 u64 delta = snd_una - dfrag->data_seq; in __mptcp_clean_una()
1090 dfrag->data_seq += delta; in __mptcp_clean_una()
1170 dfrag->data_seq = msk->write_seq; in mptcp_carve_data_frag()
1188 static int mptcp_check_allowed_size(struct mptcp_sock *msk, u64 data_seq, in mptcp_check_allowed_size() argument
1196 if (!before64(data_seq + avail_size, window_end)) { in mptcp_check_allowed_size()
1197 u64 allowed_size = window_end - data_seq; in mptcp_check_allowed_size()
1286 u64 data_seq = dfrag->data_seq + info->sent; in mptcp_sendmsg_frag() local
1297 msk, ssk, dfrag->data_seq, dfrag->data_len, info->sent); in mptcp_sendmsg_frag()
1311 if (!mptcp_skb_can_collapse_to(data_seq, skb, mpext)) { in mptcp_sendmsg_frag()
1330 avail_size = mptcp_check_allowed_size(msk, data_seq, avail_size); in mptcp_sendmsg_frag()
1337 data_seq = snd_una - 1; in mptcp_sendmsg_frag()
1369 mpext->data_seq = data_seq; in mptcp_sendmsg_frag()
1376 mpext->data_seq, mpext->subflow_seq, mpext->data_len, in mptcp_sendmsg_frag()
1738 dfrag->data_seq, dfrag->data_len, dfrag->already_sent, in mptcp_sendmsg()
2193 msk->tx_pending_data += msk->snd_nxt - rtx_head->data_seq; in __mptcp_retransmit_pending_data()
2194 msk->snd_nxt = rtx_head->data_seq; in __mptcp_retransmit_pending_data()