168 	struct sctp_stream_out *strq, *strqt;  in sctp_ss_default_select()  local
178 	strqt = asoc->ss_data.last_out_stream;  in sctp_ss_default_select()
179 	KASSERT(strqt == NULL || strqt->ss_params.scheduled,  in sctp_ss_default_select()
180 	    ("last_out_stream %p not scheduled", (void *)strqt));  in sctp_ss_default_select()
183 	if (strqt == NULL) {  in sctp_ss_default_select()
186 		strq = TAILQ_NEXT(strqt, ss_params.ss.rr.next_spoke);  in sctp_ss_default_select()
211 				strqt = strq;  in sctp_ss_default_select()
307 	struct sctp_stream_out *strqt;  in sctp_ss_rr_add()  local
315 			strqt = TAILQ_FIRST(&asoc->ss_data.out.wheel);  in sctp_ss_rr_add()
316 			while (strqt != NULL && (strqt->sid < strq->sid)) {  in sctp_ss_rr_add()
317 				strqt = TAILQ_NEXT(strqt, ss_params.ss.rr.next_spoke);  in sctp_ss_rr_add()
319 			if (strqt != NULL) {  in sctp_ss_rr_add()
320 				TAILQ_INSERT_BEFORE(strqt, strq, ss_params.ss.rr.next_spoke);  in sctp_ss_rr_add()
348 	struct sctp_stream_out *strq, *strqt;  in sctp_ss_rrp_packet_done()  local
352 	strqt = asoc->ss_data.last_out_stream;  in sctp_ss_rrp_packet_done()
353 	KASSERT(strqt == NULL || strqt->ss_params.scheduled,  in sctp_ss_rrp_packet_done()
354 	    ("last_out_stream %p not scheduled", (void *)strqt));  in sctp_ss_rrp_packet_done()
357 	if (strqt == NULL) {  in sctp_ss_rrp_packet_done()
360 		strq = TAILQ_NEXT(strqt, ss_params.ss.rr.next_spoke);  in sctp_ss_rrp_packet_done()
385 				strqt = strq;  in sctp_ss_rrp_packet_done()
445 	struct sctp_stream_out *strqt;  in sctp_ss_prio_add()  local
454 			strqt = TAILQ_FIRST(&asoc->ss_data.out.wheel);  in sctp_ss_prio_add()
455 			while (strqt != NULL && strqt->ss_params.ss.prio.priority < strq->ss_params.ss.prio.priority) {  in sctp_ss_prio_add()
456 				strqt = TAILQ_NEXT(strqt, ss_params.ss.prio.next_spoke);  in sctp_ss_prio_add()
458 			if (strqt != NULL) {  in sctp_ss_prio_add()
459 				TAILQ_INSERT_BEFORE(strqt, strq, ss_params.ss.prio.next_spoke);  in sctp_ss_prio_add()
505 	struct sctp_stream_out *strq, *strqt, *strqn;  in sctp_ss_prio_select()  local
515 	strqt = asoc->ss_data.last_out_stream;  in sctp_ss_prio_select()
516 	KASSERT(strqt == NULL || strqt->ss_params.scheduled,  in sctp_ss_prio_select()
517 	    ("last_out_stream %p not scheduled", (void *)strqt));  in sctp_ss_prio_select()
520 	if (strqt == NULL) {  in sctp_ss_prio_select()
523 		strqn = TAILQ_NEXT(strqt, ss_params.ss.prio.next_spoke);  in sctp_ss_prio_select()
525 		    strqn->ss_params.ss.prio.priority == strqt->ss_params.ss.prio.priority) {  in sctp_ss_prio_select()
551 				strqt = strq;  in sctp_ss_prio_select()
685 	struct sctp_stream_out *strq = NULL, *strqt;  in sctp_ss_fb_select()  local
697 		strqt = TAILQ_FIRST(&asoc->ss_data.out.wheel);  in sctp_ss_fb_select()
699 		strqt = TAILQ_NEXT(asoc->ss_data.last_out_stream, ss_params.ss.fb.next_spoke);  in sctp_ss_fb_select()
702 		if ((strqt != NULL) &&  in sctp_ss_fb_select()
705 …   (net == NULL || (TAILQ_FIRST(&strqt->outqueue) && TAILQ_FIRST(&strqt->outqueue)->net == NULL) ||  in sctp_ss_fb_select()
706 		    (net != NULL && TAILQ_FIRST(&strqt->outqueue) && TAILQ_FIRST(&strqt->outqueue)->net != NULL &&  in sctp_ss_fb_select()
707 		    TAILQ_FIRST(&strqt->outqueue)->net == net))))) {  in sctp_ss_fb_select()
708 			if ((strqt->ss_params.ss.fb.rounds >= 0) &&  in sctp_ss_fb_select()
710 			    (strqt->ss_params.ss.fb.rounds < strq->ss_params.ss.fb.rounds))) {  in sctp_ss_fb_select()
711 				strq = strqt;  in sctp_ss_fb_select()
714 		if (strqt != NULL) {  in sctp_ss_fb_select()
715 			strqt = TAILQ_NEXT(strqt, ss_params.ss.fb.next_spoke);  in sctp_ss_fb_select()
717 			strqt = TAILQ_FIRST(&asoc->ss_data.out.wheel);  in sctp_ss_fb_select()
719 	} while (strqt != strq);  in sctp_ss_fb_select()
729 	struct sctp_stream_out *strqt;  in sctp_ss_fb_scheduled()  local
745 	TAILQ_FOREACH(strqt, &asoc->ss_data.out.wheel, ss_params.ss.fb.next_spoke) {  in sctp_ss_fb_scheduled()
746 		strqt->ss_params.ss.fb.rounds -= subtract;  in sctp_ss_fb_scheduled()
747 		if (strqt->ss_params.ss.fb.rounds < 0)  in sctp_ss_fb_scheduled()
748 			strqt->ss_params.ss.fb.rounds = 0;  in sctp_ss_fb_scheduled()