Lines Matching refs:stream

25 static void sctp_sched_fc_unsched_all(struct sctp_stream *stream);
27 static int sctp_sched_wfq_set(struct sctp_stream *stream, __u16 sid, in sctp_sched_wfq_set() argument
30 struct sctp_stream_out_ext *soute = SCTP_SO(stream, sid)->ext; in sctp_sched_wfq_set()
39 static int sctp_sched_wfq_get(struct sctp_stream *stream, __u16 sid, in sctp_sched_wfq_get() argument
42 struct sctp_stream_out_ext *soute = SCTP_SO(stream, sid)->ext; in sctp_sched_wfq_get()
48 static int sctp_sched_fc_set(struct sctp_stream *stream, __u16 sid, in sctp_sched_fc_set() argument
54 static int sctp_sched_fc_get(struct sctp_stream *stream, __u16 sid, in sctp_sched_fc_get() argument
60 static int sctp_sched_fc_init(struct sctp_stream *stream) in sctp_sched_fc_init() argument
62 INIT_LIST_HEAD(&stream->fc_list); in sctp_sched_fc_init()
67 static int sctp_sched_fc_init_sid(struct sctp_stream *stream, __u16 sid, in sctp_sched_fc_init_sid() argument
70 struct sctp_stream_out_ext *soute = SCTP_SO(stream, sid)->ext; in sctp_sched_fc_init_sid()
79 static void sctp_sched_fc_free_sid(struct sctp_stream *stream, __u16 sid) in sctp_sched_fc_free_sid() argument
83 static void sctp_sched_fc_sched(struct sctp_stream *stream, in sctp_sched_fc_sched() argument
91 list_for_each_entry(pos, &stream->fc_list, fc_list) in sctp_sched_fc_sched()
101 struct sctp_stream *stream; in sctp_sched_fc_enqueue() local
107 stream = &q->asoc->stream; in sctp_sched_fc_enqueue()
108 sctp_sched_fc_sched(stream, SCTP_SO(stream, sid)->ext); in sctp_sched_fc_enqueue()
113 struct sctp_stream *stream = &q->asoc->stream; in sctp_sched_fc_dequeue() local
122 if (stream->out_curr) in sctp_sched_fc_dequeue()
123 soute = stream->out_curr->ext; in sctp_sched_fc_dequeue()
125 soute = list_entry(stream->fc_list.next, struct sctp_stream_out_ext, fc_list); in sctp_sched_fc_dequeue()
135 struct sctp_stream *stream = &q->asoc->stream; in sctp_sched_fc_dequeue_done() local
140 soute = SCTP_SO(stream, sid)->ext; in sctp_sched_fc_dequeue_done()
143 for (i = 0; i < stream->outcnt; i++) { in sctp_sched_fc_dequeue_done()
144 pos = SCTP_SO(stream, i)->ext; in sctp_sched_fc_dequeue_done()
162 list_for_each_entry_continue(pos, &stream->fc_list, fc_list) in sctp_sched_fc_dequeue_done()
169 static void sctp_sched_fc_sched_all(struct sctp_stream *stream) in sctp_sched_fc_sched_all() argument
174 asoc = container_of(stream, struct sctp_association, stream); in sctp_sched_fc_sched_all()
178 if (SCTP_SO(stream, sid)->ext) in sctp_sched_fc_sched_all()
179 sctp_sched_fc_sched(stream, SCTP_SO(stream, sid)->ext); in sctp_sched_fc_sched_all()
183 static void sctp_sched_fc_unsched_all(struct sctp_stream *stream) in sctp_sched_fc_unsched_all() argument
187 list_for_each_entry_safe(soute, tmp, &stream->fc_list, fc_list) in sctp_sched_fc_unsched_all()