Method Run

executor/lib/graph_task.cpp:314–365

}

bool GraphTask::Run(exec_event_t& event)
{
    wait_event_.mutex.lock();

    if(status_ != EXEC_STATUS_INITED && status_ != EXEC_STATUS_READY)
    {
        XLOG_ERROR() << "bad status: " << dev_engine_->GetStatusStr(status_) << "\n";
        wait_event_.mutex.unlock();
        return false;
    }

    /* inital status */
    status_ = EXEC_STATUS_RUN;
    wait_event_.mutex.unlock();

    output_wait_count_ = output_task_number_;
    active_sub_task_count_ = 0;
    task_done_ = false;

    wait_event_.wait_count = 0;
    int task_launched = 0;

    // let all input tasks run
    for(auto e : sub_task_list_)
    {
        if(!e->saved_input_wait_count_)
        {
            if(RunSubgraphTask(e))
                task_launched++;
            else
            {
                XLOG_ERROR() << "failed to run task on dev executor: " << e->dev_executor->GetName() << "\n";
                status_ = EXEC_STATUS_BAD;
                break;
            }
        }
    }

    if(!task_launched)
    {
        XLOG_ERROR() << "No sub task launched!!\n";

        status_ = EXEC_STATUS_BAD;
    }

    if(status_ == EXEC_STATUS_BAD)
        return false;

    event = &wait_event_;

    return true;
}

bool GraphTask::SetCallback(exec_event_t& e, int event, exec_cb_t cb)
{