bsd/kern/pthread_support.c

491 int ksyn_queue_insert(ksyn_wait_queue_t kwq, ksyn_queue_t kq, uint32_t mgen, struct uthread * uth, ksyn_waitq_element_t kwe, int firstfit);
765 	uthread_t uth;
776 	uth = current_uthread();
778 	kwe = &uth->uu_kwe;
780 	kwe->kwe_uth = uth;
861 	error = ksyn_queue_insert(kwq, &kwq->kw_ksynqueues[KSYN_QUEUE_WRITER], mgen, uth, kwe, ins_flags);
891 	uthread_t uth = current_uthread();
895 	kwe = &uth->uu_kwe;
921 		uth->uu_rval[0] = updatebits;
1041 	uthread_t uth = get_bsdthread_info(th);
1042 	ksyn_waitq_element_t kwe = &uth->uu_kwe;
1245 	uthread_t uth;
1384 	uth = current_uthread();
1385 	kwe = &uth->uu_kwe;
1390 	kwe->kwe_uth = uth;
1397 	error = ksyn_queue_insert(ckwq, kq, cgen, uth, kwe, SEQFIT);
1424 	uthread_t uth = current_uthread();
1441 		__PTHREAD_TRACE_DEBUG(_PSYNCH_TRACE_THWAKEUP | DBG_FUNC_NONE, 0xf4f3f2f1, (uintptr_t)uth, result, 0, 0);
1445 	kwe = &uth->uu_kwe;
1450 		uth->uu_rval[0] = kwe->kwe_psynchretval;
1494 			uth->uu_rval[0] = PTHRW_INC | PTH_RWS_CV_CBIT;
1496 			uth->uu_rval[0] = 0;
1501 	__PTHREAD_TRACE_DEBUG(_PSYNCH_TRACE_CVWAIT | DBG_FUNC_END, (uint32_t)ckwq->kw_addr, 0xeeeeeeed, uth->uu_rval[0], local_error, 0);
1589 	uthread_t uth;
1598 	uth = current_uthread();
1601 	kwe = &uth->uu_kwe;
1603 	kwe->kwe_uth = uth;
1700 	error = ksyn_queue_insert(kwq, &kwq->kw_ksynqueues[KSYN_QUEUE_READ], lgen, uth, kwe, SEQFIT);
1764 	uthread_t uth;
1770 	uth = current_uthread();
1771 	kwe = &uth->uu_kwe;
1773 	kwe->kwe_uth = uth;
1845 	error = ksyn_queue_insert(kwq, &kwq->kw_ksynqueues[KSYN_QUEUE_LREAD], lgen, uth, kwe, SEQFIT);
1906 	uthread_t uth;
1916 	uth = current_uthread();
1917 	kwe = &uth->uu_kwe;
1919 	kwe->kwe_uth = uth;
1996 	error = ksyn_queue_insert(kwq, &kwq->kw_ksynqueues[KSYN_QUEUE_WRITER], lgen, uth, kwe, SEQFIT);
2060 	uthread_t uth;
2070 	uth = current_uthread();
2071 	kwe = &uth->uu_kwe;
2073 	kwe->kwe_uth = uth;
2145 	error = ksyn_queue_insert(kwq, &kwq->kw_ksynqueues[KSYN_QUEUE_YWRITER], lgen, uth, kwe, SEQFIT);
2207 	uthread_t uth;
2213 	uth = current_uthread();
2320 	uthread_t uth;
2329 	uth = current_uthread();
2330 	kwe = &uth->uu_kwe;
2332 	kwe->kwe_uth = uth;
2404 	error = ksyn_queue_insert(kwq, &kwq->kw_ksynqueues[KSYN_QUEUE_UPGRADE], lgen, uth, kwe, SEQFIT);
2474 	uthread_t uth;
2485 	uth = current_uthread();
3092 	uthread_t uth = NULL;
3113 	uth = current_uthread();
3116 		__PTHREAD_TRACE_DEBUG(_PSYNCH_TRACE_THWAKEUP | DBG_FUNC_NONE, 0xf4f3f2f1, (uint32_t)uth, kret, 0, 0);
3131 	uthread_t uth = NULL;
3139 	uth = kwe->kwe_uth;
3141 	__PTHREAD_TRACE_DEBUG(_PSYNCH_TRACE_THWAKEUP | DBG_FUNC_NONE, 0xf1f2f3f4, (uint32_t)uth, kret, 0, 0);
3350 	uthread_t uth;
3550 				uth = current_uthread();
3551 				kwe = &uth->uu_kwe;
3591 				uth = get_bsdthread_info(th);
3592 				kwe = &uth->uu_kwe;
3647 						uth = current_uthread();
3648 						kwe = &uth->uu_kwe;
3674 						uth = current_uthread();
3675 						kwe = &uth->uu_kwe;
3710 					uth = get_bsdthread_info(th);
3711 					kwe = &uth->uu_kwe;
3856 ksyn_queue_insert(ksyn_wait_queue_t kwq, ksyn_queue_t kq, uint32_t mgen, struct uthread * uth, ksyn_waitq_element_t kwe, int fit)
3928 	if (uth != NULL)
3929 		kwe->kwe_uth = uth;