| 335 | } |
| 336 | |
| 337 | result ze_queue::wait() { |
| 338 | std::shared_ptr<dag_node_event> _last_event; |
| 339 | { |
| 340 | std::lock_guard<std::mutex> lock{_mutex}; |
| 341 | _last_event = _last_submitted_op_event; |
| 342 | } |
| 343 | if(_last_event) |
| 344 | _last_event->wait(); |
| 345 | return make_success(); |
| 346 | } |
| 347 | |
| 348 | result ze_queue::submit_queue_wait_for(const dag_node_ptr& node) { |
| 349 | std::lock_guard<std::mutex> lock{_mutex}; |
no test coverage detected