| 784 | } |
| 785 | |
| 786 | void SubgraphTask::OnInputNodeReady(Node* node, bool sync_mode) |
| 787 | { |
| 788 | if(input_wait_count_.fetch_sub(1) == 1 && !sync_mode) |
| 789 | { |
| 790 | // all input nodes are ready |
| 791 | graph_task->RunSubgraphTask(this); |
| 792 | } |
| 793 | } |
| 794 | |
| 795 | void SubgraphTask::SetNodeInputWaitMask(Node* node, std::uint64_t wait_mask) |
| 796 | { |
nothing calls this directly
no test coverage detected