bsd/kern/pthread_support.c

3859 	ksyn_waitq_element_t q_kwe, r_kwe;
3884 			q_kwe = ksyn_queue_find_seq(kwq, kq, lockseq, 0);
3885 			if ((q_kwe != NULL) && ((nuth = (uthread_t)q_kwe->kwe_uth) != NULL) &&
3916 	TAILQ_FOREACH_SAFE(q_kwe, &kq->ksynq_kwelist, kwe_list, r_kwe) {
3917 		if (is_seqhigher(q_kwe->kwe_lockseq, lockseq) != 0) {
3918 			TAILQ_INSERT_BEFORE(q_kwe, kwe, kwe_list);
3941 	ksyn_waitq_element_t q_kwe;
3952 			q_kwe = TAILQ_FIRST(&kq->ksynq_kwelist);
3953 			kq->ksynq_firstnum = (q_kwe->kwe_lockseq & PTHRW_COUNT_MASK);
3975 	ksyn_waitq_element_t q_kwe;
3982 			q_kwe = TAILQ_FIRST(&kq->ksynq_kwelist);
3983 			kq->ksynq_firstnum = (q_kwe->kwe_lockseq & PTHRW_COUNT_MASK);
3984 			q_kwe = TAILQ_LAST(&kq->ksynq_kwelist, ksynq_kwelist_head);
3985 			kq->ksynq_lastnum = (q_kwe->kwe_lockseq & PTHRW_COUNT_MASK);
4009 	ksyn_waitq_element_t q_kwe, r_kwe;
4013 	TAILQ_FOREACH_SAFE(q_kwe, &kq->ksynq_kwelist, kwe_list, r_kwe) {
4014 		if ((q_kwe->kwe_lockseq & PTHRW_COUNT_MASK) == seq) {
4016 				ksyn_queue_removeitem(kwq, kq, q_kwe);
4017 			return(q_kwe);
4028 	ksyn_waitq_element_t q_kwe, r_kwe;
4032 	TAILQ_FOREACH_SAFE(q_kwe, &kq->ksynq_kwelist, kwe_list, r_kwe) {
4035 		if (is_seqlower((q_kwe->kwe_lockseq & PTHRW_COUNT_MASK), cgen) != 0)
4038 		switch (q_kwe->kwe_flags) {
4041 			if ((q_kwe->kwe_lockseq & PTHRW_COUNT_MASK) != lgen)
4047 			return (q_kwe);
4057 	ksyn_waitq_element_t q_kwe, r_kwe, t_kwe = NULL;
4060 	TAILQ_FOREACH_SAFE(q_kwe, &kq->ksynq_kwelist, kwe_list, r_kwe) {
4062 		switch (q_kwe->kwe_flags) {
4065 			if (is_seqhigher((q_kwe->kwe_lockseq & PTHRW_COUNT_MASK), uptoseq))
4071 			if (is_seqlower((q_kwe->kwe_lockseq & PTHRW_COUNT_MASK), uptoseq))
4073 			return  q_kwe;
4081 			if (is_seqhigher((q_kwe->kwe_lockseq & PTHRW_COUNT_MASK), uptoseq))
4084 			if (q_kwe->kwe_kwqqueue == kwq) {
4085 				uthread_t ut = q_kwe->kwe_uth;
4088 					if (is_seqhigher_eq((q_kwe->kwe_lockseq & PTHRW_COUNT_MASK), signalseq))
4089 						return q_kwe;
4093 						t_kwe = q_kwe;
4099 			panic("ksyn_queue_find_signalseq(): unknow wait queue element type (%d)\n", q_kwe->kwe_flags);