Lines Matching refs:state

83     RK_U32                  state;  member
109 MppWorkerState state; member
232 node->state = NODE_VALID | NODE_IDLE; in mpp_node_task_attach()
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()
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()
324 node_name, node->state, proc->run_count); in mpp_node_task_detach()
382 p->state = WORKER_IDLE; in cluster_worker_init()
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()
488 RK_U32 state; 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()
506 if (!(state & NODE_VALID)) { in cluster_worker_run_task()
513 } else if (state & NODE_SIGNAL) { in cluster_worker_run_task()
519 old_st = state; 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()
573 p->state = WORKER_IDLE; in cluster_worker()
575 p->state = WORKER_RUNNING; in cluster_worker()
598 if (worker->state == WORKER_IDLE) { in cluster_signal_f()