Causes the queue to wait until an event on another queue has occured. the other queue must be from the same backend
| 593 | /// Causes the queue to wait until an event on another queue has occured. |
| 594 | /// the other queue must be from the same backend |
| 595 | result omp_queue::submit_queue_wait_for(const dag_node_ptr& node) { |
| 596 | HIPSYCL_DEBUG_INFO << "omp_queue: Submitting wait for other queue..." |
| 597 | << std::endl; |
| 598 | auto evt = node->get_event(); |
| 599 | if (!evt) { |
| 600 | return register_error( |
| 601 | __acpp_here(), |
| 602 | error_info{"omp_queue: event for synchronization is null.", |
| 603 | error_type::invalid_parameter_error}); |
| 604 | } |
| 605 | |
| 606 | _worker([=]() { evt->wait(); }); |
| 607 | |
| 608 | return make_success(); |
| 609 | } |
| 610 | |
| 611 | result omp_queue::wait() { |
| 612 | _worker.wait(); |
nothing calls this directly
no test coverage detected