Lines Matching defs:strq
3871 struct sctp_stream_out *strq)
3877 TAILQ_INSERT_HEAD(&asoc->out_wheel, strq, next_spoke);
3882 if (stre->stream_no > strq->stream_no) {
3883 TAILQ_INSERT_BEFORE(stre, strq, next_spoke);
3885 } else if (stre->stream_no == strq->stream_no) {
3890 TAILQ_INSERT_AFTER(&asoc->out_wheel, stre, strq,
3898 struct sctp_stream_out *strq)
3901 TAILQ_REMOVE(&asoc->out_wheel, strq, next_spoke);
3902 strq->next_spoke.tqe_next = NULL;
3903 strq->next_spoke.tqe_prev = NULL;
3996 struct sctp_stream_out *strq,
4033 template->rec.data.stream_seq = strq->next_sequence_sent;
4130 struct sctp_stream_out *strq;
4209 strq = &asoc->strmout[srcv->sinfo_stream];
4338 sctp_prepare_chunk(chk, stcb, srcv, strq, net);
4362 strq->next_sequence_sent++;
4366 TAILQ_INSERT_TAIL(&strq->outqueue, chk, sctp_next);
4368 if ((strq->next_spoke.tqe_next == NULL) &&
4369 (strq->next_spoke.tqe_prev == NULL)) {
4373 sctp_insert_on_wheel(asoc, strq);
4383 sctp_prepare_chunk(&template, stcb, srcv, strq, net);
4477 strq->next_sequence_sent++;
4494 TAILQ_INSERT_TAIL(&strq->outqueue, chk, sctp_next);
4498 if ((strq->next_spoke.tqe_next == NULL) &&
4499 (strq->next_spoke.tqe_prev == NULL)) {
4503 sctp_insert_on_wheel(asoc, strq);
4989 struct sctp_stream_out *strq)
5003 chk = TAILQ_FIRST(&strq->outqueue);
5057 TAILQ_REMOVE(&strq->outqueue, chk, sctp_next);
5113 dchkh->dp.stream_id = htons(strq->stream_no);
5129 struct sctp_stream_out *strq, *strqn;
5146 strq = asoc->last_out_stream = TAILQ_FIRST(&asoc->out_wheel);
5153 strq = TAILQ_NEXT(asoc->last_out_stream, next_spoke);
5155 if (strq == NULL) {
5159 if (strq == NULL) {
5162 strq = TAILQ_FIRST(&asoc->out_wheel);
5174 strq = TAILQ_FIRST(&asoc->out_wheel);
5176 if (strq == NULL)
5180 strqn = TAILQ_NEXT(strq, next_spoke);
5181 if ((chk = TAILQ_FIRST(&strq->outqueue)) == NULL) {
5183 sctp_remove_from_wheel(asoc, strq);
5184 if (strq == asoc->last_out_stream) {
5188 strq = strqn;
5195 strq = strqn;
5198 mtu_fromwheel += sctp_move_to_outqueue(stcb, strq);
5201 asoc->last_out_stream = strq;
5202 strq = strqn;
9296 struct sctp_stream_out *strq;
9521 strq = &asoc->strmout[srcv->sinfo_stream];
9547 sctp_prepare_chunk(chk, stcb, srcv, strq, net);
9565 strq->next_sequence_sent++;
9581 TAILQ_INSERT_TAIL(&strq->outqueue, chk, sctp_next);
9583 if ((strq->next_spoke.tqe_next == NULL) &&
9584 (strq->next_spoke.tqe_prev == NULL)) {
9588 sctp_insert_on_wheel(asoc, strq);
9606 sctp_prepare_chunk(&template, stcb, srcv, strq, net);
9654 strq->next_sequence_sent++;
9681 TAILQ_INSERT_TAIL(&strq->outqueue, chk, sctp_next);
9685 if ((strq->next_spoke.tqe_next == NULL) &&
9686 (strq->next_spoke.tqe_prev == NULL)) {
9690 sctp_insert_on_wheel(asoc, strq);