| 714 | #include <unistd.h> |
| 715 | |
| 716 | void SubgraphTask::OnTaskDone(bool exec_success) |
| 717 | { |
| 718 | input_wait_count_ = saved_input_wait_count_; |
| 719 | |
| 720 | if(!exec_success) |
| 721 | { |
| 722 | graph_task->OnSubgraphTaskError(this); |
| 723 | return; |
| 724 | } |
| 725 | |
| 726 | // for all output nodes, |
| 727 | for(unsigned int i = 0; i < sub_graph->output_nodes.size(); i++) |
| 728 | { |
| 729 | Node* node = sub_graph->output_nodes[i]; |
| 730 | OnOutputNodeDone(node, false); |
| 731 | } |
| 732 | |
| 733 | if(is_output_task) |
| 734 | graph_task->OnOutputSubgraphTaskDone(this); |
| 735 | } |
| 736 | |
| 737 | void SubgraphTask::OnOutputNodeDone(Node* node, bool sync_mode) |
| 738 | { |
no test coverage detected