| 500 | } |
| 501 | |
| 502 | auto get_remote_queue() noexcept -> remote_queue* |
| 503 | { |
| 504 | remote_queue* queue = remotes_.get(); |
| 505 | std::size_t index = 0; |
| 506 | for (std::thread& t: threads_) |
| 507 | { |
| 508 | if (t.get_id() == queue->id_) |
| 509 | { |
| 510 | queue->index_ = index; |
| 511 | break; |
| 512 | } |
| 513 | |
| 514 | ++index; |
| 515 | } |
| 516 | return queue; |
| 517 | } |
| 518 | |
| 519 | void request_stop() noexcept; |
| 520 |
no test coverage detected