Lines Matching defs:strq
7230 struct sctp_stream_out *strq,
7253 sp = TAILQ_FIRST(&strq->outqueue);
7255 sp = TAILQ_FIRST(&strq->outqueue);
7261 (strq->last_msg_incomplete)) {
7263 strq->sid,
7264 strq->last_msg_incomplete);
7265 strq->last_msg_incomplete = 0;
7286 TAILQ_REMOVE(&strq->outqueue, sp, next);
7287 stcb->asoc.ss_functions.sctp_ss_remove_from_stream(stcb, asoc, strq, sp);
7288 if ((strq->state == SCTP_STREAM_RESET_PENDING) &&
7289 (strq->chunks_on_queues == 0) &&
7290 TAILQ_EMPTY(&strq->outqueue)) {
7552 chk->rec.data.mid = strq->next_mid_ordered;
7554 strq->next_mid_ordered++;
7559 chk->rec.data.mid = strq->next_mid_unordered;
7561 strq->next_mid_unordered++;
7564 chk->rec.data.mid = strq->next_mid_ordered;
7566 strq->next_mid_ordered++;
7589 stcb->asoc.ss_functions.sctp_ss_scheduled(stcb, net, asoc, strq, to_move);
7627 dchkh->dp.sid = htons(strq->sid);
7635 ndchkh->dp.sid = htons(strq->sid);
7673 TAILQ_REMOVE(&strq->outqueue, sp, next);
7674 stcb->asoc.ss_functions.sctp_ss_remove_from_stream(stcb, asoc, strq, sp);
7675 if ((strq->state == SCTP_STREAM_RESET_PENDING) &&
7676 (strq->chunks_on_queues == 0) &&
7677 TAILQ_EMPTY(&strq->outqueue)) {
7691 strq->chunks_on_queues++;
7704 struct sctp_stream_out *strq;
7732 strq = stcb->asoc.ss_functions.sctp_ss_select_stream(stcb, net, asoc);
7735 while ((space_left > 0) && (strq != NULL)) {
7736 moved = sctp_move_to_outqueue(stcb, net, strq, space_left,
7742 strq = stcb->asoc.ss_functions.sctp_ss_select_stream(stcb, net, asoc);