Lines Matching refs:tqg_queue
597 struct taskqgroup_cpu tqg_queue[MAXCPU]; member
613 qcpu = &qgroup->tqg_queue[idx]; in taskqgroup_cpu_create()
645 if (qgroup->tqg_queue[i].tgc_cnt > mincnt) in taskqgroup_find()
648 LIST_FOREACH(n, &qgroup->tqg_queue[i].tgc_tasks, in taskqgroup_find()
655 mincnt = qgroup->tqg_queue[i].tgc_cnt; in taskqgroup_find()
681 qgroup->tqg_queue[qid].tgc_cnt++; in taskqgroup_attach()
682 LIST_INSERT_HEAD(&qgroup->tqg_queue[qid].tgc_tasks, gtask, gt_list); in taskqgroup_attach()
683 gtask->gt_taskqueue = qgroup->tqg_queue[qid].tgc_taskq; in taskqgroup_attach()
685 cpu = qgroup->tqg_queue[qid].tgc_cpu; in taskqgroup_attach()
709 if (qgroup->tqg_queue[i].tgc_cpu == cpu) { in taskqgroup_attach_cpu()
718 qgroup->tqg_queue[qid].tgc_cnt++; in taskqgroup_attach_cpu()
719 LIST_INSERT_HEAD(&qgroup->tqg_queue[qid].tgc_tasks, gtask, gt_list); in taskqgroup_attach_cpu()
720 gtask->gt_taskqueue = qgroup->tqg_queue[qid].tgc_taskq; in taskqgroup_attach_cpu()
721 cpu = qgroup->tqg_queue[qid].tgc_cpu; in taskqgroup_attach_cpu()
741 if (qgroup->tqg_queue[i].tgc_taskq == gtask->gt_taskqueue) in taskqgroup_detach()
745 qgroup->tqg_queue[i].tgc_cnt--; in taskqgroup_detach()
788 gtask->bt_cpuid = qgroup->tqg_queue[i].tgc_cpu; in taskqgroup_bind()
789 grouptaskqueue_enqueue(qgroup->tqg_queue[i].tgc_taskq, in taskqgroup_bind()
824 q = tqg->tqg_queue[i].tgc_taskq; in taskqgroup_drain_all()