Lines Matching defs:strm
739 struct sctp_stream_in *strm;
741 strm = &asoc->strmin[stream_no];
742 nxt_todel = strm->last_sequence_delivered + 1;
743 chk = TAILQ_FIRST(&strm->inqueue);
750 TAILQ_REMOVE(&strm->inqueue,
755 strm->last_sequence_delivered++;
770 strm->last_sequence_delivered + 1;
804 struct sctp_stream_in *strm;
818 strm = &asoc->strmin[chk->rec.data.stream_number];
819 nxt_todel = strm->last_sequence_delivered + 1;
827 (u_int)strm->last_sequence_delivered, (u_int)nxt_todel);
830 if (compare_with_wrap(strm->last_sequence_delivered,
832 (strm->last_sequence_delivered == chk->rec.data.stream_seq)) {
838 strm->last_sequence_delivered);
845 TAILQ_INSERT_HEAD(&strm->inqueue, chk, sctp_next);
879 strm->last_sequence_delivered++;
881 chk = TAILQ_FIRST(&strm->inqueue);
884 nxt_todel = strm->last_sequence_delivered + 1;
887 TAILQ_REMOVE(&strm->inqueue, chk, sctp_next);
890 strm->last_sequence_delivered++;
918 if (TAILQ_EMPTY(&strm->inqueue)) {
923 TAILQ_INSERT_HEAD(&strm->inqueue, chk, sctp_next);
925 TAILQ_FOREACH(at, &strm->inqueue, sctp_next) {
978 TAILQ_INSERT_AFTER(&strm->inqueue,
4420 struct sctp_stream_in *strm;
4664 strm = &asoc->strmin[stseq[i].stream];
4666 strm->last_sequence_delivered, MAX_SEQ)) {
4668 strm->last_sequence_delivered =
4672 sctp_kick_prsctp_reorder_queue(stcb, strm);