Cleanup

1 files changed, 1 insertions, 28 deletions

diff --git a/src/main.rs b/src/main.rs
index 6f5d2ae..8a94ff6 100644
--- a/src/main.rs
+++ b/src/main.rs
@@ -55,14 +55,8 @@ struct Scheduler<'a> {
 
 enum Request {
     NewTask,
-    Heartbeat,
-    ReadPerf,
     RemoveTask,
 }
-enum Response {
-    Parent(i32),
-    Energy(u64),
-}
 
 impl<'a> Scheduler<'a> {
     fn init(
@@ -100,7 +94,6 @@ impl<'a> Scheduler<'a> {
         let selector = Box::new(RoundRobinSelector::new(&e_cores));
 
         let (request_send, request_recieve) = std::sync::mpsc::sync_channel(1000);
-        let (response_send, response_recieve) = std::sync::mpsc::sync_channel(100);
 
         std::thread::spawn(move || {
             let mut module: Box<dyn KernelModule> = if use_mocking {
@@ -111,20 +104,13 @@ impl<'a> Scheduler<'a> {
             };
             let mut tasks = BTreeSet::new();
 
-            let mut i = 0;
             loop {
-                i += 1;
-                // if i % 1000 == 0 {
-                // println!("reading energy");
-                for pid in tasks.iter()
-                /*.nth((i / 100) % tasks.len().max(100))*/
-                {
+                for pid in tasks.iter() {
                     let energy = module.read_consumption(*pid as u64);
                     if let Some(mut entry) = thread_map.try_get_mut(pid).try_unwrap() {
                         entry.0 = energy;
                     }
                 }
-                // }
 
                 if let Ok((pid, request)) = request_recieve.try_recv() {
                     match request {
@@ -137,24 +123,11 @@ impl<'a> Scheduler<'a> {
                             module.start_trace(pid as u64);
                             tasks.insert(pid);
                             thread_map.insert(pid, (0, parent));
-
-                            // response_send
-                            //     .try_send((pid, Response::Parent(parent)))
-                            //     .unwrap();
-                        }
-                        Request::ReadPerf => {
-                            response_send
-                                .try_send((
-                                    pid,
-                                    Response::Energy(module.read_consumption(pid as u64)),
-                                ))
-                                .unwrap();
                         }
                         Request::RemoveTask => {
                             tasks.remove(&pid);
                             module.stop_trace(pid as u64)
                         }
-                        Request::Heartbeat => {}
                     }
                 }
                 std::thread::sleep(Duration::from_micros(5000));