Lines Matching refs:task
305 svc_pool_map_set_cpumask(struct task_struct *task, unsigned int pidx) in svc_pool_map_set_cpumask() argument
321 set_cpus_allowed_ptr(task, cpumask_of(node)); in svc_pool_map_set_cpumask()
326 set_cpus_allowed_ptr(task, cpumask_of_node(node)); in svc_pool_map_set_cpumask()
678 struct task_struct *task = NULL; in choose_victim() local
705 task = rqstp->rq_task; in choose_victim()
709 return task; in choose_victim()
717 struct task_struct *task; in svc_start_kthreads() local
732 task = kthread_create_on_node(serv->sv_ops->svo_function, rqstp, in svc_start_kthreads()
734 if (IS_ERR(task)) { in svc_start_kthreads()
737 return PTR_ERR(task); in svc_start_kthreads()
740 rqstp->rq_task = task; in svc_start_kthreads()
742 svc_pool_map_set_cpumask(task, chosen_pool->sp_id); in svc_start_kthreads()
745 wake_up_process(task); in svc_start_kthreads()
756 struct task_struct *task; in svc_signal_kthreads() local
761 task = choose_victim(serv, pool, &state); in svc_signal_kthreads()
762 if (task == NULL) in svc_signal_kthreads()
764 send_sig(SIGINT, task, 1); in svc_signal_kthreads()
810 struct task_struct *task; in svc_stop_kthreads() local
815 task = choose_victim(serv, pool, &state); in svc_stop_kthreads()
816 if (task == NULL) in svc_stop_kthreads()
818 rqstp = kthread_data(task); in svc_stop_kthreads()
820 if (kthread_stop(task) == -EINTR) in svc_stop_kthreads()
1566 struct rpc_task *task; in bc_svc_process() local
1618 task = rpc_run_bc_task(req); in bc_svc_process()
1619 if (IS_ERR(task)) { in bc_svc_process()
1620 error = PTR_ERR(task); in bc_svc_process()
1624 WARN_ON_ONCE(atomic_read(&task->tk_count) != 1); in bc_svc_process()
1625 error = task->tk_status; in bc_svc_process()
1626 rpc_put_task(task); in bc_svc_process()