Lines Matching refs:rq
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()
800 let current = rq.current(); in scheduler_tick()
803 rq.update_rq_clock(); in scheduler_tick()
806 SchedPolicy::CFS => CompletelyFairScheduler::tick(rq, current, false), in scheduler_tick()
809 SchedPolicy::IDLE => IdleScheduler::tick(rq, current, false), in scheduler_tick()
812 rq.calculate_global_load_tick(); in scheduler_tick()
832 let rq = cpu_rq(cpu); in __schedule() localVariable
834 let mut prev = rq.current(); in __schedule()
842 let (rq, _guard) = rq.self_lock(); in __schedule()
844 rq.clock_updata_flags = ClockUpdataFlag::from_bits_truncate(rq.clock_updata_flags.bits() << 1); in __schedule()
846 rq.update_rq_clock(); in __schedule()
847 rq.clock_updata_flags = ClockUpdataFlag::RQCF_UPDATE; in __schedule()
880 rq.deactivate_task( in __schedule()
886 let next = rq.pick_next_task(prev.clone()); in __schedule()
907 rq.set_current(Arc::downgrade(&next)); in __schedule()
973 let rq = cpu_rq(cpu.data() as usize); in __set_task_cpu() localVariable
974 se.force_mut().set_cfs(Arc::downgrade(&rq.cfs)); in __set_task_cpu()
989 let rq = Arc::new(CpuRunQueue::new(cpu)); in sched_init() localVariable
990 rq.cfs.force_mut().set_rq(Arc::downgrade(&rq)); in sched_init()
991 cpu_runqueue.push(rq); in sched_init()