| /linux/net/mptcp/ |
| A D | sockopt.c | 87 ssk->sk_prot->keepalive(ssk, !!val); in mptcp_sol_socket_sync_intval()
585 lock_sock(ssk); in mptcp_setsockopt_sol_tcp_congestion()
617 struct sock *ssk; in mptcp_setsockopt() local
636 if (ssk) in mptcp_setsockopt()
654 struct sock *ssk; in mptcp_getsockopt_first_sf_only() local
657 ssk = msk->first; in mptcp_getsockopt_first_sf_only()
658 if (ssk) { in mptcp_getsockopt_first_sf_only()
967 struct sock *ssk; in mptcp_getsockopt() local
980 if (ssk) in mptcp_getsockopt()
997 ssk->sk_prot->keepalive(ssk, 1); in sync_socket_options()
[all …]
|
| A D | protocol.c | 1451 send_info[subflow->backup].ssk = ssk; in mptcp_subflow_get_send()
1459 send_info[0].ssk = send_info[1].ssk; in mptcp_subflow_get_send()
1535 if (!ssk) in __mptcp_push_pending()
1561 if (ssk) in __mptcp_push_pending()
1623 tcp_push(ssk, 0, info.mss_now, tcp_sk(ssk)->nonagle, in __mptcp_subflow_push_pending()
2141 pick = ssk; in mptcp_subflow_get_retrans()
2241 sock_put(ssk); in __mptcp_close_ssk()
2369 if (!ssk) in __mptcp_retrans()
2372 lock_sock(ssk); in __mptcp_retrans()
2388 tcp_push(ssk, 0, info.mss_now, tcp_sk(ssk)->nonagle, in __mptcp_retrans()
[all …]
|
| A D | subflow.c | 364 tcp_done(ssk); in mptcp_subflow_reset()
894 sk_eat_skb(ssk, skb); in validate_data_csum()
956 sk_eat_skb(ssk, skb); in get_mapping_status()
1084 sk_eat_skb(ssk, skb); in mptcp_subflow_discard_data()
1171 sk_eat_skb(ssk, skb); in subflow_check_data_avail()
1173 ssk->sk_err = EBADMSG; in subflow_check_data_avail()
1186 ssk->sk_err = EBADMSG; in subflow_check_data_avail()
1388 struct sock *ssk; in __mptcp_subflow_connect() local
1402 ssk = sf->sk; in __mptcp_subflow_connect()
1507 ssk->sk_prot = &tcp_prot; in mptcp_subflow_ops_undo_override()
[all …]
|
| A D | protocol.h | 494 void mptcp_subflow_process_delegated(struct sock *ssk);
561 void mptcp_close_ssk(struct sock *sk, struct sock *ssk,
563 void mptcp_subflow_send_ack(struct sock *ssk);
564 void mptcp_subflow_reset(struct sock *ssk);
578 struct sock *ssk = mptcp_subflow_tcp_sock(subflow); in __mptcp_subflow_active() local
603 static inline bool mptcp_has_another_subflow(struct sock *ssk) in mptcp_has_another_subflow() argument
636 void mptcp_data_ready(struct sock *sk, struct sock *ssk);
652 void __mptcp_check_push(struct sock *sk, struct sock *ssk);
669 WRITE_ONCE(sk->sk_sndbuf, ssk->sk_sndbuf); in mptcp_propagate_sndbuf()
746 const struct sock *ssk, gfp_t gfp);
[all …]
|
| A D | pm_netlink.c | 652 mptcp_subflow_send_ack(ssk); in mptcp_pm_nl_addr_send_ack()
681 mptcp_subflow_send_ack(ssk); in mptcp_pm_nl_mp_prio_send_ack()
1020 slow = lock_sock_fast(ssk); in mptcp_pm_nl_subflow_chk_stale()
1750 switch (ssk->sk_family) { in mptcp_event_add_subflow()
1778 sf = mptcp_subflow_ctx(ssk); in mptcp_event_add_subflow()
1793 const struct sock *ssk) in mptcp_event_put_token_and_ssk() argument
1805 sf = mptcp_subflow_ctx(ssk); in mptcp_event_put_token_and_ssk()
1812 if (ssk->sk_bound_dev_if && in mptcp_event_put_token_and_ssk()
1816 sk_err = ssk->sk_err; in mptcp_event_put_token_and_ssk()
1833 const struct sock *ssk) in mptcp_event_sub_closed() argument
[all …]
|
| A D | pm.c | 74 void mptcp_pm_new_connection(struct mptcp_sock *msk, const struct sock *ssk, int server_side) in mptcp_pm_new_connection() argument
81 mptcp_event(MPTCP_EVENT_CREATED, msk, ssk, GFP_ATOMIC); in mptcp_pm_new_connection()
126 void mptcp_pm_fully_established(struct mptcp_sock *msk, const struct sock *ssk, gfp_t gfp) in mptcp_pm_fully_established() argument
150 mptcp_event(MPTCP_EVENT_ESTABLISHED, msk, ssk, gfp); in mptcp_pm_fully_established()
340 void mptcp_pm_subflow_chk_stale(const struct mptcp_sock *msk, struct sock *ssk) in mptcp_pm_subflow_chk_stale() argument
342 struct mptcp_subflow_context *subflow = mptcp_subflow_ctx(ssk); in mptcp_pm_subflow_chk_stale()
343 u32 rcv_tstamp = READ_ONCE(tcp_sk(ssk)->rcv_tstamp); in mptcp_pm_subflow_chk_stale()
352 mptcp_pm_nl_subflow_chk_stale(msk, ssk); in mptcp_pm_subflow_chk_stale()
|
| A D | options.c | 905 tcp_send_ack(ssk); in check_fully_established()
961 clear_3rdack_retransmission(ssk); in check_fully_established()
964 mptcp_pm_fully_established(msk, ssk, GFP_ATOMIC); in check_fully_established()
969 mptcp_subflow_reset(ssk); in check_fully_established()
990 struct sock *ssk, in ack_update_msk() argument
1010 new_wnd_end = new_snd_una + tcp_sk(ssk)->snd_wnd; in ack_update_msk()
1017 __mptcp_check_push(sk, ssk); in ack_update_msk()
1198 const struct sock *ssk = (const struct sock *)tp; in mptcp_set_rwin() local
1203 subflow = mptcp_subflow_ctx(ssk); in mptcp_set_rwin()
1244 subflow = mptcp_subflow_ctx(ssk); in mptcp_write_options()
[all …]
|
| /linux/include/trace/events/ |
| A D | mptcp.h | 34 struct sock *ssk;
44 ssk = mptcp_subflow_tcp_sock(subflow);
45 if (ssk && sk_fullsock(ssk)) {
46 __entry->snd_wnd = tcp_sk(ssk)->snd_wnd;
47 __entry->pace = ssk->sk_pacing_rate;
53 if (ssk && sk_fullsock(ssk) && __entry->pace)
54 __entry->ratio = div_u64((u64)ssk->sk_wmem_queued << 32, __entry->pace);
|
| /linux/include/linux/ |
| A D | netlink.h | 156 int netlink_unicast(struct sock *ssk, struct sk_buff *skb, __u32 portid, int nonblock);
157 int netlink_broadcast(struct sock *ssk, struct sk_buff *skb, __u32 portid,
159 int netlink_set_err(struct sock *ssk, __u32 portid, __u32 group, int code);
166 long *timeo, struct sock *ssk);
244 int __netlink_dump_start(struct sock *ssk, struct sk_buff *skb,
247 static inline int netlink_dump_start(struct sock *ssk, struct sk_buff *skb, in netlink_dump_start() argument
254 return __netlink_dump_start(ssk, skb, nlh, control); in netlink_dump_start()
|
| /linux/net/netlink/ |
| A D | af_netlink.c | 1154 sock = netlink_lookup(sock_net(ssk), ssk->sk_protocol, portid); in netlink_getsockbyportid()
1220 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
1317 NETLINK_CB(skb).sk = ssk; in netlink_unicast_kernel()
1318 netlink_deliver_tap_kernel(sk, ssk, skb); in netlink_unicast_kernel()
1337 timeo = sock_sndtimeo(ssk, nonblock); in netlink_unicast()
1493 struct net *net = sock_net(ssk); in netlink_broadcast()
1499 info.exclude_sk = ssk; in netlink_broadcast()
1586 info.exclude_sk = ssk; in netlink_set_err()
[all …]
|
| /linux/include/net/ |
| A D | mptcp.h | 117 void mptcp_space(const struct sock *ssk, int *space, int *full_space);
271 static inline void mptcp_space(const struct sock *ssk, int *s, int *fs) { } in mptcp_space() argument
|