Home
last modified time | relevance | path

Searched refs:mptcp_sk (Results 1 - 17 of 17) sorted by relevance

/kernel/linux/linux-6.6/net/mptcp/
H A Dprotocol.c139 WRITE_ONCE(mptcp_sk(sk)->rmem_fwd_alloc, in mptcp_rmem_fwd_alloc_add()
140 mptcp_sk(sk)->rmem_fwd_alloc + size); in mptcp_rmem_fwd_alloc_add()
192 struct mptcp_sock *msk = mptcp_sk(sk); in mptcp_rmem_uncharge()
338 struct mptcp_sock *msk = mptcp_sk(sk); in mptcp_rmem_schedule()
413 mptcp_sk(sk)->timer_ival = 0; in mptcp_stop_rtx_timer()
431 struct mptcp_sock *msk = mptcp_sk(sk); in mptcp_pending_data_fin_ack()
440 struct mptcp_sock *msk = mptcp_sk(sk); in mptcp_check_data_fin_ack()
462 struct mptcp_sock *msk = mptcp_sk(sk); in mptcp_pending_data_fin()
488 mptcp_sk(sk)->timer_ival = TCP_RTO_MIN << retransmits; in mptcp_set_datafin_timeout()
493 mptcp_sk(s in __mptcp_set_timeout()
[all...]
H A 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()
222 msk = mptcp_sk(sk); in mptcp_token_exists()
258 msk = mptcp_sk(sk); in mptcp_token_get_sock()
330 ret = mptcp_sk(sk); in mptcp_token_iter_next()
H A Dprotocol.h346 #define mptcp_sk(ptr) container_of_const(ptr, struct mptcp_sock, sk.icsk_inet.sk) macro
353 return atomic_read(&sk->sk_rmem_alloc) - READ_ONCE(mptcp_sk(sk)->rmem_released); in __mptcp_rmem()
358 return __tcp_win_from_space(mptcp_sk(sk)->scaling_ratio, space); in mptcp_win_from_space()
368 const struct mptcp_sock *msk = mptcp_sk(sk); in mptcp_send_head()
375 struct mptcp_sock *msk = mptcp_sk(sk); in mptcp_send_next()
385 const struct mptcp_sock *msk = mptcp_sk(sk); in mptcp_pending_tail()
398 struct mptcp_sock *msk = mptcp_sk(sk); in mptcp_rtx_head()
740 mptcp_reset_tout_timer(mptcp_sk(sk), 0); in mptcp_start_tout_timer()
746 READ_ONCE(mptcp_sk(sk)->fully_established); in mptcp_is_fully_established()
780 if (test_and_clear_bit(MPTCP_NOSPACE, &mptcp_sk(s in mptcp_write_space()
[all...]
H A Dsubflow.c411 if (!test_and_set_bit(MPTCP_WORK_CLOSE_SUBFLOW, &mptcp_sk(sk)->flags)) in mptcp_subflow_reset()
425 struct mptcp_sock *msk = mptcp_sk(sk); in __mptcp_sync_state()
469 struct mptcp_sock *msk = mptcp_sk(sk); in mptcp_propagate_state()
503 msk = mptcp_sk(parent); in subflow_finish_connect()
587 struct mptcp_sock *msk = mptcp_sk(subflow->conn); in subflow_chk_local_id()
849 owner = mptcp_sk(ctx->conn); in subflow_syn_recv_sock()
1130 WRITE_ONCE(mptcp_sk(subflow->conn)->use_64bit_ack, !!mpext->dsn64); in get_mapping_status()
1220 struct mptcp_sock *msk = mptcp_sk(subflow->conn); in subflow_can_fallback()
1269 msk = mptcp_sk(subflow->conn); in subflow_check_data_avail()
1405 __set_bit(MPTCP_ERROR_REPORT, &mptcp_sk(s in subflow_error_report()
[all...]
H A Dbpf.c18 return mptcp_sk(mptcp_subflow_ctx(sk)->conn); in bpf_mptcp_sock_from_subflow()
H A Dfastopen.c55 mptcp_sk(sk)->bytes_received += skb->len; in mptcp_fastopen_subflow_synack_set_params()
H A Dpm.c223 struct mptcp_sock *msk = mptcp_sk(subflow->conn); in mptcp_pm_add_addr_received()
301 msk = mptcp_sk(sk); in mptcp_pm_mp_prio_received()
311 struct mptcp_sock *msk = mptcp_sk(subflow->conn); in mptcp_pm_mp_fail_received()
H A Doptions.c449 struct mptcp_sock *msk = mptcp_sk(subflow->conn); in mptcp_established_options_mp()
534 u64 data_fin_tx_seq = READ_ONCE(mptcp_sk(subflow->conn)->write_seq) - 1; in mptcp_write_data_fin()
562 struct mptcp_sock *msk = mptcp_sk(subflow->conn); in mptcp_established_options_dss()
655 struct mptcp_sock *msk = mptcp_sk(subflow->conn); in mptcp_established_options_add_addr()
710 struct mptcp_sock *msk = mptcp_sk(subflow->conn); in mptcp_established_options_rm_addr()
785 struct mptcp_sock *msk = mptcp_sk(subflow->conn); in mptcp_established_options_fastclose()
830 struct mptcp_sock *msk = mptcp_sk(subflow->conn); in mptcp_established_options()
1117 struct mptcp_sock *msk = mptcp_sk(subflow->conn); in mptcp_incoming_options()
1260 msk = mptcp_sk(subflow->conn); in mptcp_set_rwin()
H A Dmptcp_diag.c203 struct mptcp_sock *msk = mptcp_sk(sk); in mptcp_diag_get_info()
H A Dsockopt.c832 struct mptcp_sock *msk = mptcp_sk(sk); in mptcp_setsockopt()
1376 struct mptcp_sock *msk = mptcp_sk(sk); in mptcp_getsockopt()
H A Dpm_netlink.c1036 ssk = __mptcp_nmpc_sk(mptcp_sk(newsk)); in mptcp_pm_nl_create_listen_socket()
2146 struct mptcp_sock *msk = mptcp_sk(subflow->conn); in mptcp_event_addr_announced()
/kernel/linux/linux-5.10/net/mptcp/
H A Dprotocol.c325 mptcp_sk(sk)->timer_ival = 0; in mptcp_stop_timer()
330 struct mptcp_sock *msk = mptcp_sk(sk); in mptcp_check_data_fin_ack()
365 struct mptcp_sock *msk = mptcp_sk(sk); in mptcp_pending_data_fin()
389 tout = mptcp_sk(sk)->timer_ival; in mptcp_set_timeout()
390 mptcp_sk(sk)->timer_ival = tout > 0 ? tout : TCP_RTO_MIN; in mptcp_set_timeout()
395 struct mptcp_sock *msk = mptcp_sk(sk); in mptcp_check_data_fin()
626 struct mptcp_sock *msk = mptcp_sk(sk); in mptcp_data_ready()
681 tout = READ_ONCE(mptcp_sk(sk)->timer_ival); in mptcp_reset_timer()
691 if ((!test_bit(MPTCP_SEND_SPACE, &mptcp_sk(sk)->flags) || in mptcp_data_acked()
693 schedule_work(&mptcp_sk(s in mptcp_data_acked()
[all...]
H A Dtoken.c75 if (mptcp_sk(sk)->token == token) in __token_lookup_msk()
76 return mptcp_sk(sk); in __token_lookup_msk()
155 struct mptcp_sock *msk = mptcp_sk(subflow->conn); in mptcp_token_new_connect()
219 msk = mptcp_sk(sk); in mptcp_token_exists()
255 msk = mptcp_sk(sk); in mptcp_token_get_sock()
327 ret = mptcp_sk(sk); in mptcp_token_iter_next()
H A Dsubflow.c280 if (!test_and_set_bit(MPTCP_WORK_CLOSE_SUBFLOW, &mptcp_sk(sk)->flags) && in mptcp_subflow_reset()
281 schedule_work(&mptcp_sk(sk)->work)) in mptcp_subflow_reset()
313 pr_fallback(mptcp_sk(subflow->conn)); in subflow_finish_connect()
352 mptcp_rcv_space_init(mptcp_sk(parent), sk); in subflow_finish_connect()
479 mptcp_destroy_common(mptcp_sk(sk)); in mptcp_sock_destruct()
517 struct mptcp_sock *msk = mptcp_sk(subflow->conn); in mptcp_subflow_fully_established()
612 mptcp_pm_new_connection(mptcp_sk(new_msk), 1); in subflow_syn_recv_sock()
613 mptcp_token_accept(subflow_req, mptcp_sk(new_msk)); in subflow_syn_recv_sock()
815 WRITE_ONCE(mptcp_sk(subflow->conn)->use_64bit_ack, !!mpext->dsn64); in get_mapping_status()
893 msk = mptcp_sk(subflo in subflow_check_data_avail()
[all...]
H A Dprotocol.h238 static inline struct mptcp_sock *mptcp_sk(const struct sock *sk) in mptcp_sk() function
245 struct mptcp_sock *msk = mptcp_sk(sk); in mptcp_rtx_tail()
255 struct mptcp_sock *msk = mptcp_sk(sk); in mptcp_rtx_head()
405 READ_ONCE(mptcp_sk(sk)->fully_established); in mptcp_is_fully_established()
514 struct mptcp_sock *msk = mptcp_sk(subflow->conn); in mptcp_check_fallback()
531 struct mptcp_sock *msk = mptcp_sk(subflow->conn); in mptcp_do_fallback()
544 !mptcp_sk(parent)->pm.server_side && in subflow_simultaneous_connect()
H A Doptions.c462 u64 data_fin_tx_seq = READ_ONCE(mptcp_sk(subflow->conn)->write_seq) - 1; in mptcp_write_data_fin()
490 struct mptcp_sock *msk = mptcp_sk(subflow->conn); in mptcp_established_options_dss()
585 struct mptcp_sock *msk = mptcp_sk(subflow->conn); in mptcp_established_options_add_addr()
633 struct mptcp_sock *msk = mptcp_sk(subflow->conn); in mptcp_established_options_rm_addr()
888 struct mptcp_sock *msk = mptcp_sk(subflow->conn); in mptcp_incoming_options()
H A Dmptcp_diag.c116 struct mptcp_sock *msk = mptcp_sk(sk); in mptcp_diag_get_info()

Completed in 40 milliseconds