bsd/kern/pthread_support.c

321 int find_diff(uint32_t upto, uint32_t lowest);
494 int ksyn_queue_move_tofree(ksyn_wait_queue_t kwq, ksyn_queue_t kq, uint32_t upto, ksyn_queue_t freeq, int all, int reease);
499 int find_seq_till(ksyn_wait_queue_t kwq, uint32_t upto, uint32_t  nwaiters, uint32_t *countp);
500 uint32_t ksyn_queue_count_tolowest(ksyn_queue_t kq, uint32_t upto);
503 uint32_t ksyn_queue_cvcount_entries(ksyn_queue_t kq, uint32_t upto, uint32_t from, int * numwaitersp, int * numintrp, int * numprepop);
504 void ksyn_handle_cvbroad(ksyn_wait_queue_t ckwq, uint32_t upto, uint32_t *updatep);
1039 ksyn_queue_find_threadseq(ksyn_wait_queue_t ckwq, __unused ksyn_queue_t kq, thread_t th, uint32_t upto)
1045 	    is_seqhigher((kwe->kwe_lockseq & PTHRW_COUNT_MASK), upto)) {
3274 /* wakeup readers and longreaders to upto the  writer limits */
4077 			 * Match any (non-cancelled) thread at or below our upto sequence -
4108 ksyn_queue_move_tofree(ksyn_wait_queue_t ckwq, ksyn_queue_t kq, uint32_t upto, ksyn_queue_t kfreeq, int all, int release)
4112 	uint32_t tseq = upto & PTHRW_COUNT_MASK;
4284 find_diff(uint32_t upto, uint32_t lowest)
4288 	if (upto == lowest)
4291 	diff = diff_genseq(upto, lowest);
4293         if (is_seqlower(upto, lowest) != 0)
4294                 diff = diff_genseq(lowest, upto);
4296                 diff = diff_genseq(upto, lowest);
4304 find_seq_till(ksyn_wait_queue_t kwq, uint32_t upto, uint32_t nwaiters, uint32_t *countp)
4311 	__PTHREAD_TRACE_DEBUG(_PSYNCH_TRACE_FSEQTILL | DBG_FUNC_START, 0, 0, upto, nwaiters, 0);
4315 		count += ksyn_queue_count_tolowest(&kwq->kw_ksynqueues[i], upto);
4340 ksyn_queue_count_tolowest(ksyn_queue_t kq, uint32_t upto)
4346 	/* if nothing or the  first num is greater than upto, return none */
4347 	if ((kq->ksynq_count == 0) || (is_seqhigher(kq->ksynq_firstnum, upto) != 0))
4349 	if (upto == kq->ksynq_firstnum)
4354 		if (upto == curval) {
4357 		} else if (is_seqhigher(curval, upto) != 0) {
4370 ksyn_handle_cvbroad(ksyn_wait_queue_t ckwq, uint32_t upto, uint32_t * updatep)
4380 	__PTHREAD_TRACE_DEBUG(_PSYNCH_TRACE_CVHBROAD | DBG_FUNC_START, 0xcbcbcbc2, upto, 0, 0, 0);
4389 		if (is_seqhigher((kwe->kwe_lockseq & PTHRW_COUNT_MASK), upto))	/* outside our range */
4448 		newkwe->kwe_lockseq = upto;
4454 		__PTHREAD_TRACE_DEBUG(_PSYNCH_TRACE_CVHBROAD | DBG_FUNC_NONE, (uint32_t)ckwq->kw_addr, 0xfeedfeed, upto, 0, 0);
4457 		(void)ksyn_queue_insert(ckwq, &ckwq->kw_ksynqueues[KSYN_QUEUE_WRITER], upto, NULL, newkwe, SEQFIT);