taskq_bucket_t
taskq_bucket_t *b = mdb_zalloc(bsize, UM_SLEEP | UM_GC);
OFFSETOF(taskq_bucket_t, tqbucket_backlog);
wd->tq_bucket += sizeof (taskq_bucket_t);
taskq_bucket_dispatch(taskq_bucket_t *b, task_func_t func, void *arg)
taskq_bucket_t *idleb = &tq->tq_buckets[tq->tq_nbuckets];
DTRACE_PROBE2(taskq__d__enqueue, taskq_bucket_t *, b,
taskq_idlebucket_dispatch(taskq_bucket_t *b, task_func_t func, void *arg)
taskq_bucket_t *idleb = &tq->tq_buckets[tq->tq_nbuckets];
DTRACE_PROBE2(taskq__d__enqueue, taskq_bucket_t *, b,
taskq_backlog_dispatch(taskq_bucket_t *bucket, task_func_t func, void *arg,
taskq_backlog_enqueue(taskq_bucket_t *bucket, taskq_ent_t *tqe, int flags)
taskq_bucket_t *, bucket,
taskq_bucket_t *bucket = NULL; /* Which bucket needs extension */
taskq_bucket_t *b = tq->tq_buckets;
taskq_bucket_t *b = tq->tq_buckets;
taskq_bucket_t *b = tq->tq_buckets;
taskq_bucket_t *bucket, taskq_t *tq)
taskq_bucket_t *, bucket, taskq_ent_t *, tqe);
taskq_bucket_t *, bucket, taskq_ent_t *, tqe);
taskq_bucket_t *, bucket,
taskq_bucket_t *b;
taskq_bucket_t *bucket = tqe->tqent_un.tqent_bucket;
taskq_bucket_t *idle_bucket = &tq->tq_buckets[tq->tq_nbuckets];
taskq_bucket_t *bucket = kmem_zalloc(sizeof (taskq_bucket_t) *
taskq_bucket_t *idle_bucket = &bucket[bsize];
taskq_bucket_t *b;
sizeof (taskq_bucket_t) * (tq->tq_nbuckets + 1));
taskq_bucket_t *b = arg;
taskq_bucket_extend(taskq_bucket_t *b)
taskq_bucket_t *idleb = &tq->tq_buckets[tq->tq_nbuckets];
taskq_bucket_redist(taskq_bucket_t *bucket)
taskq_bucket_t *idle_bucket = &tq->tq_buckets[tq->tq_nbuckets];
taskq_bucket_t *db; /* donor bucket candidate */
taskq_bucket_t *, bucket);
taskq_bucket_t *, bucket, taskq_ent_t *, tqe);
taskq_bucket_t *b;
static taskq_ent_t *taskq_bucket_extend(taskq_bucket_t *);
static void taskq_bucket_redist(taskq_bucket_t *);
static taskq_ent_t *taskq_bucket_dispatch(taskq_bucket_t *, task_func_t,
static void taskq_backlog_enqueue(taskq_bucket_t *,
taskq_bucket_t *tq_buckets; /* Per-cpu array of buckets */
taskq_bucket_t *tqent_bucket;