| /linux/net/mptcp/ |
| H A D | sockopt.c | 70 static void __mptcp_subflow_set_rcvbuf(struct sock *ssk, int val) in __mptcp_subflow_set_rcvbuf() argument
72 WRITE_ONCE(ssk->sk_rcvbuf, val); in __mptcp_subflow_set_rcvbuf()
73 tcp_set_rcvbuf(ssk, val); in __mptcp_subflow_set_rcvbuf()
85 struct sock *ssk = mptcp_subflow_tcp_sock(subflow); in mptcp_sol_socket_sync_intval() local
86 bool slow = lock_sock_fast(ssk); in mptcp_sol_socket_sync_intval()
90 sock_valbool_flag(ssk, SOCK_DBG, !!val); in mptcp_sol_socket_sync_intval()
93 if (ssk->sk_prot->keepalive) in mptcp_sol_socket_sync_intval()
94 ssk->sk_prot->keepalive(ssk, !!val); in mptcp_sol_socket_sync_intval()
95 sock_valbool_flag(ssk, SOCK_KEEPOPEN, !!val); in mptcp_sol_socket_sync_intval()
98 WRITE_ONCE(ssk->sk_priority, val); in mptcp_sol_socket_sync_intval()
[all …]
|
| H A D | protocol.c | 354 static void mptcp_init_skb(struct sock *ssk, struct sk_buff *skb, int offset, in mptcp_init_skb() argument
357 struct mptcp_subflow_context *subflow = mptcp_subflow_ctx(ssk); in mptcp_init_skb()
370 __skb_unlink(skb, &ssk->sk_receive_queue); in mptcp_init_skb()
446 struct sock *ssk = mptcp_subflow_tcp_sock(subflow); in mptcp_shutdown_subflows() local
449 slow = lock_sock_fast(ssk); in mptcp_shutdown_subflows()
450 tcp_shutdown(ssk, SEND_SHUTDOWN); in mptcp_shutdown_subflows()
451 unlock_sock_fast(ssk, slow); in mptcp_shutdown_subflows()
527 const struct sock *ssk = mptcp_subflow_tcp_sock(subflow); in mptcp_timeout_from_subflow() local
529 return inet_csk(ssk)->icsk_pending && !subflow->stale_count ? in mptcp_timeout_from_subflow()
530 tcp_timeout_expires(ssk) - jiffies : 0; in mptcp_timeout_from_subflow()
[all …]
|
| H A D | subflow.c | 30 static void mptcp_subflow_ops_undo_override(struct sock *ssk);
430 void mptcp_subflow_reset(struct sock *ssk) in mptcp_subflow_reset() argument
432 struct mptcp_subflow_context *subflow = mptcp_subflow_ctx(ssk); in mptcp_subflow_reset()
438 if (ssk->sk_state == TCP_CLOSE) in mptcp_subflow_reset()
444 mptcp_send_active_reset_reason(ssk); in mptcp_subflow_reset()
445 tcp_done(ssk); in mptcp_subflow_reset()
461 struct sock *ssk = msk->first; in __mptcp_sync_state() local
463 subflow = mptcp_subflow_ctx(ssk); in __mptcp_sync_state()
464 __mptcp_propagate_sndbuf(sk, ssk); in __mptcp_sync_state()
501 static void mptcp_propagate_state(struct sock *sk, struct sock *ssk, in mptcp_propagate_state() argument
[all …]
|
| H A D | pm_netlink.c | 298 static int mptcp_event_add_subflow(struct sk_buff *skb, const struct sock *ssk) in mptcp_event_add_subflow() argument
300 const struct inet_sock *issk = inet_sk(ssk); in mptcp_event_add_subflow()
303 if (nla_put_u16(skb, MPTCP_ATTR_FAMILY, ssk->sk_family)) in mptcp_event_add_subflow()
306 switch (ssk->sk_family) { in mptcp_event_add_subflow()
317 if (nla_put_in6_addr(skb, MPTCP_ATTR_DADDR6, &ssk->sk_v6_daddr)) in mptcp_event_add_subflow()
332 sf = mptcp_subflow_ctx(ssk); in mptcp_event_add_subflow()
347 const struct sock *ssk) in mptcp_event_put_token_and_ssk() argument
356 if (mptcp_event_add_subflow(skb, ssk)) in mptcp_event_put_token_and_ssk()
359 sf = mptcp_subflow_ctx(ssk); in mptcp_event_put_token_and_ssk()
366 if (ssk->sk_bound_dev_if && in mptcp_event_put_token_and_ssk()
[all …]
|
| H A D | protocol.h | 697 struct sock *ssk = skb->sk; in mptcp_borrow_fwdmem() local
704 if (!ssk) in mptcp_borrow_fwdmem()
707 atomic_sub(skb->truesize, &ssk->sk_rmem_alloc); in mptcp_borrow_fwdmem()
741 void mptcp_subflow_process_delegated(struct sock *ssk, long actions);
789 void __mptcp_inherit_memcg(struct sock *sk, struct sock *ssk, gfp_t gfp);
790 void __mptcp_inherit_cgrp_data(struct sock *sk, struct sock *ssk);
803 bool mptcp_active_should_disable(struct sock *ssk);
815 void mptcp_subflow_shutdown(struct sock *sk, struct sock *ssk, int how);
816 void mptcp_close_ssk(struct sock *sk, struct sock *ssk,
818 void __mptcp_subflow_send_ack(struct sock *ssk);
[all …]
|
| H A D | sched.c | 21 struct sock *ssk; in mptcp_sched_default_get_send()
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()
35 ssk = mptcp_subflow_get_retrans(msk); in mptcp_sched_default_get_retrans() local
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()
22 struct sock *ssk; mptcp_sched_default_get_send() local
|
| H A D | pm.c | 190 struct sock *ssk = mptcp_subflow_tcp_sock(subflow); in __mptcp_pm_send_ack() local
197 slow = lock_sock_fast(ssk); in __mptcp_pm_send_ack()
203 __mptcp_subflow_send_ack(ssk); in __mptcp_pm_send_ack()
204 unlock_sock_fast(ssk, slow); in __mptcp_pm_send_ack()
284 struct sock *ssk = mptcp_subflow_tcp_sock(subflow); in mptcp_pm_mp_prio_send_ack() local
290 mptcp_local_address((struct sock_common *)ssk, &local); in mptcp_pm_mp_prio_send_ack()
295 mptcp_remote_address((struct sock_common *)ssk, &remote); in mptcp_pm_mp_prio_send_ack()
318 struct sock *ssk = mptcp_subflow_tcp_sock(subflow); in mptcp_adjust_add_addr_timeout() local
319 struct inet_connection_sock *icsk = inet_csk(ssk); in mptcp_adjust_add_addr_timeout()
542 void mptcp_pm_new_connection(struct mptcp_sock *msk, const struct sock *ssk, int server_side) in mptcp_pm_new_connection() argument
[all …]
|
| H A D | fastopen.c | 12 struct sock *sk, *ssk; in mptcp_fastopen_subflow_synack_set_params() local
23 ssk = subflow->tcp_sock; in mptcp_fastopen_subflow_synack_set_params()
25 tp = tcp_sk(ssk); in mptcp_fastopen_subflow_synack_set_params()
29 skb = skb_peek(&ssk->sk_receive_queue); in mptcp_fastopen_subflow_synack_set_params()
34 __skb_unlink(skb, &ssk->sk_receive_queue); in mptcp_fastopen_subflow_synack_set_params()
|
| H A D | pm_kernel.c | 105 struct sock *ssk = mptcp_subflow_tcp_sock(subflow); in lookup_subflow_by_daddr() local
107 if (!((1 << inet_sk_state_load(ssk)) & in lookup_subflow_by_daddr()
111 mptcp_remote_address((struct sock_common *)ssk, &cur); in lookup_subflow_by_daddr()
209 struct sock *sk = (struct sock *)msk, *ssk; in fill_remote_addresses_fullmesh() local
222 ssk = mptcp_subflow_tcp_sock(subflow); in fill_remote_addresses_fullmesh()
223 mptcp_remote_address((struct sock_common *)ssk, &addrs[i]); in fill_remote_addresses_fullmesh()
516 struct sock *ssk = mptcp_subflow_tcp_sock(subflow); in fill_local_laminar_endp() local
518 if ((1 << inet_sk_state_load(ssk)) & in fill_local_laminar_endp()
847 struct sock *newsk, *ssk; in mptcp_pm_nl_create_listen_socket() local
873 ssk = __mptcp_nmpc_sk(mptcp_sk(newsk)); in mptcp_pm_nl_create_listen_socket()
[all …]
|
| /linux/net/netlink/ |
| H A D | af_netlink.c | 1136 static struct sock *netlink_getsockbyportid(struct sock *ssk, u32 portid) in netlink_getsockbyportid() argument
1141 sock = netlink_lookup(sock_net(ssk), ssk->sk_protocol, portid); in netlink_getsockbyportid()
1149 READ_ONCE(nlk->dst_portid) != nlk_sk(ssk)->portid) { in netlink_getsockbyportid()
1210 long *timeo, struct sock *ssk) in netlink_attachskb() argument
1228 if (!ssk || netlink_is_kernel(ssk)) in netlink_attachskb()
1306 struct sock *ssk) in netlink_unicast_kernel() argument
1316 NETLINK_CB(skb).sk = ssk; in netlink_unicast_kernel()
1317 netlink_deliver_tap_kernel(sk, ssk, skb); in netlink_unicast_kernel()
1327 int netlink_unicast(struct sock *ssk, struct sk_buff *skb, in netlink_unicast() argument
1336 timeo = sock_sndtimeo(ssk, nonblock); in netlink_unicast()
[all …]
|
| /linux/include/net/ |
| H A D | mptcp.h | 147 void mptcp_space(const struct sock *ssk, int *space, int *full_space); in rsk_is_mptcp()
300 static inline void mptcp_space(const struct sock *ssk, int *s, int *fs) { } in mptcp_skb_ext_copy()
309 mptcp_space(const struct sock * ssk,int * s,int * fs) mptcp_space() argument
|
| /linux/tools/testing/selftests/bpf/progs/ |
| H A D | mptcp_sock.c | 82 const struct sock *ssk, int server_side) in BPF_PROG() argument
|
| /linux/security/ |
| H A D | security.c | 4830 int security_mptcp_add_subflow(struct sock *sk, struct sock *ssk) in security_mptcp_add_subflow() argument
4832 return call_int_hook(mptcp_add_subflow, sk, ssk); in security_mptcp_add_subflow()
|
| /linux/security/selinux/ |
| H A D | hooks.c | 5803 static int selinux_mptcp_add_subflow(struct sock *sk, struct sock *ssk) in selinux_mptcp_add_subflow() argument
5805 struct sk_security_struct *ssksec = selinux_sock(ssk); in selinux_mptcp_add_subflow()
5815 return selinux_netlbl_socket_post_create(ssk, ssk->sk_family); in selinux_mptcp_add_subflow()
|
| /linux/net/core/ |
| H A D | rtnetlink.c | 6884 static int rtnetlink_dump_start(struct sock *ssk, struct sk_buff *skb, in rtnetlink_dump_start() argument
6895 return netlink_dump_start(ssk, skb, nlh, control); in rtnetlink_dump_start()
|