Home
last modified time | relevance | path

Searched refs:ssk (Results 1 – 13 of 13) sorted by relevance

/Linux-v6.1/net/mptcp/
Dsockopt.c78 struct sock *ssk = mptcp_subflow_tcp_sock(subflow); in mptcp_sol_socket_sync_intval() local
79 bool slow = lock_sock_fast(ssk); in mptcp_sol_socket_sync_intval()
83 sock_valbool_flag(ssk, SOCK_DBG, !!val); in mptcp_sol_socket_sync_intval()
86 if (ssk->sk_prot->keepalive) in mptcp_sol_socket_sync_intval()
87 ssk->sk_prot->keepalive(ssk, !!val); in mptcp_sol_socket_sync_intval()
88 sock_valbool_flag(ssk, SOCK_KEEPOPEN, !!val); in mptcp_sol_socket_sync_intval()
91 ssk->sk_priority = val; in mptcp_sol_socket_sync_intval()
95 ssk->sk_userlocks |= SOCK_SNDBUF_LOCK; in mptcp_sol_socket_sync_intval()
96 WRITE_ONCE(ssk->sk_sndbuf, sk->sk_sndbuf); in mptcp_sol_socket_sync_intval()
100 ssk->sk_userlocks |= SOCK_RCVBUF_LOCK; in mptcp_sol_socket_sync_intval()
[all …]
Dprotocol.c327 static bool mptcp_rmem_schedule(struct sock *sk, struct sock *ssk, int size) in mptcp_rmem_schedule() argument
345 static bool __mptcp_move_skb(struct mptcp_sock *msk, struct sock *ssk, in __mptcp_move_skb() argument
349 struct mptcp_subflow_context *subflow = mptcp_subflow_ctx(ssk); in __mptcp_move_skb()
354 __skb_unlink(skb, &ssk->sk_receive_queue); in __mptcp_move_skb()
360 if (!mptcp_rmem_schedule(sk, ssk, skb->truesize)) in __mptcp_move_skb()
489 const struct sock *ssk = mptcp_subflow_tcp_sock(subflow); in mptcp_timeout_from_subflow() local
491 return inet_csk(ssk)->icsk_pending && !subflow->stale_count ? in mptcp_timeout_from_subflow()
492 inet_csk(ssk)->icsk_timeout - jiffies : 0; in mptcp_timeout_from_subflow()
505 static inline bool tcp_can_send_ack(const struct sock *ssk) in tcp_can_send_ack() argument
507 return !((1 << inet_sk_state_load(ssk)) & in tcp_can_send_ack()
[all …]
Dsubflow.c30 static void mptcp_subflow_ops_undo_override(struct sock *ssk);
354 void mptcp_subflow_reset(struct sock *ssk) in mptcp_subflow_reset() argument
356 struct mptcp_subflow_context *subflow = mptcp_subflow_ctx(ssk); in mptcp_subflow_reset()
362 tcp_set_state(ssk, TCP_CLOSE); in mptcp_subflow_reset()
363 tcp_send_active_reset(ssk, GFP_ATOMIC); in mptcp_subflow_reset()
364 tcp_done(ssk); in mptcp_subflow_reset()
625 static void subflow_drop_ctx(struct sock *ssk) in subflow_drop_ctx() argument
627 struct mptcp_subflow_context *ctx = mptcp_subflow_ctx(ssk); in subflow_drop_ctx()
632 subflow_ulp_fallback(ssk, ctx); in subflow_drop_ctx()
839 static bool skb_is_fully_mapped(struct sock *ssk, struct sk_buff *skb) in skb_is_fully_mapped() argument
[all …]
Dprotocol.h543 void mptcp_subflow_process_delegated(struct sock *ssk);
604 void mptcp_copy_inaddrs(struct sock *msk, const struct sock *ssk);
612 void mptcp_subflow_shutdown(struct sock *sk, struct sock *ssk, int how);
613 void mptcp_close_ssk(struct sock *sk, struct sock *ssk,
615 void __mptcp_subflow_send_ack(struct sock *ssk);
616 void mptcp_subflow_reset(struct sock *ssk);
617 void mptcp_subflow_queue_clean(struct sock *ssk);
634 static inline bool __tcp_can_send(const struct sock *ssk) in __tcp_can_send() argument
637 return ((1 << inet_sk_state_load(ssk)) & (TCPF_ESTABLISHED | TCPF_CLOSE_WAIT)); in __tcp_can_send()
683 void mptcp_rcv_space_init(struct mptcp_sock *msk, const struct sock *ssk);
[all …]
Dpm.c74 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()
129 void mptcp_pm_fully_established(struct mptcp_sock *msk, const struct sock *ssk, gfp_t gfp) in mptcp_pm_fully_established() argument
153 mptcp_event(MPTCP_EVENT_ESTABLISHED, msk, ssk, gfp); in mptcp_pm_fully_established()
178 void mptcp_pm_subflow_check_next(struct mptcp_sock *msk, const struct sock *ssk, in mptcp_pm_subflow_check_next() argument
202 void mptcp_pm_add_addr_received(const struct sock *ssk, in mptcp_pm_add_addr_received() argument
205 struct mptcp_subflow_context *subflow = mptcp_subflow_ctx(ssk); in mptcp_pm_add_addr_received()
212 mptcp_event_addr_announced(ssk, addr); in mptcp_pm_add_addr_received()
277 void mptcp_pm_mp_prio_received(struct sock *ssk, u8 bkup) in mptcp_pm_mp_prio_received() argument
279 struct mptcp_subflow_context *subflow = mptcp_subflow_ctx(ssk); in mptcp_pm_mp_prio_received()
[all …]
Dpm_userspace.c317 struct sock *ssk; in mptcp_nl_find_ssk() local
319 ssk = mptcp_subflow_tcp_sock(subflow); in mptcp_nl_find_ssk()
321 if (local->family != ssk->sk_family) in mptcp_nl_find_ssk()
324 issk = inet_sk(ssk); in mptcp_nl_find_ssk()
326 switch (ssk->sk_family) { in mptcp_nl_find_ssk()
334 const struct ipv6_pinfo *pinfo = inet6_sk(ssk); in mptcp_nl_find_ssk()
337 !ipv6_addr_equal(&remote->addr6, &ssk->sk_v6_daddr)) in mptcp_nl_find_ssk()
348 return ssk; in mptcp_nl_find_ssk()
362 struct sock *sk, *ssk; in mptcp_nl_cmd_sf_destroy() local
408 ssk = mptcp_nl_find_ssk(msk, &addr_l, &addr_r); in mptcp_nl_cmd_sf_destroy()
[all …]
Dpm_netlink.c430 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, &addrs[i]); in fill_remote_addresses_vec()
470 struct sock *ssk = mptcp_subflow_tcp_sock(subflow); in __mptcp_pm_send_ack() local
476 slow = lock_sock_fast(ssk); in __mptcp_pm_send_ack()
486 __mptcp_subflow_send_ack(ssk); in __mptcp_pm_send_ack()
487 unlock_sock_fast(ssk, slow); in __mptcp_pm_send_ack()
748 struct sock *ssk = mptcp_subflow_tcp_sock(subflow); in mptcp_pm_nl_mp_prio_send_ack() local
751 local_address((struct sock_common *)ssk, &local); in mptcp_pm_nl_mp_prio_send_ack()
756 remote_address((struct sock_common *)ssk, &remote); in mptcp_pm_nl_mp_prio_send_ack()
[all …]
Doptions.c919 static bool check_fully_established(struct mptcp_sock *msk, struct sock *ssk, in check_fully_established() argument
936 tcp_send_ack(ssk); in check_fully_established()
970 mptcp_do_fallback(ssk); in check_fully_established()
992 clear_3rdack_retransmission(ssk); in check_fully_established()
995 mptcp_pm_fully_established(msk, ssk, GFP_ATOMIC); in check_fully_established()
1000 mptcp_subflow_reset(ssk); in check_fully_established()
1021 struct sock *ssk, in ack_update_msk() argument
1041 new_wnd_end = new_snd_una + tcp_sk(ssk)->snd_wnd; in ack_update_msk()
1048 __mptcp_check_push(sk, ssk); in ack_update_msk()
1230 const struct sock *ssk = (const struct sock *)tp; in mptcp_set_rwin() local
[all …]
/Linux-v6.1/include/trace/events/
Dmptcp.h34 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-v6.1/include/linux/
Dnetlink.h171 int netlink_unicast(struct sock *ssk, struct sk_buff *skb, __u32 portid, int nonblock);
172 int netlink_broadcast(struct sock *ssk, struct sk_buff *skb, __u32 portid,
174 int netlink_set_err(struct sock *ssk, __u32 portid, __u32 group, int code);
181 long *timeo, struct sock *ssk);
259 int __netlink_dump_start(struct sock *ssk, struct sk_buff *skb,
262 static inline int netlink_dump_start(struct sock *ssk, struct sk_buff *skb, in netlink_dump_start() argument
269 return __netlink_dump_start(ssk, skb, nlh, control); in netlink_dump_start()
/Linux-v6.1/net/netlink/
Daf_netlink.c1149 static struct sock *netlink_getsockbyportid(struct sock *ssk, u32 portid) in netlink_getsockbyportid() argument
1154 sock = netlink_lookup(sock_net(ssk), ssk->sk_protocol, portid); in netlink_getsockbyportid()
1161 nlk->dst_portid != nlk_sk(ssk)->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()
1328 int netlink_unicast(struct sock *ssk, struct sk_buff *skb, in netlink_unicast() argument
1337 timeo = sock_sndtimeo(ssk, nonblock); in netlink_unicast()
[all …]
/Linux-v6.1/include/net/
Dmptcp.h119 void mptcp_space(const struct sock *ssk, int *space, int *full_space);
267 static inline void mptcp_space(const struct sock *ssk, int *s, int *fs) { } in mptcp_space() argument
/Linux-v6.1/tools/testing/selftests/bpf/progs/
Dmptcp_sock.c82 const struct sock *ssk, int server_side) in BPF_PROG() argument