* @brief Wait for stage processing to complete. */
| 298 | * @brief Wait for stage processing to complete. |
| 299 | */ |
| 300 | void wait() |
| 301 | { |
| 302 | std::unique_lock<std::mutex> lck(m_lock); |
| 303 | m_complete.wait(lck, [this]{ return m_is_cancelled || m_done_count == m_task_count; }); |
| 304 | } |
| 305 | |
| 306 | /** |
| 307 | * @brief Trigger the pipeline stage term step. |
no outgoing calls
no test coverage detected