Home
last modified time | relevance | path

Searched refs:cpu_queue (Results 1 – 2 of 2) sorted by relevance

/DragonOS-0.1.5/kernel/src/sched/
Dcfs.rs114 cpu_queue: Vec<&'static mut CFSQueue>, field
122 cpu_queue: Default::default(), in new()
128 .cpu_queue in new()
132 result.cpu_queue[0].idle_pcb = unsafe { &mut initial_proc_union.pcb }; in new()
148 let current_cpu_queue: &mut CFSQueue = self.cpu_queue[current_pcb().cpu_id as usize]; in timer_update_jiffies()
166 let cpu_queue = &mut self.cpu_queue[pcb.cpu_id as usize]; in enqueue_reset_vruntime() localVariable
167 if cpu_queue.queue.len() > 0 { in enqueue_reset_vruntime()
168 pcb.virtual_runtime = cpu_queue.min_vruntime().unwrap(); in enqueue_reset_vruntime()
171 cpu_queue.enqueue(pcb); in enqueue_reset_vruntime()
177 self.cpu_queue[cpu_id].idle_pcb = pcb; in set_cpu_idle()
[all …]
Drt.rs98 cpu_queue: Vec<Vec<&'static mut RTQueue>>, field
110 cpu_queue: Default::default(), in new()
116 result.cpu_queue.push(Vec::new()); in new()
119 result.cpu_queue[cpu_id as usize].push(Box::leak(Box::new(RTQueue::new()))); in new()
136 let cpu_queue_i: &mut RTQueue = self.cpu_queue[cpu_id as usize][i as usize]; in pick_next_task_rt()
149 sum += self.cpu_queue[cpu_id as usize][prio as usize].get_rt_queue_size(); in get_rt_queue_len()
159 self.cpu_queue[pcb.cpu_id as usize][pcb.priority as usize].enqueue_front(pcb); in enqueue_front()
205 self.cpu_queue[cpu_id as usize][proc.cpu_id as usize].enqueue_front(proc); in sched()
213 let cpu_queue = &mut self.cpu_queue[pcb.cpu_id as usize]; in enqueue() localVariable
214 cpu_queue[cpu_id as usize].enqueue(pcb); in enqueue()