| /linux/net/mptcp/ |
| H A D | protocol.h | 280 struct mptcp_sock { argument
392 static inline void msk_owned_by_me(const struct mptcp_sock *msk)
408 container_of_const(_ptr, struct mptcp_sock, sk.icsk_inet.sk); \ in mptcp_space_from_win()
412 #define mptcp_sk(ptr) container_of_const(ptr, struct mptcp_sock, sk.icsk_inet.sk) in __mptcp_space()
434 const struct mptcp_sock *msk = mptcp_sk(sk);
439 static inline void mptcp_init_rtt_est(struct mptcp_sock *msk) in mptcp_pending_tail()
449 static inline u32 mptcp_rtt_us_est(const struct mptcp_sock *msk) in mptcp_rtx_head()
462 struct mptcp_sock *msk = mptcp_sk(sk);
472 const struct mptcp_sock *msk = mptcp_sk(sk);
485 struct mptcp_sock *ms
272 struct mptcp_sock { global() struct
274 skmptcp_sock global() argument
275 local_keymptcp_sock global() argument
278 remote_keymptcp_sock global() argument
279 write_seqmptcp_sock global() argument
281 snd_nxtmptcp_sock global() argument
282 bytes_receivedmptcp_sock global() argument
283 ack_seqmptcp_sock global() argument
284 rcv_wnd_sentmptcp_sock global() argument
285 rcv_data_fin_seqmptcp_sock global() argument
286 bytes_retransmptcp_sock global() argument
287 bytes_consumedmptcp_sock global() argument
288 snd_burstmptcp_sock global() argument
289 old_wspacemptcp_sock global() argument
290 recovery_snd_nxtmptcp_sock global() argument
294 bytes_ackedmptcp_sock global() argument
295 snd_unamptcp_sock global() argument
296 wnd_endmptcp_sock global() argument
297 last_data_sentmptcp_sock global() argument
298 last_data_recvmptcp_sock global() argument
299 last_ack_recvmptcp_sock global() argument
300 timer_ivalmptcp_sock global() argument
301 tokenmptcp_sock global() argument
302 flagsmptcp_sock global() argument
303 cb_flagsmptcp_sock global() argument
304 recoverymptcp_sock global() argument
305 can_ackmptcp_sock global() argument
306 fully_establishedmptcp_sock global() argument
307 rcv_data_finmptcp_sock global() argument
308 snd_data_fin_enablemptcp_sock global() argument
309 rcv_fastclosemptcp_sock global() argument
310 use_64bit_ackmptcp_sock global() argument
311 csum_enabledmptcp_sock global() argument
312 allow_infinite_fallbackmptcp_sock global() argument
313 pending_statemptcp_sock global() argument
316 mpc_endpoint_idmptcp_sock global() argument
317 recvmsg_inqmptcp_sock global() argument
318 corkmptcp_sock global() argument
319 nodelaymptcp_sock global() argument
320 fastopeningmptcp_sock global() argument
321 in_accept_queuemptcp_sock global() argument
322 free_firstmptcp_sock global() argument
323 rcvspace_initmptcp_sock global() argument
324 fastclosingmptcp_sock global() argument
325 notsent_lowatmptcp_sock global() argument
326 keepalive_cntmptcp_sock global() argument
327 keepalive_idlemptcp_sock global() argument
328 keepalive_intvlmptcp_sock global() argument
329 maxsegmptcp_sock global() argument
330 workmptcp_sock global() argument
331 ooo_last_skbmptcp_sock global() argument
332 out_of_order_queuemptcp_sock global() argument
333 conn_listmptcp_sock global() argument
334 rtx_queuemptcp_sock global() argument
335 first_pendingmptcp_sock global() argument
336 join_listmptcp_sock global() argument
337 firstmptcp_sock global() argument
341 pmmptcp_sock global() argument
342 schedmptcp_sock global() argument
343 __anon07c3a8af0108mptcp_sock global() argument
348 rcvq_spacemptcp_sock global() argument
349 scaling_ratiomptcp_sock global() argument
350 allow_subflowsmptcp_sock global() argument
352 subflow_idmptcp_sock global() argument
353 setsockopt_seqmptcp_sock global() argument
354 ca_namemptcp_sock global() argument
378 backlog_unaccountedmptcp_sock msk_owned_by_me() argument
[all...] |
| H A D | pm.c | 20 struct mptcp_sock *sock;
108 static bool mptcp_pm_is_init_remote_addr(struct mptcp_sock *msk, in mptcp_pm_is_init_remote_addr()
136 mptcp_lookup_anno_list_by_saddr(const struct mptcp_sock *msk, in mptcp_lookup_anno_list_by_saddr()
151 bool mptcp_remove_anno_list_by_saddr(struct mptcp_sock *msk, in mptcp_remove_anno_list_by_saddr()
164 bool mptcp_pm_sport_in_anno_list(struct mptcp_sock *msk, const struct sock *sk) in mptcp_pm_sport_in_anno_list()
185 static void __mptcp_pm_send_ack(struct mptcp_sock *msk, in __mptcp_pm_send_ack()
206 void mptcp_pm_send_ack(struct mptcp_sock *msk, in mptcp_pm_send_ack()
229 mptcp_pm_addr_send_ack_avoid_list(struct mptcp_sock *msk, in mptcp_pm_addr_send_ack_avoid_list()
268 void mptcp_pm_addr_send_ack(struct mptcp_sock *msk) in mptcp_pm_addr_send_ack()
273 int mptcp_pm_mp_prio_send_ack(struct mptcp_sock *msk, in mptcp_pm_mp_prio_send_ack()
[all …]
|
| H A D | token_test.c | 21 struct mptcp_sock *null_msk = NULL; in mptcp_token_test_req_basic()
52 static struct mptcp_sock *build_msk(struct kunit *test) in build_msk()
54 struct mptcp_sock *msk; in build_msk()
57 msk = kunit_kzalloc(test, sizeof(struct mptcp_sock), GFP_USER); in build_msk()
75 struct mptcp_sock *msk = build_msk(test); in mptcp_token_test_msk_basic()
76 struct mptcp_sock *null_msk = NULL; in mptcp_token_test_msk_basic()
97 struct mptcp_sock *msk = build_msk(test); in mptcp_token_test_accept()
116 struct mptcp_sock *msk = build_msk(test); in mptcp_token_test_destroyed()
117 struct mptcp_sock *null_msk = NULL; in mptcp_token_test_destroyed()
|
| H A D | pm_userspace.c | 15 void mptcp_userspace_pm_free_local_addr_list(struct mptcp_sock *msk) in mptcp_userspace_pm_free_local_addr_list()
31 mptcp_userspace_pm_lookup_addr(struct mptcp_sock *msk, in mptcp_userspace_pm_lookup_addr()
43 static int mptcp_userspace_pm_append_new_local_addr(struct mptcp_sock *msk, in mptcp_userspace_pm_append_new_local_addr()
98 static int mptcp_userspace_pm_delete_local_addr(struct mptcp_sock *msk, in mptcp_userspace_pm_delete_local_addr()
118 mptcp_userspace_pm_lookup_addr_by_id(struct mptcp_sock *msk, unsigned int id) in mptcp_userspace_pm_lookup_addr_by_id()
129 int mptcp_userspace_pm_get_local_id(struct mptcp_sock *msk, in mptcp_userspace_pm_get_local_id()
148 bool mptcp_userspace_pm_is_backup(struct mptcp_sock *msk, in mptcp_userspace_pm_is_backup()
162 static struct mptcp_sock *mptcp_userspace_pm_get_sock(const struct genl_info *info) in mptcp_userspace_pm_get_sock()
164 struct mptcp_sock *msk; in mptcp_userspace_pm_get_sock()
190 struct mptcp_sock *msk; in mptcp_pm_nl_announce_doit()
[all …]
|
| H A D | sockopt.c | 20 static struct sock *__mptcp_tcp_fallback(struct mptcp_sock *msk) in __mptcp_tcp_fallback()
51 static void sockopt_seq_inc(struct mptcp_sock *msk) in sockopt_seq_inc()
58 static int mptcp_get_int_option(struct mptcp_sock *msk, sockptr_t optval, in mptcp_get_int_option()
70 static void mptcp_sol_socket_sync_intval(struct mptcp_sock *msk, int optname, int val) in mptcp_sol_socket_sync_intval()
123 static int mptcp_sol_socket_intval(struct mptcp_sock *msk, int optname, int val) in mptcp_sol_socket_intval()
138 static void mptcp_so_incoming_cpu(struct mptcp_sock *msk, int val) in mptcp_so_incoming_cpu()
147 static int mptcp_setsockopt_sol_socket_tstamp(struct mptcp_sock *msk, int optname, int val) in mptcp_setsockopt_sol_socket_tstamp()
172 static int mptcp_setsockopt_sol_socket_int(struct mptcp_sock *msk, int optname, in mptcp_setsockopt_sol_socket_int()
205 static int mptcp_setsockopt_sol_socket_timestamping(struct mptcp_sock *msk, in mptcp_setsockopt_sol_socket_timestamping()
249 static int mptcp_setsockopt_sol_socket_linger(struct mptcp_sock *msk, sockptr_t optval, in mptcp_setsockopt_sol_socket_linger()
[all …]
|
| H A D | pm_kernel.c | 40 pm_nl_get_pernet_from_msk(const struct mptcp_sock *msk) in pm_nl_get_pernet_from_msk()
50 u8 mptcp_pm_get_endp_signal_max(const struct mptcp_sock *msk) in mptcp_pm_get_endp_signal_max()
58 u8 mptcp_pm_get_endp_subflow_max(const struct mptcp_sock *msk) in mptcp_pm_get_endp_subflow_max()
66 u8 mptcp_pm_get_endp_laminar_max(const struct mptcp_sock *msk) in mptcp_pm_get_endp_laminar_max()
74 u8 mptcp_pm_get_endp_fullmesh_max(const struct mptcp_sock *msk) in mptcp_pm_get_endp_fullmesh_max()
82 u8 mptcp_pm_get_limit_add_addr_accepted(const struct mptcp_sock *msk) in mptcp_pm_get_limit_add_addr_accepted()
90 u8 mptcp_pm_get_limit_extra_subflows(const struct mptcp_sock *msk) in mptcp_pm_get_limit_extra_subflows()
121 const struct mptcp_sock *msk, in select_local_address()
149 select_signal_address(struct pm_nl_pernet *pernet, const struct mptcp_sock *msk, in select_signal_address()
180 fill_remote_addr(struct mptcp_sock *msk, struct mptcp_addr_info *local, in fill_remote_addr()
[all …]
|
| H A D | token.c | 67 static struct mptcp_sock *
154 struct mptcp_sock *msk = mptcp_sk(subflow->conn); in mptcp_token_new_connect()
192 struct mptcp_sock *msk) in mptcp_token_accept()
214 struct mptcp_sock *msk; in mptcp_token_exists()
246 struct mptcp_sock *mptcp_token_get_sock(struct net *net, u32 token) in mptcp_token_get_sock()
250 struct mptcp_sock *msk; in mptcp_token_get_sock()
299 struct mptcp_sock *mptcp_token_iter_next(const struct net *net, long *s_slot, in mptcp_token_iter_next()
302 struct mptcp_sock *ret = NULL; in mptcp_token_iter_next()
377 void mptcp_token_destroy(struct mptcp_sock *msk) in mptcp_token_destroy()
381 struct mptcp_sock *pos; in mptcp_token_destroy()
|
| H A D | protocol.c | 38 struct mptcp_sock msk;
59 static u64 mptcp_wnd_end(const struct mptcp_sock *msk) in mptcp_wnd_end()
76 bool __mptcp_try_fallback(struct mptcp_sock *msk, int fb_mib) in __mptcp_try_fallback()
103 static int __mptcp_socket_create(struct mptcp_sock *msk) in __mptcp_socket_create()
133 struct sock *__mptcp_nmpc_sk(struct mptcp_sock *msk) in __mptcp_nmpc_sk()
195 static bool mptcp_ooo_try_coalesce(struct mptcp_sock *msk, struct sk_buff *to, in mptcp_ooo_try_coalesce()
210 struct mptcp_sock *msk = mptcp_sk(sk); in mptcp_rcvbuf_grow()
243 static void mptcp_data_queue_ofo(struct mptcp_sock *msk, struct sk_buff *skb) in mptcp_data_queue_ofo()
379 struct mptcp_sock *msk = mptcp_sk(sk); in __mptcp_move_skb()
427 static void mptcp_shutdown_subflows(struct mptcp_sock *ms
[all...] |
| H A D | sched.c | 19 static int mptcp_sched_default_get_send(struct mptcp_sock *msk) in mptcp_sched_default_get_send()
31 static int mptcp_sched_default_get_retrans(struct mptcp_sock *msk) in mptcp_sched_default_get_retrans()
130 int mptcp_init_sched(struct mptcp_sock *msk, in mptcp_init_sched()
148 void mptcp_release_sched(struct mptcp_sock *msk) in mptcp_release_sched()
168 int mptcp_sched_get_send(struct mptcp_sock *msk) in mptcp_sched_get_send()
195 int mptcp_sched_get_retrans(struct mptcp_sock *msk) in mptcp_sched_get_retrans()
|
| H A D | pm_netlink.c | 291 bool mptcp_userspace_pm_active(const struct mptcp_sock *msk) in mptcp_userspace_pm_active()
346 const struct mptcp_sock *msk, in mptcp_event_put_token_and_ssk()
379 const struct mptcp_sock *msk, in mptcp_event_sub_established()
386 const struct mptcp_sock *msk, in mptcp_event_sub_closed()
408 const struct mptcp_sock *msk, in mptcp_event_created()
434 void mptcp_event_addr_removed(const struct mptcp_sock *msk, uint8_t id) in mptcp_event_addr_removed()
469 struct mptcp_sock *msk = mptcp_sk(subflow->conn); in mptcp_event_addr_announced()
572 void mptcp_event(enum mptcp_event_type type, const struct mptcp_sock *msk, in mptcp_event()
|
| H A D | subflow.c | 61 static bool mptcp_can_accept_new_subflow(const struct mptcp_sock *msk) in mptcp_can_accept_new_subflow()
72 struct mptcp_sock *msk = subflow_req->msk; in subflow_req_create_thmac()
85 static struct mptcp_sock *subflow_token_join_request(struct request_sock *req) in subflow_token_join_request()
88 struct mptcp_sock *msk; in subflow_token_join_request()
120 static bool subflow_use_different_sport(struct mptcp_sock *msk, const struct sock *sk) in subflow_use_different_sport()
452 static bool subflow_use_different_dport(struct mptcp_sock *msk, const struct sock *sk) in subflow_use_different_dport()
460 struct mptcp_sock *msk = mptcp_sk(sk); in __mptcp_sync_state()
477 static void subflow_set_remote_key(struct mptcp_sock *msk, in subflow_set_remote_key()
505 struct mptcp_sock *msk = mptcp_sk(sk); in mptcp_propagate_state()
531 struct mptcp_sock *msk; in subflow_finish_connect()
[all …]
|
| H A D | options.c | 455 struct mptcp_sock *msk = mptcp_sk(subflow->conn); in mptcp_established_options_mp()
568 struct mptcp_sock *msk = mptcp_sk(subflow->conn); in mptcp_established_options_dss()
660 struct mptcp_sock *msk = mptcp_sk(subflow->conn); in mptcp_established_options_add_addr()
724 struct mptcp_sock *msk = mptcp_sk(subflow->conn); in mptcp_established_options_rm_addr()
799 struct mptcp_sock *msk = mptcp_sk(subflow->conn); in mptcp_established_options_fastclose()
844 struct mptcp_sock *msk = mptcp_sk(subflow->conn); in mptcp_established_options()
942 static bool check_fully_established(struct mptcp_sock *msk, struct sock *ssk, in check_fully_established()
1051 static void __mptcp_snd_una_update(struct mptcp_sock *msk, u64 new_snd_una) in __mptcp_snd_una_update()
1057 static void rwin_update(struct mptcp_sock *msk, struct sock *ssk, in rwin_update()
1083 static void ack_update_msk(struct mptcp_sock *ms in ack_update_msk()
[all...] |
| H A D | mptcp_diag.c | 31 struct mptcp_sock *msk = NULL; in mptcp_diag_dump_one()
155 struct mptcp_sock *msk; in mptcp_diag_dump()
195 struct mptcp_sock *msk = mptcp_sk(sk); in mptcp_diag_get_info()
|
| H A D | bpf.c | 15 struct mptcp_sock *bpf_mptcp_sock_from_subflow(struct sock *sk) in bpf_mptcp_sock_from_subflow()
|
| H A D | syncookies.c | 97 struct mptcp_sock *msk; in mptcp_token_join_cookie_init_state()
|
| /linux/include/net/ |
| H A D | mptcp.h | 16 struct mptcp_sock;
105 int (*get_send)(struct mptcp_sock *msk);
106 int (*get_retrans)(struct mptcp_sock *msk);
112 void (*init)(struct mptcp_sock *msk);
113 void (*release)(struct mptcp_sock *msk);
125 void (*init)(struct mptcp_sock *msk);
126 void (*release)(struct mptcp_sock *msk);
160 void mptcp_diag_fill_info(struct mptcp_sock *msk, struct mptcp_info *info);
331 struct mptcp_sock *bpf_mptcp_sock_from_subflow(struct sock *sk);
333 static inline struct mptcp_sock *bpf_mptcp_sock_from_subflow(struct sock *sk) { return NULL; } in bpf_mptcp_sock_from_subflow()
[all …]
|
| /linux/tools/testing/selftests/bpf/progs/ |
| H A D | mptcp_subflow.c | 26 struct mptcp_sock *msk; in mptcp_subflow()
63 static int _check_getsockopt_subflow_mark(struct mptcp_sock *msk, struct bpf_sockopt *ctx) in _check_getsockopt_subflow_mark()
83 static int _check_getsockopt_subflow_cc(struct mptcp_sock *msk, struct bpf_sockopt *ctx) in _check_getsockopt_subflow_cc()
109 struct mptcp_sock *msk; in _getsockopt_subflow()
119 msk = bpf_core_cast(sk, struct mptcp_sock); in _getsockopt_subflow()
|
| H A D | mptcp_sock.c | 32 struct mptcp_sock *msk; in _sockops()
81 int BPF_PROG(trace_mptcp_pm_new_connection, struct mptcp_sock *msk, in BPF_PROG()
|
| /linux/tools/include/linux/ |
| H A D | btf_ids.h | 192 BTF_SOCK_TYPE(BTF_SOCK_TYPE_MPTCP, mptcp_sock) \
|
| /linux/include/linux/ |
| H A D | btf_ids.h | 257 BTF_SOCK_TYPE(BTF_SOCK_TYPE_MPTCP, mptcp_sock) \
|
| /linux/include/trace/events/ |
| H A D | mptcp.h | 216 struct mptcp_sock *msk = mptcp_sk(sk);
|
| /linux/tools/testing/selftests/bpf/prog_tests/ |
| H A D | mptcp.c | 159 struct mptcp_sock *sock_skel; in run_test()
|
| /linux/net/core/ |
| H A D | filter.c | 12043 BTF_TYPE_EMIT(struct mptcp_sock); in BPF_CALL_1()
|