diff options
| author | Lennard Kittner <lennard@kittner.dev> | 2025-03-09 15:36:26 +0100 |
|---|---|---|
| committer | Lennard Kittner <lennard@kittner.dev> | 2025-03-09 15:37:58 +0100 |
| commit | 9ceb02c0f886a10fe8a620ad879512fa6639f6f6 (patch) | |
| tree | 4474e12edf463e71291c2df2cd55ec996b82cd09 /src/e_core_selector.rs | |
| parent | dac2e1ac162c82bf02be2859e5a5d9860d0ef061 (diff) | |
Try to keep tasks on the same e-core
Diffstat (limited to 'src/e_core_selector.rs')
| -rw-r--r-- | src/e_core_selector.rs | 9 |
1 files changed, 5 insertions, 4 deletions
diff --git a/src/e_core_selector.rs b/src/e_core_selector.rs index 6952e80..251cbe8 100644 --- a/src/e_core_selector.rs +++ b/src/e_core_selector.rs @@ -1,10 +1,9 @@ use std::ops::Range; pub trait ECoreSelector { - fn next_core(&mut self) -> i32; + fn next_core(&mut self, previous_cpu: i32) -> i32; } -//TODO: better core selection e.g. try to keep task on the same core pub struct RoundRobinSelector { offset: u32, num_cores: u32, @@ -22,8 +21,10 @@ impl RoundRobinSelector { } impl ECoreSelector for RoundRobinSelector { - // TODO: use task cpu if suitable - fn next_core(&mut self) -> i32 { + fn next_core(&mut self, previous_cpu: i32) -> i32 { + if (self.offset..(self.offset + self.num_cores)).contains(&(previous_cpu as u32)) { + return previous_cpu; + } self.last_used += 1; (self.offset + (self.last_used % self.num_cores)) as i32 } |
