diff options
Diffstat (limited to 'module/spl')
-rw-r--r-- | module/spl/spl-taskq.c | 18 |
1 files changed, 9 insertions, 9 deletions
diff --git a/module/spl/spl-taskq.c b/module/spl/spl-taskq.c index 320ad3914..b362bef54 100644 --- a/module/spl/spl-taskq.c +++ b/module/spl/spl-taskq.c @@ -190,7 +190,7 @@ task_done(taskq_t *tq, taskq_ent_t *t) list_del_init(&t->tqent_list); if (tq->tq_nalloc <= tq->tq_minalloc) { - t->tqent_id = 0; + t->tqent_id = TASKQID_INVALID; t->tqent_func = NULL; t->tqent_arg = NULL; t->tqent_flags = 0; @@ -276,7 +276,7 @@ taskq_lowest_id(taskq_t *tq) if (!list_empty(&tq->tq_active_list)) { tqt = list_entry(tq->tq_active_list.next, taskq_thread_t, tqt_active_list); - ASSERT(tqt->tqt_id != 0); + ASSERT(tqt->tqt_id != TASKQID_INVALID); lowest_id = MIN(lowest_id, tqt->tqt_id); } @@ -548,7 +548,7 @@ taskqid_t taskq_dispatch(taskq_t *tq, task_func_t func, void *arg, uint_t flags) { taskq_ent_t *t; - taskqid_t rc = 0; + taskqid_t rc = TASKQID_INVALID; unsigned long irqflags; ASSERT(tq); @@ -611,7 +611,7 @@ taskqid_t taskq_dispatch_delay(taskq_t *tq, task_func_t func, void *arg, uint_t flags, clock_t expire_time) { - taskqid_t rc = 0; + taskqid_t rc = TASKQID_INVALID; taskq_ent_t *t; unsigned long irqflags; @@ -667,7 +667,7 @@ taskq_dispatch_ent(taskq_t *tq, task_func_t func, void *arg, uint_t flags, /* Taskq being destroyed and all tasks drained */ if (!(tq->tq_flags & TASKQ_ACTIVE)) { - t->tqent_id = 0; + t->tqent_id = TASKQID_INVALID; goto out; } @@ -941,7 +941,7 @@ taskq_thread(void *args) taskq_thread_spawn(tq)) seq_tasks = 0; - tqt->tqt_id = 0; + tqt->tqt_id = TASKQID_INVALID; tqt->tqt_flags = 0; wake_up_all(&tq->tq_wait_waitq); } else { @@ -975,7 +975,7 @@ taskq_thread_create(taskq_t *tq) INIT_LIST_HEAD(&tqt->tqt_thread_list); INIT_LIST_HEAD(&tqt->tqt_active_list); tqt->tqt_tq = tq; - tqt->tqt_id = 0; + tqt->tqt_id = TASKQID_INVALID; tqt->tqt_thread = spl_kthread_create(taskq_thread, tqt, "%s", tq->tq_name); @@ -1037,8 +1037,8 @@ taskq_create(const char *name, int nthreads, pri_t pri, tq->tq_maxalloc = maxalloc; tq->tq_nalloc = 0; tq->tq_flags = (flags | TASKQ_ACTIVE); - tq->tq_next_id = 1; - tq->tq_lowest_id = 1; + tq->tq_next_id = TASKQID_INITIAL; + tq->tq_lowest_id = TASKQID_INITIAL; INIT_LIST_HEAD(&tq->tq_free_list); INIT_LIST_HEAD(&tq->tq_pend_list); INIT_LIST_HEAD(&tq->tq_prio_list); |