Lines Matching refs:kfrwk
78 struct kern_totfrwk kfrwk;
81 #define KTFRWK_MUTEX_INIT() mtx_init(&kfrwk.kfrwk_mtx, "kern_test_frwk", "tfrwk", MTX_DEF)
83 #define KTFRWK_DESTROY() mtx_destroy(&kfrwk.kfrwk_mtx)
85 #define KTFRWK_LOCK() mtx_lock(&kfrwk.kfrwk_mtx)
87 #define KTFRWK_UNLOCK() mtx_unlock(&kfrwk.kfrwk_mtx)
136 TAILQ_INIT(&kfrwk.kfrwk_testq);
137 TAILQ_INIT(&kfrwk.kfrwk_testlist);
139 TASK_INIT(&kfrwk.kfrwk_que, 0, kfrwk_task, &kfrwk);
140 kfrwk.kfrwk_tq = taskqueue_create_fast("sbtls_task", M_NOWAIT,
141 taskqueue_thread_enqueue, &kfrwk.kfrwk_tq);
142 if (kfrwk.kfrwk_tq == NULL) {
144 panic("Taskqueue init fails for kfrwk");
146 taskqueue_start_threads(&kfrwk.kfrwk_tq, ncpus, PI_NET, "[kt_frwk task]");
147 kfrwk.kfrwk_waiting = ncpus;
156 if (!TAILQ_EMPTY(&kfrwk.kfrwk_testlist)) {
163 taskqueue_free(kfrwk.kfrwk_tq);
202 TAILQ_FOREACH(li, &kfrwk.kfrwk_testlist, next) {
215 if (!TAILQ_EMPTY(&kfrwk.kfrwk_testq)) {
221 if (kfrwk.kfrwk_waiting < kt.num_threads) {
230 TAILQ_INSERT_TAIL(&kfrwk.kfrwk_testq, kte, next);
231 taskqueue_enqueue(kfrwk.kfrwk_tq, &kfrwk.kfrwk_que);
255 TAILQ_FOREACH(li, &kfrwk.kfrwk_testlist, next) {
265 TAILQ_INSERT_TAIL(&kfrwk.kfrwk_testlist, te, next);
280 TAILQ_FOREACH(li, &kfrwk.kfrwk_testlist, next) {
290 if (ncpus != kfrwk.kfrwk_waiting) {
295 if (!TAILQ_EMPTY(&kfrwk.kfrwk_testq)) {
301 TAILQ_REMOVE(&kfrwk.kfrwk_testlist, te, next);
320 if (TAILQ_EMPTY(&kfrwk.kfrwk_testlist)) {