Lines Matching refs:node

69     MppNodeImpl             *node;  member
221 MPP_RET mpp_node_task_attach(MppNodeTask *task, MppNodeImpl *node, in mpp_node_task_attach() argument
226 task->node = node; in mpp_node_task_attach()
227 task->node_name = node->name; in mpp_node_task_attach()
232 node->state = NODE_VALID | NODE_IDLE; in mpp_node_task_attach()
233 node->attached = 1; in mpp_node_task_attach()
242 MppNodeImpl *node = task->node; in mpp_node_task_schedule_f() local
250 node_name, caller, node->state, proc->run_count, queue->count); in mpp_node_task_schedule_f()
253 RK_U32 old_st = node->state; in mpp_node_task_schedule_f()
275 ret = MPP_BOOL_CAS(&node->state, old_st, new_st); in mpp_node_task_schedule_f()
299 node_name, caller, node->state, proc->run_count, queue->count); in mpp_node_task_schedule_f()
306 MppNodeImpl *node = task->node; in mpp_node_task_detach() local
309 if (node->attached) { in mpp_node_task_detach()
313 MPP_FETCH_AND(&node->state, ~NODE_VALID); in mpp_node_task_detach()
318 node_name, node->state, proc->run_count); in mpp_node_task_detach()
320 sem_wait(&node->sem_detach); in mpp_node_task_detach()
321 mpp_assert(node->attached == 0); in mpp_node_task_detach()
324 node_name, node->state, proc->run_count); in mpp_node_task_detach()
330 MPP_RET mpp_node_init(MppNode *node) in mpp_node_init() argument
336 *node = p; in mpp_node_init()
341 MPP_RET mpp_node_deinit(MppNode node) in mpp_node_deinit() argument
343 MppNodeImpl *p = (MppNodeImpl *)node; in mpp_node_deinit()
359 MPP_RET mpp_node_set_func(MppNode node, TaskProc proc, void *param) in mpp_node_set_func() argument
361 MppNodeImpl *p = (MppNodeImpl *)node; in mpp_node_set_func()
426 MppNodeImpl *node = NULL; in cluster_worker_get_task() local
441 node = task->node; in cluster_worker_get_task()
446 old_st = node->state; in cluster_worker_get_task()
450 ret = MPP_BOOL_CAS(&node->state, old_st, new_st); in cluster_worker_get_task()
457 cluster_dbg_flow("%s get P%d %s -> rq %d\n", p->name, i, node->name, p->work_count); in cluster_worker_get_task()
485 MppNodeImpl *node = task->node; in cluster_worker_run_task() local
492 cluster_dbg_flow("%s run %s start atate %d\n", p->name, task->node_name, node->state); in cluster_worker_run_task()
493 mpp_assert(node->state & NODE_RUN); in cluster_worker_run_task()
494 if (!(node->state & NODE_RUN)) in cluster_worker_run_task()
495 mpp_err_f("%s run state check %x is invalid on run", p->name, node->state); in cluster_worker_run_task()
505 state = node->state; in cluster_worker_run_task()
509 node->attached = 0; in cluster_worker_run_task()
511 sem_post(&node->sem_detach); in cluster_worker_run_task()
522 cas_ret = MPP_BOOL_CAS(&node->state, old_st, new_st); in cluster_worker_run_task()
534 old_st = node->state; in cluster_worker_run_task()
537 cas_ret = MPP_BOOL_CAS(&node->state, old_st, new_st); in cluster_worker_run_task()
539 mpp_assert(node->state & NODE_IDLE); in cluster_worker_run_task()
540 mpp_assert(!(node->state & NODE_RUN)); in cluster_worker_run_task()
736 MPP_RET mpp_node_attach(MppNode node, MppClientType type) in mpp_node_attach() argument
738 MppNodeImpl *impl = (MppNodeImpl *)node; in mpp_node_attach()
763 MPP_RET mpp_node_detach(MppNode node) in mpp_node_detach() argument
765 MppNodeImpl *impl = (MppNodeImpl *)node; in mpp_node_detach()
773 MPP_RET mpp_node_trigger_f(const char *caller, MppNode node, RK_S32 trigger) in mpp_node_trigger_f() argument
776 MppNodeImpl *impl = (MppNodeImpl *)node; in mpp_node_trigger_f()