Lines Matching refs:stream
40 static int sctp_sched_fcfs_set(struct sctp_stream *stream, __u16 sid, in sctp_sched_fcfs_set() argument
46 static int sctp_sched_fcfs_get(struct sctp_stream *stream, __u16 sid, in sctp_sched_fcfs_get() argument
53 static int sctp_sched_fcfs_init(struct sctp_stream *stream) in sctp_sched_fcfs_init() argument
58 static int sctp_sched_fcfs_init_sid(struct sctp_stream *stream, __u16 sid, in sctp_sched_fcfs_init_sid() argument
64 static void sctp_sched_fcfs_free(struct sctp_stream *stream) in sctp_sched_fcfs_free() argument
75 struct sctp_stream *stream = &q->asoc->stream; in sctp_sched_fcfs_dequeue() local
82 if (stream->out_curr) { in sctp_sched_fcfs_dequeue()
83 ch = list_entry(stream->out_curr->ext->outq.next, in sctp_sched_fcfs_dequeue()
101 static void sctp_sched_fcfs_sched_all(struct sctp_stream *stream) in sctp_sched_fcfs_sched_all() argument
105 static void sctp_sched_fcfs_unsched_all(struct sctp_stream *stream) in sctp_sched_fcfs_unsched_all() argument
160 old->free(&asoc->stream); in sctp_sched_set_sched()
163 for (i = 0; i < asoc->stream.outcnt; i++) { in sctp_sched_set_sched()
164 void *p = SCTP_SO(&asoc->stream, i)->ext; in sctp_sched_set_sched()
176 n->init(&asoc->stream); in sctp_sched_set_sched()
177 for (i = 0; i < asoc->stream.outcnt; i++) { in sctp_sched_set_sched()
178 if (!SCTP_SO(&asoc->stream, i)->ext) in sctp_sched_set_sched()
181 ret = n->init_sid(&asoc->stream, i, GFP_KERNEL); in sctp_sched_set_sched()
197 n->free(&asoc->stream); in sctp_sched_set_sched()
217 if (sid >= asoc->stream.outcnt) in sctp_sched_set_value()
220 if (!SCTP_SO(&asoc->stream, sid)->ext) { in sctp_sched_set_value()
223 ret = sctp_stream_init_ext(&asoc->stream, sid); in sctp_sched_set_value()
228 return asoc->outqueue.sched->set(&asoc->stream, sid, value, gfp); in sctp_sched_set_value()
234 if (sid >= asoc->stream.outcnt) in sctp_sched_get_value()
237 if (!SCTP_SO(&asoc->stream, sid)->ext) in sctp_sched_get_value()
240 return asoc->outqueue.sched->get(&asoc->stream, sid, value); in sctp_sched_get_value()
255 sout = SCTP_SO(&q->asoc->stream, sid); in sctp_sched_dequeue_done()
256 q->asoc->stream.out_curr = sout; in sctp_sched_dequeue_done()
260 q->asoc->stream.out_curr = NULL; in sctp_sched_dequeue_done()
272 int sctp_sched_init_sid(struct sctp_stream *stream, __u16 sid, gfp_t gfp) in sctp_sched_init_sid() argument
274 struct sctp_sched_ops *sched = sctp_sched_ops_from_stream(stream); in sctp_sched_init_sid()
275 struct sctp_stream_out_ext *ext = SCTP_SO(stream, sid)->ext; in sctp_sched_init_sid()
278 return sched->init_sid(stream, sid, gfp); in sctp_sched_init_sid()
281 struct sctp_sched_ops *sctp_sched_ops_from_stream(struct sctp_stream *stream) in sctp_sched_ops_from_stream() argument
285 asoc = container_of(stream, struct sctp_association, stream); in sctp_sched_ops_from_stream()