Lines Matching refs:node
47 int node; member
59 unsigned int node; member
135 kthread->node = tsk_fork_get_node(current); in set_kthread_struct()
368 if (WARN_ON_ONCE(kthread->node == NUMA_NO_NODE)) in kthread_fetch_affinity()
370 pref = cpumask_of_node(kthread->node); in kthread_fetch_affinity()
385 if (kthread->node == NUMA_NO_NODE) { in kthread_affine_node()
483 current->pref_node_fork = create->node; in create_kthread()
504 void *data, int node, in __kthread_create_on_node() argument
517 create->node = node; in __kthread_create_on_node()
579 void *data, int node, in kthread_create_on_node() argument
587 task = __kthread_create_on_node(threadfn, data, node, namefmt, args); in kthread_create_on_node()
1000 struct kthread_work, node); in kthread_worker_fn()
1001 list_del_init(&work->node); in kthread_worker_fn()
1034 __kthread_create_worker_on_node(unsigned int flags, int node, in __kthread_create_worker_on_node() argument
1047 node, namefmt, args); in __kthread_create_worker_on_node()
1072 kthread_create_worker_on_node(unsigned int flags, int node, const char namefmt[], ...) in kthread_create_worker_on_node() argument
1078 worker = __kthread_create_worker_on_node(flags, node, namefmt, args); in kthread_create_worker_on_node()
1145 return !list_empty(&work->node) || work->canceling; in queuing_blocked()
1152 WARN_ON_ONCE(!list_empty(&work->node)); in kthread_insert_work_sanity_check()
1166 list_add_tail(&work->node, pos); in kthread_insert_work()
1228 WARN_ON_ONCE(list_empty(&work->node)); in kthread_delayed_work_timer_fn()
1229 list_del_init(&work->node); in kthread_delayed_work_timer_fn()
1260 list_add(&work->node, &worker->delayed_work_list); in __kthread_queue_delayed_work()
1336 if (!list_empty(&work->node)) in kthread_flush_work()
1337 kthread_insert_work(worker, &fwork.work, work->node.next); in kthread_flush_work()
1397 if (!list_empty(&work->node)) { in __kthread_cancel_work()
1398 list_del_init(&work->node); in __kthread_cancel_work()