Searched refs:queue (Results 1 – 7 of 7) sorted by relevance
| /DragonOS-0.1.5/kernel/src/sched/ |
| D | cfs.rs | 45 queue: Vec<&'static mut process_control_block>, field
55 queue: Vec::new(), in new()
63 self.queue in sort()
76 self.queue.push(pcb); in enqueue()
85 if self.queue.len() > 0 { in dequeue()
87 res = self.queue.pop().unwrap(); in dequeue()
100 if !self.queue.is_empty() { in min_vruntime()
101 return Some(self.queue.first().unwrap().virtual_runtime); in min_vruntime()
108 return self.queue.len(); in get_cfs_queue_size()
167 if cpu_queue.queue.len() > 0 { in enqueue_reset_vruntime()
|
| D | rt.rs | 43 queue: LinkedList<&'static mut process_control_block>, field
49 queue: LinkedList::new(), in new()
62 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()
88 self.queue.push_front(pcb); in enqueue_front()
92 return self.queue.len(); in get_rt_queue_size()
|
| /DragonOS-0.1.5/kernel/src/driver/virtio/ |
| D | transport_pci.rs | 260 fn notify(&mut self, queue: u16) { in notify()
264 volwrite!(self.common_cfg, queue_select, queue); in notify()
270 addr_of_mut!((*self.notify_region.as_ptr())[index]).vwrite(queue); in notify()
288 queue: u16, in queue_set()
297 volwrite!(self.common_cfg, queue_select, queue); in queue_set()
306 fn queue_unset(&mut self, queue: u16) { in queue_unset()
311 volwrite!(self.common_cfg, queue_select, queue); in queue_unset()
319 fn queue_used(&mut self, queue: u16) -> bool { in queue_used()
323 volwrite!(self.common_cfg, queue_select, queue); in queue_used()
|
| /DragonOS-0.1.5/kernel/src/process/ |
| D | fork.rs | 119 let queue = Box::from_raw((*pcb).sig_pending.sigqueue as *mut SigQueue); in process_exit_signal() localVariable
120 drop(queue); in process_exit_signal()
|
| /DragonOS-0.1.5/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.5/kernel/src/ipc/ |
| D | signal_types.rs | 253 pub queue: *mut SigQueue, field
|
| D | signal.rs | 589 let (info, still_pending) = unsafe { pending.queue.as_mut() } in collect_signal()
|