Lines Matching refs:write_seq
336 msk->write_seq == atomic64_read(&msk->snd_una)) { in mptcp_check_data_fin_ack()
750 static bool mptcp_skb_can_collapse_to(u64 write_seq, in mptcp_skb_can_collapse_to() argument
758 return mpext && mpext->data_seq + mpext->data_len == write_seq; in mptcp_skb_can_collapse_to()
766 df->data_seq + df->data_len == msk->write_seq; in mptcp_frag_can_collapse_to()
809 atomic64_set(&msk->snd_una, msk->write_seq); in mptcp_clean_una()
875 dfrag->data_seq = msk->write_seq; in mptcp_carve_data_frag()
896 u64 *write_seq; in mptcp_sendmsg_frag() local
906 write_seq = &msk->write_seq; in mptcp_sendmsg_frag()
909 write_seq = &dfrag->data_seq; in mptcp_sendmsg_frag()
929 mptcp_skb_can_collapse_to(*write_seq, skb, mpext); in mptcp_sendmsg_frag()
1020 mpext->data_seq = *write_seq; in mptcp_sendmsg_frag()
1033 WRITE_ONCE(*write_seq, *write_seq + ret); in mptcp_sendmsg_frag()
1601 if (atomic64_read(&msk->snd_una) == READ_ONCE(msk->write_seq)) { in mptcp_retransmit_handler()
1964 WRITE_ONCE(msk->write_seq, msk->write_seq + 1); in mptcp_close()
2071 msk->write_seq = subflow_req->idsn + 1; in mptcp_sk_clone()
2072 atomic64_set(&msk->snd_una, msk->write_seq); in mptcp_sk_clone()
2379 WRITE_ONCE(msk->write_seq, subflow->idsn + 1); in mptcp_finish_connect()
2382 atomic64_set(&msk->snd_una, msk->write_seq); in mptcp_finish_connect()
2710 WRITE_ONCE(msk->write_seq, msk->write_seq + 1); in mptcp_shutdown()