Searched refs:queue (Results 1 – 6 of 6) sorted by relevance
| /DragonOS-0.1.9/kernel/src/sched/ |
| D | cfs.rs | 66 let mut queue = self.locked_queue.lock_irqsave(); in enqueue() localVariable
73 queue.insert(pcb.sched_info().virtual_runtime() as i64, pcb.clone()); in enqueue()
79 let mut queue = self.locked_queue.lock_irqsave(); in dequeue() localVariable
80 if !queue.is_empty() { in dequeue()
82 res = queue.pop_first().unwrap().1; in dequeue()
94 queue: &SpinLockGuard<RBTree<i64, Arc<ProcessControlBlock>>>, in min_vruntime()
96 if !queue.is_empty() { in min_vruntime()
97 return Some(queue.get_first().unwrap().1.sched_info().virtual_runtime() as i64); in min_vruntime()
105 queue: &SpinLockGuard<RBTree<i64, Arc<ProcessControlBlock>>>, in get_cfs_queue_size()
107 return queue.len(); in get_cfs_queue_size()
[all …]
|
| D | rt.rs | 53 let mut queue = self.locked_queue.lock_irqsave(); in enqueue() localVariable
59 queue.push_back(pcb); in enqueue()
65 let mut queue = self.locked_queue.lock_irqsave(); in dequeue() localVariable
66 if queue.len() > 0 { in dequeue()
68 res = Some(queue.pop_front().unwrap()); in dequeue()
76 let mut queue = self.locked_queue.lock_irqsave(); in enqueue_front() localVariable
82 queue.push_front(pcb); in enqueue_front()
87 let queue = self.locked_queue.lock_irqsave(); in get_rt_queue_size() localVariable
88 return queue.len(); in get_rt_queue_size()
|
| /DragonOS-0.1.9/build-scripts/kernel_build/src/utils/ |
| D | mod.rs | 16 let mut queue: Vec<PathBuf> = Vec::new(); in list_all_files() localVariable
18 queue.push(path.clone()); in list_all_files()
20 while !queue.is_empty() { in list_all_files()
21 let path = queue.pop().unwrap(); in list_all_files()
40 queue.push(ent.path()); in list_all_files()
|
| /DragonOS-0.1.9/kernel/src/driver/virtio/ |
| D | transport_pci.rs | 281 fn notify(&mut self, queue: u16) { in notify()
285 volwrite!(self.common_cfg, queue_select, queue); in notify()
291 addr_of_mut!((*self.notify_region.as_ptr())[index]).vwrite(queue); in notify()
311 queue: u16, in queue_set()
320 volwrite!(self.common_cfg, queue_select, queue); in queue_set()
326 if queue == QUEUE_RECEIVE { in queue_set()
337 fn queue_unset(&mut self, queue: u16) { in queue_unset()
341 volwrite!(self.common_cfg, queue_select, queue); in queue_unset()
349 fn queue_used(&mut self, queue: u16) -> bool { in queue_used()
353 volwrite!(self.common_cfg, queue_select, queue); in queue_used()
|
| /DragonOS-0.1.9/kernel/src/ipc/ |
| D | signal_types.rs | 359 queue: SigQueue, field
366 queue: SigQueue::default(), in default()
381 pub fn queue(&self) -> &SigQueue { in queue() method
382 &self.queue in queue()
386 &mut self.queue in queue_mut()
461 self.queue.q.retain(filter); in flush_by_mask()
|
| D | signal.rs | 103 else if !self.is_rt_signal() && pending.queue().find(self.clone()).0.is_some() { in send_signal()
|