92     MppNodeTask             task;  member
142 #define mpp_node_task_schedule(task) \  argument
143     mpp_node_task_schedule_f(__FUNCTION__, task)
145 #define mpp_node_task_schedule_from(caller, task) \  argument
146     mpp_node_task_schedule_f(caller, task)
221 MPP_RET mpp_node_task_attach(MppNodeTask *task, MppNodeImpl *node,  in mpp_node_task_attach()  argument
224     INIT_LIST_HEAD(&task->list_sched);  in mpp_node_task_attach()
226     task->node = node;  in mpp_node_task_attach()
227     task->node_name = node->name;  in mpp_node_task_attach()
229     task->queue = queue;  in mpp_node_task_attach()
230     task->proc = proc;  in mpp_node_task_attach()
238 MPP_RET mpp_node_task_schedule_f(const char *caller, MppNodeTask *task)  in mpp_node_task_schedule_f()  argument
240     ClusterQueue *queue = task->queue;  in mpp_node_task_schedule_f()
242     MppNodeImpl *node = task->node;  in mpp_node_task_schedule_f()
243     MppNodeProc *proc = task->proc;  in mpp_node_task_schedule_f()
244     const char *node_name = task->node_name;  in mpp_node_task_schedule_f()
283         mpp_assert(list_empty(&task->list_sched));  in mpp_node_task_schedule_f()
284         list_add_tail(&task->list_sched, &queue->list);  in mpp_node_task_schedule_f()
304 MPP_RET mpp_node_task_detach(MppNodeTask *task)  in mpp_node_task_detach()  argument
306     MppNodeImpl *node = task->node;  in mpp_node_task_detach()
310         const char *node_name = task->node_name;  in mpp_node_task_detach()
311         MppNodeProc *proc = task->proc;  in mpp_node_task_detach()
315         mpp_node_task_schedule(task);  in mpp_node_task_detach()
347             mpp_node_task_detach(&p->task);  in mpp_node_deinit()
425         MppNodeTask *task = NULL;  in cluster_worker_get_task()  local
439             task = list_first_entry(&queue->list, MppNodeTask, list_sched);  in cluster_worker_get_task()
440             list_del_init(&task->list_sched);  in cluster_worker_get_task()
441             node = task->node;  in cluster_worker_get_task()
453             list_add_tail(&task->list_sched, &p->list_task);  in cluster_worker_get_task()
483         MppNodeTask *task = list_first_entry(&p->list_task, MppNodeTask, list_sched);  in cluster_worker_run_task()  local
484         MppNodeProc *proc = task->proc;  in cluster_worker_run_task()
485         MppNodeImpl *node = task->node;  in cluster_worker_run_task()
492         cluster_dbg_flow("%s run %s start atate %d\n", p->name, task->node_name, node->state);  in cluster_worker_run_task()
501         cluster_dbg_flow("%s run %s ret %d\n", p->name, task->node_name, proc_ret);  in cluster_worker_run_task()
508             list_del_init(&task->list_sched);  in cluster_worker_run_task()
514             ClusterQueue *queue = task->queue;  in cluster_worker_run_task()
516             list_del_init(&task->list_sched);  in cluster_worker_run_task()
528             list_add_tail(&task->list_sched, &queue->list);  in cluster_worker_run_task()
532             list_del_init(&task->list_sched);  in cluster_worker_run_task()
750     mpp_node_task_attach(&impl->task, impl, queue, &impl->work);  in mpp_node_attach()
757     mpp_node_task_schedule(&impl->task);  in mpp_node_attach()
767     mpp_node_task_detach(&impl->task);  in mpp_node_detach()
778         mpp_node_task_schedule_from(caller, &impl->task);  in mpp_node_trigger_f()