Searched refs:queue (Results 1 – 7 of 7) sorted by relevance
| /DragonOS-0.1.8/kernel/src/sched/ |
| D | cfs.rs | 44 queue: RBTree<i64, &'static mut process_control_block>, field
54 queue: RBTree::new(), in new()
70 self.queue.insert(pcb.virtual_runtime, pcb); in enqueue()
80 if !self.queue.is_empty() { in dequeue()
82 res = self.queue.pop_first().unwrap().1; in dequeue()
95 if !self.queue.is_empty() { in min_vruntime()
96 return Some(self.queue.get_first().unwrap().1.virtual_runtime); in min_vruntime()
103 return self.queue.len(); in get_cfs_queue_size()
162 if cpu_queue.queue.len() > 0 { in enqueue_reset_vruntime()
|
| D | rt.rs | 41 queue: LinkedList<&'static mut process_control_block>, field
47 queue: LinkedList::new(), in new()
61 self.queue.push_back(pcb); in enqueue()
70 if self.queue.len() > 0 { in dequeue()
72 res = Some(self.queue.pop_front().unwrap()); in dequeue()
89 self.queue.push_front(pcb); in enqueue_front()
93 return self.queue.len(); in get_rt_queue_size()
|
| /DragonOS-0.1.8/kernel/src/driver/virtio/ |
| D | transport_pci.rs | 233 fn notify(&mut self, queue: u16) { in notify()
237 volwrite!(self.common_cfg, queue_select, queue); in notify()
243 addr_of_mut!((*self.notify_region.as_ptr())[index]).vwrite(queue); in notify()
263 queue: u16, in queue_set()
276 volwrite!(self.common_cfg, queue_select, queue); in queue_set()
285 fn queue_unset(&mut self, queue: u16) { in queue_unset()
289 volwrite!(self.common_cfg, queue_select, queue); in queue_unset()
297 fn queue_used(&mut self, queue: u16) -> bool { in queue_used()
301 volwrite!(self.common_cfg, queue_select, queue); in queue_used()
|
| /DragonOS-0.1.8/kernel/src/process/ |
| D | fork.rs | 120 let queue = Box::from_raw((*pcb).sig_pending.sigqueue as *mut SigQueue); in process_exit_signal() localVariable
121 drop(queue); in process_exit_signal()
|
| /DragonOS-0.1.8/docs/userland/libc/apis/api-list/ |
| D | errno.md | 101 … #define ENODATA 43 /* 队列头没有可读取的消息 No message is available on the STREAM head read queue.*/
|
| /DragonOS-0.1.8/kernel/src/ipc/ |
| D | signal_types.rs | 254 pub queue: *mut SigQueue, field
|
| D | signal.rs | 550 let (info, still_pending) = unsafe { pending.queue.as_mut() } in collect_signal()
|