bsd/kern/pthread_synch.c

690 			uint32_t	affinity_tag;
703 			for (affinity_tag = 0; affinity_tag < wq->wq_reqconc[priority]; affinity_tag++) {
716 					if (wq->wq_thactive_count[i][affinity_tag]) {
720 					if (wq->wq_thscheduled_count[i][affinity_tag]) {
721 						if (wq_thread_is_busy(curtime, &wq->wq_lastblocked_ts[i][affinity_tag])) {
1534 	uint32_t affinity_tag, orig_affinity_tag;
1573 		if ((affinity_tag = oc_affinity) == (uint32_t)-1) {
1574 			for (affinity_tag = 0; affinity_tag < wq->wq_reqconc[priority]; affinity_tag++) {
1582 					scheduled_count += wq->wq_thscheduled_count[i][affinity_tag];
1583 					active_count += wq->wq_thactive_count[i][affinity_tag];
1586 					t_affinity = affinity_tag;
1589 				if (affinity_tag == 0 || scheduled_count < min_scheduled) {
1591 					t_affinity = affinity_tag;
1594 			affinity_tag = t_affinity;
1645 		affinity_tag = tl->th_affinity_tag;
1653 		if (affinity_tag < wq->wq_reqconc[priority]) {
1667 				tcount = wq->wq_thactive_count[i][affinity_tag];
1670 				if (tcount == 0 && wq->wq_thscheduled_count[i][affinity_tag]) {
1671 					if (wq_thread_is_busy(curtime, &wq->wq_lastblocked_ts[i][affinity_tag]))
1704 				affinity_tag = 1;
1717 	for (affinity_tag = 0; affinity_tag < wq->wq_reqconc[priority]; affinity_tag++) {
1728 			if (wq->wq_thactive_count[i][affinity_tag])
1731 			if (wq->wq_thscheduled_count[i][affinity_tag] &&
1732 			    wq_thread_is_busy(curtime, &wq->wq_lastblocked_ts[i][affinity_tag])) {
1743 	if (affinity_tag >= wq->wq_reqconc[priority]) {
1803 		if (ttl->th_affinity_tag == affinity_tag || ttl->th_affinity_tag == (uint16_t)-1) {
1830 	wq->wq_thscheduled_count[priority][affinity_tag]++;
1831 	OSAddAtomic(1, &wq->wq_thactive_count[priority][affinity_tag]);
1855 	tl->th_affinity_tag = affinity_tag;
1857 	if (adjust_counters == TRUE && (orig_priority != priority || orig_affinity_tag != affinity_tag)) {
1863 	        OSAddAtomic(1, &wq->wq_thactive_count[priority][affinity_tag]);
1866 		wq->wq_thscheduled_count[priority][affinity_tag]++;
1872 	if (orig_affinity_tag != affinity_tag) {
1885 		(void)thread_affinity_set(th_to_run, affinity_tag + 1);
1887 		KERNEL_DEBUG(0xefffd114 | DBG_FUNC_END, wq, affinity_tag, 0, 0, 0);