bsd/kern/pthread_support.c

4343 	ksyn_waitq_element_t kwe, newkwe;
4352 	TAILQ_FOREACH_SAFE(kwe, &kq->ksynq_kwelist, kwe_list, newkwe) {
4374 	ksyn_waitq_element_t kwe, newkwe;
4387 	TAILQ_FOREACH_SAFE(kwe, &kq->ksynq_kwelist, kwe_list, newkwe) {
4435 		newkwe = TAILQ_FIRST(&kfreeq.ksynq_kwelist);
4436 		if (newkwe == NULL) {
4438 			newkwe = (ksyn_waitq_element_t)zalloc(kwe_zone);
4439 			TAILQ_INSERT_TAIL(&kfreeq.ksynq_kwelist, newkwe, kwe_list);
4444 		TAILQ_REMOVE(&kfreeq.ksynq_kwelist, newkwe, kwe_list);
4445 		bzero(newkwe, sizeof(struct ksyn_waitq_element));
4446 		newkwe->kwe_kwqqueue = ckwq;
4447 		newkwe->kwe_flags = KWE_THREAD_BROADCAST;
4448 		newkwe->kwe_lockseq = upto;
4449 		newkwe->kwe_count = 0;
4450 		newkwe->kwe_uth = NULL;
4451 		newkwe->kwe_psynchretval = 0;
4457 		(void)ksyn_queue_insert(ckwq, &ckwq->kw_ksynqueues[KSYN_QUEUE_WRITER], upto, NULL, newkwe, SEQFIT);