Lines Matching refs:tqg_queue

614 	struct taskqgroup_cpu tqg_queue[MAXCPU];  member
632 qcpu = &qgroup->tqg_queue[idx]; in taskqgroup_cpu_create()
645 gtaskqueue_free(qgroup->tqg_queue[idx].tgc_taskq); in taskqgroup_cpu_remove()
671 if (qgroup->tqg_queue[i].tgc_cnt > mincnt) in taskqgroup_find()
675 &qgroup->tqg_queue[i].tgc_tasks, gt_list) in taskqgroup_find()
681 mincnt = qgroup->tqg_queue[i].tgc_cnt; in taskqgroup_find()
729 qgroup->tqg_queue[qid].tgc_cnt++; in taskqgroup_attach()
730 LIST_INSERT_HEAD(&qgroup->tqg_queue[qid].tgc_tasks, gtask, gt_list); in taskqgroup_attach()
731 gtask->gt_taskqueue = qgroup->tqg_queue[qid].tgc_taskq; in taskqgroup_attach()
733 gtask->gt_cpu = qgroup->tqg_queue[qid].tgc_cpu; in taskqgroup_attach()
735 CPU_SET(qgroup->tqg_queue[qid].tgc_cpu, &mask); in taskqgroup_attach()
753 cpu = qgroup->tqg_queue[qid].tgc_cpu; in taskqgroup_attach_deferred()
766 qgroup->tqg_queue[qid].tgc_cnt++; in taskqgroup_attach_deferred()
767 LIST_INSERT_HEAD(&qgroup->tqg_queue[qid].tgc_tasks, gtask, gt_list); in taskqgroup_attach_deferred()
768 MPASS(qgroup->tqg_queue[qid].tgc_taskq != NULL); in taskqgroup_attach_deferred()
769 gtask->gt_taskqueue = qgroup->tqg_queue[qid].tgc_taskq; in taskqgroup_attach_deferred()
788 if (qgroup->tqg_queue[i].tgc_cpu == cpu) { in taskqgroup_attach_cpu()
799 qgroup->tqg_queue[qid].tgc_cnt++; in taskqgroup_attach_cpu()
800 LIST_INSERT_HEAD(&qgroup->tqg_queue[qid].tgc_tasks, gtask, gt_list); in taskqgroup_attach_cpu()
801 gtask->gt_taskqueue = qgroup->tqg_queue[qid].tgc_taskq; in taskqgroup_attach_cpu()
802 cpu = qgroup->tqg_queue[qid].tgc_cpu; in taskqgroup_attach_cpu()
828 if (qgroup->tqg_queue[i].tgc_cpu == cpu) { in taskqgroup_attach_cpu_deferred()
837 qgroup->tqg_queue[qid].tgc_cnt++; in taskqgroup_attach_cpu_deferred()
838 LIST_INSERT_HEAD(&qgroup->tqg_queue[qid].tgc_tasks, gtask, gt_list); in taskqgroup_attach_cpu_deferred()
839 MPASS(qgroup->tqg_queue[qid].tgc_taskq != NULL); in taskqgroup_attach_cpu_deferred()
840 gtask->gt_taskqueue = qgroup->tqg_queue[qid].tgc_taskq; in taskqgroup_attach_cpu_deferred()
863 if (qgroup->tqg_queue[i].tgc_taskq == gtask->gt_taskqueue) in taskqgroup_detach()
867 qgroup->tqg_queue[i].tgc_cnt--; in taskqgroup_detach()
909 gtask->bt_cpuid = qgroup->tqg_queue[i].tgc_cpu; in taskqgroup_bind()
910 grouptaskqueue_enqueue(qgroup->tqg_queue[i].tgc_taskq, in taskqgroup_bind()
921 LIST_SWAP(&gtask_head, &qgroup->tqg_queue[0].tgc_tasks, in taskqgroup_config_init()
923 qgroup->tqg_queue[0].tgc_cnt = 0; in taskqgroup_config_init()
956 old_cpu = qgroup->tqg_queue[old_cnt].tgc_cpu; in _taskqgroup_adjust()
962 LIST_SWAP(&gtask_head, &qgroup->tqg_queue[0].tgc_tasks, in _taskqgroup_adjust()
964 qgroup->tqg_queue[0].tgc_cnt = 0; in _taskqgroup_adjust()
985 while ((gtask = LIST_FIRST(&qgroup->tqg_queue[i].tgc_tasks))) { in _taskqgroup_adjust()
987 qgroup->tqg_queue[i].tgc_cnt--; in _taskqgroup_adjust()
1004 MPASS(qgroup->tqg_queue[i].tgc_taskq != NULL); in _taskqgroup_adjust()
1005 LIST_FOREACH(gtask, &qgroup->tqg_queue[i].tgc_tasks, gt_list) in _taskqgroup_adjust()
1044 LIST_INIT(&qgroup->tqg_queue[0].tgc_tasks); in taskqgroup_create()