git://git.camperquake.de
/
zfs.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
Added arcstat.py from FreeNAS
[zfs.git]
/
lib
/
libzpool
/
taskq.c
diff --git
a/lib/libzpool/taskq.c
b/lib/libzpool/taskq.c
index
803f7dc
..
96c0d5c
100644
(file)
--- 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);
}
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)
{
int
taskq_empty_ent(taskq_ent_t *t)
{
@@
-204,6
+211,12
@@
taskq_wait(taskq_t *tq)
mutex_exit(&tq->tq_lock);
}
mutex_exit(&tq->tq_lock);
}
+void
+taskq_wait_id(taskq_t *tq, taskqid_t id)
+{
+ taskq_wait(tq);
+}
+
static void
taskq_thread(void *arg)
{
static void
taskq_thread(void *arg)
{
@@
-339,6
+352,12
@@
taskq_member(taskq_t *tq, kthread_t *t)
return (0);
}
return (0);
}
+int
+taskq_cancel_id(taskq_t *tq, taskqid_t id)
+{
+ return (ENOENT);
+}
+
void
system_taskq_init(void)
{
void
system_taskq_init(void)
{