Lines Matching refs:msk
19 static int mptcp_sched_default_get_subflow(struct mptcp_sock *msk, in mptcp_sched_default_get_subflow() argument
24 ssk = data->reinject ? mptcp_subflow_get_retrans(msk) : in mptcp_sched_default_get_subflow()
25 mptcp_subflow_get_send(msk); in mptcp_sched_default_get_subflow()
86 int mptcp_init_sched(struct mptcp_sock *msk, in mptcp_init_sched() argument
95 msk->sched = sched; in mptcp_init_sched()
96 if (msk->sched->init) in mptcp_init_sched()
97 msk->sched->init(msk); in mptcp_init_sched()
99 pr_debug("sched=%s", msk->sched->name); in mptcp_init_sched()
104 void mptcp_release_sched(struct mptcp_sock *msk) in mptcp_release_sched() argument
106 struct mptcp_sched_ops *sched = msk->sched; in mptcp_release_sched()
111 msk->sched = NULL; in mptcp_release_sched()
113 sched->release(msk); in mptcp_release_sched()
124 int mptcp_sched_get_send(struct mptcp_sock *msk) in mptcp_sched_get_send() argument
129 msk_owned_by_me(msk); in mptcp_sched_get_send()
132 if (__mptcp_check_fallback(msk)) { in mptcp_sched_get_send()
133 if (msk->first && in mptcp_sched_get_send()
134 __tcp_can_send(msk->first) && in mptcp_sched_get_send()
135 sk_stream_memory_free(msk->first)) { in mptcp_sched_get_send()
136 mptcp_subflow_set_scheduled(mptcp_subflow_ctx(msk->first), true); in mptcp_sched_get_send()
142 mptcp_for_each_subflow(msk, subflow) { in mptcp_sched_get_send()
148 if (msk->sched == &mptcp_sched_default || !msk->sched) in mptcp_sched_get_send()
149 return mptcp_sched_default_get_subflow(msk, &data); in mptcp_sched_get_send()
150 return msk->sched->get_subflow(msk, &data); in mptcp_sched_get_send()
153 int mptcp_sched_get_retrans(struct mptcp_sock *msk) in mptcp_sched_get_retrans() argument
158 msk_owned_by_me(msk); in mptcp_sched_get_retrans()
161 if (__mptcp_check_fallback(msk)) in mptcp_sched_get_retrans()
164 mptcp_for_each_subflow(msk, subflow) { in mptcp_sched_get_retrans()
170 if (msk->sched == &mptcp_sched_default || !msk->sched) in mptcp_sched_get_retrans()
171 return mptcp_sched_default_get_subflow(msk, &data); in mptcp_sched_get_retrans()
172 return msk->sched->get_subflow(msk, &data); in mptcp_sched_get_retrans()