Method DevRun

executor/lib/node_dev_executor.cpp:127–173

 */

bool NodeExecutor::DevRun(void* graph_handle)
{
    NodeContext* context = reinterpret_cast<NodeContext*>(graph_handle);
    Subgraph* graph = context->optimized_graph;
    Node* node;

    unsigned int i;
    for(i = 0; i < graph->seq_nodes.size(); i++)
    {
        node = graph->seq_nodes[i];
        node->SetNodeIndex(i);

        if(node->ExistAttr("DEV_RUN"))
            break;
    }

    if(i == graph->seq_nodes.size())
        return true;

    // set callback

    auto f = std::bind(&NodeExecutor::OnNodeDone, this, context, std::placeholders::_1, std::placeholders::_2);

    backend_dev_->SetNodeDoneHook(context->dev_context, dev_node_cb_t(f));

    std::cout << "Run graph: " << graph->GetName() << " from node: " << node->GetName() << "\n";

    if(worker_)
    {
        // push the node to worker
        NodeTask task;
        task.dev_context = context->dev_context;
        task.node = node;

        std::vector<NodeTask> list;

        list.emplace_back(task);

        worker_->PushTask(list);

        return true;
    }
    else
    {
        return backend_dev_->Run(context->dev_context, node);
    }
}

void NodeExecutor::ProcessTask(const NodeTask& task)
{