147505b8bSThomas Gleixner // SPDX-License-Identifier: GPL-2.0-or-later
2637784adSMarcelo Ricardo Leitner /* SCTP kernel implementation
3637784adSMarcelo Ricardo Leitner * (C) Copyright Red Hat Inc. 2017
4637784adSMarcelo Ricardo Leitner *
5637784adSMarcelo Ricardo Leitner * This file is part of the SCTP kernel implementation
6637784adSMarcelo Ricardo Leitner *
7637784adSMarcelo Ricardo Leitner * These functions manipulate sctp stream queue/scheduling.
8637784adSMarcelo Ricardo Leitner *
9637784adSMarcelo Ricardo Leitner * Please send any bug reports or fixes you make to the
10637784adSMarcelo Ricardo Leitner * email addresched(es):
11637784adSMarcelo Ricardo Leitner * lksctp developers <linux-sctp@vger.kernel.org>
12637784adSMarcelo Ricardo Leitner *
13637784adSMarcelo Ricardo Leitner * Written or modified by:
14637784adSMarcelo Ricardo Leitner * Marcelo Ricardo Leitner <marcelo.leitner@gmail.com>
15637784adSMarcelo Ricardo Leitner */
16637784adSMarcelo Ricardo Leitner
17637784adSMarcelo Ricardo Leitner #include <linux/list.h>
18637784adSMarcelo Ricardo Leitner #include <net/sctp/sctp.h>
19637784adSMarcelo Ricardo Leitner #include <net/sctp/sm.h>
20637784adSMarcelo Ricardo Leitner #include <net/sctp/stream_sched.h>
21637784adSMarcelo Ricardo Leitner
22637784adSMarcelo Ricardo Leitner /* Priority handling
23637784adSMarcelo Ricardo Leitner * RFC DRAFT ndata section 3.4
24637784adSMarcelo Ricardo Leitner */
25637784adSMarcelo Ricardo Leitner
26637784adSMarcelo Ricardo Leitner static void sctp_sched_prio_unsched_all(struct sctp_stream *stream);
27637784adSMarcelo Ricardo Leitner
sctp_sched_prio_head_get(struct sctp_stream_priorities * p)28*68ba4463SXin Long static struct sctp_stream_priorities *sctp_sched_prio_head_get(struct sctp_stream_priorities *p)
29*68ba4463SXin Long {
30*68ba4463SXin Long p->users++;
31*68ba4463SXin Long return p;
32*68ba4463SXin Long }
33*68ba4463SXin Long
sctp_sched_prio_head_put(struct sctp_stream_priorities * p)34*68ba4463SXin Long static void sctp_sched_prio_head_put(struct sctp_stream_priorities *p)
35*68ba4463SXin Long {
36*68ba4463SXin Long if (p && --p->users == 0)
37*68ba4463SXin Long kfree(p);
38*68ba4463SXin Long }
39*68ba4463SXin Long
sctp_sched_prio_new_head(struct sctp_stream * stream,int prio,gfp_t gfp)40637784adSMarcelo Ricardo Leitner static struct sctp_stream_priorities *sctp_sched_prio_new_head(
41637784adSMarcelo Ricardo Leitner struct sctp_stream *stream, int prio, gfp_t gfp)
42637784adSMarcelo Ricardo Leitner {
43637784adSMarcelo Ricardo Leitner struct sctp_stream_priorities *p;
44637784adSMarcelo Ricardo Leitner
45637784adSMarcelo Ricardo Leitner p = kmalloc(sizeof(*p), gfp);
46637784adSMarcelo Ricardo Leitner if (!p)
47637784adSMarcelo Ricardo Leitner return NULL;
48637784adSMarcelo Ricardo Leitner
49637784adSMarcelo Ricardo Leitner INIT_LIST_HEAD(&p->prio_sched);
50637784adSMarcelo Ricardo Leitner INIT_LIST_HEAD(&p->active);
51637784adSMarcelo Ricardo Leitner p->next = NULL;
52637784adSMarcelo Ricardo Leitner p->prio = prio;
53*68ba4463SXin Long p->users = 1;
54637784adSMarcelo Ricardo Leitner
55637784adSMarcelo Ricardo Leitner return p;
56637784adSMarcelo Ricardo Leitner }
57637784adSMarcelo Ricardo Leitner
sctp_sched_prio_get_head(struct sctp_stream * stream,int prio,gfp_t gfp)58637784adSMarcelo Ricardo Leitner static struct sctp_stream_priorities *sctp_sched_prio_get_head(
59637784adSMarcelo Ricardo Leitner struct sctp_stream *stream, int prio, gfp_t gfp)
60637784adSMarcelo Ricardo Leitner {
61637784adSMarcelo Ricardo Leitner struct sctp_stream_priorities *p;
62637784adSMarcelo Ricardo Leitner int i;
63637784adSMarcelo Ricardo Leitner
64637784adSMarcelo Ricardo Leitner /* Look into scheduled priorities first, as they are sorted and
65637784adSMarcelo Ricardo Leitner * we can find it fast IF it's scheduled.
66637784adSMarcelo Ricardo Leitner */
67637784adSMarcelo Ricardo Leitner list_for_each_entry(p, &stream->prio_list, prio_sched) {
68637784adSMarcelo Ricardo Leitner if (p->prio == prio)
69*68ba4463SXin Long return sctp_sched_prio_head_get(p);
70637784adSMarcelo Ricardo Leitner if (p->prio > prio)
71637784adSMarcelo Ricardo Leitner break;
72637784adSMarcelo Ricardo Leitner }
73637784adSMarcelo Ricardo Leitner
74637784adSMarcelo Ricardo Leitner /* No luck. So we search on all streams now. */
75637784adSMarcelo Ricardo Leitner for (i = 0; i < stream->outcnt; i++) {
7605364ca0SKonstantin Khorenko if (!SCTP_SO(stream, i)->ext)
77637784adSMarcelo Ricardo Leitner continue;
78637784adSMarcelo Ricardo Leitner
7905364ca0SKonstantin Khorenko p = SCTP_SO(stream, i)->ext->prio_head;
80637784adSMarcelo Ricardo Leitner if (!p)
81637784adSMarcelo Ricardo Leitner /* Means all other streams won't be initialized
82637784adSMarcelo Ricardo Leitner * as well.
83637784adSMarcelo Ricardo Leitner */
84637784adSMarcelo Ricardo Leitner break;
85637784adSMarcelo Ricardo Leitner if (p->prio == prio)
86*68ba4463SXin Long return sctp_sched_prio_head_get(p);
87637784adSMarcelo Ricardo Leitner }
88637784adSMarcelo Ricardo Leitner
89637784adSMarcelo Ricardo Leitner /* If not even there, allocate a new one. */
90637784adSMarcelo Ricardo Leitner return sctp_sched_prio_new_head(stream, prio, gfp);
91637784adSMarcelo Ricardo Leitner }
92637784adSMarcelo Ricardo Leitner
sctp_sched_prio_next_stream(struct sctp_stream_priorities * p)93637784adSMarcelo Ricardo Leitner static void sctp_sched_prio_next_stream(struct sctp_stream_priorities *p)
94637784adSMarcelo Ricardo Leitner {
95637784adSMarcelo Ricardo Leitner struct list_head *pos;
96637784adSMarcelo Ricardo Leitner
97637784adSMarcelo Ricardo Leitner pos = p->next->prio_list.next;
98637784adSMarcelo Ricardo Leitner if (pos == &p->active)
99637784adSMarcelo Ricardo Leitner pos = pos->next;
100637784adSMarcelo Ricardo Leitner p->next = list_entry(pos, struct sctp_stream_out_ext, prio_list);
101637784adSMarcelo Ricardo Leitner }
102637784adSMarcelo Ricardo Leitner
sctp_sched_prio_unsched(struct sctp_stream_out_ext * soute)103637784adSMarcelo Ricardo Leitner static bool sctp_sched_prio_unsched(struct sctp_stream_out_ext *soute)
104637784adSMarcelo Ricardo Leitner {
105637784adSMarcelo Ricardo Leitner bool scheduled = false;
106637784adSMarcelo Ricardo Leitner
107637784adSMarcelo Ricardo Leitner if (!list_empty(&soute->prio_list)) {
108637784adSMarcelo Ricardo Leitner struct sctp_stream_priorities *prio_head = soute->prio_head;
109637784adSMarcelo Ricardo Leitner
110637784adSMarcelo Ricardo Leitner /* Scheduled */
111637784adSMarcelo Ricardo Leitner scheduled = true;
112637784adSMarcelo Ricardo Leitner
113637784adSMarcelo Ricardo Leitner if (prio_head->next == soute)
114637784adSMarcelo Ricardo Leitner /* Try to move to the next stream */
115637784adSMarcelo Ricardo Leitner sctp_sched_prio_next_stream(prio_head);
116637784adSMarcelo Ricardo Leitner
117637784adSMarcelo Ricardo Leitner list_del_init(&soute->prio_list);
118637784adSMarcelo Ricardo Leitner
119637784adSMarcelo Ricardo Leitner /* Also unsched the priority if this was the last stream */
120637784adSMarcelo Ricardo Leitner if (list_empty(&prio_head->active)) {
121637784adSMarcelo Ricardo Leitner list_del_init(&prio_head->prio_sched);
122637784adSMarcelo Ricardo Leitner /* If there is no stream left, clear next */
123637784adSMarcelo Ricardo Leitner prio_head->next = NULL;
124637784adSMarcelo Ricardo Leitner }
125637784adSMarcelo Ricardo Leitner }
126637784adSMarcelo Ricardo Leitner
127637784adSMarcelo Ricardo Leitner return scheduled;
128637784adSMarcelo Ricardo Leitner }
129637784adSMarcelo Ricardo Leitner
sctp_sched_prio_sched(struct sctp_stream * stream,struct sctp_stream_out_ext * soute)130637784adSMarcelo Ricardo Leitner static void sctp_sched_prio_sched(struct sctp_stream *stream,
131637784adSMarcelo Ricardo Leitner struct sctp_stream_out_ext *soute)
132637784adSMarcelo Ricardo Leitner {
133637784adSMarcelo Ricardo Leitner struct sctp_stream_priorities *prio, *prio_head;
134637784adSMarcelo Ricardo Leitner
135637784adSMarcelo Ricardo Leitner prio_head = soute->prio_head;
136637784adSMarcelo Ricardo Leitner
137637784adSMarcelo Ricardo Leitner /* Nothing to do if already scheduled */
138637784adSMarcelo Ricardo Leitner if (!list_empty(&soute->prio_list))
139637784adSMarcelo Ricardo Leitner return;
140637784adSMarcelo Ricardo Leitner
141637784adSMarcelo Ricardo Leitner /* Schedule the stream. If there is a next, we schedule the new
142637784adSMarcelo Ricardo Leitner * one before it, so it's the last in round robin order.
143637784adSMarcelo Ricardo Leitner * If there isn't, we also have to schedule the priority.
144637784adSMarcelo Ricardo Leitner */
145637784adSMarcelo Ricardo Leitner if (prio_head->next) {
146637784adSMarcelo Ricardo Leitner list_add(&soute->prio_list, prio_head->next->prio_list.prev);
147637784adSMarcelo Ricardo Leitner return;
148637784adSMarcelo Ricardo Leitner }
149637784adSMarcelo Ricardo Leitner
150637784adSMarcelo Ricardo Leitner list_add(&soute->prio_list, &prio_head->active);
151637784adSMarcelo Ricardo Leitner prio_head->next = soute;
152637784adSMarcelo Ricardo Leitner
153637784adSMarcelo Ricardo Leitner list_for_each_entry(prio, &stream->prio_list, prio_sched) {
154637784adSMarcelo Ricardo Leitner if (prio->prio > prio_head->prio) {
155637784adSMarcelo Ricardo Leitner list_add(&prio_head->prio_sched, prio->prio_sched.prev);
156637784adSMarcelo Ricardo Leitner return;
157637784adSMarcelo Ricardo Leitner }
158637784adSMarcelo Ricardo Leitner }
159637784adSMarcelo Ricardo Leitner
160637784adSMarcelo Ricardo Leitner list_add_tail(&prio_head->prio_sched, &stream->prio_list);
161637784adSMarcelo Ricardo Leitner }
162637784adSMarcelo Ricardo Leitner
sctp_sched_prio_set(struct sctp_stream * stream,__u16 sid,__u16 prio,gfp_t gfp)163637784adSMarcelo Ricardo Leitner static int sctp_sched_prio_set(struct sctp_stream *stream, __u16 sid,
164637784adSMarcelo Ricardo Leitner __u16 prio, gfp_t gfp)
165637784adSMarcelo Ricardo Leitner {
16605364ca0SKonstantin Khorenko struct sctp_stream_out *sout = SCTP_SO(stream, sid);
167637784adSMarcelo Ricardo Leitner struct sctp_stream_out_ext *soute = sout->ext;
168637784adSMarcelo Ricardo Leitner struct sctp_stream_priorities *prio_head, *old;
169637784adSMarcelo Ricardo Leitner bool reschedule = false;
170*68ba4463SXin Long
171*68ba4463SXin Long old = soute->prio_head;
172*68ba4463SXin Long if (old && old->prio == prio)
173*68ba4463SXin Long return 0;
174637784adSMarcelo Ricardo Leitner
175637784adSMarcelo Ricardo Leitner prio_head = sctp_sched_prio_get_head(stream, prio, gfp);
176637784adSMarcelo Ricardo Leitner if (!prio_head)
177637784adSMarcelo Ricardo Leitner return -ENOMEM;
178637784adSMarcelo Ricardo Leitner
179637784adSMarcelo Ricardo Leitner reschedule = sctp_sched_prio_unsched(soute);
180637784adSMarcelo Ricardo Leitner soute->prio_head = prio_head;
181637784adSMarcelo Ricardo Leitner if (reschedule)
182637784adSMarcelo Ricardo Leitner sctp_sched_prio_sched(stream, soute);
183637784adSMarcelo Ricardo Leitner
184*68ba4463SXin Long sctp_sched_prio_head_put(old);
185637784adSMarcelo Ricardo Leitner return 0;
186637784adSMarcelo Ricardo Leitner }
187637784adSMarcelo Ricardo Leitner
sctp_sched_prio_get(struct sctp_stream * stream,__u16 sid,__u16 * value)188637784adSMarcelo Ricardo Leitner static int sctp_sched_prio_get(struct sctp_stream *stream, __u16 sid,
189637784adSMarcelo Ricardo Leitner __u16 *value)
190637784adSMarcelo Ricardo Leitner {
19105364ca0SKonstantin Khorenko *value = SCTP_SO(stream, sid)->ext->prio_head->prio;
192637784adSMarcelo Ricardo Leitner return 0;
193637784adSMarcelo Ricardo Leitner }
194637784adSMarcelo Ricardo Leitner
sctp_sched_prio_init(struct sctp_stream * stream)195637784adSMarcelo Ricardo Leitner static int sctp_sched_prio_init(struct sctp_stream *stream)
196637784adSMarcelo Ricardo Leitner {
197637784adSMarcelo Ricardo Leitner INIT_LIST_HEAD(&stream->prio_list);
198637784adSMarcelo Ricardo Leitner
199637784adSMarcelo Ricardo Leitner return 0;
200637784adSMarcelo Ricardo Leitner }
201637784adSMarcelo Ricardo Leitner
sctp_sched_prio_init_sid(struct sctp_stream * stream,__u16 sid,gfp_t gfp)202637784adSMarcelo Ricardo Leitner static int sctp_sched_prio_init_sid(struct sctp_stream *stream, __u16 sid,
203637784adSMarcelo Ricardo Leitner gfp_t gfp)
204637784adSMarcelo Ricardo Leitner {
20505364ca0SKonstantin Khorenko INIT_LIST_HEAD(&SCTP_SO(stream, sid)->ext->prio_list);
206637784adSMarcelo Ricardo Leitner return sctp_sched_prio_set(stream, sid, 0, gfp);
207637784adSMarcelo Ricardo Leitner }
208637784adSMarcelo Ricardo Leitner
sctp_sched_prio_free_sid(struct sctp_stream * stream,__u16 sid)2099ed7bfc7SZhengchao Shao static void sctp_sched_prio_free_sid(struct sctp_stream *stream, __u16 sid)
2109ed7bfc7SZhengchao Shao {
211*68ba4463SXin Long sctp_sched_prio_head_put(SCTP_SO(stream, sid)->ext->prio_head);
2129ed7bfc7SZhengchao Shao SCTP_SO(stream, sid)->ext->prio_head = NULL;
2139ed7bfc7SZhengchao Shao }
2149ed7bfc7SZhengchao Shao
sctp_sched_prio_enqueue(struct sctp_outq * q,struct sctp_datamsg * msg)215637784adSMarcelo Ricardo Leitner static void sctp_sched_prio_enqueue(struct sctp_outq *q,
216637784adSMarcelo Ricardo Leitner struct sctp_datamsg *msg)
217637784adSMarcelo Ricardo Leitner {
218637784adSMarcelo Ricardo Leitner struct sctp_stream *stream;
219637784adSMarcelo Ricardo Leitner struct sctp_chunk *ch;
220637784adSMarcelo Ricardo Leitner __u16 sid;
221637784adSMarcelo Ricardo Leitner
222637784adSMarcelo Ricardo Leitner ch = list_first_entry(&msg->chunks, struct sctp_chunk, frag_list);
223637784adSMarcelo Ricardo Leitner sid = sctp_chunk_stream_no(ch);
224637784adSMarcelo Ricardo Leitner stream = &q->asoc->stream;
22505364ca0SKonstantin Khorenko sctp_sched_prio_sched(stream, SCTP_SO(stream, sid)->ext);
226637784adSMarcelo Ricardo Leitner }
227637784adSMarcelo Ricardo Leitner
sctp_sched_prio_dequeue(struct sctp_outq * q)228637784adSMarcelo Ricardo Leitner static struct sctp_chunk *sctp_sched_prio_dequeue(struct sctp_outq *q)
229637784adSMarcelo Ricardo Leitner {
230637784adSMarcelo Ricardo Leitner struct sctp_stream *stream = &q->asoc->stream;
231637784adSMarcelo Ricardo Leitner struct sctp_stream_priorities *prio;
232637784adSMarcelo Ricardo Leitner struct sctp_stream_out_ext *soute;
233637784adSMarcelo Ricardo Leitner struct sctp_chunk *ch = NULL;
234637784adSMarcelo Ricardo Leitner
235637784adSMarcelo Ricardo Leitner /* Bail out quickly if queue is empty */
236637784adSMarcelo Ricardo Leitner if (list_empty(&q->out_chunk_list))
237637784adSMarcelo Ricardo Leitner goto out;
238637784adSMarcelo Ricardo Leitner
239637784adSMarcelo Ricardo Leitner /* Find which chunk is next. It's easy, it's either the current
240637784adSMarcelo Ricardo Leitner * one or the first chunk on the next active stream.
241637784adSMarcelo Ricardo Leitner */
242637784adSMarcelo Ricardo Leitner if (stream->out_curr) {
243637784adSMarcelo Ricardo Leitner soute = stream->out_curr->ext;
244637784adSMarcelo Ricardo Leitner } else {
245637784adSMarcelo Ricardo Leitner prio = list_entry(stream->prio_list.next,
246637784adSMarcelo Ricardo Leitner struct sctp_stream_priorities, prio_sched);
247637784adSMarcelo Ricardo Leitner soute = prio->next;
248637784adSMarcelo Ricardo Leitner }
249637784adSMarcelo Ricardo Leitner ch = list_entry(soute->outq.next, struct sctp_chunk, stream_list);
250637784adSMarcelo Ricardo Leitner sctp_sched_dequeue_common(q, ch);
251637784adSMarcelo Ricardo Leitner
252637784adSMarcelo Ricardo Leitner out:
253637784adSMarcelo Ricardo Leitner return ch;
254637784adSMarcelo Ricardo Leitner }
255637784adSMarcelo Ricardo Leitner
sctp_sched_prio_dequeue_done(struct sctp_outq * q,struct sctp_chunk * ch)256637784adSMarcelo Ricardo Leitner static void sctp_sched_prio_dequeue_done(struct sctp_outq *q,
257637784adSMarcelo Ricardo Leitner struct sctp_chunk *ch)
258637784adSMarcelo Ricardo Leitner {
259637784adSMarcelo Ricardo Leitner struct sctp_stream_priorities *prio;
260637784adSMarcelo Ricardo Leitner struct sctp_stream_out_ext *soute;
261637784adSMarcelo Ricardo Leitner __u16 sid;
262637784adSMarcelo Ricardo Leitner
263637784adSMarcelo Ricardo Leitner /* Last chunk on that msg, move to the next stream on
264637784adSMarcelo Ricardo Leitner * this priority.
265637784adSMarcelo Ricardo Leitner */
266637784adSMarcelo Ricardo Leitner sid = sctp_chunk_stream_no(ch);
26705364ca0SKonstantin Khorenko soute = SCTP_SO(&q->asoc->stream, sid)->ext;
268637784adSMarcelo Ricardo Leitner prio = soute->prio_head;
269637784adSMarcelo Ricardo Leitner
270637784adSMarcelo Ricardo Leitner sctp_sched_prio_next_stream(prio);
271637784adSMarcelo Ricardo Leitner
272637784adSMarcelo Ricardo Leitner if (list_empty(&soute->outq))
273637784adSMarcelo Ricardo Leitner sctp_sched_prio_unsched(soute);
274637784adSMarcelo Ricardo Leitner }
275637784adSMarcelo Ricardo Leitner
sctp_sched_prio_sched_all(struct sctp_stream * stream)276637784adSMarcelo Ricardo Leitner static void sctp_sched_prio_sched_all(struct sctp_stream *stream)
277637784adSMarcelo Ricardo Leitner {
278637784adSMarcelo Ricardo Leitner struct sctp_association *asoc;
279637784adSMarcelo Ricardo Leitner struct sctp_stream_out *sout;
280637784adSMarcelo Ricardo Leitner struct sctp_chunk *ch;
281637784adSMarcelo Ricardo Leitner
282637784adSMarcelo Ricardo Leitner asoc = container_of(stream, struct sctp_association, stream);
283637784adSMarcelo Ricardo Leitner list_for_each_entry(ch, &asoc->outqueue.out_chunk_list, list) {
284637784adSMarcelo Ricardo Leitner __u16 sid;
285637784adSMarcelo Ricardo Leitner
286637784adSMarcelo Ricardo Leitner sid = sctp_chunk_stream_no(ch);
28705364ca0SKonstantin Khorenko sout = SCTP_SO(stream, sid);
288637784adSMarcelo Ricardo Leitner if (sout->ext)
289637784adSMarcelo Ricardo Leitner sctp_sched_prio_sched(stream, sout->ext);
290637784adSMarcelo Ricardo Leitner }
291637784adSMarcelo Ricardo Leitner }
292637784adSMarcelo Ricardo Leitner
sctp_sched_prio_unsched_all(struct sctp_stream * stream)293637784adSMarcelo Ricardo Leitner static void sctp_sched_prio_unsched_all(struct sctp_stream *stream)
294637784adSMarcelo Ricardo Leitner {
295637784adSMarcelo Ricardo Leitner struct sctp_stream_priorities *p, *tmp;
296637784adSMarcelo Ricardo Leitner struct sctp_stream_out_ext *soute, *souttmp;
297637784adSMarcelo Ricardo Leitner
298637784adSMarcelo Ricardo Leitner list_for_each_entry_safe(p, tmp, &stream->prio_list, prio_sched)
299637784adSMarcelo Ricardo Leitner list_for_each_entry_safe(soute, souttmp, &p->active, prio_list)
300637784adSMarcelo Ricardo Leitner sctp_sched_prio_unsched(soute);
301637784adSMarcelo Ricardo Leitner }
302637784adSMarcelo Ricardo Leitner
3031ba896f6SXin Long static struct sctp_sched_ops sctp_sched_prio = {
304637784adSMarcelo Ricardo Leitner .set = sctp_sched_prio_set,
305637784adSMarcelo Ricardo Leitner .get = sctp_sched_prio_get,
306637784adSMarcelo Ricardo Leitner .init = sctp_sched_prio_init,
307637784adSMarcelo Ricardo Leitner .init_sid = sctp_sched_prio_init_sid,
3089ed7bfc7SZhengchao Shao .free_sid = sctp_sched_prio_free_sid,
309637784adSMarcelo Ricardo Leitner .enqueue = sctp_sched_prio_enqueue,
310637784adSMarcelo Ricardo Leitner .dequeue = sctp_sched_prio_dequeue,
311637784adSMarcelo Ricardo Leitner .dequeue_done = sctp_sched_prio_dequeue_done,
312637784adSMarcelo Ricardo Leitner .sched_all = sctp_sched_prio_sched_all,
313637784adSMarcelo Ricardo Leitner .unsched_all = sctp_sched_prio_unsched_all,
314637784adSMarcelo Ricardo Leitner };
3151ba896f6SXin Long
sctp_sched_ops_prio_init(void)3161ba896f6SXin Long void sctp_sched_ops_prio_init(void)
3171ba896f6SXin Long {
3181ba896f6SXin Long sctp_sched_ops_register(SCTP_SS_PRIO, &sctp_sched_prio);
3191ba896f6SXin Long }
320