/openbmc/linux/net/mptcp/ |
H A D | subflow.c | 329 struct mptcp_subflow_context *subflow = mptcp_subflow_ctx(sk); in subflow_prep_synack() local 337 mptcp_fastopen_subflow_synack_set_params(subflow, req); in subflow_prep_synack() 394 static bool subflow_thmac_valid(struct mptcp_subflow_context *subflow) in subflow_thmac_valid() argument 399 subflow_generate_hmac(subflow->remote_key, subflow->local_key, in subflow_thmac_valid() 400 subflow->remote_nonce, subflow->local_nonce, in subflow_thmac_valid() 405 subflow, subflow->token, thmac, subflow->thmac); in subflow_thmac_valid() 407 return thmac == subflow->thmac; in subflow_thmac_valid() 412 struct mptcp_subflow_context *subflow = mptcp_subflow_ctx(ssk); in mptcp_subflow_reset() local 413 struct sock *sk = subflow->conn; in mptcp_subflow_reset() 439 struct mptcp_subflow_context *subflow; in __mptcp_sync_state() local [all …]
|
H A D | options.c | 404 struct mptcp_subflow_context *subflow = mptcp_subflow_ctx(sk); in mptcp_syn_options() local 409 subflow->snd_isn = TCP_SKB_CB(skb)->end_seq; in mptcp_syn_options() 410 if (subflow->request_mptcp) { in mptcp_syn_options() 416 } else if (subflow->request_join) { in mptcp_syn_options() 417 pr_debug("remote_token=%u, nonce=%u\n", subflow->remote_token, in mptcp_syn_options() 418 subflow->local_nonce); in mptcp_syn_options() 420 opts->join_id = subflow->local_id; in mptcp_syn_options() 421 opts->token = subflow->remote_token; in mptcp_syn_options() 422 opts->nonce = subflow->local_nonce; in mptcp_syn_options() 423 opts->backup = subflow->request_bkup; in mptcp_syn_options() [all …]
|
H A D | protocol.c | 70 struct mptcp_subflow_context *subflow; in __mptcp_socket_create() local 81 subflow = mptcp_subflow_ctx(ssock->sk); in __mptcp_socket_create() 82 list_add(&subflow->node, &msk->conn_list); in __mptcp_socket_create() 84 subflow->request_mptcp = 1; in __mptcp_socket_create() 85 subflow->subflow_id = msk->subflow_id++; in __mptcp_socket_create() 88 WRITE_ONCE(subflow->local_id, 0); in __mptcp_socket_create() 345 struct mptcp_subflow_context *subflow = mptcp_subflow_ctx(ssk); in __mptcp_move_skb() local 367 MPTCP_SKB_CB(skb)->map_seq = mptcp_subflow_get_mapped_dsn(subflow); in __mptcp_move_skb() 485 static long mptcp_timeout_from_subflow(const struct mptcp_subflow_context *subflow) in mptcp_timeout_from_subflow() argument 487 const struct sock *ssk = mptcp_subflow_tcp_sock(subflow); in mptcp_timeout_from_subflow() [all …]
|
H A D | protocol.h | 559 mptcp_subflow_tcp_sock(const struct mptcp_subflow_context *subflow) in mptcp_subflow_tcp_sock() argument 561 return subflow->tcp_sock; in mptcp_subflow_tcp_sock() 565 mptcp_subflow_ctx_reset(struct mptcp_subflow_context *subflow) in mptcp_subflow_ctx_reset() argument 567 memset(&subflow->reset, 0, sizeof(subflow->reset)); in mptcp_subflow_ctx_reset() 568 subflow->request_mptcp = 1; in mptcp_subflow_ctx_reset() 569 WRITE_ONCE(subflow->local_id, -1); in mptcp_subflow_ctx_reset() 573 mptcp_subflow_get_map_offset(const struct mptcp_subflow_context *subflow) in mptcp_subflow_get_map_offset() argument 575 return tcp_sk(mptcp_subflow_tcp_sock(subflow))->copied_seq - in mptcp_subflow_get_map_offset() 576 subflow->ssn_offset - in mptcp_subflow_get_map_offset() 577 subflow->map_subflow_seq; in mptcp_subflow_get_map_offset() [all …]
|
H A D | pm.c | 178 const struct mptcp_subflow_context *subflow) in mptcp_pm_subflow_check_next() argument 183 update_subflows = subflow->request_join || subflow->mp_join; in mptcp_pm_subflow_check_next() 212 struct mptcp_subflow_context *subflow = mptcp_subflow_ctx(ssk); in mptcp_pm_add_addr_received() local 213 struct mptcp_sock *msk = mptcp_sk(subflow->conn); in mptcp_pm_add_addr_received() 288 struct mptcp_subflow_context *subflow = mptcp_subflow_ctx(ssk); in mptcp_pm_mp_prio_received() local 289 struct sock *sk = subflow->conn; in mptcp_pm_mp_prio_received() 292 pr_debug("subflow->backup=%d, bkup=%d\n", subflow->backup, bkup); in mptcp_pm_mp_prio_received() 294 if (subflow->backup != bkup) in mptcp_pm_mp_prio_received() 295 subflow->backup = bkup; in mptcp_pm_mp_prio_received() 302 struct mptcp_subflow_context *subflow = mptcp_subflow_ctx(sk); in mptcp_pm_mp_fail_received() local [all …]
|
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() [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 19 if (!subflow) in mptcp_fastopen_subflow_synack_set_params() 22 ssk = subflow->tcp_sock; in mptcp_fastopen_subflow_synack_set_params() 23 sk = subflow->conn; in mptcp_fastopen_subflow_synack_set_params() 26 subflow->is_mptfo = 1; in mptcp_fastopen_subflow_synack_set_params() 41 subflow->ssn_offset += skb->len; in mptcp_fastopen_subflow_synack_set_params() 62 void __mptcp_fastopen_gen_msk_ackseq(struct mptcp_sock *msk, struct mptcp_subflow_context *subflow, in __mptcp_fastopen_gen_msk_ackseq() argument
|
H A D | sched.c | 118 void mptcp_subflow_set_scheduled(struct mptcp_subflow_context *subflow, in mptcp_subflow_set_scheduled() argument 121 WRITE_ONCE(subflow->scheduled, scheduled); in mptcp_subflow_set_scheduled() 126 struct mptcp_subflow_context *subflow; in mptcp_sched_get_send() local 142 mptcp_for_each_subflow(msk, subflow) { in mptcp_sched_get_send() 143 if (READ_ONCE(subflow->scheduled)) in mptcp_sched_get_send() 155 struct mptcp_subflow_context *subflow; in mptcp_sched_get_retrans() local 164 mptcp_for_each_subflow(msk, subflow) { in mptcp_sched_get_retrans() 165 if (READ_ONCE(subflow->scheduled)) in mptcp_sched_get_retrans()
|
H A D | token.c | 153 struct mptcp_subflow_context *subflow = mptcp_subflow_ctx(ssk); in mptcp_token_new_connect() local 154 struct mptcp_sock *msk = mptcp_sk(subflow->conn); in mptcp_token_new_connect() 156 struct sock *sk = subflow->conn; in mptcp_token_new_connect() 160 mptcp_crypto_key_gen_sha(&subflow->local_key, &subflow->token, in mptcp_token_new_connect() 161 &subflow->idsn); in mptcp_token_new_connect() 163 bucket = token_bucket(subflow->token); in mptcp_token_new_connect() 165 if (__token_bucket_busy(bucket, subflow->token)) { in mptcp_token_new_connect() 173 ssk, subflow->local_key, subflow->token, subflow->idsn); in mptcp_token_new_connect() 175 WRITE_ONCE(msk->token, subflow->token); in mptcp_token_new_connect()
|
H A D | pm_netlink.c | 118 struct mptcp_subflow_context *subflow; in lookup_subflow_by_saddr() local 122 list_for_each_entry(subflow, list, node) { in lookup_subflow_by_saddr() 123 skc = (struct sock_common *)mptcp_subflow_tcp_sock(subflow); in lookup_subflow_by_saddr() 136 struct mptcp_subflow_context *subflow; in lookup_subflow_by_daddr() local 139 list_for_each_entry(subflow, list, node) { in lookup_subflow_by_daddr() 140 struct sock *ssk = mptcp_subflow_tcp_sock(subflow); in lookup_subflow_by_daddr() 426 struct mptcp_subflow_context *subflow; in fill_remote_addresses_vec() local 453 mptcp_for_each_subflow(msk, subflow) in fill_remote_addresses_vec() 454 if (READ_ONCE(subflow->local_id) == local->id) in fill_remote_addresses_vec() 455 __set_bit(subflow->remote_id, unavail_id); in fill_remote_addresses_vec() [all …]
|
H A D | pm_userspace.c | 256 struct mptcp_subflow_context *subflow; in mptcp_userspace_pm_remove_id_zero_address() local 262 mptcp_for_each_subflow(msk, subflow) { in mptcp_userspace_pm_remove_id_zero_address() 263 if (subflow->local_id == 0) { in mptcp_userspace_pm_remove_id_zero_address() 433 struct mptcp_subflow_context *subflow; in mptcp_nl_find_ssk() local 438 mptcp_for_each_subflow(msk, subflow) { in mptcp_nl_find_ssk() 442 ssk = mptcp_subflow_tcp_sock(subflow); in mptcp_nl_find_ssk() 545 struct mptcp_subflow_context *subflow = mptcp_subflow_ctx(ssk); in mptcp_nl_cmd_sf_destroy() local 552 mptcp_close_ssk(sk, ssk, subflow); in mptcp_nl_cmd_sf_destroy()
|
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
|
/openbmc/linux/tools/testing/selftests/net/mptcp/ |
H A D | mptcp_join.sh | 2009 pm_nl_add_endpoint $ns2 10.0.3.2 flags subflow 2018 pm_nl_add_endpoint $ns2 10.0.3.2 flags subflow 2027 pm_nl_add_endpoint $ns2 10.0.3.2 flags subflow 2036 pm_nl_add_endpoint $ns2 10.0.3.2 flags subflow 2037 pm_nl_add_endpoint $ns2 10.0.2.2 flags subflow 2046 pm_nl_add_endpoint $ns2 10.0.3.2 flags subflow 2047 pm_nl_add_endpoint $ns2 10.0.2.2 flags subflow 2056 pm_nl_add_endpoint $ns2 10.0.3.2 flags subflow dev ns2eth3 2069 pm_nl_add_endpoint $ns2 10.0.1.2 flags subflow 2080 pm_nl_add_endpoint $ns2 10.0.3.2 flags subflow [all …]
|
H A D | pm_netlink.sh | 87 ip netns exec $ns1 ./pm_nl_ctl add 10.0.1.2 flags subflow dev lo 177 ip netns exec $ns1 ./pm_nl_ctl add 10.0.1.1 flags subflow
|
H A D | simult_flows.sh | 91 ip netns exec "$ns1" ./pm_nl_ctl add 10.0.2.1 dev ns1eth2 flags subflow
|
/openbmc/linux/include/trace/events/ |
H A D | mptcp.h | 20 TP_PROTO(struct mptcp_subflow_context *subflow), 22 TP_ARGS(subflow), 36 __entry->active = mptcp_subflow_active(subflow); 37 __entry->backup = subflow->backup || subflow->request_bkup; 39 if (subflow->tcp_sock && sk_fullsock(subflow->tcp_sock)) 40 __entry->free = sk_stream_memory_free(subflow->tcp_sock); 44 ssk = mptcp_subflow_tcp_sock(subflow);
|
/openbmc/linux/Documentation/networking/ |
H A D | mptcp-sysctl.rst | 38 by the initial subflow if the value is 1. This controls a flag that is 51 socket. In-kernel path management will control subflow 54 API. Userspace path management puts per-MPTCP-connection subflow 68 pending outstanding data on a given subflow required to declare it stale.
|
/openbmc/linux/ |
H A D | opengrok0.0.log | 2750 2024-12-28 20:09:06.469-0600 FINEST t1156 PendingFileCompleter.doRename: Moved pending as file: '/opengrok/data/xref/openbmc/linux/net/mptcp/subflow.c.gz' [all...] |
H A D | opengrok2.0.log | [all...] |
/openbmc/ |
D | opengrok1.0.log | [all...] |
D | opengrok2.0.log | [all...] |