Lines Matching refs:cpu_id
116 for cpu_id in 0..MAX_CPU_NUM { in new()
120 result.cpu_queue[cpu_id as usize].push(Box::leak(Box::new(RTQueue::new()))); in new()
133 pub fn pick_next_task_rt(&mut self, cpu_id: u32) -> Option<&'static mut process_control_block> { in pick_next_task_rt()
137 let cpu_queue_i: &mut RTQueue = self.cpu_queue[cpu_id as usize][i as usize]; in pick_next_task_rt()
147 pub fn rt_queue_len(&mut self, cpu_id: u32) -> usize { in rt_queue_len()
150 sum += self.cpu_queue[cpu_id as usize][prio as usize].get_rt_queue_size(); in rt_queue_len()
157 pub fn load_list_len(&mut self, cpu_id: u32) -> usize { in load_list_len()
158 return self.load_list[cpu_id as usize].len(); in load_list_len()
162 self.cpu_queue[pcb.cpu_id as usize][pcb.priority as usize].enqueue_front(pcb); in enqueue_front()
172 let cpu_id = current_pcb().cpu_id; in sched() localVariable
174 self.pick_next_task_rt(cpu_id).expect("No RT process found"); in sched()
208 self.cpu_queue[cpu_id as usize][proc.cpu_id as usize].enqueue_front(proc); in sched()
215 let cpu_id = pcb.cpu_id; in enqueue() localVariable
216 let cpu_queue = &mut self.cpu_queue[pcb.cpu_id as usize]; in enqueue()
217 cpu_queue[cpu_id as usize].enqueue(pcb); in enqueue()