X-Git-Url: https://git.camperquake.de/gitweb.cgi?a=blobdiff_plain;f=lib%2Flibzpool%2Ftaskq.c;h=96c0d5c2be989446a4c8d0e17d64672dc6a4b918;hb=7634cd54db25a69e00aaab6448ad710441bd8e7d;hp=803f7dc37444aefcfd55ceea20095104946bc606;hpb=844793c3cc6ebf8e850057e41497089131569be0;p=zfs.git diff --git a/lib/libzpool/taskq.c b/lib/libzpool/taskq.c index 803f7dc..96c0d5c 100644 --- a/lib/libzpool/taskq.c +++ b/lib/libzpool/taskq.c @@ -147,6 +147,13 @@ taskq_dispatch(taskq_t *tq, task_func_t func, void *arg, uint_t tqflags) return (1); } +taskqid_t +taskq_dispatch_delay(taskq_t *tq, task_func_t func, void *arg, uint_t tqflags, + clock_t expire_time) +{ + return (0); +} + int taskq_empty_ent(taskq_ent_t *t) { @@ -204,6 +211,12 @@ taskq_wait(taskq_t *tq) mutex_exit(&tq->tq_lock); } +void +taskq_wait_id(taskq_t *tq, taskqid_t id) +{ + taskq_wait(tq); +} + static void taskq_thread(void *arg) { @@ -339,6 +352,12 @@ taskq_member(taskq_t *tq, kthread_t *t) return (0); } +int +taskq_cancel_id(taskq_t *tq, taskqid_t id) +{ + return (ENOENT); +} + void system_taskq_init(void) {