Lines Matching refs:strqt
193 struct sctp_stream_out *strq, *strqt; in sctp_ss_default_select() local
198 strqt = asoc->ss_data.last_out_stream; in sctp_ss_default_select()
201 if (strqt == NULL) { in sctp_ss_default_select()
204 strq = TAILQ_NEXT(strqt, ss_params.rr.next_spoke); in sctp_ss_default_select()
229 strqt = strq; in sctp_ss_default_select()
313 struct sctp_stream_out *strqt; in sctp_ss_rr_add() local
324 strqt = TAILQ_FIRST(&asoc->ss_data.out.wheel); in sctp_ss_rr_add()
325 while (strqt != NULL && (strqt->sid < strq->sid)) { in sctp_ss_rr_add()
326 strqt = TAILQ_NEXT(strqt, ss_params.rr.next_spoke); in sctp_ss_rr_add()
328 if (strqt != NULL) { in sctp_ss_rr_add()
329 TAILQ_INSERT_BEFORE(strqt, strq, ss_params.rr.next_spoke); in sctp_ss_rr_add()
357 struct sctp_stream_out *strq, *strqt; in sctp_ss_rrp_packet_done() local
359 strqt = asoc->ss_data.last_out_stream; in sctp_ss_rrp_packet_done()
362 if (strqt == NULL) { in sctp_ss_rrp_packet_done()
365 strq = TAILQ_NEXT(strqt, ss_params.rr.next_spoke); in sctp_ss_rrp_packet_done()
390 strqt = strq; in sctp_ss_rrp_packet_done()
456 struct sctp_stream_out *strqt; in sctp_ss_prio_add() local
468 strqt = TAILQ_FIRST(&asoc->ss_data.out.wheel); in sctp_ss_prio_add()
469 while (strqt != NULL && strqt->ss_params.prio.priority < strq->ss_params.prio.priority) { in sctp_ss_prio_add()
470 strqt = TAILQ_NEXT(strqt, ss_params.prio.next_spoke); in sctp_ss_prio_add()
472 if (strqt != NULL) { in sctp_ss_prio_add()
473 TAILQ_INSERT_BEFORE(strqt, strq, ss_params.prio.next_spoke); in sctp_ss_prio_add()
522 struct sctp_stream_out *strq, *strqt, *strqn; in sctp_ss_prio_select() local
527 strqt = asoc->ss_data.last_out_stream; in sctp_ss_prio_select()
530 if (strqt == NULL) { in sctp_ss_prio_select()
533 strqn = TAILQ_NEXT(strqt, ss_params.prio.next_spoke); in sctp_ss_prio_select()
535 strqn->ss_params.prio.priority == strqt->ss_params.prio.priority) { in sctp_ss_prio_select()
561 strqt = strq; in sctp_ss_prio_select()
701 struct sctp_stream_out *strq = NULL, *strqt; in sctp_ss_fb_select() local
708 strqt = TAILQ_FIRST(&asoc->ss_data.out.wheel); in sctp_ss_fb_select()
710 strqt = TAILQ_NEXT(asoc->ss_data.last_out_stream, ss_params.fb.next_spoke); in sctp_ss_fb_select()
713 if ((strqt != NULL) && in sctp_ss_fb_select()
716 … (net == NULL || (TAILQ_FIRST(&strqt->outqueue) && TAILQ_FIRST(&strqt->outqueue)->net == NULL) || in sctp_ss_fb_select()
717 … (net != NULL && TAILQ_FIRST(&strqt->outqueue) && TAILQ_FIRST(&strqt->outqueue)->net != NULL && in sctp_ss_fb_select()
718 TAILQ_FIRST(&strqt->outqueue)->net == net))))) { in sctp_ss_fb_select()
719 if ((strqt->ss_params.fb.rounds >= 0) && (strq == NULL || in sctp_ss_fb_select()
720 strqt->ss_params.fb.rounds < strq->ss_params.fb.rounds)) { in sctp_ss_fb_select()
721 strq = strqt; in sctp_ss_fb_select()
724 if (strqt != NULL) { in sctp_ss_fb_select()
725 strqt = TAILQ_NEXT(strqt, ss_params.fb.next_spoke); in sctp_ss_fb_select()
727 strqt = TAILQ_FIRST(&asoc->ss_data.out.wheel); in sctp_ss_fb_select()
729 } while (strqt != strq); in sctp_ss_fb_select()
739 struct sctp_stream_out *strqt; in sctp_ss_fb_scheduled() local
753 TAILQ_FOREACH(strqt, &asoc->ss_data.out.wheel, ss_params.fb.next_spoke) { in sctp_ss_fb_scheduled()
754 strqt->ss_params.fb.rounds -= subtract; in sctp_ss_fb_scheduled()
755 if (strqt->ss_params.fb.rounds < 0) in sctp_ss_fb_scheduled()
756 strqt->ss_params.fb.rounds = 0; in sctp_ss_fb_scheduled()