Lines Matching refs:subflow

588 mptcp_subflow_tcp_sock(const struct mptcp_subflow_context *subflow)  in mptcp_subflow_tcp_sock()  argument
590 return subflow->tcp_sock; in mptcp_subflow_tcp_sock()
594 mptcp_subflow_ctx_reset(struct mptcp_subflow_context *subflow) in mptcp_subflow_ctx_reset() argument
596 memset(&subflow->reset, 0, sizeof(subflow->reset)); in mptcp_subflow_ctx_reset()
597 subflow->request_mptcp = 1; in mptcp_subflow_ctx_reset()
598 WRITE_ONCE(subflow->local_id, -1); in mptcp_subflow_ctx_reset()
631 struct mptcp_subflow_context *subflow = mptcp_subflow_ctx(sk); in mptcp_send_active_reset_reason() local
634 reason = sk_rst_convert_mptcp_reason(subflow->reset_reason); in mptcp_send_active_reset_reason()
639 mptcp_subflow_get_map_offset(const struct mptcp_subflow_context *subflow) in mptcp_subflow_get_map_offset() argument
641 return tcp_sk(mptcp_subflow_tcp_sock(subflow))->copied_seq - in mptcp_subflow_get_map_offset()
642 subflow->ssn_offset - in mptcp_subflow_get_map_offset()
643 subflow->map_subflow_seq; in mptcp_subflow_get_map_offset()
647 mptcp_subflow_get_mapped_dsn(const struct mptcp_subflow_context *subflow) in mptcp_subflow_get_mapped_dsn() argument
649 return subflow->map_seq + mptcp_subflow_get_map_offset(subflow); in mptcp_subflow_get_mapped_dsn()
654 static inline void mptcp_subflow_delegate(struct mptcp_subflow_context *subflow, int action) in mptcp_subflow_delegate() argument
667 old = set_mask_bits(&subflow->delegated_status, 0, set_bits); in mptcp_subflow_delegate()
669 if (WARN_ON_ONCE(!list_empty(&subflow->delegated_node))) in mptcp_subflow_delegate()
674 list_add_tail(&subflow->delegated_node, &delegated->head); in mptcp_subflow_delegate()
675 sock_hold(mptcp_subflow_tcp_sock(subflow)); in mptcp_subflow_delegate()
709 struct mptcp_subflow_context *subflow,
718 struct mptcp_subflow_context *subflow);
749 void mptcp_subflow_set_scheduled(struct mptcp_subflow_context *subflow,
780 static inline bool __mptcp_subflow_active(struct mptcp_subflow_context *subflow) in __mptcp_subflow_active() argument
783 if (subflow->request_join && !subflow->fully_established) in __mptcp_subflow_active()
786 return __tcp_can_send(mptcp_subflow_tcp_sock(subflow)); in __mptcp_subflow_active()
789 void mptcp_subflow_set_active(struct mptcp_subflow_context *subflow);
791 bool mptcp_subflow_active(struct mptcp_subflow_context *subflow);
910 struct mptcp_subflow_context *subflow; in __mptcp_sync_sndbuf() local
917 mptcp_for_each_subflow(mptcp_sk(sk), subflow) { in __mptcp_sync_sndbuf()
918 ssk_sndbuf = READ_ONCE(mptcp_subflow_tcp_sock(subflow)->sk_sndbuf); in __mptcp_sync_sndbuf()
920 subflow->cached_sndbuf = ssk_sndbuf; in __mptcp_sync_sndbuf()
934 struct mptcp_subflow_context *subflow = mptcp_subflow_ctx(ssk); in __mptcp_propagate_sndbuf() local
936 if (READ_ONCE(ssk->sk_sndbuf) != subflow->cached_sndbuf) in __mptcp_propagate_sndbuf()
947 struct mptcp_subflow_context *subflow = mptcp_subflow_ctx(ssk); in mptcp_propagate_sndbuf() local
949 if (likely(READ_ONCE(ssk->sk_sndbuf) == subflow->cached_sndbuf)) in mptcp_propagate_sndbuf()
953 mptcp_subflow_delegate(subflow, MPTCP_DELEGATE_SNDBUF); in mptcp_propagate_sndbuf()
1003 const struct mptcp_subflow_context *subflow);
1049 void __mptcp_fastopen_gen_msk_ackseq(struct mptcp_sock *msk, struct mptcp_subflow_context *subflow,
1051 void mptcp_fastopen_subflow_synack_set_params(struct mptcp_subflow_context *subflow,
1132 static inline u8 subflow_get_local_id(const struct mptcp_subflow_context *subflow) in subflow_get_local_id() argument
1134 int local_id = READ_ONCE(subflow->local_id); in subflow_get_local_id()
1178 struct mptcp_subflow_context *subflow = mptcp_subflow_ctx(sk); in mptcp_check_fallback() local
1179 struct mptcp_sock *msk = mptcp_sk(subflow->conn); in mptcp_check_fallback()
1204 struct mptcp_subflow_context *subflow = mptcp_subflow_ctx(ssk); in mptcp_do_fallback() local
1205 struct sock *sk = subflow->conn; in mptcp_do_fallback()
1226 struct mptcp_subflow_context *subflow) in mptcp_subflow_early_fallback() argument
1229 subflow->request_mptcp = 0; in mptcp_subflow_early_fallback()
1244 static inline bool is_active_ssk(struct mptcp_subflow_context *subflow) in is_active_ssk() argument
1246 return (subflow->request_mptcp || subflow->request_join); in is_active_ssk()
1251 struct mptcp_subflow_context *subflow = mptcp_subflow_ctx(sk); in subflow_simultaneous_connect() local
1255 is_active_ssk(subflow) && in subflow_simultaneous_connect()
1256 !subflow->conn_finished; in subflow_simultaneous_connect()