bsd/kern/pthread_support.c

192 	uint32_t	ksynq_count;		/* number of entries in queue */
3182 	if ((kwq->kw_ksynqueues[KSYN_QUEUE_READ].ksynq_count != 0) || ((flags & KW_UNLOCK_PREPOST_READLOCK) != 0)) {
3185 		if (kwq->kw_ksynqueues[KSYN_QUEUE_READ].ksynq_count != 0) {
3199 	if ((kwq->kw_ksynqueues[KSYN_QUEUE_LREAD].ksynq_count != 0) || ((flags & KW_UNLOCK_PREPOST_LREADLOCK) != 0)) {
3202 		if (kwq->kw_ksynqueues[KSYN_QUEUE_LREAD].ksynq_count != 0) {
3217 	if ((kwq->kw_ksynqueues[KSYN_QUEUE_WRITER].ksynq_count != 0) || ((flags & KW_UNLOCK_PREPOST_WRLOCK) != 0)) {
3220 		if (kwq->kw_ksynqueues[KSYN_QUEUE_WRITER].ksynq_count != 0) {
3234 	if ((kwq->kw_ksynqueues[KSYN_QUEUE_YWRITER].ksynq_count != 0) || ((flags & KW_UNLOCK_PREPOST_YWRLOCK) != 0)) {
3237 		if (kwq->kw_ksynqueues[KSYN_QUEUE_YWRITER].ksynq_count != 0) {
3317 		while ((kq->ksynq_count != 0) && (allreaders || (is_seqlower(kq->ksynq_firstnum, limitread) != 0))) {
3376 		if (kwq->kw_ksynqueues[KSYN_QUEUE_WRITER].ksynq_count != 0)
3378 		if (kwq->kw_ksynqueues[KSYN_QUEUE_YWRITER].ksynq_count != 0)
3389 		if (kwq->kw_ksynqueues[KSYN_QUEUE_UPGRADE].ksynq_count > 0) {
3502 				numneeded += kwq->kw_ksynqueues[KSYN_QUEUE_READ].ksynq_count;
3503 				numneeded += kwq->kw_ksynqueues[KSYN_QUEUE_LREAD].ksynq_count;
3520 						numneeded += kwq->kw_ksynqueues[KSYN_QUEUE_READ].ksynq_count;
3537 						numneeded += kwq->kw_ksynqueues[KSYN_QUEUE_READ].ksynq_count;
3573 			if ((kwq->kw_ksynqueues[KSYN_QUEUE_WRITER].ksynq_count != 0) && ((updatebits & PTH_RWL_WBIT) == 0))
3586 				if (kwq->kw_ksynqueues[KSYN_QUEUE_WRITER].ksynq_count != 0)
3599 				if ((kwq->kw_ksynqueues[KSYN_QUEUE_WRITER].ksynq_count != 0) || ((flags & KW_UNLOCK_PREPOST_WRLOCK) != 0) )
3671 					numneeded = kwq->kw_ksynqueues[KSYN_QUEUE_READ].ksynq_count;
3706 					else if (kwq->kw_ksynqueues[KSYN_QUEUE_YWRITER].ksynq_count != 0)
3720 					else if ((kwq->kw_ksynqueues[KSYN_QUEUE_YWRITER].ksynq_count != 0) || ((flags & KW_UNLOCK_PREPOST_YWRLOCK) != 0) )
3816 	if (kwq->kw_ksynqueues[KSYN_QUEUE_WRITER].ksynq_count > 0) {
3818 		if (kwq->kw_ksynqueues[KSYN_QUEUE_LREAD].ksynq_count > 0) {
3824 		if (kwq->kw_ksynqueues[KSYN_QUEUE_YWRITER].ksynq_count > 0) {
3826 			if (kwq->kw_ksynqueues[KSYN_QUEUE_LREAD].ksynq_count > 0) {
3850 	kq->ksynq_count = 0;
3863 	if (kq->ksynq_count == 0) {
3930 	kq->ksynq_count++;
3944 	if (kq->ksynq_count != 0) {
3948 		kq->ksynq_count--;
3951 		if(kq->ksynq_count != 0) {
3978 	if (kq->ksynq_count > 0) {
3980 		kq->ksynq_count--;
3981 		if(kq->ksynq_count != 0) {
4190 		if (kwq->kw_ksynqueues[i].ksynq_count != 0) {
4217 		if (kwq->kw_ksynqueues[i].ksynq_count != 0) {
4347 	if ((kq->ksynq_count == 0) || (is_seqhigher(kq->ksynq_firstnum, upto) != 0))