net/mptcp/protocol.h

259 struct mptcp_sock {
348 static inline void msk_owned_by_me(const struct mptcp_sock *msk)
364 	container_of_const(_ptr, struct mptcp_sock, sk.icsk_inet.sk);	\
368 #define mptcp_sk(ptr) container_of_const(ptr, struct mptcp_sock, sk.icsk_inet.sk)
391 	const struct mptcp_sock *msk = mptcp_sk(sk);
398 	struct mptcp_sock *msk = mptcp_sk(sk);
408 	const struct mptcp_sock *msk = mptcp_sk(sk);
421 	struct mptcp_sock *msk = mptcp_sk(sk);
452 	struct mptcp_sock	*msk;
550 	struct	sock *conn;	    /* parent mptcp_sock */
645 void __mptcp_subflow_fully_established(struct mptcp_sock *msk,
660 struct sock *__mptcp_nmpc_sk(struct mptcp_sock *msk);
683 int mptcp_init_sched(struct mptcp_sock *msk,
685 void mptcp_release_sched(struct mptcp_sock *msk);
688 struct sock *mptcp_subflow_get_send(struct mptcp_sock *msk);
689 struct sock *mptcp_subflow_get_retrans(struct mptcp_sock *msk);
690 int mptcp_sched_get_send(struct mptcp_sock *msk);
691 int mptcp_sched_get_retrans(struct mptcp_sock *msk);
693 static inline u64 mptcp_data_avail(const struct mptcp_sock *msk)
757 void mptcp_reset_tout_timer(struct mptcp_sock *msk, unsigned long fail_tout);
786 void mptcp_rcv_space_init(struct mptcp_sock *msk, const struct sock *ssk);
806 bool mptcp_update_rcv_data_fin(struct mptcp_sock *msk, u64 data_fin_seq, bool use_64bit);
807 static inline bool mptcp_data_fin_enabled(const struct mptcp_sock *msk)
824 	const struct mptcp_sock *msk = mptcp_sk(sk);
894 void mptcp_destroy_common(struct mptcp_sock *msk, unsigned int flags);
908 			struct mptcp_sock *msk);
910 struct mptcp_sock *mptcp_token_get_sock(struct net *net, u32 token);
911 struct mptcp_sock *mptcp_token_iter_next(const struct net *net, long *s_slot,
913 void mptcp_token_destroy(struct mptcp_sock *msk);
921 void mptcp_pm_data_init(struct mptcp_sock *msk);
922 void mptcp_pm_data_reset(struct mptcp_sock *msk);
931 void mptcp_pm_subflow_chk_stale(const struct mptcp_sock *msk, struct sock *ssk);
932 void mptcp_pm_nl_subflow_chk_stale(const struct mptcp_sock *msk, struct sock *ssk);
933 void mptcp_pm_new_connection(struct mptcp_sock *msk, const struct sock *ssk, int server_side);
934 void mptcp_pm_fully_established(struct mptcp_sock *msk, const struct sock *ssk);
935 bool mptcp_pm_allow_new_subflow(struct mptcp_sock *msk);
936 void mptcp_pm_connection_closed(struct mptcp_sock *msk);
937 void mptcp_pm_subflow_established(struct mptcp_sock *msk);
938 bool mptcp_pm_nl_check_work_pending(struct mptcp_sock *msk);
939 void mptcp_pm_subflow_check_next(struct mptcp_sock *msk,
943 void mptcp_pm_add_addr_echoed(struct mptcp_sock *msk,
945 void mptcp_pm_add_addr_send_ack(struct mptcp_sock *msk);
946 void mptcp_pm_nl_addr_send_ack(struct mptcp_sock *msk);
947 void mptcp_pm_rm_addr_received(struct mptcp_sock *msk,
951 int mptcp_pm_nl_mp_prio_send_ack(struct mptcp_sock *msk,
955 bool mptcp_pm_alloc_anno_list(struct mptcp_sock *msk,
957 void mptcp_pm_free_anno_list(struct mptcp_sock *msk);
958 bool mptcp_pm_sport_in_anno_list(struct mptcp_sock *msk, const struct sock *sk);
960 mptcp_pm_del_add_timer(struct mptcp_sock *msk,
963 mptcp_lookup_anno_list_by_saddr(const struct mptcp_sock *msk,
965 int mptcp_pm_get_flags_and_ifindex_by_id(struct mptcp_sock *msk,
968 int mptcp_pm_nl_get_flags_and_ifindex_by_id(struct mptcp_sock *msk, unsigned int id,
970 int mptcp_userspace_pm_get_flags_and_ifindex_by_id(struct mptcp_sock *msk,
976 int mptcp_pm_announce_addr(struct mptcp_sock *msk,
979 int mptcp_pm_remove_addr(struct mptcp_sock *msk, const struct mptcp_rm_list *rm_list);
980 int mptcp_pm_remove_subflow(struct mptcp_sock *msk, const struct mptcp_rm_list *rm_list);
981 void mptcp_pm_remove_addrs(struct mptcp_sock *msk, struct list_head *rm_list);
983 void mptcp_free_local_addr_list(struct mptcp_sock *msk);
985 void mptcp_event(enum mptcp_event_type type, const struct mptcp_sock *msk,
988 void mptcp_event_addr_removed(const struct mptcp_sock *msk, u8 id);
991 bool mptcp_userspace_pm_active(const struct mptcp_sock *msk);
993 void __mptcp_fastopen_gen_msk_ackseq(struct mptcp_sock *msk, struct mptcp_subflow_context *subflow,
1000 static inline bool mptcp_pm_should_add_signal(struct mptcp_sock *msk)
1006 static inline bool mptcp_pm_should_add_signal_addr(struct mptcp_sock *msk)
1011 static inline bool mptcp_pm_should_add_signal_echo(struct mptcp_sock *msk)
1016 static inline bool mptcp_pm_should_rm_signal(struct mptcp_sock *msk)
1021 static inline bool mptcp_pm_is_userspace(const struct mptcp_sock *msk)
1026 static inline bool mptcp_pm_is_kernel(const struct mptcp_sock *msk)
1054 bool mptcp_pm_add_addr_signal(struct mptcp_sock *msk, const struct sk_buff *skb,
1058 bool mptcp_pm_rm_addr_signal(struct mptcp_sock *msk, unsigned int remaining,
1060 int mptcp_pm_get_local_id(struct mptcp_sock *msk, struct sock_common *skc);
1061 int mptcp_pm_nl_get_local_id(struct mptcp_sock *msk, struct mptcp_addr_info *skc);
1062 int mptcp_userspace_pm_get_local_id(struct mptcp_sock *msk, struct mptcp_addr_info *skc);
1083 void mptcp_pm_nl_work(struct mptcp_sock *msk);
1084 void mptcp_pm_nl_rm_subflow_received(struct mptcp_sock *msk,
1086 unsigned int mptcp_pm_get_add_addr_signal_max(const struct mptcp_sock *msk);
1087 unsigned int mptcp_pm_get_add_addr_accept_max(const struct mptcp_sock *msk);
1088 unsigned int mptcp_pm_get_subflows_max(const struct mptcp_sock *msk);
1089 unsigned int mptcp_pm_get_local_addr_max(const struct mptcp_sock *msk);
1092 static inline void __mptcp_pm_close_subflow(struct mptcp_sock *msk)
1098 static inline void mptcp_pm_close_subflow(struct mptcp_sock *msk)
1105 void mptcp_sockopt_sync(struct mptcp_sock *msk, struct sock *ssk);
1106 void mptcp_sockopt_sync_locked(struct mptcp_sock *msk, struct sock *ssk);
1115 static inline bool __mptcp_check_fallback(const struct mptcp_sock *msk)
1123 	struct mptcp_sock *msk = mptcp_sk(subflow->conn);
1128 static inline void __mptcp_do_fallback(struct mptcp_sock *msk)
1137 static inline bool __mptcp_has_initial_subflow(const struct mptcp_sock *msk)
1150 	struct mptcp_sock *msk;