Lines Matching refs:scheduled

82 		KASSERT(strq->ss_params.scheduled, ("strq %p not scheduled", (void *)strq));  in sctp_ss_default_clear()
84 strq->ss_params.scheduled = false; in sctp_ss_default_clear()
103 strq->ss_params.scheduled = false; in sctp_ss_default_init_stream()
115 if (!TAILQ_EMPTY(&strq->outqueue) && !strq->ss_params.scheduled) { in sctp_ss_default_add()
118 strq->ss_params.scheduled = true; in sctp_ss_default_add()
142 if (TAILQ_EMPTY(&strq->outqueue) && strq->ss_params.scheduled) { in sctp_ss_default_remove()
159 strq->ss_params.scheduled = false; in sctp_ss_default_remove()
173 KASSERT(asoc->ss_data.locked_on_sending->ss_params.scheduled, in sctp_ss_default_select()
179 KASSERT(strqt == NULL || strqt->ss_params.scheduled, in sctp_ss_default_select()
191 KASSERT(strq == NULL || strq->ss_params.scheduled, in sctp_ss_default_select()
229 KASSERT(strq->ss_params.scheduled, ("strq %p is not scheduled", (void *)strq)); in sctp_ss_default_scheduled()
311 if (!TAILQ_EMPTY(&strq->outqueue) && !strq->ss_params.scheduled) { in sctp_ss_rr_add()
325 strq->ss_params.scheduled = true; in sctp_ss_rr_add()
353 KASSERT(strqt == NULL || strqt->ss_params.scheduled, in sctp_ss_rrp_packet_done()
365 KASSERT(strq == NULL || strq->ss_params.scheduled, in sctp_ss_rrp_packet_done()
408 KASSERT(strq->ss_params.scheduled, ("strq %p not scheduled", (void *)strq)); in sctp_ss_prio_clear()
413 strq->ss_params.scheduled = false; in sctp_ss_prio_clear()
432 strq->ss_params.scheduled = false; in sctp_ss_prio_init_stream()
450 if (!TAILQ_EMPTY(&strq->outqueue) && !strq->ss_params.scheduled) { in sctp_ss_prio_add()
464 strq->ss_params.scheduled = true; in sctp_ss_prio_add()
479 if (TAILQ_EMPTY(&strq->outqueue) && strq->ss_params.scheduled) { in sctp_ss_prio_remove()
496 strq->ss_params.scheduled = false; in sctp_ss_prio_remove()
510 KASSERT(asoc->ss_data.locked_on_sending->ss_params.scheduled, in sctp_ss_prio_select()
516 KASSERT(strqt == NULL || strqt->ss_params.scheduled, in sctp_ss_prio_select()
531 KASSERT(strq == NULL || strq->ss_params.scheduled, in sctp_ss_prio_select()
601 KASSERT(strq->ss_params.scheduled, ("strq %p not scheduled", (void *)strq)); in sctp_ss_fb_clear()
606 strq->ss_params.scheduled = false; in sctp_ss_fb_clear()
625 strq->ss_params.scheduled = false; in sctp_ss_fb_init_stream()
640 if (!TAILQ_EMPTY(&strq->outqueue) && !strq->ss_params.scheduled) { in sctp_ss_fb_add()
644 strq->ss_params.scheduled = true; in sctp_ss_fb_add()
659 if (TAILQ_EMPTY(&strq->outqueue) && strq->ss_params.scheduled) { in sctp_ss_fb_remove()
676 strq->ss_params.scheduled = false; in sctp_ss_fb_remove()
690 KASSERT(asoc->ss_data.locked_on_sending->ss_params.scheduled, in sctp_ss_fb_select()
813 KASSERT(sp->scheduled, ("sp %p not scheduled", (void *)sp)); in sctp_ss_fcfs_clear()
815 sp->scheduled = false; in sctp_ss_fcfs_clear()
834 strq->ss_params.scheduled = false; in sctp_ss_fcfs_init_stream()
844 if (!sp->scheduled) { in sctp_ss_fcfs_add()
846 sp->scheduled = true; in sctp_ss_fcfs_add()
865 if (sp->scheduled) { in sctp_ss_fcfs_remove()
867 sp->scheduled = false; in sctp_ss_fcfs_remove()