| /net/mptcp/ |
| A D | sockopt.c | 88 ssk->sk_prot->keepalive(ssk, !!val); in mptcp_sol_socket_sync_intval()
294 struct sock *ssk; in mptcp_setsockopt_sol_socket() local
610 lock_sock(ssk); in mptcp_setsockopt_sol_tcp_congestion()
636 lock_sock(ssk); in __mptcp_setsockopt_set_val()
660 lock_sock(ssk); in __mptcp_setsockopt_sol_tcp_cork()
680 lock_sock(ssk); in __mptcp_setsockopt_sol_tcp_nodelay()
915 if (ssk) in mptcp_setsockopt()
939 if (ssk) in mptcp_getsockopt_first_sf_only()
1517 if (ssk) in mptcp_getsockopt()
1538 ssk->sk_prot->keepalive(ssk, 1); in sync_socket_options()
[all …]
|
| A D | protocol.c | 1391 send_info[backup].ssk = ssk; in mptcp_subflow_get_send()
1412 ssk = send_info[SSK_MODE_ACTIVE].ssk; in mptcp_subflow_get_send()
1413 if (!ssk || !sk_stream_memory_free(ssk)) in mptcp_subflow_get_send()
1419 return ssk; in mptcp_subflow_get_send()
1426 return ssk; in mptcp_subflow_get_send()
1570 if (ssk) in __mptcp_push_pending()
1636 tcp_push(ssk, 0, info.mss_now, tcp_sk(ssk)->nonagle, in __mptcp_subflow_push_pending()
2643 tcp_push(ssk, 0, info.mss_now, tcp_sk(ssk)->nonagle, in __mptcp_retrans()
2690 if (!ssk) in mptcp_mp_fail_no_response()
3743 err = ssk->sk_prot->connect(ssk, uaddr, addr_len); in mptcp_connect()
[all …]
|
| A D | subflow.c | 445 tcp_done(ssk); in mptcp_subflow_reset()
1131 sk_eat_skb(ssk, skb); in get_mapping_status()
1271 sk_eat_skb(ssk, skb); in mptcp_subflow_discard_data()
1337 tcp_send_ack(ssk); in mptcp_subflow_fail()
1611 struct sock *ssk; in __mptcp_subflow_connect() local
1627 ssk = sf->sk; in __mptcp_subflow_connect()
1677 sock_hold(ssk); in __mptcp_subflow_connect()
1883 struct sock *sk, *ssk; in mptcp_subflow_queue_clean() local
1905 ssk = req->sk; in mptcp_subflow_queue_clean()
1906 if (!sk_is_mptcp(ssk)) in mptcp_subflow_queue_clean()
[all …]
|
| A D | pm_netlink.c | 305 switch (ssk->sk_family) { in mptcp_event_add_subflow()
331 sf = mptcp_subflow_ctx(ssk); in mptcp_event_add_subflow()
346 const struct sock *ssk) in mptcp_event_put_token_and_ssk() argument
358 sf = mptcp_subflow_ctx(ssk); in mptcp_event_put_token_and_ssk()
365 if (ssk->sk_bound_dev_if && in mptcp_event_put_token_and_ssk()
369 sk_err = READ_ONCE(ssk->sk_err); in mptcp_event_put_token_and_ssk()
386 const struct sock *ssk) in mptcp_event_sub_closed() argument
393 sf = mptcp_subflow_ctx(ssk); in mptcp_event_sub_closed()
408 const struct sock *ssk) in mptcp_event_created() argument
481 inet_sk(ssk)->inet_dport : in mptcp_event_addr_announced()
[all …]
|
| A D | protocol.h | 736 void mptcp_subflow_reset(struct sock *ssk);
817 void mptcp_subflow_drop_ctx(struct sock *ssk);
837 struct sock *ssk,
993 int mptcp_token_new_connect(struct sock *ssk);
1081 const struct sock *ssk, gfp_t gfp);
1228 struct sock *ssk = READ_ONCE(msk->first); in __mptcp_has_initial_subflow() local
1230 return ssk && ((1 << inet_sk_state_load(ssk)) & in __mptcp_has_initial_subflow()
1252 ssk->sk_allocation = GFP_ATOMIC; in mptcp_try_fallback()
1253 ssk->sk_shutdown |= SEND_SHUTDOWN; in mptcp_try_fallback()
1254 tcp_shutdown(ssk, SEND_SHUTDOWN); in mptcp_try_fallback()
[all …]
|
| A D | pm.c | 195 slow = lock_sock_fast(ssk); in __mptcp_pm_send_ack()
201 __mptcp_subflow_send_ack(ssk); in __mptcp_pm_send_ack()
202 unlock_sock_fast(ssk, slow); in __mptcp_pm_send_ack()
603 mptcp_event_addr_announced(ssk, addr); in mptcp_pm_add_addr_received()
686 if ((1 << inet_sk_state_load(ssk)) & in mptcp_pm_rm_addr_or_subflow()
698 mptcp_subflow_shutdown(sk, ssk, how); in mptcp_pm_rm_addr_or_subflow()
702 mptcp_close_ssk(sk, ssk, subflow); in mptcp_pm_rm_addr_or_subflow()
921 slow = lock_sock_fast(ssk); in mptcp_pm_subflows_chk_stale()
922 if (!tcp_rtx_and_write_queues_empty(ssk)) { in mptcp_pm_subflows_chk_stale()
927 unlock_sock_fast(ssk, slow); in mptcp_pm_subflows_chk_stale()
[all …]
|
| A D | sched.c | 21 struct sock *ssk; in mptcp_sched_default_get_send() local
23 ssk = mptcp_subflow_get_send(msk); in mptcp_sched_default_get_send()
24 if (!ssk) in mptcp_sched_default_get_send()
27 mptcp_subflow_set_scheduled(mptcp_subflow_ctx(ssk), true); in mptcp_sched_default_get_send()
33 struct sock *ssk; in mptcp_sched_default_get_retrans() local
35 ssk = mptcp_subflow_get_retrans(msk); in mptcp_sched_default_get_retrans()
36 if (!ssk) in mptcp_sched_default_get_retrans()
39 mptcp_subflow_set_scheduled(mptcp_subflow_ctx(ssk), true); in mptcp_sched_default_get_retrans()
|
| A D | fastopen.c | 12 struct sock *sk, *ssk; in mptcp_fastopen_subflow_synack_set_params() local
22 ssk = subflow->tcp_sock; in mptcp_fastopen_subflow_synack_set_params()
24 tp = tcp_sk(ssk); in mptcp_fastopen_subflow_synack_set_params()
28 skb = skb_peek(&ssk->sk_receive_queue); in mptcp_fastopen_subflow_synack_set_params()
33 __skb_unlink(skb, &ssk->sk_receive_queue); in mptcp_fastopen_subflow_synack_set_params()
|
| A D | pm_userspace.c | 441 struct sock *ssk; in mptcp_nl_find_ssk() local
443 ssk = mptcp_subflow_tcp_sock(subflow); in mptcp_nl_find_ssk()
445 if (local->family != ssk->sk_family) in mptcp_nl_find_ssk()
448 issk = inet_sk(ssk); in mptcp_nl_find_ssk()
450 switch (ssk->sk_family) { in mptcp_nl_find_ssk()
459 !ipv6_addr_equal(&remote->addr6, &ssk->sk_v6_daddr)) in mptcp_nl_find_ssk()
470 return ssk; in mptcp_nl_find_ssk()
482 struct sock *sk, *ssk; in mptcp_pm_nl_subflow_destroy_doit() local
534 ssk = mptcp_nl_find_ssk(msk, &addr_l.addr, &addr_r); in mptcp_pm_nl_subflow_destroy_doit()
535 if (!ssk) { in mptcp_pm_nl_subflow_destroy_doit()
[all …]
|
| A D | pm_kernel.c | 90 if (!((1 << inet_sk_state_load(ssk)) & in lookup_subflow_by_daddr()
204 ssk = mptcp_subflow_tcp_sock(subflow); in fill_remote_addresses_vec()
636 struct sock *newsk, *ssk; in mptcp_pm_nl_create_listen_socket() local
662 ssk = __mptcp_nmpc_sk(mptcp_sk(newsk)); in mptcp_pm_nl_create_listen_socket()
664 if (IS_ERR(ssk)) in mptcp_pm_nl_create_listen_socket()
665 return PTR_ERR(ssk); in mptcp_pm_nl_create_listen_socket()
672 if (ssk->sk_family == AF_INET) in mptcp_pm_nl_create_listen_socket()
675 else if (ssk->sk_family == AF_INET6) in mptcp_pm_nl_create_listen_socket()
687 lock_sock(ssk); in mptcp_pm_nl_create_listen_socket()
689 err = __inet_listen_sk(ssk, backlog); in mptcp_pm_nl_create_listen_socket()
[all …]
|
| A D | ctrl.c | 466 bool mptcp_active_should_disable(struct sock *ssk) in mptcp_active_should_disable() argument
468 struct net *net = sock_net(ssk); in mptcp_active_should_disable()
512 void mptcp_active_detect_blackhole(struct sock *ssk, bool expired) in mptcp_active_detect_blackhole() argument
519 if (likely(!sk_is_mptcp(ssk) || ssk->sk_state != TCP_SYN_SENT)) in mptcp_active_detect_blackhole()
522 subflow = mptcp_subflow_ctx(ssk); in mptcp_active_detect_blackhole()
531 net = sock_net(ssk); in mptcp_active_detect_blackhole()
532 timeouts = inet_csk(ssk)->icsk_retransmits; in mptcp_active_detect_blackhole()
|
| A D | options.c | 946 tcp_send_ack(ssk); in check_fully_established()
1010 clear_3rdack_retransmission(ssk); in check_fully_established()
1013 mptcp_pm_fully_established(msk, ssk); in check_fully_established()
1018 mptcp_subflow_reset(ssk); in check_fully_established()
1045 struct sock *ssk, in ack_update_msk() argument
1065 new_wnd_end = new_snd_una + tcp_sk(ssk)->snd_wnd; in ack_update_msk()
1072 __mptcp_check_push(sk, ssk); in ack_update_msk()
1260 const struct sock *ssk = (const struct sock *)tp; in mptcp_set_rwin() local
1267 subflow = mptcp_subflow_ctx(ssk); in mptcp_set_rwin()
1593 subflow = mptcp_subflow_ctx(ssk); in mptcp_write_options()
[all …]
|
| A D | token.c | 151 int mptcp_token_new_connect(struct sock *ssk) in mptcp_token_new_connect() argument
153 struct mptcp_subflow_context *subflow = mptcp_subflow_ctx(ssk); in mptcp_token_new_connect()
173 ssk, subflow->local_key, subflow->token, subflow->idsn); in mptcp_token_new_connect()
|
| /net/netlink/ |
| A D | af_netlink.c | 1143 sock = netlink_lookup(sock_net(ssk), ssk->sk_protocol, portid); in netlink_getsockbyportid()
1212 long *timeo, struct sock *ssk) in netlink_attachskb() argument
1230 if (!ssk || netlink_is_kernel(ssk)) in netlink_attachskb()
1308 struct sock *ssk) in netlink_unicast_kernel() argument
1318 NETLINK_CB(skb).sk = ssk; in netlink_unicast_kernel()
1319 netlink_deliver_tap_kernel(sk, ssk, skb); in netlink_unicast_kernel()
1338 timeo = sock_sndtimeo(ssk, nonblock); in netlink_unicast()
1510 struct net *net = sock_net(ssk); in netlink_broadcast_filtered()
1516 info.exclude_sk = ssk; in netlink_broadcast_filtered()
1614 info.exclude_sk = ssk; in netlink_set_err()
[all …]
|
| /net/core/ |
| A D | rtnetlink.c | 6833 static int rtnetlink_dump_start(struct sock *ssk, struct sk_buff *skb, in rtnetlink_dump_start() argument
6844 return netlink_dump_start(ssk, skb, nlh, control); in rtnetlink_dump_start()
|