Home
last modified time | relevance | path

Searched refs:mptcp_sk (Results 1 – 9 of 9) sorted by relevance

/Linux-v5.15/net/mptcp/
Dprotocol.c338 mptcp_sk(sk)->timer_ival = 0; in mptcp_stop_timer()
356 struct mptcp_sock *msk = mptcp_sk(sk); in mptcp_pending_data_fin_ack()
366 struct mptcp_sock *msk = mptcp_sk(sk); in mptcp_check_data_fin_ack()
388 struct mptcp_sock *msk = mptcp_sk(sk); in mptcp_pending_data_fin()
410 mptcp_sk(sk)->timer_ival = min(TCP_RTO_MAX, in mptcp_set_datafin_timeout()
416 mptcp_sk(sk)->timer_ival = tout > 0 ? tout : TCP_RTO_MIN; in __mptcp_set_timeout()
432 mptcp_for_each_subflow(mptcp_sk(sk), subflow) in mptcp_set_timeout()
505 struct mptcp_sock *msk = mptcp_sk(sk); in mptcp_check_data_fin()
721 struct mptcp_sock *msk = mptcp_sk(sk); in mptcp_data_ready()
807 tout = mptcp_sk(sk)->timer_ival; in mptcp_reset_timer()
[all …]
Dtoken.c74 if (mptcp_sk(sk)->token == token) in __token_lookup_msk()
75 return mptcp_sk(sk); in __token_lookup_msk()
154 struct mptcp_sock *msk = mptcp_sk(subflow->conn); in mptcp_token_new_connect()
218 msk = mptcp_sk(sk); in mptcp_token_exists()
254 msk = mptcp_sk(sk); in mptcp_token_get_sock()
326 ret = mptcp_sk(sk); in mptcp_token_iter_next()
Dsubflow.c365 if (!test_and_set_bit(MPTCP_WORK_CLOSE_SUBFLOW, &mptcp_sk(sk)->flags) && in mptcp_subflow_reset()
366 schedule_work(&mptcp_sk(sk)->work)) in mptcp_subflow_reset()
391 set_bit(MPTCP_CONNECTED, &mptcp_sk(sk)->flags); in mptcp_set_connected()
419 pr_fallback(mptcp_sk(subflow->conn)); in subflow_finish_connect()
424 WRITE_ONCE(mptcp_sk(parent)->csum_enabled, true); in subflow_finish_connect()
426 WRITE_ONCE(mptcp_sk(parent)->pm.remote_deny_join_id0, true); in subflow_finish_connect()
468 if (subflow_use_different_dport(mptcp_sk(parent), sk)) { in subflow_finish_connect()
476 mptcp_rcv_space_init(mptcp_sk(parent), sk); in subflow_finish_connect()
579 mptcp_destroy_common(mptcp_sk(sk)); in mptcp_sock_destruct()
620 struct mptcp_sock *msk = mptcp_sk(subflow->conn); in mptcp_subflow_fully_established()
[all …]
Dprotocol.h300 static inline struct mptcp_sock *mptcp_sk(const struct sock *sk) in mptcp_sk() function
310 return atomic_read(&sk->sk_rmem_alloc) - READ_ONCE(mptcp_sk(sk)->rmem_released); in __mptcp_rmem()
320 const struct mptcp_sock *msk = mptcp_sk(sk); in mptcp_send_head()
327 struct mptcp_sock *msk = mptcp_sk(sk); in mptcp_send_next()
337 struct mptcp_sock *msk = mptcp_sk(sk); in mptcp_pending_tail()
350 struct mptcp_sock *msk = mptcp_sk(sk); in mptcp_rtx_head()
619 struct mptcp_sock *msk = mptcp_sk(subflow->conn); in mptcp_has_another_subflow()
646 READ_ONCE(mptcp_sk(sk)->fully_established); in mptcp_is_fully_established()
691 if (test_and_clear_bit(MPTCP_NOSPACE, &mptcp_sk(sk)->flags)) in mptcp_write_space()
847 struct mptcp_sock *msk = mptcp_sk(subflow->conn); in mptcp_check_fallback()
[all …]
Doptions.c464 struct mptcp_sock *msk = mptcp_sk(subflow->conn); in mptcp_established_options_mp()
541 u64 data_fin_tx_seq = READ_ONCE(mptcp_sk(subflow->conn)->write_seq) - 1; in mptcp_write_data_fin()
570 struct mptcp_sock *msk = mptcp_sk(subflow->conn); in mptcp_established_options_dss()
664 struct mptcp_sock *msk = mptcp_sk(subflow->conn); in mptcp_established_options_add_addr()
717 struct mptcp_sock *msk = mptcp_sk(subflow->conn); in mptcp_established_options_rm_addr()
814 struct mptcp_sock *msk = mptcp_sk(subflow->conn); in mptcp_established_options()
1088 struct mptcp_sock *msk = mptcp_sk(subflow->conn); in mptcp_incoming_options()
1222 msk = mptcp_sk(subflow->conn); in mptcp_set_rwin()
Dmptcp_diag.c114 struct mptcp_sock *msk = mptcp_sk(sk); in mptcp_diag_get_info()
Dsockopt.c615 struct mptcp_sock *msk = mptcp_sk(sk); in mptcp_setsockopt()
690 struct mptcp_sock *msk = mptcp_sk(sk); in mptcp_getsockopt()
Dpm.c249 mptcp_event(MPTCP_EVENT_SUB_PRIORITY, mptcp_sk(subflow->conn), sk, GFP_ATOMIC); in mptcp_pm_mp_prio_received()
Dpm_netlink.c871 msk = mptcp_sk(entry->lsk->sk); in mptcp_pm_nl_create_listen_socket()