diff options
| -rw-r--r-- | src/main.rs | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/src/main.rs b/src/main.rs index 6cbc1fa..faac9a7 100644 --- a/src/main.rs +++ b/src/main.rs @@ -216,7 +216,8 @@ impl<'a> Scheduler<'a> { // If no task is ready to run (or in case of error), stop dispatching tasks and notify // the BPF component that all tasks have been scheduled / dispatched, with no remaining // pending tasks. - if self.task_queue.is_empty() { + //TODO: both queues? + if self.task_queue.is_empty() && self.no_budget_task_queue.is_empty() { self.bpf.notify_complete(0); break; } |