Lines Matching full:wheel
58 TAILQ_INIT(&asoc->ss_data.out.wheel); in sctp_ss_default_init()
62 * stream queues to the wheel. in sctp_ss_default_init()
78 while (!TAILQ_EMPTY(&asoc->ss_data.out.wheel)) { in sctp_ss_default_clear()
81 strq = TAILQ_FIRST(&asoc->ss_data.out.wheel); in sctp_ss_default_clear()
83 TAILQ_REMOVE(&asoc->ss_data.out.wheel, strq, ss_params.ss.rr.next_spoke); in sctp_ss_default_clear()
114 /* Add to wheel if not already on it and stream queue not empty */ in sctp_ss_default_add()
116 TAILQ_INSERT_TAIL(&asoc->ss_data.out.wheel, in sctp_ss_default_add()
128 return (TAILQ_EMPTY(&asoc->ss_data.out.wheel)); in sctp_ss_default_is_empty()
139 * Remove from wheel if stream queue is empty and actually is on the in sctp_ss_default_remove()
140 * wheel in sctp_ss_default_remove()
148 asoc->ss_data.last_out_stream = TAILQ_LAST(&asoc->ss_data.out.wheel, in sctp_ss_default_remove()
158 TAILQ_REMOVE(&asoc->ss_data.out.wheel, strq, ss_params.ss.rr.next_spoke); in sctp_ss_default_remove()
184 strq = TAILQ_FIRST(&asoc->ss_data.out.wheel); in sctp_ss_default_select()
188 strq = TAILQ_FIRST(&asoc->ss_data.out.wheel); in sctp_ss_default_select()
312 if (TAILQ_EMPTY(&asoc->ss_data.out.wheel)) { in sctp_ss_rr_add()
313 TAILQ_INSERT_HEAD(&asoc->ss_data.out.wheel, strq, ss_params.ss.rr.next_spoke); in sctp_ss_rr_add()
315 strqt = TAILQ_FIRST(&asoc->ss_data.out.wheel); in sctp_ss_rr_add()
322 TAILQ_INSERT_TAIL(&asoc->ss_data.out.wheel, strq, ss_params.ss.rr.next_spoke); in sctp_ss_rr_add()
358 strq = TAILQ_FIRST(&asoc->ss_data.out.wheel); in sctp_ss_rrp_packet_done()
362 strq = TAILQ_FIRST(&asoc->ss_data.out.wheel); in sctp_ss_rrp_packet_done()
404 while (!TAILQ_EMPTY(&asoc->ss_data.out.wheel)) { in sctp_ss_prio_clear()
407 strq = TAILQ_FIRST(&asoc->ss_data.out.wheel); in sctp_ss_prio_clear()
412 TAILQ_REMOVE(&asoc->ss_data.out.wheel, strq, ss_params.ss.prio.next_spoke); in sctp_ss_prio_clear()
449 /* Add to wheel if not already on it and stream queue not empty */ in sctp_ss_prio_add()
451 if (TAILQ_EMPTY(&asoc->ss_data.out.wheel)) { in sctp_ss_prio_add()
452 TAILQ_INSERT_HEAD(&asoc->ss_data.out.wheel, strq, ss_params.ss.prio.next_spoke); in sctp_ss_prio_add()
454 strqt = TAILQ_FIRST(&asoc->ss_data.out.wheel); in sctp_ss_prio_add()
461 TAILQ_INSERT_TAIL(&asoc->ss_data.out.wheel, strq, ss_params.ss.prio.next_spoke); in sctp_ss_prio_add()
476 * Remove from wheel if stream queue is empty and actually is on the in sctp_ss_prio_remove()
477 * wheel in sctp_ss_prio_remove()
485 asoc->ss_data.last_out_stream = TAILQ_LAST(&asoc->ss_data.out.wheel, in sctp_ss_prio_remove()
495 TAILQ_REMOVE(&asoc->ss_data.out.wheel, strq, ss_params.ss.prio.next_spoke); in sctp_ss_prio_remove()
521 strq = TAILQ_FIRST(&asoc->ss_data.out.wheel); in sctp_ss_prio_select()
528 strq = TAILQ_FIRST(&asoc->ss_data.out.wheel); in sctp_ss_prio_select()
597 while (!TAILQ_EMPTY(&asoc->ss_data.out.wheel)) { in sctp_ss_fb_clear()
600 strq = TAILQ_FIRST(&asoc->ss_data.out.wheel); in sctp_ss_fb_clear()
605 TAILQ_REMOVE(&asoc->ss_data.out.wheel, strq, ss_params.ss.fb.next_spoke); in sctp_ss_fb_clear()
643 TAILQ_INSERT_TAIL(&asoc->ss_data.out.wheel, strq, ss_params.ss.fb.next_spoke); in sctp_ss_fb_add()
656 * Remove from wheel if stream queue is empty and actually is on the in sctp_ss_fb_remove()
657 * wheel in sctp_ss_fb_remove()
665 asoc->ss_data.last_out_stream = TAILQ_LAST(&asoc->ss_data.out.wheel, in sctp_ss_fb_remove()
675 TAILQ_REMOVE(&asoc->ss_data.out.wheel, strq, ss_params.ss.fb.next_spoke); in sctp_ss_fb_remove()
696 …TAILQ_FIRST(&asoc->ss_data.out.wheel) == TAILQ_LAST(&asoc->ss_data.out.wheel, sctpwheel_listhead))… in sctp_ss_fb_select()
697 strqt = TAILQ_FIRST(&asoc->ss_data.out.wheel); in sctp_ss_fb_select()
717 strqt = TAILQ_FIRST(&asoc->ss_data.out.wheel); in sctp_ss_fb_select()
745 TAILQ_FOREACH(strqt, &asoc->ss_data.out.wheel, ss_params.ss.fb.next_spoke) { in sctp_ss_fb_scheduled()