Lines Matching refs:write_seq
338 msk->write_seq == atomic64_read(&msk->snd_una)) { in mptcp_check_data_fin_ack()
752 static bool mptcp_skb_can_collapse_to(u64 write_seq, in mptcp_skb_can_collapse_to() argument
760 return mpext && mpext->data_seq + mpext->data_len == write_seq; in mptcp_skb_can_collapse_to()
774 df->data_seq + df->data_len == msk->write_seq; in mptcp_frag_can_collapse_to()
817 atomic64_set(&msk->snd_una, msk->write_seq); in mptcp_clean_una()
883 dfrag->data_seq = msk->write_seq; in mptcp_carve_data_frag()
904 u64 *write_seq; in mptcp_sendmsg_frag() local
914 write_seq = &msk->write_seq; in mptcp_sendmsg_frag()
917 write_seq = &dfrag->data_seq; in mptcp_sendmsg_frag()
937 mptcp_skb_can_collapse_to(*write_seq, skb, mpext); in mptcp_sendmsg_frag()
1028 mpext->data_seq = *write_seq; in mptcp_sendmsg_frag()
1041 WRITE_ONCE(*write_seq, *write_seq + ret); in mptcp_sendmsg_frag()
1609 if (atomic64_read(&msk->snd_una) == READ_ONCE(msk->write_seq)) { in mptcp_retransmit_handler()
1975 WRITE_ONCE(msk->write_seq, msk->write_seq + 1); in mptcp_close()
2131 msk->write_seq = subflow_req->idsn + 1; in mptcp_sk_clone()
2132 atomic64_set(&msk->snd_una, msk->write_seq); in mptcp_sk_clone()
2488 WRITE_ONCE(msk->write_seq, subflow->idsn + 1); in mptcp_finish_connect()
2491 atomic64_set(&msk->snd_una, msk->write_seq); in mptcp_finish_connect()
2819 WRITE_ONCE(msk->write_seq, msk->write_seq + 1); in mptcp_shutdown()