| 233 | } |
| 234 | |
| 235 | void server_response::add_waiting_task_ids(const std::unordered_set<int> & id_tasks) { |
| 236 | std::unique_lock<std::mutex> lock(mutex_results); |
| 237 | |
| 238 | for (const auto & id_task : id_tasks) { |
| 239 | RES_DBG("add task %d to waiting list. current waiting = %d (before add)\n", id_task, (int) waiting_task_ids.size()); |
| 240 | waiting_task_ids.insert(id_task); |
| 241 | } |
| 242 | } |
| 243 | |
| 244 | void server_response::remove_waiting_task_id(int id_task) { |
| 245 | RES_DBG("remove task %d from waiting list. current waiting = %d (before remove)\n", id_task, (int) waiting_task_ids.size()); |
no test coverage detected