| /linux/net/mptcp/ |
| H A D | subflow.c | 347 struct mptcp_subflow_context *subflow = mptcp_subflow_ctx(sk); in subflow_prep_synack() local
355 mptcp_fastopen_subflow_synack_set_params(subflow, req); in subflow_prep_synack()
414 static bool subflow_thmac_valid(struct mptcp_subflow_context *subflow) in subflow_thmac_valid() argument
419 subflow_generate_hmac(subflow->remote_key, subflow->local_key, in subflow_thmac_valid()
420 subflow->remote_nonce, subflow->local_nonce, in subflow_thmac_valid()
424 pr_debug("subflow=%p, token=%u, thmac=%llu, subflow->thmac=%llu\n", in subflow_thmac_valid()
425 subflow, subflo in subflow_thmac_valid()
432 struct mptcp_subflow_context *subflow = mptcp_subflow_ctx(ssk); mptcp_subflow_reset() local
459 struct mptcp_subflow_context *subflow; __mptcp_sync_state() local
478 subflow_set_remote_key(struct mptcp_sock * msk,struct mptcp_subflow_context * subflow,const struct mptcp_options_received * mp_opt) subflow_set_remote_key() argument
502 mptcp_propagate_state(struct sock * sk,struct sock * ssk,struct mptcp_subflow_context * subflow,const struct mptcp_options_received * mp_opt) mptcp_propagate_state() argument
528 struct mptcp_subflow_context *subflow = mptcp_subflow_ctx(sk); subflow_finish_connect() local
624 subflow_set_local_id(struct mptcp_subflow_context * subflow,int local_id) subflow_set_local_id() argument
632 struct mptcp_subflow_context *subflow = mptcp_subflow_ctx(sk); subflow_chk_local_id() local
676 struct mptcp_subflow_context *subflow = mptcp_subflow_ctx(sk); subflow_v4_conn_request() local
707 struct mptcp_subflow_context *subflow = mptcp_subflow_ctx(sk); subflow_v6_conn_request() local
798 __mptcp_subflow_fully_established(struct mptcp_sock * msk,struct mptcp_subflow_context * subflow,const struct mptcp_options_received * mp_opt) __mptcp_subflow_fully_established() argument
938 struct mptcp_subflow_context *subflow = mptcp_subflow_ctx(child); subflow_syn_recv_sock() local
988 dbg_bad_map(struct mptcp_subflow_context * subflow,u32 ssn) dbg_bad_map() argument
996 struct mptcp_subflow_context *subflow = mptcp_subflow_ctx(ssk); skb_is_fully_mapped() local
1011 struct mptcp_subflow_context *subflow = mptcp_subflow_ctx(ssk); validate_mapping() local
1033 struct mptcp_subflow_context *subflow = mptcp_subflow_ctx(ssk); validate_data_csum() local
1112 struct mptcp_subflow_context *subflow = mptcp_subflow_ctx(ssk); get_mapping_status() local
1259 struct mptcp_subflow_context *subflow = mptcp_subflow_ctx(ssk); mptcp_subflow_discard_data() local
1291 const struct mptcp_subflow_context *subflow = mptcp_subflow_ctx(ssk); subflow_sched_work_if_closed() local
1317 struct mptcp_subflow_context *subflow = mptcp_subflow_ctx(ssk); mptcp_subflow_fail() local
1354 struct mptcp_subflow_context *subflow = mptcp_subflow_ctx(ssk); subflow_check_data_avail() local
1453 struct mptcp_subflow_context *subflow = mptcp_subflow_ctx(sk); mptcp_subflow_data_available() local
1480 const struct mptcp_subflow_context *subflow = mptcp_subflow_ctx(ssk); mptcp_space() local
1508 struct mptcp_subflow_context *subflow = mptcp_subflow_ctx(sk); subflow_data_ready() local
1565 struct mptcp_subflow_context *subflow = mptcp_subflow_ctx(sk); mptcpv6_handle_mapped() local
1617 struct mptcp_subflow_context *subflow; __mptcp_subflow_connect() local
1779 struct mptcp_subflow_context *subflow; mptcp_subflow_create_socket() local
1876 struct mptcp_subflow_context *subflow = mptcp_subflow_ctx(sk); subflow_state_change() local
1897 struct mptcp_subflow_context *subflow; mptcp_subflow_queue_clean() local
2093 struct mptcp_subflow_context *subflow = mptcp_subflow_ctx(ssk); tcp_release_cb_override() local
[all...] |
| H A D | pm.c | 121 struct mptcp_subflow_context *subflow; in mptcp_lookup_subflow_by_saddr()
125 list_for_each_entry(subflow, list, node) { in mptcp_lookup_subflow_by_saddr()
126 skc = (struct sock_common *)mptcp_subflow_tcp_sock(subflow); in mptcp_lookup_subflow_by_saddr()
187 struct mptcp_subflow_context *subflow, in __mptcp_pm_send_ack()
190 struct sock *ssk = mptcp_subflow_tcp_sock(subflow); in __mptcp_pm_send_ack()
199 subflow->send_mp_prio = 1; in __mptcp_pm_send_ack()
200 subflow->request_bkup = backup; in __mptcp_pm_send_ack()
208 struct mptcp_subflow_context *subflow, in mptcp_pm_send_ack()
212 __mptcp_pm_send_ack(msk, subflow, prio, backup); in mptcp_pm_send_ack()
216 static bool subflow_in_rm_list(const struct mptcp_subflow_context *subflow, in subflow_in_rm_list()
120 struct mptcp_subflow_context *subflow; mptcp_lookup_subflow_by_saddr() local
186 __mptcp_pm_send_ack(struct mptcp_sock * msk,struct mptcp_subflow_context * subflow,bool prio,bool backup) __mptcp_pm_send_ack() argument
207 mptcp_pm_send_ack(struct mptcp_sock * msk,struct mptcp_subflow_context * subflow,bool prio,bool backup) mptcp_pm_send_ack() argument
215 subflow_in_rm_list(const struct mptcp_subflow_context * subflow,const struct mptcp_rm_list * rm_list) subflow_in_rm_list() argument
232 struct mptcp_subflow_context *subflow, *stale = NULL, *same_id = NULL; mptcp_pm_addr_send_ack_avoid_list() local
278 struct mptcp_subflow_context *subflow; mptcp_pm_mp_prio_send_ack() local
307 struct mptcp_subflow_context *subflow; mptcp_adjust_add_addr_timeout() local
626 mptcp_pm_subflow_check_next(struct mptcp_sock * msk,const struct mptcp_subflow_context * subflow) mptcp_pm_subflow_check_next() argument
662 struct mptcp_subflow_context *subflow = mptcp_subflow_ctx(ssk); mptcp_pm_add_addr_received() local
727 struct mptcp_subflow_context *subflow, *tmp; mptcp_pm_rm_addr_or_subflow() local
818 struct mptcp_subflow_context *subflow = mptcp_subflow_ctx(ssk); mptcp_pm_mp_prio_received() local
832 struct mptcp_subflow_context *subflow = mptcp_subflow_ctx(sk); mptcp_pm_mp_fail_received() local
973 struct mptcp_subflow_context *iter, *subflow = mptcp_subflow_ctx(ssk); mptcp_pm_subflows_chk_stale() local
1010 struct mptcp_subflow_context *subflow = mptcp_subflow_ctx(ssk); mptcp_pm_subflow_chk_stale() local
[all...] |
| H A D | protocol.c | 84 * in the fallback case only the current subflow is touching in __mptcp_try_fallback()
105 struct mptcp_subflow_context *subflow; in __mptcp_socket_create() local
116 subflow = mptcp_subflow_ctx(ssock->sk); in __mptcp_socket_create()
117 list_add(&subflow->node, &msk->conn_list); in __mptcp_socket_create()
119 subflow->request_mptcp = 1; in __mptcp_socket_create()
120 subflow->subflow_id = msk->subflow_id++; in __mptcp_socket_create()
122 /* This is the first subflow, always with id 0 */ in __mptcp_socket_create()
123 WRITE_ONCE(subflow->local_id, 0); in __mptcp_socket_create()
130 /* If the MPC handshake is not started, returns the first subflow,
357 struct mptcp_subflow_context *subflow in mptcp_init_skb() local
429 struct mptcp_subflow_context *subflow; mptcp_shutdown_subflows() local
511 mptcp_timeout_from_subflow(const struct mptcp_subflow_context * subflow) mptcp_timeout_from_subflow() argument
521 struct mptcp_subflow_context *subflow; mptcp_set_timeout() local
552 struct mptcp_subflow_context *subflow; mptcp_send_ack() local
584 struct mptcp_subflow_context *subflow; mptcp_cleanup_rbuf() local
657 __mptcp_add_backlog(struct sock * sk,struct mptcp_subflow_context * subflow,struct sk_buff * skb) __mptcp_add_backlog() argument
701 struct mptcp_subflow_context *subflow = mptcp_subflow_ctx(ssk); __mptcp_move_skbs_from_subflow() local
851 struct mptcp_subflow_context *subflow; __mptcp_error_report() local
883 mptcp_rcv_rtt_update(struct mptcp_sock * msk,struct mptcp_subflow_context * subflow) mptcp_rcv_rtt_update() argument
910 struct mptcp_subflow_context *subflow = mptcp_subflow_ctx(ssk); mptcp_data_ready() local
963 struct mptcp_subflow_context *tmp, *subflow; __mptcp_flush_join_list() local
1134 struct mptcp_subflow_context *subflow; mptcp_enter_memory_pressure() local
1461 mptcp_subflow_set_active(struct mptcp_subflow_context * subflow) mptcp_subflow_set_active() argument
1470 mptcp_subflow_active(struct mptcp_subflow_context * subflow) mptcp_subflow_active() argument
1494 struct mptcp_subflow_context *subflow; mptcp_subflow_get_send() local
1664 struct mptcp_subflow_context *subflow; __mptcp_push_pending() local
1733 struct mptcp_subflow_context *subflow = mptcp_subflow_ctx(ssk); __mptcp_subflow_push_pending() local
1886 struct mptcp_subflow_context *subflow; mptcp_rps_record_subflows() local
2140 struct mptcp_subflow_context *subflow; mptcp_rcv_space_adjust() local
2437 struct mptcp_subflow_context *subflow; mptcp_subflow_get_retrans() local
2515 __mptcp_subflow_disconnect(struct sock * ssk,struct mptcp_subflow_context * subflow,bool fastclosing) __mptcp_subflow_disconnect() argument
2539 __mptcp_close_ssk(struct sock * sk,struct sock * ssk,struct mptcp_subflow_context * subflow,unsigned int flags) __mptcp_close_ssk() argument
2642 mptcp_close_ssk(struct sock * sk,struct sock * ssk,struct mptcp_subflow_context * subflow) mptcp_close_ssk() argument
2682 struct mptcp_subflow_context *subflow, *tmp; __mptcp_close_subflow() local
2718 struct mptcp_subflow_context *subflow, *tmp; mptcp_check_fastclose() local
2769 struct mptcp_subflow_context *subflow; __mptcp_retrans() local
2928 struct mptcp_subflow_context *subflow, *tmp; mptcp_do_fastclose() local
2986 struct mptcp_subflow_context *subflow, *tmp; mptcp_worker() local
3199 struct mptcp_subflow_context *subflow; mptcp_check_send_data_fin() local
3292 struct mptcp_subflow_context *subflow; __mptcp_close() local
3399 struct mptcp_subflow_context *subflow, *tmp; mptcp_destroy_common() local
3536 struct mptcp_subflow_context *subflow; mptcp_sk_clone_init() local
3730 struct mptcp_subflow_context *subflow = mptcp_subflow_ctx(ssk); mptcp_subflow_process_delegated() local
3780 struct mptcp_subflow_context *subflow; mptcp_finish_connect() local
3829 struct mptcp_subflow_context *subflow = mptcp_subflow_ctx(ssk); mptcp_finish_join() local
3967 struct mptcp_subflow_context *subflow; mptcp_connect() local
4144 struct mptcp_subflow_context *subflow; mptcp_graft_subflows() local
4227 struct mptcp_subflow_context *subflow; mptcp_stream_accept() local
4576 struct mptcp_subflow_context *subflow; mptcp_napi_poll() local
[all...] |
| H A D | protocol.h | 641 mptcp_subflow_tcp_sock(const struct mptcp_subflow_context *subflow) in mptcp_subflow_tcp_sock() argument
643 return subflow->tcp_sock; in mptcp_subflow_tcp_sock()
647 mptcp_subflow_ctx_reset(struct mptcp_subflow_context *subflow) in mptcp_subflow_ctx_reset() argument
649 memset(&subflow->reset, 0, sizeof(subflow->reset)); in mptcp_subflow_ctx_reset()
650 subflow->request_mptcp = 1; in mptcp_subflow_ctx_reset()
651 WRITE_ONCE(subflow->local_id, -1); in mptcp_subflow_ctx_reset()
684 struct mptcp_subflow_context *subflow = mptcp_subflow_ctx(sk); in mptcp_send_active_reset_reason() local
687 reason = sk_rst_convert_mptcp_reason(subflow->reset_reason); in mptcp_send_active_reset_reason()
712 __mptcp_subflow_lend_fwdmem(struct mptcp_subflow_context *subflow, int size) in __mptcp_subflow_lend_fwdmem() argument
714 int frag = (subflow->lent_mem_frag + size) & (PAGE_SIZE - 1); in __mptcp_subflow_lend_fwdmem()
[all …]
|
| H A D | fastopen.c | 9 void mptcp_fastopen_subflow_synack_set_params(struct mptcp_subflow_context *subflow, in mptcp_fastopen_subflow_synack_set_params() argument
17 /* on early fallback the subflow context is deleted by in mptcp_fastopen_subflow_synack_set_params()
20 if (!subflow) in mptcp_fastopen_subflow_synack_set_params()
23 ssk = subflow->tcp_sock; in mptcp_fastopen_subflow_synack_set_params()
24 sk = subflow->conn; in mptcp_fastopen_subflow_synack_set_params()
27 subflow->is_mptfo = 1; in mptcp_fastopen_subflow_synack_set_params()
37 mptcp_subflow_lend_fwdmem(subflow, skb); in mptcp_fastopen_subflow_synack_set_params()
40 * space, need to offset it in the subflow sequence, see mptcp_subflow_get_map_offset() in mptcp_fastopen_subflow_synack_set_params()
43 subflow->ssn_offset += skb->len; in mptcp_fastopen_subflow_synack_set_params()
|
| H A D | sockopt.c | 72 struct mptcp_subflow_context *subflow; in mptcp_sol_socket_sync_intval() local
78 mptcp_for_each_subflow(msk, subflow) { in mptcp_sol_socket_sync_intval()
79 struct sock *ssk = mptcp_subflow_tcp_sock(subflow); in mptcp_sol_socket_sync_intval()
116 subflow->setsockopt_seq = msk->setsockopt_seq; in mptcp_sol_socket_sync_intval()
150 struct mptcp_subflow_context *subflow; in mptcp_setsockopt_sol_socket_tstamp() local
160 mptcp_for_each_subflow(msk, subflow) { in mptcp_setsockopt_sol_socket_tstamp()
161 struct sock *ssk = mptcp_subflow_tcp_sock(subflow); in mptcp_setsockopt_sol_socket_tstamp()
210 struct mptcp_subflow_context *subflow; in mptcp_setsockopt_sol_socket_timestamping() local
236 mptcp_for_each_subflow(msk, subflow) { in mptcp_setsockopt_sol_socket_timestamping()
237 struct sock *ssk = mptcp_subflow_tcp_sock(subflow); in mptcp_setsockopt_sol_socket_timestamping()
252 struct mptcp_subflow_context *subflow; mptcp_setsockopt_sol_socket_linger() local
585 struct mptcp_subflow_context *subflow; mptcp_setsockopt_sol_tcp_congestion() local
629 struct mptcp_subflow_context *subflow; __mptcp_setsockopt_set_val() local
652 struct mptcp_subflow_context *subflow; __mptcp_setsockopt_sol_tcp_cork() local
672 struct mptcp_subflow_context *subflow; __mptcp_setsockopt_sol_tcp_nodelay() local
738 struct mptcp_subflow_context *subflow; mptcp_setsockopt_v4_set_tos() local
805 struct mptcp_subflow_context *subflow; mptcp_setsockopt_all_sf() local
1104 struct mptcp_subflow_context *subflow; mptcp_getsockopt_tcpinfo() local
1196 struct mptcp_subflow_context *subflow; mptcp_getsockopt_subflow_addrs() local
1295 struct mptcp_subflow_context *subflow; mptcp_getsockopt_full_info() local
1591 struct mptcp_subflow_context *subflow = mptcp_subflow_ctx(ssk); mptcp_sockopt_sync_locked() local
1615 struct mptcp_subflow_context *subflow; mptcp_set_rcvlowat() local
[all...] |
| H A D | sched.c | 162 void mptcp_subflow_set_scheduled(struct mptcp_subflow_context *subflow, in mptcp_sched_get_send()
165 WRITE_ONCE(subflow->scheduled, scheduled); in mptcp_sched_get_send()
170 struct mptcp_subflow_context *subflow; in mptcp_sched_get_send()
185 mptcp_for_each_subflow(msk, subflow) { in mptcp_sched_get_retrans()
186 if (READ_ONCE(subflow->scheduled)) in mptcp_sched_get_retrans()
197 struct mptcp_subflow_context *subflow; in mptcp_sched_get_retrans()
205 mptcp_for_each_subflow(msk, subflow) { in mptcp_sched_get_retrans()
206 if (READ_ONCE(subflow->scheduled)) in mptcp_sched_get_retrans()
151 mptcp_subflow_set_scheduled(struct mptcp_subflow_context * subflow,bool scheduled) mptcp_subflow_set_scheduled() argument
159 struct mptcp_subflow_context *subflow; mptcp_sched_get_send() local
187 struct mptcp_subflow_context *subflow; mptcp_sched_get_retrans() local
|
| H A D | pm_kernel.c | 101 struct mptcp_subflow_context *subflow; in lookup_subflow_by_daddr() local
104 list_for_each_entry(subflow, list, node) { in lookup_subflow_by_daddr()
105 struct sock *ssk = mptcp_subflow_tcp_sock(subflow); in lookup_subflow_by_daddr()
210 struct mptcp_subflow_context *subflow; in fill_remote_addresses_fullmesh() local
217 mptcp_for_each_subflow(msk, subflow) in fill_remote_addresses_fullmesh()
218 if (READ_ONCE(subflow->local_id) == local->id) in fill_remote_addresses_fullmesh()
219 __set_bit(subflow->remote_id, unavail_id); in fill_remote_addresses_fullmesh()
221 mptcp_for_each_subflow(msk, subflow) { in fill_remote_addresses_fullmesh()
222 ssk = mptcp_subflow_tcp_sock(subflow); in fill_remote_addresses_fullmesh()
224 addrs[i].id = READ_ONCE(subflow in fill_remote_addresses_fullmesh()
298 struct mptcp_subflow_context *subflow; mptcp_mpc_endpoint_setup() local
502 struct mptcp_subflow_context *subflow; fill_local_laminar_endp() local
[all...] |
| H A D | Makefile | 4 mptcp-y := protocol.o subflow.o options.o token.o crypto.o ctrl.o pm.o diag.o \
|
| H A D | Kconfig | 10 subflows in order to utilize multiple network paths. Each subflow
|
| H A D | pm_netlink.c | 468 struct mptcp_subflow_context *subflow = mptcp_subflow_ctx(ssk); in mptcp_event_addr_announced() local
469 struct mptcp_sock *msk = mptcp_sk(subflow->conn); in mptcp_event_addr_announced()
|
| /linux/tools/testing/selftests/net/mptcp/ |
| H A D | mptcp_join.sh | 1841 local subflow="client"
1855 subflow="server"
1868 print_check "rm subflow ${subflow}"
2114 pm_nl_add_endpoint $ns2 10.0.3.2 flags subflow
2123 pm_nl_add_endpoint $ns2 10.0.3.2 flags subflow
2133 pm_nl_add_endpoint $ns2 10.0.3.2 flags subflow
2142 pm_nl_add_endpoint $ns2 10.0.3.2 flags subflow
2143 pm_nl_add_endpoint $ns2 10.0.2.2 flags subflow
2152 pm_nl_add_endpoint $ns2 10.0.3.2 flags subflow
2153 pm_nl_add_endpoint $ns2 10.0.2.2 flags subflow
[all …]
|
| H A D | pm_netlink.sh | 153 add_endpoint 10.0.1.2 flags subflow dev lo
159 "2,10.0.1.2,subflow,lo" \
254 add_endpoint 10.0.1.1 flags subflow
256 check "show_endpoints" "$(format_endpoints "1,10.0.1.1,subflow backup")" \
259 check "show_endpoints" "$(format_endpoints "1,10.0.1.1,subflow")" \
266 check "show_endpoints" "$(format_endpoints "1,10.0.1.1,subflow fullmesh")" \
269 check "show_endpoints" "$(format_endpoints "1,10.0.1.1,subflow")" \
272 check "show_endpoints" "$(format_endpoints "1,10.0.1.1,subflow backup fullmesh")" \
|
| H A D | simult_flows.sh | 90 mptcp_lib_pm_nl_add_endpoint "${ns1}" 10.0.2.1 dev ns1eth2 flags subflow
|
| /linux/Documentation/networking/ |
| H A D | mptcp.rst | 41 (Linux-specific), a *subflow* (or *path*) is created. This *subflow* consists of
45 *option* field of the underlying TCP *subflow*. This field contains, amongst
79 The Packet Scheduler is in charge of selecting which available *subflow(s)* to
127 values per subflow.
151 kernel is in charge of creating subflow sockets: they are TCP sockets where the
|