diff options
Diffstat (limited to 'src')
| -rw-r--r-- | src/main.rs | 45 |
1 files changed, 24 insertions, 21 deletions
diff --git a/src/main.rs b/src/main.rs index e26218e..5a5051d 100644 --- a/src/main.rs +++ b/src/main.rs @@ -65,27 +65,29 @@ impl<'a> Scheduler<'a> { Box::new(KernelDriver::default()) }; - let e_cores_file = File::open("/sys/devices/cpu_atom/cpus")?; - let e_cores_reader = BufReader::new(e_cores_file); - let e_cores = if let Some(Ok(line)) = e_cores_reader.lines().next() { - let cores: Vec<&str> = line.split('-').collect(); - cores[0].parse::<i32>().unwrap()..cores[1].parse::<i32>().unwrap() - } else { - panic!( - "Was not able to differentiate between core types. Does the system have e cores?" - ) - }; + // let e_cores_file = File::open("/sys/devices/cpu_atom/cpus")?; + // let e_cores_reader = BufReader::new(e_cores_file); + // let e_cores = if let Some(Ok(line)) = e_cores_reader.lines().next() { + // let cores: Vec<&str> = line.split('-').collect(); + // cores[0].parse::<i32>().unwrap()..cores[1].parse::<i32>().unwrap() + // } else { + // panic!( + // "Was not able to differentiate between core types. Does the system have e cores?" + // ) + // }; - let p_cores_file = File::open("/sys/devices/cpu_core/cpus")?; - let p_cores_reader = BufReader::new(p_cores_file); - let p_cores = if let Some(Ok(line)) = p_cores_reader.lines().next() { - let cores: Vec<&str> = line.split('-').collect(); - cores[0].parse::<i32>().unwrap()..cores[1].parse::<i32>().unwrap() - } else { - panic!( - "Was not able to differentiate between core types. Does the system have e cores?" - ) - }; + // let p_cores_file = File::open("/sys/devices/cpu_core/cpus")?; + // let p_cores_reader = BufReader::new(p_cores_file); + // let p_cores = if let Some(Ok(line)) = p_cores_reader.lines().next() { + // let cores: Vec<&str> = line.split('-').collect(); + // cores[0].parse::<i32>().unwrap()..cores[1].parse::<i32>().unwrap() + // } else { + // panic!( + // "Was not able to differentiate between core types. Does the system have e cores?" + // ) + // }; + let e_cores = 0..2; + let p_cores = 2..4; let selector = Box::new(RoundRobinSelector::new(&e_cores)); @@ -217,6 +219,7 @@ impl<'a> Scheduler<'a> { } fn dispatch_tasks(&mut self) { + panic!(); loop { //TODO: we should probably not do this every time, but instead wait a predefined amount of time between invocations self.reset_budgets_and_garbage_collect(); @@ -241,7 +244,7 @@ impl<'a> Scheduler<'a> { } fn run(&mut self) -> Result<UserExitInfo> { - while !self.bpf.exited() { + while dbg!(!self.bpf.exited()) { self.dispatch_tasks(); } self.bpf.shutdown_and_report() |