Lines Matching defs:task
303 svc_pool_map_set_cpumask(struct task_struct *task, unsigned int pidx)
319 set_cpus_allowed_ptr(task, cpumask_of(node));
324 set_cpus_allowed_ptr(task, cpumask_of_node(node));
672 struct task_struct *task = NULL;
699 task = rqstp->rq_task;
703 return task;
711 struct task_struct *task;
726 task = kthread_create_on_node(serv->sv_ops->svo_function, rqstp,
728 if (IS_ERR(task)) {
731 return PTR_ERR(task);
734 rqstp->rq_task = task;
736 svc_pool_map_set_cpumask(task, chosen_pool->sp_id);
739 wake_up_process(task);
750 struct task_struct *task;
755 task = choose_victim(serv, pool, &state);
756 if (task == NULL)
758 send_sig(SIGINT, task, 1);
804 struct task_struct *task;
809 task = choose_victim(serv, pool, &state);
810 if (task == NULL)
812 rqstp = kthread_data(task);
814 if (kthread_stop(task) == -EINTR)
1548 struct rpc_task *task;
1600 task = rpc_run_bc_task(req);
1601 if (IS_ERR(task)) {
1602 error = PTR_ERR(task);
1606 WARN_ON_ONCE(atomic_read(&task->tk_count) != 1);
1607 error = task->tk_status;
1608 rpc_put_task(task);