Lines Matching refs:sock
47 static void __mptcp_destroy_sock(struct sock *sk);
48 static void mptcp_check_send_data_fin(struct sock *sk);
61 static const struct proto_ops *mptcp_fallback_tcp_ops(const struct sock *sk) in mptcp_fallback_tcp_ops()
73 struct net *net = sock_net((struct sock *)msk); in __mptcp_try_fallback()
94 struct sock *sk = (struct sock *)msk; in __mptcp_socket_create()
121 struct sock *__mptcp_nmpc_sk(struct mptcp_sock *msk) in __mptcp_nmpc_sk()
123 struct sock *sk = (struct sock *)msk; in __mptcp_nmpc_sk()
138 static void mptcp_drop(struct sock *sk, struct sk_buff *skb) in mptcp_drop()
144 static bool mptcp_try_coalesce(struct sock *sk, struct sk_buff *to, in mptcp_try_coalesce()
178 return mptcp_try_coalesce((struct sock *)msk, to, from); in mptcp_ooo_try_coalesce()
187 struct sock *sk = (struct sock *)msk; in mptcp_data_queue_ofo()
296 static bool __mptcp_move_skb(struct mptcp_sock *msk, struct sock *ssk, in __mptcp_move_skb()
301 struct sock *sk = (struct sock *)msk; in __mptcp_move_skb()
353 static void mptcp_stop_rtx_timer(struct sock *sk) in mptcp_stop_rtx_timer()
361 static void mptcp_close_wake_up(struct sock *sk) in mptcp_close_wake_up()
375 static bool mptcp_pending_data_fin_ack(struct sock *sk) in mptcp_pending_data_fin_ack()
384 static void mptcp_check_data_fin_ack(struct sock *sk) in mptcp_check_data_fin_ack()
407 static bool mptcp_pending_data_fin(struct sock *sk, u64 *seq) in mptcp_pending_data_fin()
427 static void mptcp_set_datafin_timeout(struct sock *sk) in mptcp_set_datafin_timeout()
438 static void __mptcp_set_timeout(struct sock *sk, long tout) in __mptcp_set_timeout()
445 const struct sock *ssk = mptcp_subflow_tcp_sock(subflow); in mptcp_timeout_from_subflow()
451 static void mptcp_set_timeout(struct sock *sk) in mptcp_set_timeout()
461 static inline bool tcp_can_send_ack(const struct sock *ssk) in tcp_can_send_ack()
467 void __mptcp_subflow_send_ack(struct sock *ssk) in __mptcp_subflow_send_ack()
473 static void mptcp_subflow_send_ack(struct sock *ssk) in mptcp_subflow_send_ack()
490 static void mptcp_subflow_cleanup_rbuf(struct sock *ssk, int copied) in mptcp_subflow_cleanup_rbuf()
500 static bool mptcp_subflow_could_cleanup(const struct sock *ssk, bool rx_empty) in mptcp_subflow_could_cleanup()
517 struct sock *sk = (struct sock *)msk; in mptcp_cleanup_rbuf()
525 struct sock *ssk = mptcp_subflow_tcp_sock(subflow); in mptcp_cleanup_rbuf()
532 static bool mptcp_check_data_fin(struct sock *sk) in mptcp_check_data_fin()
582 static void mptcp_dss_corruption(struct mptcp_sock *msk, struct sock *ssk) in mptcp_dss_corruption()
591 struct sock *ssk) in __mptcp_move_skbs_from_subflow()
594 struct sock *sk = (struct sock *)msk; in __mptcp_move_skbs_from_subflow()
663 struct sock *sk = (struct sock *)msk; in __mptcp_ofo_queue()
706 static bool __mptcp_subflow_error_report(struct sock *sk, struct sock *ssk) in __mptcp_subflow_error_report()
736 void __mptcp_error_report(struct sock *sk) in __mptcp_error_report()
749 static bool move_skbs_to_msk(struct mptcp_sock *msk, struct sock *ssk) in move_skbs_to_msk()
751 struct sock *sk = (struct sock *)msk; in move_skbs_to_msk()
773 static void __mptcp_rcvbuf_update(struct sock *sk, struct sock *ssk) in __mptcp_rcvbuf_update()
779 static void __mptcp_data_ready(struct sock *sk, struct sock *ssk) in __mptcp_data_ready()
790 void mptcp_data_ready(struct sock *sk, struct sock *ssk) in mptcp_data_ready()
809 static void mptcp_subflow_joined(struct mptcp_sock *msk, struct sock *ssk) in mptcp_subflow_joined()
816 static bool __mptcp_finish_join(struct mptcp_sock *msk, struct sock *ssk) in __mptcp_finish_join()
818 struct sock *sk = (struct sock *)msk; in __mptcp_finish_join()
844 static void __mptcp_flush_join_list(struct sock *sk, struct list_head *join_list) in __mptcp_flush_join_list()
850 struct sock *ssk = mptcp_subflow_tcp_sock(subflow); in __mptcp_flush_join_list()
860 static bool mptcp_rtx_timer_pending(struct sock *sk) in mptcp_rtx_timer_pending()
865 static void mptcp_reset_rtx_timer(struct sock *sk) in mptcp_reset_rtx_timer()
878 bool mptcp_schedule_work(struct sock *sk) in mptcp_schedule_work()
920 static void dfrag_uncharge(struct sock *sk, int len) in dfrag_uncharge()
926 static void dfrag_clear(struct sock *sk, struct mptcp_data_frag *dfrag) in dfrag_clear()
936 static void __mptcp_clean_una(struct sock *sk) in __mptcp_clean_una()
995 static void __mptcp_clean_una_wakeup(struct sock *sk) in __mptcp_clean_una_wakeup()
1003 static void mptcp_clean_una_wakeup(struct sock *sk) in mptcp_clean_una_wakeup()
1010 static void mptcp_enter_memory_pressure(struct sock *sk) in mptcp_enter_memory_pressure()
1017 struct sock *ssk = mptcp_subflow_tcp_sock(subflow); in mptcp_enter_memory_pressure()
1031 static bool mptcp_page_frag_refill(struct sock *sk, struct page_frag *pfrag) in mptcp_page_frag_refill()
1068 static int mptcp_check_allowed_size(const struct mptcp_sock *msk, struct sock *ssk, in mptcp_check_allowed_size()
1098 static struct sk_buff *__mptcp_do_alloc_tx_skb(struct sock *sk, gfp_t gfp) in __mptcp_do_alloc_tx_skb()
1117 static struct sk_buff *__mptcp_alloc_tx_skb(struct sock *sk, struct sock *ssk, gfp_t gfp) in __mptcp_alloc_tx_skb()
1134 static struct sk_buff *mptcp_alloc_tx_skb(struct sock *sk, struct sock *ssk, bool data_lock_held) in mptcp_alloc_tx_skb()
1154 struct sock *ssk, in mptcp_update_infinite_map()
1174 static int mptcp_sendmsg_frag(struct sock *sk, struct sock *ssk, in mptcp_sendmsg_frag()
1319 struct sock *ssk;
1353 struct sock *mptcp_subflow_get_send(struct mptcp_sock *msk) in mptcp_subflow_get_send()
1357 struct sock *sk = (struct sock *)msk; in mptcp_subflow_get_send()
1360 struct sock *ssk; in mptcp_subflow_get_send()
1429 static void mptcp_push_release(struct sock *ssk, struct mptcp_sendmsg_info *info) in mptcp_push_release()
1462 void mptcp_check_and_set_pending(struct sock *sk) in mptcp_check_and_set_pending()
1471 static int __subflow_push_pending(struct sock *sk, struct sock *ssk, in __subflow_push_pending()
1515 void __mptcp_push_pending(struct sock *sk, unsigned int flags) in __mptcp_push_pending()
1517 struct sock *prev_ssk = NULL, *ssk = NULL; in __mptcp_push_pending()
1580 static void __mptcp_subflow_push_pending(struct sock *sk, struct sock *ssk, bool first) in __mptcp_subflow_push_pending()
1587 struct sock *xmit_ssk; in __mptcp_subflow_push_pending()
1647 static int mptcp_disconnect(struct sock *sk, int flags);
1649 static int mptcp_sendmsg_fastopen(struct sock *sk, struct msghdr *msg, in mptcp_sendmsg_fastopen()
1654 struct sock *ssk; in mptcp_sendmsg_fastopen()
1707 static int do_copy_data_nocache(struct sock *sk, int copy, in do_copy_data_nocache()
1724 static u32 mptcp_send_limit(const struct sock *sk) in mptcp_send_limit()
1743 static int mptcp_sendmsg(struct sock *sk, struct msghdr *msg, size_t len) in mptcp_sendmsg()
1874 static int __mptcp_recvmsg_mskq(struct sock *sk, in __mptcp_recvmsg_mskq()
1940 struct sock *sk = (struct sock *)msk; in mptcp_rcv_space_adjust()
2013 struct sock *ssk; in mptcp_rcv_space_adjust()
2047 static bool __mptcp_move_skbs(struct sock *sk) in __mptcp_move_skbs()
2064 struct sock *ssk; in __mptcp_move_skbs()
2090 mptcp_check_data_fin((struct sock *)msk); in __mptcp_move_skbs()
2094 static unsigned int mptcp_inq_hint(const struct sock *sk) in mptcp_inq_hint()
2115 static int mptcp_recvmsg(struct sock *sk, struct msghdr *msg, size_t len, in mptcp_recvmsg()
2235 struct sock *sk = &icsk->icsk_inet.sk; in mptcp_retransmit_timer()
2253 struct sock *sk = timer_container_of(sk, t, sk_timer); in mptcp_tout_timer()
2264 struct sock *mptcp_subflow_get_retrans(struct mptcp_sock *msk) in mptcp_subflow_get_retrans()
2266 struct sock *backup = NULL, *pick = NULL; in mptcp_subflow_get_retrans()
2271 struct sock *ssk = mptcp_subflow_tcp_sock(subflow); in mptcp_subflow_get_retrans()
2300 bool __mptcp_retransmit_pending_data(struct sock *sk) in __mptcp_retransmit_pending_data()
2345 static void __mptcp_subflow_disconnect(struct sock *ssk, in __mptcp_subflow_disconnect()
2369 static void __mptcp_close_ssk(struct sock *sk, struct sock *ssk, in __mptcp_close_ssk()
2462 void mptcp_close_ssk(struct sock *sk, struct sock *ssk, in mptcp_close_ssk()
2482 static unsigned int mptcp_sync_mss(struct sock *sk, u32 pmtu) in mptcp_sync_mss()
2487 static void __mptcp_close_subflow(struct sock *sk) in __mptcp_close_subflow()
2495 struct sock *ssk = mptcp_subflow_tcp_sock(subflow); in __mptcp_close_subflow()
2512 static bool mptcp_close_tout_expired(const struct sock *sk) in mptcp_close_tout_expired()
2525 struct sock *sk = (struct sock *)msk; in mptcp_check_fastclose()
2533 struct sock *tcp_sk = mptcp_subflow_tcp_sock(subflow); in mptcp_check_fastclose()
2571 static void __mptcp_retrans(struct sock *sk) in __mptcp_retrans()
2577 struct sock *ssk; in __mptcp_retrans()
2668 struct sock *sk = (struct sock *)msk; in mptcp_reset_tout_timer()
2687 struct sock *ssk = msk->first; in mptcp_mp_fail_no_response()
2701 static void mptcp_do_fastclose(struct sock *sk) in mptcp_do_fastclose()
2715 struct sock *sk = (struct sock *)msk; in mptcp_worker()
2757 static void __mptcp_init_sock(struct sock *sk) in __mptcp_init_sock()
2789 static void mptcp_ca_reset(struct sock *sk) in mptcp_ca_reset()
2802 static int mptcp_init_sock(struct sock *sk) in mptcp_init_sock()
2836 static void __mptcp_clear_xmit(struct sock *sk) in __mptcp_clear_xmit()
2846 void mptcp_cancel_work(struct sock *sk) in mptcp_cancel_work()
2854 void mptcp_subflow_shutdown(struct sock *sk, struct sock *ssk, int how) in mptcp_subflow_shutdown()
2889 void mptcp_set_state(struct sock *sk, int state) in mptcp_set_state()
2929 static int mptcp_close_state(struct sock *sk) in mptcp_close_state()
2939 static void mptcp_check_send_data_fin(struct sock *sk) in mptcp_check_send_data_fin()
2958 struct sock *tcp_sk = mptcp_subflow_tcp_sock(subflow); in mptcp_check_send_data_fin()
2964 static void __mptcp_wr_shutdown(struct sock *sk) in __mptcp_wr_shutdown()
2979 static void __mptcp_destroy_sock(struct sock *sk) in __mptcp_destroy_sock()
3000 void __mptcp_unaccepted_force_close(struct sock *sk) in __mptcp_unaccepted_force_close()
3007 static __poll_t mptcp_check_readable(struct sock *sk) in mptcp_check_readable()
3012 static void mptcp_check_listen_stop(struct sock *sk) in mptcp_check_listen_stop()
3014 struct sock *ssk; in mptcp_check_listen_stop()
3032 bool __mptcp_close(struct sock *sk, long timeout) in __mptcp_close()
3062 struct sock *ssk = mptcp_subflow_tcp_sock(subflow); in __mptcp_close()
3102 static void mptcp_close(struct sock *sk, long timeout) in mptcp_close()
3116 static void mptcp_copy_inaddrs(struct sock *msk, const struct sock *ssk) in mptcp_copy_inaddrs()
3139 static int mptcp_disconnect(struct sock *sk, int flags) in mptcp_disconnect()
3196 static struct ipv6_pinfo *mptcp_inet6_sk(const struct sock *sk) in mptcp_inet6_sk()
3203 static void mptcp_copy_ip6_options(struct sock *newsk, const struct sock *sk) in mptcp_copy_ip6_options()
3223 static void mptcp_copy_ip_options(struct sock *newsk, const struct sock *sk) in mptcp_copy_ip_options()
3243 struct sock *mptcp_sk_clone_init(const struct sock *sk, in mptcp_sk_clone_init()
3245 struct sock *ssk, in mptcp_sk_clone_init()
3249 struct sock *nsk = sk_clone_lock(sk, GFP_ATOMIC); in mptcp_sk_clone_init()
3323 void mptcp_rcv_space_init(struct mptcp_sock *msk, const struct sock *ssk) in mptcp_rcv_space_init()
3343 struct sock *sk = (struct sock *)msk; in mptcp_destroy_common()
3361 static void mptcp_destroy(struct sock *sk) in mptcp_destroy()
3371 void __mptcp_data_acked(struct sock *sk) in __mptcp_data_acked()
3379 void __mptcp_check_push(struct sock *sk, struct sock *ssk) in __mptcp_check_push()
3396 static void mptcp_release_cb(struct sock *sk) in mptcp_release_cb()
3457 static void schedule_3rdack_retransmission(struct sock *ssk) in schedule_3rdack_retransmission()
3479 void mptcp_subflow_process_delegated(struct sock *ssk, long status) in mptcp_subflow_process_delegated()
3482 struct sock *sk = subflow->conn; in mptcp_subflow_process_delegated()
3504 static int mptcp_hash(struct sock *sk) in mptcp_hash()
3513 static void mptcp_unhash(struct sock *sk) in mptcp_unhash()
3518 static int mptcp_get_port(struct sock *sk, unsigned short snum) in mptcp_get_port()
3529 void mptcp_finish_connect(struct sock *ssk) in mptcp_finish_connect()
3533 struct sock *sk; in mptcp_finish_connect()
3552 void mptcp_sock_graft(struct sock *sk, struct socket *parent) in mptcp_sock_graft()
3561 bool mptcp_finish_join(struct sock *ssk) in mptcp_finish_join()
3565 struct sock *parent = (void *)msk; in mptcp_finish_join()
3620 static void mptcp_shutdown(struct sock *sk, int how) in mptcp_shutdown()
3630 const struct sock *sk = (void *)msk; in mptcp_ioctl_outq()
3657 static int mptcp_ioctl(struct sock *sk, int cmd, int *karg) in mptcp_ioctl()
3690 static int mptcp_connect(struct sock *sk, struct sockaddr *uaddr, int addr_len) in mptcp_connect()
3695 struct sock *ssk; in mptcp_connect()
3800 static int mptcp_bind(struct socket *sock, struct sockaddr *uaddr, int addr_len) in mptcp_bind() argument
3802 struct mptcp_sock *msk = mptcp_sk(sock->sk); in mptcp_bind()
3803 struct sock *ssk, *sk = sock->sk; in mptcp_bind()
3827 static int mptcp_listen(struct socket *sock, int backlog) in mptcp_listen() argument
3829 struct mptcp_sock *msk = mptcp_sk(sock->sk); in mptcp_listen()
3830 struct sock *sk = sock->sk; in mptcp_listen()
3831 struct sock *ssk; in mptcp_listen()
3839 if (sock->state != SS_UNCONNECTED || sock->type != SOCK_STREAM) in mptcp_listen()
3867 static int mptcp_stream_accept(struct socket *sock, struct socket *newsock, in mptcp_stream_accept() argument
3870 struct mptcp_sock *msk = mptcp_sk(sock->sk); in mptcp_stream_accept()
3871 struct sock *ssk, *newsk; in mptcp_stream_accept()
3890 struct sock *new_mptcp_sock; in mptcp_stream_accept()
3908 __inet_accept(sock, newsock, newsk); in mptcp_stream_accept()
3918 struct sock *ssk = mptcp_subflow_tcp_sock(subflow); in mptcp_stream_accept()
3937 __inet_accept(sock, newsock, newsk); in mptcp_stream_accept()
3954 struct sock *sk = (struct sock *)msk; in mptcp_check_writeable()
3967 static __poll_t mptcp_poll(struct file *file, struct socket *sock, in mptcp_poll() argument
3970 struct sock *sk = sock->sk; in mptcp_poll()
3977 sock_poll_wait(file, sock, wait); in mptcp_poll()
3982 struct sock *ssk = READ_ONCE(msk->first); in mptcp_poll()
4054 struct sock *ssk = mptcp_subflow_tcp_sock(subflow); in mptcp_napi_poll()