| 773 | } |
| 774 | |
| 775 | void |
| 776 | taskqgroup_bind(struct taskqgroup *qgroup) |
| 777 | { |
| 778 | struct taskq_bind_task *gtask; |
| 779 | int i; |
| 780 | |
| 781 | /* |
| 782 | * Bind taskqueue threads to specific CPUs, if they have been assigned |
| 783 | * one. |
| 784 | */ |
| 785 | if (qgroup->tqg_cnt == 1) |
| 786 | return; |
| 787 | |
| 788 | for (i = 0; i < qgroup->tqg_cnt; i++) { |
| 789 | gtask = malloc(sizeof(*gtask), M_DEVBUF, M_WAITOK); |
| 790 | GTASK_INIT(>ask->bt_task, 0, 0, taskqgroup_binder, gtask); |
| 791 | gtask->bt_cpuid = qgroup->tqg_queue[i].tgc_cpu; |
| 792 | grouptaskqueue_enqueue(qgroup->tqg_queue[i].tgc_taskq, |
| 793 | >ask->bt_task); |
| 794 | } |
| 795 | } |
| 796 | |
| 797 | struct taskqgroup * |
| 798 | taskqgroup_create(const char *name, int cnt, int stride) |
nothing calls this directly
no test coverage detected