Lines Matching refs:subflow
597 mptcp_subflow_tcp_sock(const struct mptcp_subflow_context *subflow) in mptcp_subflow_tcp_sock() argument
599 return subflow->tcp_sock; in mptcp_subflow_tcp_sock()
603 mptcp_subflow_ctx_reset(struct mptcp_subflow_context *subflow) in mptcp_subflow_ctx_reset() argument
605 memset(&subflow->reset, 0, sizeof(subflow->reset)); in mptcp_subflow_ctx_reset()
606 subflow->request_mptcp = 1; in mptcp_subflow_ctx_reset()
607 WRITE_ONCE(subflow->local_id, -1); in mptcp_subflow_ctx_reset()
640 struct mptcp_subflow_context *subflow = mptcp_subflow_ctx(sk); in mptcp_send_active_reset_reason() local
643 reason = sk_rst_convert_mptcp_reason(subflow->reset_reason); in mptcp_send_active_reset_reason()
648 mptcp_subflow_get_map_offset(const struct mptcp_subflow_context *subflow) in mptcp_subflow_get_map_offset() argument
650 return tcp_sk(mptcp_subflow_tcp_sock(subflow))->copied_seq - in mptcp_subflow_get_map_offset()
651 subflow->ssn_offset - in mptcp_subflow_get_map_offset()
652 subflow->map_subflow_seq; in mptcp_subflow_get_map_offset()
656 mptcp_subflow_get_mapped_dsn(const struct mptcp_subflow_context *subflow) in mptcp_subflow_get_mapped_dsn() argument
658 return subflow->map_seq + mptcp_subflow_get_map_offset(subflow); in mptcp_subflow_get_mapped_dsn()
663 static inline void mptcp_subflow_delegate(struct mptcp_subflow_context *subflow, int action) in mptcp_subflow_delegate() argument
676 old = set_mask_bits(&subflow->delegated_status, 0, set_bits); in mptcp_subflow_delegate()
678 if (WARN_ON_ONCE(!list_empty(&subflow->delegated_node))) in mptcp_subflow_delegate()
684 list_add_tail(&subflow->delegated_node, &delegated->head); in mptcp_subflow_delegate()
686 sock_hold(mptcp_subflow_tcp_sock(subflow)); in mptcp_subflow_delegate()
725 struct mptcp_subflow_context *subflow,
734 struct mptcp_subflow_context *subflow);
768 void mptcp_subflow_set_scheduled(struct mptcp_subflow_context *subflow,
804 static inline bool __mptcp_subflow_active(struct mptcp_subflow_context *subflow) in __mptcp_subflow_active() argument
807 if (subflow->request_join && !READ_ONCE(subflow->fully_established)) in __mptcp_subflow_active()
810 return __tcp_can_send(mptcp_subflow_tcp_sock(subflow)); in __mptcp_subflow_active()
813 void mptcp_subflow_set_active(struct mptcp_subflow_context *subflow);
815 bool mptcp_subflow_active(struct mptcp_subflow_context *subflow);
934 struct mptcp_subflow_context *subflow; in __mptcp_sync_sndbuf() local
941 mptcp_for_each_subflow(mptcp_sk(sk), subflow) { in __mptcp_sync_sndbuf()
942 ssk_sndbuf = READ_ONCE(mptcp_subflow_tcp_sock(subflow)->sk_sndbuf); in __mptcp_sync_sndbuf()
944 subflow->cached_sndbuf = ssk_sndbuf; in __mptcp_sync_sndbuf()
958 struct mptcp_subflow_context *subflow = mptcp_subflow_ctx(ssk); in __mptcp_propagate_sndbuf() local
960 if (READ_ONCE(ssk->sk_sndbuf) != subflow->cached_sndbuf) in __mptcp_propagate_sndbuf()
971 struct mptcp_subflow_context *subflow = mptcp_subflow_ctx(ssk); in mptcp_propagate_sndbuf() local
973 if (likely(READ_ONCE(ssk->sk_sndbuf) == subflow->cached_sndbuf)) in mptcp_propagate_sndbuf()
977 mptcp_subflow_delegate(subflow, MPTCP_DELEGATE_SNDBUF); in mptcp_propagate_sndbuf()
1027 const struct mptcp_subflow_context *subflow);
1034 struct mptcp_subflow_context *subflow,
1088 void mptcp_fastopen_subflow_synack_set_params(struct mptcp_subflow_context *subflow,
1171 static inline u8 subflow_get_local_id(const struct mptcp_subflow_context *subflow) in subflow_get_local_id() argument
1173 int local_id = READ_ONCE(subflow->local_id); in subflow_get_local_id()
1220 struct mptcp_subflow_context *subflow = mptcp_subflow_ctx(sk); in mptcp_check_fallback() local
1221 struct mptcp_sock *msk = mptcp_sk(subflow->conn); in mptcp_check_fallback()
1239 struct mptcp_subflow_context *subflow = mptcp_subflow_ctx(ssk); in mptcp_try_fallback() local
1240 struct sock *sk = subflow->conn; in mptcp_try_fallback()
1261 struct mptcp_subflow_context *subflow, in mptcp_early_fallback() argument
1264 subflow->request_mptcp = 0; in mptcp_early_fallback()
1279 static inline bool is_active_ssk(struct mptcp_subflow_context *subflow) in is_active_ssk() argument
1281 return (subflow->request_mptcp || subflow->request_join); in is_active_ssk()
1286 struct mptcp_subflow_context *subflow = mptcp_subflow_ctx(sk); in subflow_simultaneous_connect() local
1290 is_active_ssk(subflow) && in subflow_simultaneous_connect()
1291 !subflow->conn_finished; in subflow_simultaneous_connect()