| 609 | }; |
| 610 | |
| 611 | static void |
| 612 | taskqgroup_cpu_create(struct taskqgroup *qgroup, int idx, int cpu) |
| 613 | { |
| 614 | struct taskqgroup_cpu *qcpu; |
| 615 | |
| 616 | qcpu = &qgroup->tqg_queue[idx]; |
| 617 | LIST_INIT(&qcpu->tgc_tasks); |
| 618 | qcpu->tgc_taskq = gtaskqueue_create_fast(NULL, M_WAITOK, |
| 619 | taskqueue_thread_enqueue, &qcpu->tgc_taskq); |
| 620 | gtaskqueue_start_threads(&qcpu->tgc_taskq, 1, PI_SOFT, |
| 621 | "%s_%d", qgroup->tqg_name, idx); |
| 622 | qcpu->tgc_cpu = cpu; |
| 623 | } |
| 624 | |
| 625 | /* |
| 626 | * Find the taskq with least # of tasks that doesn't currently have any |
no test coverage detected