Searched refs:rq (Results 1 – 7 of 7) sorted by relevance
| /DragonOS/kernel/src/sched/ |
| H A D | syscall.rs | 19 let rq = cpu_rq(pcb.sched_info().on_cpu().unwrap_or(current_cpu_id()).data() as usize); in do_sched_yield() localVariable
20 let (rq, guard) = rq.self_lock(); in do_sched_yield()
24 CompletelyFairScheduler::yield_task(rq); in do_sched_yield()
|
| H A D | mod.rs | 99 fn enqueue(rq: &mut CpuRunQueue, pcb: Arc<ProcessControlBlock>, flags: EnqueueFlag); in enqueue()
102 fn dequeue(rq: &mut CpuRunQueue, pcb: Arc<ProcessControlBlock>, flags: DequeueFlag); in dequeue()
105 fn yield_task(rq: &mut CpuRunQueue); in yield_task()
109 rq: &mut CpuRunQueue, in check_preempt_currnet()
116 fn pick_task(rq: &mut CpuRunQueue) -> Option<Arc<ProcessControlBlock>>; in pick_task()
120 rq: &mut CpuRunQueue, in pick_next_task()
125 fn tick(rq: &mut CpuRunQueue, pcb: Arc<ProcessControlBlock>, queued: bool); in tick()
130 fn put_prev_task(rq: &mut CpuRunQueue, prev: Arc<ProcessControlBlock>); in put_prev_task()
795 let rq = cpu_rq(cpu_idx); in scheduler_tick() localVariable
797 let (rq, guard) = rq.self_lock(); in scheduler_tick()
[all …]
|
| H A D | fair.rs | 348 rq: Weak<CpuRunQueue>, field
394 rq: Weak::new(), in new()
410 pub fn rq(&self) -> Arc<CpuRunQueue> { in rq() method
411 self.rq.upgrade().unwrap() in rq()
415 pub fn set_rq(&mut self, rq: Weak<CpuRunQueue>) { in set_rq()
416 self.rq = rq; in set_rq()
528 self.rq().resched_current(); in check_preempt_tick()
560 self.rq().resched_current(); in entity_tick()
572 let now = self.rq().clock_task(); in update_current()
620 self.rq().resched_current(); in account_cfs_rq_runtime()
[all …]
|
| H A D | pelt.rs | 210 let rq = self.rq(); in cfs_rq_clock_pelt() localVariable
211 let (rq, _guard) = rq.self_lock(); in cfs_rq_clock_pelt()
213 return rq.rq_clock_pelt() - self.throttled_clock_pelt_time; in cfs_rq_clock_pelt()
|
| H A D | idle.rs | 24 rq: &mut super::CpuRunQueue, in check_preempt_currnet()
28 rq.resched_current(); in check_preempt_currnet()
|
| /DragonOS/kernel/src/process/ |
| H A D | idle.rs | 64 let rq = cpu_rq(i as usize); in init_idle() localVariable
65 let (rq, _guard) = rq.self_lock(); in init_idle()
66 rq.set_current(Arc::downgrade(&idle_pcb)); in init_idle()
67 rq.set_idle(Arc::downgrade(&idle_pcb)); in init_idle()
75 .set_cfs(Arc::downgrade(&rq.cfs_rq())); in init_idle()
|
| H A D | mod.rs | 240 let rq = in wakeup() localVariable
243 let (rq, _guard) = rq.self_lock(); in wakeup()
244 rq.update_rq_clock(); in wakeup()
245 rq.activate_task( in wakeup()
250 rq.check_preempt_currnet(pcb, WakeupFlags::empty()); in wakeup()
278 let rq = cpu_rq(pcb.sched_info().on_cpu().unwrap().data() as usize); in wakeup_stop() localVariable
280 let (rq, _guard) = rq.self_lock(); in wakeup_stop()
281 rq.update_rq_clock(); in wakeup_stop()
282 rq.activate_task( in wakeup_stop()
287 rq.check_preempt_currnet(pcb, WakeupFlags::empty()); in wakeup_stop()
[all …]
|