Lines Matching refs:ss_data
65 asoc->ss_data.locked_on_sending = NULL; in sctp_ss_default_init()
66 asoc->ss_data.last_out_stream = NULL; in sctp_ss_default_init()
67 TAILQ_INIT(&asoc->ss_data.out.wheel); in sctp_ss_default_init()
92 while (!TAILQ_EMPTY(&asoc->ss_data.out.wheel)) { in sctp_ss_default_clear()
95 strq = TAILQ_FIRST(&asoc->ss_data.out.wheel); in sctp_ss_default_clear()
96 TAILQ_REMOVE(&asoc->ss_data.out.wheel, strq, ss_params.rr.next_spoke); in sctp_ss_default_clear()
100 asoc->ss_data.last_out_stream = NULL; in sctp_ss_default_clear()
111 if (stcb->asoc.ss_data.locked_on_sending == with_strq) { in sctp_ss_default_init_stream()
112 stcb->asoc.ss_data.locked_on_sending = strq; in sctp_ss_default_init_stream()
114 if (stcb->asoc.ss_data.last_out_stream == with_strq) { in sctp_ss_default_init_stream()
115 stcb->asoc.ss_data.last_out_stream = strq; in sctp_ss_default_init_stream()
135 TAILQ_INSERT_TAIL(&asoc->ss_data.out.wheel, in sctp_ss_default_add()
147 if (TAILQ_EMPTY(&asoc->ss_data.out.wheel)) { in sctp_ss_default_is_empty()
166 if (asoc->ss_data.last_out_stream == strq) { in sctp_ss_default_remove()
167 asoc->ss_data.last_out_stream = TAILQ_PREV(asoc->ss_data.last_out_stream, in sctp_ss_default_remove()
170 if (asoc->ss_data.last_out_stream == NULL) { in sctp_ss_default_remove()
171 asoc->ss_data.last_out_stream = TAILQ_LAST(&asoc->ss_data.out.wheel, in sctp_ss_default_remove()
174 if (asoc->ss_data.last_out_stream == strq) { in sctp_ss_default_remove()
175 asoc->ss_data.last_out_stream = NULL; in sctp_ss_default_remove()
178 TAILQ_REMOVE(&asoc->ss_data.out.wheel, strq, ss_params.rr.next_spoke); in sctp_ss_default_remove()
195 if (asoc->ss_data.locked_on_sending) { in sctp_ss_default_select()
196 return (asoc->ss_data.locked_on_sending); in sctp_ss_default_select()
198 strqt = asoc->ss_data.last_out_stream; in sctp_ss_default_select()
202 strq = TAILQ_FIRST(&asoc->ss_data.out.wheel); in sctp_ss_default_select()
206 strq = TAILQ_FIRST(&asoc->ss_data.out.wheel); in sctp_ss_default_select()
226 if (strq == asoc->ss_data.last_out_stream) { in sctp_ss_default_select()
246 asoc->ss_data.last_out_stream = strq; in sctp_ss_default_scheduled()
250 stcb->asoc.ss_data.locked_on_sending = strq; in sctp_ss_default_scheduled()
252 stcb->asoc.ss_data.locked_on_sending = NULL; in sctp_ss_default_scheduled()
255 stcb->asoc.ss_data.locked_on_sending = NULL; in sctp_ss_default_scheduled()
293 strq = asoc->ss_data.locked_on_sending; in sctp_ss_default_is_user_msgs_incomplete()
321 if (TAILQ_EMPTY(&asoc->ss_data.out.wheel)) { in sctp_ss_rr_add()
322 TAILQ_INSERT_HEAD(&asoc->ss_data.out.wheel, strq, ss_params.rr.next_spoke); in sctp_ss_rr_add()
324 strqt = TAILQ_FIRST(&asoc->ss_data.out.wheel); in sctp_ss_rr_add()
331 TAILQ_INSERT_TAIL(&asoc->ss_data.out.wheel, strq, ss_params.rr.next_spoke); in sctp_ss_rr_add()
350 return (asoc->ss_data.last_out_stream); in sctp_ss_rrp_select()
359 strqt = asoc->ss_data.last_out_stream; in sctp_ss_rrp_packet_done()
363 strq = TAILQ_FIRST(&asoc->ss_data.out.wheel); in sctp_ss_rrp_packet_done()
367 strq = TAILQ_FIRST(&asoc->ss_data.out.wheel); in sctp_ss_rrp_packet_done()
387 if (strq == asoc->ss_data.last_out_stream) { in sctp_ss_rrp_packet_done()
395 asoc->ss_data.last_out_stream = strq; in sctp_ss_rrp_packet_done()
411 while (!TAILQ_EMPTY(&asoc->ss_data.out.wheel)) { in sctp_ss_prio_clear()
414 strq = TAILQ_FIRST(&asoc->ss_data.out.wheel); in sctp_ss_prio_clear()
418 TAILQ_REMOVE(&asoc->ss_data.out.wheel, strq, ss_params.prio.next_spoke); in sctp_ss_prio_clear()
423 asoc->ss_data.last_out_stream = NULL; in sctp_ss_prio_clear()
434 if (stcb->asoc.ss_data.locked_on_sending == with_strq) { in sctp_ss_prio_init_stream()
435 stcb->asoc.ss_data.locked_on_sending = strq; in sctp_ss_prio_init_stream()
437 if (stcb->asoc.ss_data.last_out_stream == with_strq) { in sctp_ss_prio_init_stream()
438 stcb->asoc.ss_data.last_out_stream = strq; in sctp_ss_prio_init_stream()
465 if (TAILQ_EMPTY(&asoc->ss_data.out.wheel)) { in sctp_ss_prio_add()
466 TAILQ_INSERT_HEAD(&asoc->ss_data.out.wheel, strq, ss_params.prio.next_spoke); in sctp_ss_prio_add()
468 strqt = TAILQ_FIRST(&asoc->ss_data.out.wheel); in sctp_ss_prio_add()
475 TAILQ_INSERT_TAIL(&asoc->ss_data.out.wheel, strq, ss_params.prio.next_spoke); in sctp_ss_prio_add()
497 if (asoc->ss_data.last_out_stream == strq) { in sctp_ss_prio_remove()
498 asoc->ss_data.last_out_stream = TAILQ_PREV(asoc->ss_data.last_out_stream, sctpwheel_listhead, in sctp_ss_prio_remove()
500 if (asoc->ss_data.last_out_stream == NULL) { in sctp_ss_prio_remove()
501 asoc->ss_data.last_out_stream = TAILQ_LAST(&asoc->ss_data.out.wheel, in sctp_ss_prio_remove()
504 if (asoc->ss_data.last_out_stream == strq) { in sctp_ss_prio_remove()
505 asoc->ss_data.last_out_stream = NULL; in sctp_ss_prio_remove()
508 TAILQ_REMOVE(&asoc->ss_data.out.wheel, strq, ss_params.prio.next_spoke); in sctp_ss_prio_remove()
524 if (asoc->ss_data.locked_on_sending) { in sctp_ss_prio_select()
525 return (asoc->ss_data.locked_on_sending); in sctp_ss_prio_select()
527 strqt = asoc->ss_data.last_out_stream; in sctp_ss_prio_select()
531 strq = TAILQ_FIRST(&asoc->ss_data.out.wheel); in sctp_ss_prio_select()
538 strq = TAILQ_FIRST(&asoc->ss_data.out.wheel); in sctp_ss_prio_select()
558 if (strq == asoc->ss_data.last_out_stream) { in sctp_ss_prio_select()
604 while (!TAILQ_EMPTY(&asoc->ss_data.out.wheel)) { in sctp_ss_fb_clear()
607 strq = TAILQ_FIRST(&asoc->ss_data.out.wheel); in sctp_ss_fb_clear()
611 TAILQ_REMOVE(&asoc->ss_data.out.wheel, strq, ss_params.fb.next_spoke); in sctp_ss_fb_clear()
615 asoc->ss_data.last_out_stream = NULL; in sctp_ss_fb_clear()
626 if (stcb->asoc.ss_data.locked_on_sending == with_strq) { in sctp_ss_fb_init_stream()
627 stcb->asoc.ss_data.locked_on_sending = strq; in sctp_ss_fb_init_stream()
629 if (stcb->asoc.ss_data.last_out_stream == with_strq) { in sctp_ss_fb_init_stream()
630 stcb->asoc.ss_data.last_out_stream = strq; in sctp_ss_fb_init_stream()
656 TAILQ_INSERT_TAIL(&asoc->ss_data.out.wheel, strq, ss_params.fb.next_spoke); in sctp_ss_fb_add()
676 if (asoc->ss_data.last_out_stream == strq) { in sctp_ss_fb_remove()
677 asoc->ss_data.last_out_stream = TAILQ_PREV(asoc->ss_data.last_out_stream, sctpwheel_listhead, in sctp_ss_fb_remove()
679 if (asoc->ss_data.last_out_stream == NULL) { in sctp_ss_fb_remove()
680 asoc->ss_data.last_out_stream = TAILQ_LAST(&asoc->ss_data.out.wheel, in sctp_ss_fb_remove()
683 if (asoc->ss_data.last_out_stream == strq) { in sctp_ss_fb_remove()
684 asoc->ss_data.last_out_stream = NULL; in sctp_ss_fb_remove()
687 TAILQ_REMOVE(&asoc->ss_data.out.wheel, strq, ss_params.fb.next_spoke); in sctp_ss_fb_remove()
703 if (asoc->ss_data.locked_on_sending) { in sctp_ss_fb_select()
704 return (asoc->ss_data.locked_on_sending); in sctp_ss_fb_select()
706 if (asoc->ss_data.last_out_stream == NULL || in sctp_ss_fb_select()
707 …TAILQ_FIRST(&asoc->ss_data.out.wheel) == TAILQ_LAST(&asoc->ss_data.out.wheel, sctpwheel_listhead))… in sctp_ss_fb_select()
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()
727 strqt = TAILQ_FIRST(&asoc->ss_data.out.wheel); in sctp_ss_fb_select()
745 stcb->asoc.ss_data.locked_on_sending = strq; in sctp_ss_fb_scheduled()
747 stcb->asoc.ss_data.locked_on_sending = NULL; in sctp_ss_fb_scheduled()
750 stcb->asoc.ss_data.locked_on_sending = NULL; in sctp_ss_fb_scheduled()
753 TAILQ_FOREACH(strqt, &asoc->ss_data.out.wheel, ss_params.fb.next_spoke) { in sctp_ss_fb_scheduled()
763 asoc->ss_data.last_out_stream = strq; in sctp_ss_fb_scheduled()
787 TAILQ_INIT(&asoc->ss_data.out.list); in sctp_ss_fcfs_init()
828 while (!TAILQ_EMPTY(&asoc->ss_data.out.list)) { in sctp_ss_fcfs_clear()
829 sp = TAILQ_FIRST(&asoc->ss_data.out.list); in sctp_ss_fcfs_clear()
830 TAILQ_REMOVE(&asoc->ss_data.out.list, sp, ss_next); in sctp_ss_fcfs_clear()
845 if (stcb->asoc.ss_data.locked_on_sending == with_strq) { in sctp_ss_fcfs_init_stream()
846 stcb->asoc.ss_data.locked_on_sending = strq; in sctp_ss_fcfs_init_stream()
848 if (stcb->asoc.ss_data.last_out_stream == with_strq) { in sctp_ss_fcfs_init_stream()
849 stcb->asoc.ss_data.last_out_stream = strq; in sctp_ss_fcfs_init_stream()
867 TAILQ_INSERT_TAIL(&asoc->ss_data.out.list, sp, ss_next); in sctp_ss_fcfs_add()
878 if (TAILQ_EMPTY(&asoc->ss_data.out.list)) { in sctp_ss_fcfs_is_empty()
896 TAILQ_REMOVE(&asoc->ss_data.out.list, sp, ss_next); in sctp_ss_fcfs_remove()
914 if (asoc->ss_data.locked_on_sending) { in sctp_ss_fcfs_select()
915 return (asoc->ss_data.locked_on_sending); in sctp_ss_fcfs_select()
917 sp = TAILQ_FIRST(&asoc->ss_data.out.list); in sctp_ss_fcfs_select()