Method OnOutputNodeDone

executor/lib/graph_task.cpp:737–765

}

void SubgraphTask::OnOutputNodeDone(Node* node, bool sync_mode)
{
    int out_tensor_num = node->GetOutputNum();

    for(int i = 0; i < out_tensor_num; i++)
    {
        Tensor* out_tensor = node->GetOutputTensor(i);

        for(unsigned int j = 0; j < out_tensor->consumer.size(); j++)
        {
            NodePort* port = out_tensor->consumer[j];
            Node* consumer = port->owner;

            if(!consumer->ExistAttr("consumer_task"))
            {
                /*
                LOG_DEBUG()<<"consumer: "<<consumer->GetName()
                    <<" has no task attached. from node: "
                    <<node->GetName()<<"\n";
                */
                continue;
            }

            SubgraphTask* consumer_task = any_cast<SubgraphTask*>(consumer->GetAttr("consumer_task"));

            consumer_task->OnNodeInputTensorReady(consumer, port->port_index, sync_mode);
        }
    }
}

void SubgraphTask::OnNodeInputTensorReady(Node* node, int input_idx, bool sync_mode)
{