Lines Matching refs:strq
7228 struct sctp_stream_out *strq, in sctp_move_to_outqueue() argument
7251 sp = TAILQ_FIRST(&strq->outqueue); in sctp_move_to_outqueue()
7253 sp = TAILQ_FIRST(&strq->outqueue); in sctp_move_to_outqueue()
7259 (strq->last_msg_incomplete)) { in sctp_move_to_outqueue()
7261 strq->sid, in sctp_move_to_outqueue()
7262 strq->last_msg_incomplete); in sctp_move_to_outqueue()
7263 strq->last_msg_incomplete = 0; in sctp_move_to_outqueue()
7284 TAILQ_REMOVE(&strq->outqueue, sp, next); in sctp_move_to_outqueue()
7285 stcb->asoc.ss_functions.sctp_ss_remove_from_stream(stcb, asoc, strq, sp); in sctp_move_to_outqueue()
7286 if ((strq->state == SCTP_STREAM_RESET_PENDING) && in sctp_move_to_outqueue()
7287 (strq->chunks_on_queues == 0) && in sctp_move_to_outqueue()
7288 TAILQ_EMPTY(&strq->outqueue)) { in sctp_move_to_outqueue()
7550 chk->rec.data.mid = strq->next_mid_ordered; in sctp_move_to_outqueue()
7552 strq->next_mid_ordered++; in sctp_move_to_outqueue()
7557 chk->rec.data.mid = strq->next_mid_unordered; in sctp_move_to_outqueue()
7559 strq->next_mid_unordered++; in sctp_move_to_outqueue()
7562 chk->rec.data.mid = strq->next_mid_ordered; in sctp_move_to_outqueue()
7564 strq->next_mid_ordered++; in sctp_move_to_outqueue()
7587 stcb->asoc.ss_functions.sctp_ss_scheduled(stcb, net, asoc, strq, to_move); in sctp_move_to_outqueue()
7625 dchkh->dp.sid = htons(strq->sid); in sctp_move_to_outqueue()
7633 ndchkh->dp.sid = htons(strq->sid); in sctp_move_to_outqueue()
7671 TAILQ_REMOVE(&strq->outqueue, sp, next); in sctp_move_to_outqueue()
7672 stcb->asoc.ss_functions.sctp_ss_remove_from_stream(stcb, asoc, strq, sp); in sctp_move_to_outqueue()
7673 if ((strq->state == SCTP_STREAM_RESET_PENDING) && in sctp_move_to_outqueue()
7674 (strq->chunks_on_queues == 0) && in sctp_move_to_outqueue()
7675 TAILQ_EMPTY(&strq->outqueue)) { in sctp_move_to_outqueue()
7689 strq->chunks_on_queues++; in sctp_move_to_outqueue()
7702 struct sctp_stream_out *strq; in sctp_fill_outqueue() local
7730 strq = stcb->asoc.ss_functions.sctp_ss_select_stream(stcb, net, asoc); in sctp_fill_outqueue()
7733 while ((space_left > 0) && (strq != NULL)) { in sctp_fill_outqueue()
7734 moved = sctp_move_to_outqueue(stcb, net, strq, space_left, in sctp_fill_outqueue()
7740 strq = stcb->asoc.ss_functions.sctp_ss_select_stream(stcb, net, asoc); in sctp_fill_outqueue()