Home
last modified time | relevance | path

Searched refs:subflow (Results 1 – 15 of 15) sorted by relevance

/linux/net/mptcp/
A Dsubflow.c341 subflow_generate_hmac(subflow->remote_key, subflow->local_key, in subflow_thmac_valid()
342 subflow->remote_nonce, subflow->local_nonce, in subflow_thmac_valid()
347 subflow, subflow->token, in subflow_thmac_valid()
447 subflow, subflow->thmac, subflow->remote_nonce, in subflow_finish_connect()
459 subflow_generate_hmac(subflow->local_key, subflow->remote_key, in subflow_finish_connect()
807 ssn, subflow->map_subflow_seq, subflow->map_data_len); in dbg_bad_map()
857 if (subflow->map_csum_len == subflow->map_data_len) in validate_data_csum()
865 delta = subflow->map_data_len - subflow->map_csum_len; in validate_data_csum()
1051 subflow->map_seq, subflow->map_subflow_seq, in get_mapping_status()
1052 subflow->map_data_len, subflow->map_csum_reqd, in get_mapping_status()
[all …]
A Doptions.c413 subflow->local_nonce); in mptcp_syn_options()
462 if (subflow->mp_capable) { in mptcp_established_options_mp()
497 subflow, subflow->local_key, subflow->remote_key, in mptcp_established_options_mp()
915 if (subflow->mp_join) in check_fully_established()
935 if (subflow->mp_join) in check_fully_established()
937 subflow->mp_capable = 0; in check_fully_established()
956 if (likely(subflow->pm_notified) || list_empty(&subflow->node)) in check_fully_established()
959 subflow->pm_notified = 1; in check_fully_established()
960 if (subflow->mp_join) { in check_fully_established()
1132 subflow->reset_seen = 1; in mptcp_incoming_options()
[all …]
A Dprotocol.c68 return msk->subflow; in __mptcp_nmpc_socket()
113 msk->subflow = ssock; in __mptcp_socket_create()
117 subflow->request_mptcp = 1; in __mptcp_socket_create()
1377 if (!subflow->stale) in mptcp_subflow_set_active()
1380 subflow->stale = 0; in mptcp_subflow_set_active()
2153 if (msk->subflow) { in mptcp_dispose_initial_subflow()
2155 msk->subflow = NULL; in mptcp_dispose_initial_subflow()
2249 if (msk->subflow && ssk == msk->subflow->sk) in __mptcp_close_ssk()
2801 msk->subflow = NULL; in mptcp_sk_clone()
3080 sk = subflow->conn; in mptcp_finish_connect()
[all …]
A Dprotocol.h468 return subflow->tcp_sock; in mptcp_subflow_tcp_sock()
475 subflow->ssn_offset - in mptcp_subflow_get_map_offset()
476 subflow->map_subflow_seq; in mptcp_subflow_get_map_offset()
482 return subflow->map_seq + mptcp_subflow_get_map_offset(subflow); in mptcp_subflow_get_mapped_dsn()
488 sock_hold(mptcp_subflow_tcp_sock(subflow)); in mptcp_add_pending_subflow()
510 if (!list_empty(&subflow->delegated_node)) in mptcp_subflow_delegate()
516 sock_hold(mptcp_subflow_tcp_sock(subflow)); in mptcp_subflow_delegate()
581 if (subflow->request_join && !subflow->fully_established) in __mptcp_subflow_active()
609 if (tmp != subflow) in mptcp_has_another_subflow()
858 struct sock *parent = subflow->conn; in subflow_simultaneous_connect()
[all …]
A Dsockopt.c71 struct mptcp_subflow_context *subflow; in mptcp_sol_socket_sync_intval() local
77 mptcp_for_each_subflow(msk, subflow) { in mptcp_sol_socket_sync_intval()
148 struct mptcp_subflow_context *subflow; in mptcp_setsockopt_sol_socket_tstamp() local
158 mptcp_for_each_subflow(msk, 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()
252 struct mptcp_subflow_context *subflow; in mptcp_setsockopt_sol_socket_linger() local
271 mptcp_for_each_subflow(msk, subflow) { in mptcp_setsockopt_sol_socket_linger()
560 struct mptcp_subflow_context *subflow; in mptcp_setsockopt_sol_tcp_congestion() local
581 mptcp_for_each_subflow(msk, subflow) { in mptcp_setsockopt_sol_tcp_congestion()
[all …]
A Dtoken.c153 struct mptcp_subflow_context *subflow = mptcp_subflow_ctx(sk); in mptcp_token_new_connect() local
154 struct mptcp_sock *msk = mptcp_sk(subflow->conn); in mptcp_token_new_connect()
159 mptcp_crypto_key_gen_sha(&subflow->local_key, &subflow->token, in mptcp_token_new_connect()
160 &subflow->idsn); in mptcp_token_new_connect()
162 bucket = token_bucket(subflow->token); in mptcp_token_new_connect()
164 if (__token_bucket_busy(bucket, subflow->token)) { in mptcp_token_new_connect()
172 sk, subflow->local_key, subflow->token, subflow->idsn); in mptcp_token_new_connect()
174 WRITE_ONCE(msk->token, subflow->token); in mptcp_token_new_connect()
A Dpm.c244 struct mptcp_subflow_context *subflow = mptcp_subflow_ctx(sk); in mptcp_pm_mp_prio_received() local
247 subflow->backup = bkup; in mptcp_pm_mp_prio_received()
342 struct mptcp_subflow_context *subflow = mptcp_subflow_ctx(ssk); in mptcp_pm_subflow_chk_stale() local
346 if (!subflow->stale_count) { in mptcp_pm_subflow_chk_stale()
347 subflow->stale_rcv_tstamp = rcv_tstamp; in mptcp_pm_subflow_chk_stale()
348 subflow->stale_count++; in mptcp_pm_subflow_chk_stale()
349 } else if (subflow->stale_rcv_tstamp == rcv_tstamp) { in mptcp_pm_subflow_chk_stale()
350 if (subflow->stale_count < U8_MAX) in mptcp_pm_subflow_chk_stale()
351 subflow->stale_count++; in mptcp_pm_subflow_chk_stale()
354 subflow->stale_count = 0; in mptcp_pm_subflow_chk_stale()
[all …]
A Dpm_netlink.c128 struct mptcp_subflow_context *subflow; in lookup_subflow_by_saddr() local
644 subflow = list_first_entry_or_null(&msk->conn_list, typeof(*subflow), node); in mptcp_pm_nl_addr_send_ack()
645 if (subflow) { in mptcp_pm_nl_addr_send_ack()
674 subflow->backup = bkup; in mptcp_pm_nl_mp_prio_send_ack()
675 subflow->send_mp_prio = 1; in mptcp_pm_nl_mp_prio_send_ack()
676 subflow->request_bkup = bkup; in mptcp_pm_nl_mp_prio_send_ack()
716 u8 id = subflow->local_id; in mptcp_pm_nl_rm_addr_or_subflow()
719 id = subflow->remote_id; in mptcp_pm_nl_rm_addr_or_subflow()
726 i, rm_list->ids[i], subflow->local_id, subflow->remote_id); in mptcp_pm_nl_rm_addr_or_subflow()
1011 if (subflow->stale || !stale_loss_cnt || subflow->stale_count <= stale_loss_cnt) in mptcp_pm_nl_subflow_chk_stale()
[all …]
A DMakefile4 mptcp-y := protocol.o subflow.o options.o token.o crypto.o ctrl.o pm.o diag.o \
A DKconfig10 subflows in order to utilize multiple network paths. Each subflow
/linux/tools/testing/selftests/net/mptcp/
A Dmptcp_join.sh950 ip netns exec $ns2 ./pm_nl_ctl add 10.0.3.2 flags subflow
958 ip netns exec $ns2 ./pm_nl_ctl add 10.0.3.2 flags subflow
966 ip netns exec $ns2 ./pm_nl_ctl add 10.0.3.2 flags subflow
974 ip netns exec $ns2 ./pm_nl_ctl add 10.0.3.2 flags subflow
975 ip netns exec $ns2 ./pm_nl_ctl add 10.0.2.2 flags subflow
983 ip netns exec $ns2 ./pm_nl_ctl add 10.0.3.2 flags subflow
984 ip netns exec $ns2 ./pm_nl_ctl add 10.0.2.2 flags subflow
1023 ip netns exec $ns2 ./pm_nl_ctl add 10.0.3.2 flags subflow
1033 ip netns exec $ns2 ./pm_nl_ctl add 10.0.3.2 flags subflow
1034 ip netns exec $ns2 ./pm_nl_ctl add 10.0.4.2 flags subflow
[all …]
A Dpm_netlink.sh76 ip netns exec $ns1 ./pm_nl_ctl add 10.0.1.2 flags subflow dev lo
A Dsimult_flows.sh84 ip netns exec "$ns1" ./pm_nl_ctl add 10.0.2.1 dev ns1eth2 flags subflow
/linux/include/trace/events/
A Dmptcp.h20 TP_PROTO(struct mptcp_subflow_context *subflow),
22 TP_ARGS(subflow),
36 __entry->active = mptcp_subflow_active(subflow);
37 __entry->backup = subflow->backup;
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);
/linux/Documentation/networking/
A Dmptcp-sysctl.rst38 by the initial subflow if the value is 1. This controls a flag that is
51 pending outstanding data on a given subflow required to declare it stale.

Completed in 43 milliseconds