Lines Matching defs:stream
7 * These functions implement sctp stream message interleaving, mostly
33 dp.stream = htons(sinfo->sinfo_stream);
50 struct sctp_stream *stream;
59 stream = &chunk->asoc->stream;
76 sctp_mid_uo_next(stream, out, sid) :
77 sctp_mid_uo_peek(stream, out, sid);
80 sctp_mid_next(stream, out, sid) :
81 sctp_mid_peek(stream, out, sid);
89 struct sctp_stream *stream;
98 stream = &chunk->asoc->stream;
102 return !SSN_lt(ssn, sctp_ssn_peek(stream, in, sid));
107 struct sctp_stream *stream;
117 stream = &chunk->asoc->stream;
121 return !MID_lt(mid, sctp_mid_peek(stream, in, sid));
138 if (event->stream == cevent->stream &&
147 if ((event->stream == cevent->stream &&
149 event->stream > cevent->stream) {
158 if (event->stream < cevent->stream ||
159 (event->stream == cevent->stream &&
164 if (event->stream == cevent->stream &&
192 sin = sctp_stream_in(&ulpq->asoc->stream, event->stream);
197 if (cevent->stream < event->stream)
200 if (cevent->stream > event->stream ||
272 sin = sctp_stream_in(&ulpq->asoc->stream, event->stream);
277 if (cevent->stream < event->stream)
279 if (cevent->stream > event->stream)
361 sin = sctp_stream_in(&ulpq->asoc->stream, event->stream);
385 if (event->stream == cevent->stream &&
391 if (event->stream > cevent->stream) {
400 if (cevent->stream > event->stream) {
404 if (cevent->stream == event->stream &&
421 struct sctp_stream *stream;
423 __u16 sid = event->stream;
425 stream = &ulpq->asoc->stream;
431 if (cevent->stream > sid)
434 if (cevent->stream < sid)
437 if (cevent->mid != sctp_mid_peek(stream, in, sid))
440 sctp_mid_next(stream, in, sid);
451 struct sctp_stream *stream;
454 stream = &ulpq->asoc->stream;
455 sid = event->stream;
457 if (event->mid != sctp_mid_peek(stream, in, sid)) {
462 sctp_mid_next(stream, in, sid);
523 if (event->stream == cevent->stream &&
532 if ((event->stream == cevent->stream &&
534 event->stream > cevent->stream) {
542 if (event->stream < cevent->stream ||
543 (event->stream == cevent->stream &&
547 if (event->stream == cevent->stream &&
570 sin = sctp_stream_in(&ulpq->asoc->stream, event->stream);
575 if (cevent->stream < event->stream)
577 if (cevent->stream > event->stream)
654 sin = sctp_stream_in(&ulpq->asoc->stream, event->stream);
659 if (cevent->stream < event->stream)
661 if (cevent->stream > event->stream)
744 sin = sctp_stream_in(&ulpq->asoc->stream, event->stream);
768 csin = sctp_stream_in(&ulpq->asoc->stream, cevent->stream);
780 sid = cevent->stream;
786 if (cevent->stream == sid &&
874 csin = sctp_stream_in(&ulpq->asoc->stream, cevent->stream);
887 sid = cevent->stream;
893 if (cevent->stream == sid &&
1004 struct sctp_stream *stream = &ulpq->asoc->stream;
1015 csid = cevent->stream;
1024 if (!MID_lt(cmid, sctp_mid_peek(stream, in, csid)))
1036 csid = cevent->stream;
1039 if (csid == sid && cmid == sctp_mid_peek(stream, in, csid)) {
1040 sctp_mid_next(stream, in, csid);
1055 struct sctp_stream *stream = &ulpq->asoc->stream;
1058 for (sid = 0; sid < stream->incnt; sid++) {
1059 struct sctp_stream_in *sin = SCTP_SI(stream, sid);
1074 sctp_mid_skip(stream, in, sid, mid);
1085 int nskips, __be16 stream, __u8 flags)
1090 if (skiplist[i].stream == stream &&
1122 __be16 sid = chunk->subh.idata_hdr->stream;
1132 ftsn_skip_arr[skip_pos].stream = sid;
1172 incnt = chunk->asoc->stream.incnt;
1174 if (ntohs(skip->stream) >= incnt)
1188 incnt = chunk->asoc->stream.incnt;
1190 if (ntohs(skip->stream) >= incnt)
1248 sctp_ulpq_skip(ulpq, ntohs(skip->stream), ntohs(skip->ssn));
1254 struct sctp_stream_in *sin = sctp_stream_in(&ulpq->asoc->stream, sid);
1255 struct sctp_stream *stream = &ulpq->asoc->stream;
1266 if (MID_lt(mid, sctp_mid_peek(stream, in, sid)))
1274 sctp_mid_skip(stream, in, sid, mid);
1283 /* Walk through all the skipped MIDs and abort stream pd if possible */
1285 sctp_intl_skip(ulpq, ntohs(skip->stream),
1346 void sctp_stream_interleave_init(struct sctp_stream *stream)
1350 asoc = container_of(stream, struct sctp_association, stream);
1351 stream->si = asoc->peer.intl_capable ? &sctp_stream_interleave_1