| /net/mptcp/ |
| D | sockopt.c | 76 struct sock *ssk = mptcp_subflow_tcp_sock(subflow); in mptcp_sol_socket_sync_intval() local
77 bool slow = lock_sock_fast(ssk); in mptcp_sol_socket_sync_intval()
81 sock_valbool_flag(ssk, SOCK_DBG, !!val); in mptcp_sol_socket_sync_intval()
84 if (ssk->sk_prot->keepalive) in mptcp_sol_socket_sync_intval()
85 ssk->sk_prot->keepalive(ssk, !!val); in mptcp_sol_socket_sync_intval()
86 sock_valbool_flag(ssk, SOCK_KEEPOPEN, !!val); in mptcp_sol_socket_sync_intval()
89 ssk->sk_priority = val; in mptcp_sol_socket_sync_intval()
93 ssk->sk_userlocks |= SOCK_SNDBUF_LOCK; in mptcp_sol_socket_sync_intval()
94 WRITE_ONCE(ssk->sk_sndbuf, sk->sk_sndbuf); in mptcp_sol_socket_sync_intval()
98 ssk->sk_userlocks |= SOCK_RCVBUF_LOCK; in mptcp_sol_socket_sync_intval()
[all …]
|
| D | protocol.c | 273 static bool __mptcp_move_skb(struct mptcp_sock *msk, struct sock *ssk, in __mptcp_move_skb() argument
277 struct mptcp_subflow_context *subflow = mptcp_subflow_ctx(ssk); in __mptcp_move_skb()
282 __skb_unlink(skb, &ssk->sk_receive_queue); in __mptcp_move_skb()
291 if (ssk->sk_forward_alloc < amount) in __mptcp_move_skb()
294 ssk->sk_forward_alloc -= amount; in __mptcp_move_skb()
423 const struct sock *ssk = mptcp_subflow_tcp_sock(subflow); in mptcp_timeout_from_subflow() local
425 return inet_csk(ssk)->icsk_pending && !subflow->stale_count ? in mptcp_timeout_from_subflow()
426 inet_csk(ssk)->icsk_timeout - jiffies : 0; in mptcp_timeout_from_subflow()
439 static bool tcp_can_send_ack(const struct sock *ssk) in tcp_can_send_ack() argument
441 return !((1 << inet_sk_state_load(ssk)) & in tcp_can_send_ack()
[all …]
|
| D | subflow.c | 30 static void mptcp_subflow_ops_undo_override(struct sock *ssk);
353 void mptcp_subflow_reset(struct sock *ssk) in mptcp_subflow_reset() argument
355 struct mptcp_subflow_context *subflow = mptcp_subflow_ctx(ssk); in mptcp_subflow_reset()
361 tcp_send_active_reset(ssk, GFP_ATOMIC); in mptcp_subflow_reset()
362 tcp_done(ssk); in mptcp_subflow_reset()
627 static void subflow_drop_ctx(struct sock *ssk) in subflow_drop_ctx() argument
629 struct mptcp_subflow_context *ctx = mptcp_subflow_ctx(ssk); in subflow_drop_ctx()
634 subflow_ulp_fallback(ssk, ctx); in subflow_drop_ctx()
834 static bool skb_is_fully_mapped(struct sock *ssk, struct sk_buff *skb) in skb_is_fully_mapped() argument
836 struct mptcp_subflow_context *subflow = mptcp_subflow_ctx(ssk); in skb_is_fully_mapped()
[all …]
|
| D | protocol.h | 509 void mptcp_subflow_process_delegated(struct sock *ssk);
575 void mptcp_subflow_shutdown(struct sock *sk, struct sock *ssk, int how);
576 void mptcp_close_ssk(struct sock *sk, struct sock *ssk,
578 void mptcp_subflow_send_ack(struct sock *ssk);
579 void mptcp_subflow_reset(struct sock *ssk);
593 struct sock *ssk = mptcp_subflow_tcp_sock(subflow); in __mptcp_subflow_active() local
600 return ((1 << ssk->sk_state) & (TCPF_ESTABLISHED | TCPF_CLOSE_WAIT)); in __mptcp_subflow_active()
618 static inline bool mptcp_has_another_subflow(struct sock *ssk) in mptcp_has_another_subflow() argument
620 struct mptcp_subflow_context *subflow = mptcp_subflow_ctx(ssk), *tmp; in mptcp_has_another_subflow()
649 void mptcp_rcv_space_init(struct mptcp_sock *msk, const struct sock *ssk);
[all …]
|
| D | pm_netlink.c | 433 struct sock *sk = (struct sock *)msk, *ssk; in fill_remote_addresses_vec() local
450 ssk = mptcp_subflow_tcp_sock(subflow); in fill_remote_addresses_vec()
451 remote_address((struct sock_common *)ssk, &remote); in fill_remote_addresses_vec()
668 struct sock *ssk = mptcp_subflow_tcp_sock(subflow); in mptcp_pm_nl_addr_send_ack() local
674 mptcp_subflow_send_ack(ssk); in mptcp_pm_nl_addr_send_ack()
688 struct sock *ssk = mptcp_subflow_tcp_sock(subflow); in mptcp_pm_nl_mp_prio_send_ack() local
692 local_address((struct sock_common *)ssk, &local); in mptcp_pm_nl_mp_prio_send_ack()
705 mptcp_subflow_send_ack(ssk); in mptcp_pm_nl_mp_prio_send_ack()
740 struct sock *ssk = mptcp_subflow_tcp_sock(subflow); in mptcp_pm_nl_rm_addr_or_subflow() local
754 mptcp_subflow_shutdown(sk, ssk, how); in mptcp_pm_nl_rm_addr_or_subflow()
[all …]
|
| 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()
344 void mptcp_pm_subflow_chk_stale(const struct mptcp_sock *msk, struct sock *ssk) in mptcp_pm_subflow_chk_stale() argument
346 struct mptcp_subflow_context *subflow = mptcp_subflow_ctx(ssk); in mptcp_pm_subflow_chk_stale()
347 u32 rcv_tstamp = READ_ONCE(tcp_sk(ssk)->rcv_tstamp); in mptcp_pm_subflow_chk_stale()
356 mptcp_pm_nl_subflow_chk_stale(msk, ssk); in mptcp_pm_subflow_chk_stale()
|
| D | options.c | 893 static bool check_fully_established(struct mptcp_sock *msk, struct sock *ssk, in check_fully_established() argument
910 tcp_send_ack(ssk); in check_fully_established()
966 clear_3rdack_retransmission(ssk); in check_fully_established()
969 mptcp_pm_fully_established(msk, ssk, GFP_ATOMIC); in check_fully_established()
974 mptcp_subflow_reset(ssk); in check_fully_established()
995 struct sock *ssk, in ack_update_msk() argument
1015 new_wnd_end = new_snd_una + tcp_sk(ssk)->snd_wnd; in ack_update_msk()
1022 __mptcp_check_push(sk, ssk); in ack_update_msk()
1202 const struct sock *ssk = (const struct sock *)tp; in mptcp_set_rwin() local
1207 subflow = mptcp_subflow_ctx(ssk); in mptcp_set_rwin()
[all …]
|
| /net/netlink/ |
| D | af_netlink.c | 1159 static struct sock *netlink_getsockbyportid(struct sock *ssk, u32 portid) in netlink_getsockbyportid() argument
1164 sock = netlink_lookup(sock_net(ssk), ssk->sk_protocol, portid); in netlink_getsockbyportid()
1172 READ_ONCE(nlk->dst_portid) != nlk_sk(ssk)->portid) { in netlink_getsockbyportid()
1231 long *timeo, struct sock *ssk) in netlink_attachskb() argument
1241 if (!ssk || netlink_is_kernel(ssk)) in netlink_attachskb()
1319 struct sock *ssk) in netlink_unicast_kernel() argument
1328 NETLINK_CB(skb).sk = ssk; in netlink_unicast_kernel()
1329 netlink_deliver_tap_kernel(sk, ssk, skb); in netlink_unicast_kernel()
1339 int netlink_unicast(struct sock *ssk, struct sk_buff *skb, in netlink_unicast() argument
1348 timeo = sock_sndtimeo(ssk, nonblock); in netlink_unicast()
[all …]
|