| 271 | } |
| 272 | |
| 273 | int Scheduler::schedule_node(Task &task) { |
| 274 | int node_id = task.node_id_; |
| 275 | std::shared_ptr<Node> node; |
| 276 | callback_.get_node_(node_id, node); |
| 277 | node->inc_pending_task(); |
| 278 | std::shared_ptr<SchedulerQueue> scheduler_queue; |
| 279 | int scheduler_queue_id = node->get_scheduler_queue_id(); |
| 280 | scheduler_queue = scheduler_queues_[scheduler_queue_id]; |
| 281 | // TODO: ??? Useless priority |
| 282 | scheduler_queue->add_task(task, 1); |
| 283 | return 0; |
| 284 | } |
| 285 | |
| 286 | int Scheduler::clear_task(int node_id, int scheduler_queue_id) { |
| 287 | std::shared_ptr<SchedulerQueue> scheduler_queue = |
no test coverage detected