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