Lines Matching defs:msk
19 static int mptcp_sched_default_get_send(struct mptcp_sock *msk)
23 ssk = mptcp_subflow_get_send(msk);
31 static int mptcp_sched_default_get_retrans(struct mptcp_sock *msk)
35 ssk = mptcp_subflow_get_retrans(msk);
130 int mptcp_init_sched(struct mptcp_sock *msk,
139 msk->sched = sched;
140 if (msk->sched->init)
141 msk->sched->init(msk);
143 pr_debug("sched=%s\n", msk->sched->name);
148 void mptcp_release_sched(struct mptcp_sock *msk)
150 struct mptcp_sched_ops *sched = msk->sched;
155 msk->sched = NULL;
157 sched->release(msk);
168 int mptcp_sched_get_send(struct mptcp_sock *msk)
172 msk_owned_by_me(msk);
175 if (__mptcp_check_fallback(msk)) {
176 if (msk->first &&
177 __tcp_can_send(msk->first) &&
178 sk_stream_memory_free(msk->first)) {
179 mptcp_subflow_set_scheduled(mptcp_subflow_ctx(msk->first), true);
185 mptcp_for_each_subflow(msk, subflow) {
190 if (msk->sched == &mptcp_sched_default || !msk->sched)
191 return mptcp_sched_default_get_send(msk);
192 return msk->sched->get_send(msk);
195 int mptcp_sched_get_retrans(struct mptcp_sock *msk)
199 msk_owned_by_me(msk);
202 if (__mptcp_check_fallback(msk))
205 mptcp_for_each_subflow(msk, subflow) {
210 if (msk->sched == &mptcp_sched_default || !msk->sched)
211 return mptcp_sched_default_get_retrans(msk);
212 if (msk->sched->get_retrans)
213 return msk->sched->get_retrans(msk);
214 return msk->sched->get_send(msk);