Home | History | Annotate | Download | only in threadpool_tester

Lines Matching defs:pool

70 	struct threadpool *pool, *opool = NULL;
86 error = threadpool_get(&pool, val);
95 ctx->ctx_unbound[pri_to_idx(val)] = pool;
101 /* Should have gotten reference to existing pool. */
102 TP_LOG(("%s: found existing unbound pool for pri %d (%s)\n",
103 __func__, val, opool == pool ? "match" : "NO MATCH"));
104 KASSERT(opool == pool);
105 threadpool_put(pool, val);
108 TP_LOG(("%s: created unbound pool for pri %d\n",
119 struct threadpool *pool;
137 pool = ctx->ctx_unbound[pri_to_idx(val)];
141 if (pool == NULL) {
142 TP_LOG(("%s: no unbound pool for pri %d\n",
147 threadpool_put(pool, val);
148 TP_LOG(("%s: released unbound pool for pri %d\n",
158 struct threadpool *pool;
175 pool = ctx->ctx_unbound[pri_to_idx(val)];
176 if (pool == NULL) {
177 TP_LOG(("%s: no unbound pool for pri %d\n",
183 threadpool_schedule_job(pool, &ctx->ctx_job);
184 TP_LOG(("%s: scheduled job on unbound pool for pri %d\n",
226 /* Should have gotten reference to existing pool. */
227 TP_LOG(("%s: found existing unbound pool for pri %d (%s)\n",
233 TP_LOG(("%s: created percpu pool for pri %d\n",
267 TP_LOG(("%s: no percpu pool for pri %d\n",
273 TP_LOG(("%s: released percpu pool for pri %d\n",
284 struct threadpool *pool;
303 TP_LOG(("%s: no percpu pool for pri %d\n",
309 pool = threadpool_percpu_ref(pcpu);
310 KASSERT(pool != NULL);
312 threadpool_schedule_job(pool, &ctx->ctx_job);
313 TP_LOG(("%s: scheduled job on percpu pool for pri %d\n",
389 SYSCTL_DESCR("get unbound pool of specified priority"),
396 SYSCTL_DESCR("put unbound pool of specified priority"),
403 SYSCTL_DESCR("run on unbound pool of specified priority"),
410 SYSCTL_DESCR("get percpu pool of specified priority"),
417 SYSCTL_DESCR("put percpu pool of specified priority"),
424 SYSCTL_DESCR("run on percpu pool of specified priority"),
450 struct threadpool *pool =
456 * threadpool_cancel_job() may be called on a pool
461 if (pool != NULL) {
462 threadpool_cancel_job(pool, &tester_ctx.ctx_job);
463 threadpool_put(pool, pri);
467 pool = threadpool_percpu_ref(pcpu);
468 threadpool_cancel_job(pool, &tester_ctx.ctx_job);