1139 	taskq_bucket_t *bucket = NULL;	/* Which bucket needs extension */  in taskq_dispatch()  local
1191 		bucket = tq->tq_buckets;  in taskq_dispatch()
1219 		bucket = b;  in taskq_dispatch()
1255 		taskq_bucket_extend(bucket);  in taskq_dispatch()
1256 		TQ_STAT(bucket, tqs_disptcreates);  in taskq_dispatch()
1257 		if ((tqe = taskq_bucket_dispatch(bucket, func, arg)) != NULL)  in taskq_dispatch()
1261 	ASSERT(bucket != NULL);  in taskq_dispatch()
1269 	if (!taskq_ent_exists(tq, taskq_bucket_extend, bucket)) {  in taskq_dispatch()
1271 			TQ_ENQUEUE_FRONT(tq, tqe1, taskq_bucket_extend, bucket);  in taskq_dispatch()
1273 			TQ_STAT(bucket, tqs_nomem);  in taskq_dispatch()
1285 			TQ_STAT(bucket, tqs_nomem);  in taskq_dispatch()
1671 	taskq_bucket_t	*bucket = tqe->tqent_un.tqent_bucket;  in taskq_d_thread()  local
1672 	taskq_t		*tq = bucket->tqbucket_taskq;  in taskq_d_thread()
1673 	kmutex_t	*lock = &bucket->tqbucket_lock;  in taskq_d_thread()
1691 			ASSERT(bucket->tqbucket_nalloc > 0);  in taskq_d_thread()
1707 			    taskq_bucket_t *, bucket, taskq_ent_t *, tqe);  in taskq_d_thread()
1710 			    taskq_bucket_t *, bucket, taskq_ent_t *, tqe);  in taskq_d_thread()
1713 			bucket->tqbucket_totaltime += end - start;  in taskq_d_thread()
1719 			TQ_APPEND(bucket->tqbucket_freelist, tqe);  in taskq_d_thread()
1720 			bucket->tqbucket_nalloc--;  in taskq_d_thread()
1721 			bucket->tqbucket_nfree++;  in taskq_d_thread()
1722 			ASSERT(!IS_EMPTY(bucket->tqbucket_freelist));  in taskq_d_thread()
1727 			cv_signal(&bucket->tqbucket_cv);  in taskq_d_thread()
1735 		ASSERT(bucket->tqbucket_nfree > 0);  in taskq_d_thread()
1740 		if (! (bucket->tqbucket_flags & TQBUCKET_CLOSE)) {  in taskq_d_thread()
1757 		    (bucket->tqbucket_nfree > 0));  in taskq_d_thread()
1760 		    (bucket->tqbucket_nalloc > 0));  in taskq_d_thread()
1763 		ASSERT((bucket->tqbucket_nfree > 0) ||  in taskq_d_thread()
1764 		    IS_EMPTY(bucket->tqbucket_freelist));  in taskq_d_thread()
1765 		ASSERT((bucket->tqbucket_nfree == 0) ||  in taskq_d_thread()
1766 		    !IS_EMPTY(bucket->tqbucket_freelist));  in taskq_d_thread()
1769 		    ((w == -1) || (bucket->tqbucket_flags & TQBUCKET_CLOSE))) {  in taskq_d_thread()
1781 			ASSERT(bucket->tqbucket_nfree > 0);  in taskq_d_thread()
1782 			bucket->tqbucket_nfree--;  in taskq_d_thread()
1784 			TQ_STAT(bucket, tqs_tdeaths);  in taskq_d_thread()
1785 			cv_signal(&bucket->tqbucket_cv);  in taskq_d_thread()
1974 		taskq_bucket_t *bucket = kmem_zalloc(sizeof (taskq_bucket_t) *  in taskq_create_common()  local
1978 		tq->tq_buckets = bucket;  in taskq_create_common()
1981 		for (b_id = 0; b_id < bsize; b_id++, bucket++) {  in taskq_create_common()
1982 			mutex_init(&bucket->tqbucket_lock, NULL, MUTEX_DEFAULT,  in taskq_create_common()
1984 			cv_init(&bucket->tqbucket_cv, NULL, CV_DEFAULT, NULL);  in taskq_create_common()
1985 			bucket->tqbucket_taskq = tq;  in taskq_create_common()
1986 			bucket->tqbucket_freelist.tqent_next =  in taskq_create_common()
1987 			    bucket->tqbucket_freelist.tqent_prev =  in taskq_create_common()
1988 			    &bucket->tqbucket_freelist;  in taskq_create_common()
1990 				taskq_bucket_extend(bucket);  in taskq_create_common()