bsd/kern/pthread_support.c

972 	uint32_t uptoseq, fromseq;
991 	uptoseq = cgen & PTHRW_COUNT_MASK;
994 	if (is_seqhigher(fromseq, uptoseq) || is_seqhigher((csgen & PTHRW_COUNT_MASK), uptoseq)) {
1021 	ksyn_handle_cvbroad(ckwq, uptoseq, &updatebits);
1060 	uint32_t cgen, csgen, signalseq, uptoseq;
1081 	uptoseq = cgen & PTHRW_COUNT_MASK;
1085 	if (((threadport == 0) && (is_seqhigher(signalseq, uptoseq))) || is_seqhigher((csgen & PTHRW_COUNT_MASK), uptoseq)) {
1119 		kwe = (th != NULL) ? ksyn_queue_find_threadseq(ckwq, kq, th, uptoseq) :
1120 			ksyn_queue_find_signalseq(ckwq, kq, uptoseq, signalseq);
1129 				/* merge in with existing prepost at our same uptoseq */
1145 					__PTHREAD_TRACE_DEBUG(_PSYNCH_TRACE_CVSIGNAL | DBG_FUNC_NONE, (uint32_t)ckwq->kw_addr, 0xc1c1c1c1, uptoseq, 0, 0);
1147 					ksyn_handle_cvbroad(ckwq, uptoseq, &updatebits);
1177 			ksyn_handle_cvbroad(ckwq, uptoseq, &updatebits);
1190 			nkwe->kwe_lockseq = uptoseq;
1196 			__PTHREAD_TRACE_DEBUG(_PSYNCH_TRACE_CVSIGNAL | DBG_FUNC_NONE, (uint32_t)ckwq->kw_addr, 0xfeedfefe, uptoseq, 0, 0);
1199 			(void)ksyn_queue_insert(ckwq, &ckwq->kw_ksynqueues[KSYN_QUEUE_WRITER], uptoseq, NULL, nkwe, SEQFIT);
4055 ksyn_queue_find_signalseq(__unused ksyn_wait_queue_t kwq, ksyn_queue_t kq, uint32_t uptoseq, uint32_t signalseq)
4065 			if (is_seqhigher((q_kwe->kwe_lockseq & PTHRW_COUNT_MASK), uptoseq))
4070 			/* match any prepost at our same uptoseq or any broadcast above */
4071 			if (is_seqlower((q_kwe->kwe_lockseq & PTHRW_COUNT_MASK), uptoseq))
4081 			if (is_seqhigher((q_kwe->kwe_lockseq & PTHRW_COUNT_MASK), uptoseq))