| 255 | } |
| 256 | |
| 257 | void server_response::remove_waiting_task_ids(const std::unordered_set<int> & id_tasks) { |
| 258 | std::unique_lock<std::mutex> lock(mutex_results); |
| 259 | |
| 260 | for (const auto & id_task : id_tasks) { |
| 261 | RES_DBG("remove task %d from waiting list. current waiting = %d (before remove)\n", id_task, (int) waiting_task_ids.size()); |
| 262 | waiting_task_ids.erase(id_task); |
| 263 | } |
| 264 | } |
| 265 | |
| 266 | server_task_result_ptr server_response::recv(const std::unordered_set<int> & id_tasks) { |
| 267 | while (true) { |