| taskq.c (302408) | taskq.c (339034) |
|---|---|
| 1/* 2 * CDDL HEADER START 3 * 4 * The contents of this file are subject to the terms of the 5 * Common Development and Distribution License (the "License"). 6 * You may not use this file except in compliance with the License. 7 * 8 * You can obtain a copy of the license at usr/src/OPENSOLARIS.LICENSE --- 173 unchanged lines hidden (view full) --- 182taskq_wait(taskq_t *tq) 183{ 184 mutex_enter(&tq->tq_lock); 185 while (tq->tq_task.tqent_next != &tq->tq_task || tq->tq_active != 0) 186 cv_wait(&tq->tq_wait_cv, &tq->tq_lock); 187 mutex_exit(&tq->tq_lock); 188} 189 | 1/* 2 * CDDL HEADER START 3 * 4 * The contents of this file are subject to the terms of the 5 * Common Development and Distribution License (the "License"). 6 * You may not use this file except in compliance with the License. 7 * 8 * You can obtain a copy of the license at usr/src/OPENSOLARIS.LICENSE --- 173 unchanged lines hidden (view full) --- 182taskq_wait(taskq_t *tq) 183{ 184 mutex_enter(&tq->tq_lock); 185 while (tq->tq_task.tqent_next != &tq->tq_task || tq->tq_active != 0) 186 cv_wait(&tq->tq_wait_cv, &tq->tq_lock); 187 mutex_exit(&tq->tq_lock); 188} 189 |
| 190void 191taskq_wait_id(taskq_t *tq, taskqid_t id) 192{ 193 taskq_wait(tq); 194} 195 |
|
| 190static void * 191taskq_thread(void *arg) 192{ 193 taskq_t *tq = arg; 194 taskq_ent_t *t; 195 boolean_t prealloc; 196 197 mutex_enter(&tq->tq_lock); --- 145 unchanged lines hidden --- | 196static void * 197taskq_thread(void *arg) 198{ 199 taskq_t *tq = arg; 200 taskq_ent_t *t; 201 boolean_t prealloc; 202 203 mutex_enter(&tq->tq_lock); --- 145 unchanged lines hidden --- |