Lines Matching refs:stream
33 dp.stream = htons(sinfo->sinfo_stream); in sctp_make_idatafrag_empty()
50 struct sctp_stream *stream; in sctp_chunk_assign_mid() local
59 stream = &chunk->asoc->stream; in sctp_chunk_assign_mid()
76 sctp_mid_uo_next(stream, out, sid) : in sctp_chunk_assign_mid()
77 sctp_mid_uo_peek(stream, out, sid); in sctp_chunk_assign_mid()
80 sctp_mid_next(stream, out, sid) : in sctp_chunk_assign_mid()
81 sctp_mid_peek(stream, out, sid); in sctp_chunk_assign_mid()
89 struct sctp_stream *stream; in sctp_validate_data() local
98 stream = &chunk->asoc->stream; in sctp_validate_data()
102 return !SSN_lt(ssn, sctp_ssn_peek(stream, in, sid)); in sctp_validate_data()
107 struct sctp_stream *stream; in sctp_validate_idata() local
117 stream = &chunk->asoc->stream; in sctp_validate_idata()
121 return !MID_lt(mid, sctp_mid_peek(stream, in, sid)); in sctp_validate_idata()
138 if (event->stream == cevent->stream && in sctp_intl_store_reasm()
147 if ((event->stream == cevent->stream && in sctp_intl_store_reasm()
149 event->stream > cevent->stream) { in sctp_intl_store_reasm()
158 if (event->stream < cevent->stream || in sctp_intl_store_reasm()
159 (event->stream == cevent->stream && in sctp_intl_store_reasm()
164 if (event->stream == cevent->stream && in sctp_intl_store_reasm()
192 sin = sctp_stream_in(&ulpq->asoc->stream, event->stream); in sctp_intl_retrieve_partial()
197 if (cevent->stream < event->stream) in sctp_intl_retrieve_partial()
200 if (cevent->stream > event->stream || in sctp_intl_retrieve_partial()
272 sin = sctp_stream_in(&ulpq->asoc->stream, event->stream); in sctp_intl_retrieve_reassembled()
277 if (cevent->stream < event->stream) in sctp_intl_retrieve_reassembled()
279 if (cevent->stream > event->stream) in sctp_intl_retrieve_reassembled()
361 sin = sctp_stream_in(&ulpq->asoc->stream, event->stream); in sctp_intl_reasm()
385 if (event->stream == cevent->stream && in sctp_intl_store_ordered()
391 if (event->stream > cevent->stream) { in sctp_intl_store_ordered()
400 if (cevent->stream > event->stream) { in sctp_intl_store_ordered()
404 if (cevent->stream == event->stream && in sctp_intl_store_ordered()
421 struct sctp_stream *stream; in sctp_intl_retrieve_ordered() local
423 __u16 sid = event->stream; in sctp_intl_retrieve_ordered()
425 stream = &ulpq->asoc->stream; in sctp_intl_retrieve_ordered()
431 if (cevent->stream > sid) in sctp_intl_retrieve_ordered()
434 if (cevent->stream < sid) in sctp_intl_retrieve_ordered()
437 if (cevent->mid != sctp_mid_peek(stream, in, sid)) in sctp_intl_retrieve_ordered()
440 sctp_mid_next(stream, in, sid); in sctp_intl_retrieve_ordered()
451 struct sctp_stream *stream; in sctp_intl_order() local
454 stream = &ulpq->asoc->stream; in sctp_intl_order()
455 sid = event->stream; in sctp_intl_order()
457 if (event->mid != sctp_mid_peek(stream, in, sid)) { in sctp_intl_order()
462 sctp_mid_next(stream, in, sid); in sctp_intl_order()
529 if (event->stream == cevent->stream && in sctp_intl_store_reasm_uo()
538 if ((event->stream == cevent->stream && in sctp_intl_store_reasm_uo()
540 event->stream > cevent->stream) { in sctp_intl_store_reasm_uo()
548 if (event->stream < cevent->stream || in sctp_intl_store_reasm_uo()
549 (event->stream == cevent->stream && in sctp_intl_store_reasm_uo()
553 if (event->stream == cevent->stream && in sctp_intl_store_reasm_uo()
576 sin = sctp_stream_in(&ulpq->asoc->stream, event->stream); in sctp_intl_retrieve_partial_uo()
581 if (cevent->stream < event->stream) in sctp_intl_retrieve_partial_uo()
583 if (cevent->stream > event->stream) in sctp_intl_retrieve_partial_uo()
660 sin = sctp_stream_in(&ulpq->asoc->stream, event->stream); in sctp_intl_retrieve_reassembled_uo()
665 if (cevent->stream < event->stream) in sctp_intl_retrieve_reassembled_uo()
667 if (cevent->stream > event->stream) in sctp_intl_retrieve_reassembled_uo()
750 sin = sctp_stream_in(&ulpq->asoc->stream, event->stream); in sctp_intl_reasm_uo()
774 csin = sctp_stream_in(&ulpq->asoc->stream, cevent->stream); in sctp_intl_retrieve_first_uo()
786 sid = cevent->stream; in sctp_intl_retrieve_first_uo()
792 if (cevent->stream == sid && in sctp_intl_retrieve_first_uo()
880 csin = sctp_stream_in(&ulpq->asoc->stream, cevent->stream); in sctp_intl_retrieve_first()
893 sid = cevent->stream; in sctp_intl_retrieve_first()
899 if (cevent->stream == sid && in sctp_intl_retrieve_first()
1012 struct sctp_stream *stream = &ulpq->asoc->stream; in sctp_intl_reap_ordered() local
1023 csid = cevent->stream; in sctp_intl_reap_ordered()
1032 if (!MID_lt(cmid, sctp_mid_peek(stream, in, csid))) in sctp_intl_reap_ordered()
1044 csid = cevent->stream; in sctp_intl_reap_ordered()
1047 if (csid == sid && cmid == sctp_mid_peek(stream, in, csid)) { in sctp_intl_reap_ordered()
1048 sctp_mid_next(stream, in, csid); in sctp_intl_reap_ordered()
1063 struct sctp_stream *stream = &ulpq->asoc->stream; in sctp_intl_abort_pd() local
1066 for (sid = 0; sid < stream->incnt; sid++) { in sctp_intl_abort_pd()
1067 struct sctp_stream_in *sin = SCTP_SI(stream, sid); in sctp_intl_abort_pd()
1082 sctp_mid_skip(stream, in, sid, mid); in sctp_intl_abort_pd()
1093 int nskips, __be16 stream, __u8 flags) in sctp_get_skip_pos() argument
1098 if (skiplist[i].stream == stream && in sctp_get_skip_pos()
1130 __be16 sid = chunk->subh.idata_hdr->stream; in sctp_generate_iftsn()
1140 ftsn_skip_arr[skip_pos].stream = sid; in sctp_generate_iftsn()
1180 incnt = chunk->asoc->stream.incnt; in sctp_validate_fwdtsn()
1182 if (ntohs(skip->stream) >= incnt) in sctp_validate_fwdtsn()
1196 incnt = chunk->asoc->stream.incnt; in sctp_validate_iftsn()
1198 if (ntohs(skip->stream) >= incnt) in sctp_validate_iftsn()
1256 sctp_ulpq_skip(ulpq, ntohs(skip->stream), ntohs(skip->ssn)); in sctp_handle_fwdtsn()
1262 struct sctp_stream_in *sin = sctp_stream_in(&ulpq->asoc->stream, sid); in sctp_intl_skip()
1263 struct sctp_stream *stream = &ulpq->asoc->stream; in sctp_intl_skip() local
1274 if (MID_lt(mid, sctp_mid_peek(stream, in, sid))) in sctp_intl_skip()
1282 sctp_mid_skip(stream, in, sid, mid); in sctp_intl_skip()
1293 sctp_intl_skip(ulpq, ntohs(skip->stream), in sctp_handle_iftsn()
1354 void sctp_stream_interleave_init(struct sctp_stream *stream) in sctp_stream_interleave_init() argument
1358 asoc = container_of(stream, struct sctp_association, stream); in sctp_stream_interleave_init()
1359 stream->si = asoc->peer.intl_capable ? &sctp_stream_interleave_1 in sctp_stream_interleave_init()