Lines Matching refs:ssk
661 void mptcp_subflow_process_delegated(struct sock *ssk, long actions);
720 bool mptcp_active_should_disable(struct sock *ssk);
732 void mptcp_subflow_shutdown(struct sock *sk, struct sock *ssk, int how);
733 void mptcp_close_ssk(struct sock *sk, struct sock *ssk,
735 void __mptcp_subflow_send_ack(struct sock *ssk);
736 void mptcp_subflow_reset(struct sock *ssk);
737 void mptcp_subflow_queue_clean(struct sock *sk, struct sock *ssk);
798 static inline bool __tcp_can_send(const struct sock *ssk) in __tcp_can_send() argument
801 return ((1 << inet_sk_state_load(ssk)) & (TCPF_ESTABLISHED | TCPF_CLOSE_WAIT)); in __tcp_can_send()
817 void mptcp_subflow_drop_ctx(struct sock *ssk);
837 struct sock *ssk,
873 void mptcp_rcv_space_init(struct mptcp_sock *msk, const struct sock *ssk);
874 void mptcp_data_ready(struct sock *sk, struct sock *ssk);
890 void __mptcp_check_push(struct sock *sk, struct sock *ssk);
956 static inline void __mptcp_propagate_sndbuf(struct sock *sk, struct sock *ssk) in __mptcp_propagate_sndbuf() argument
958 struct mptcp_subflow_context *subflow = mptcp_subflow_ctx(ssk); in __mptcp_propagate_sndbuf()
960 if (READ_ONCE(ssk->sk_sndbuf) != subflow->cached_sndbuf) in __mptcp_propagate_sndbuf()
969 static inline void mptcp_propagate_sndbuf(struct sock *sk, struct sock *ssk) in mptcp_propagate_sndbuf() argument
971 struct mptcp_subflow_context *subflow = mptcp_subflow_ctx(ssk); in mptcp_propagate_sndbuf()
973 if (likely(READ_ONCE(ssk->sk_sndbuf) == subflow->cached_sndbuf)) in mptcp_propagate_sndbuf()
993 int mptcp_token_new_connect(struct sock *ssk);
1019 void mptcp_pm_subflow_chk_stale(const struct mptcp_sock *msk, struct sock *ssk);
1020 void mptcp_pm_new_connection(struct mptcp_sock *msk, const struct sock *ssk, int server_side);
1021 void mptcp_pm_fully_established(struct mptcp_sock *msk, const struct sock *ssk);
1028 void mptcp_pm_add_addr_received(const struct sock *ssk,
1081 const struct sock *ssk, gfp_t gfp);
1082 void mptcp_event_addr_announced(const struct sock *ssk, const struct mptcp_addr_info *info);
1084 void mptcp_event_pm_listener(const struct sock *ssk,
1204 void mptcp_sockopt_sync_locked(struct mptcp_sock *msk, struct sock *ssk);
1228 struct sock *ssk = READ_ONCE(msk->first); in __mptcp_has_initial_subflow() local
1230 return ssk && ((1 << inet_sk_state_load(ssk)) & in __mptcp_has_initial_subflow()
1237 static inline bool mptcp_try_fallback(struct sock *ssk, int fb_mib) in mptcp_try_fallback() argument
1239 struct mptcp_subflow_context *subflow = mptcp_subflow_ctx(ssk); in mptcp_try_fallback()
1246 if (READ_ONCE(msk->snd_data_fin_enable) && !(ssk->sk_shutdown & SEND_SHUTDOWN)) { in mptcp_try_fallback()
1247 gfp_t saved_allocation = ssk->sk_allocation; in mptcp_try_fallback()
1252 ssk->sk_allocation = GFP_ATOMIC; in mptcp_try_fallback()
1253 ssk->sk_shutdown |= SEND_SHUTDOWN; in mptcp_try_fallback()
1254 tcp_shutdown(ssk, SEND_SHUTDOWN); in mptcp_try_fallback()
1255 ssk->sk_allocation = saved_allocation; in mptcp_try_fallback()