Method OnNodeDone

executor/lib/node_dev_executor.cpp:180–234

}

void NodeExecutor::OnNodeDone(NodeContext* context, Node* node, bool exec_success)
{
    Subgraph* graph = context->optimized_graph;

    if(!exec_success)
    {
        OnSubgraphDone(graph, false);

        return;
    }

    std::cout << "node " << node->GetName() << " is done\n";
    // search next node to run

    unsigned int idx = node->GetNodeIndex();

    Node* next_node = nullptr;

    for(idx++; idx < graph->seq_nodes.size(); idx++)
    {
        next_node = graph->seq_nodes[idx];
        next_node->SetNodeIndex(idx);

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

    if(idx < graph->seq_nodes.size())
    {
        std::cout << "issue node: " << next_node->GetName() << " to run\n";

        if(worker_)
        {
            NodeTask task;

            task.dev_context = context->dev_context;
            task.node = next_node;

            std::vector<NodeTask> list;

            list.emplace_back(task);

            worker_->PushTask(list);
        }
        else
        {
            backend_dev_->Run(context->dev_context, next_node);
        }
    }
    else
    {
        std::cout << "graph " << graph->GetName() << " is done\n";
        OnSubgraphDone(graph, true);
    }
}

bool NodeExecutor::DevSyncRun(void* graph_handle)
{