| /DragonOS-0.1.9/kernel/src/driver/tty/virtual_terminal/ |
| D | virtual_console.rs | 38 pub state: VirtualConsoleInfo, field
149 state: VirtualConsoleInfo::new(0, 0), in new()
216 self.pos = self.cols * self.state.y + self.state.x; in init()
283 self.state.x = 0; in reset()
284 self.state.y = 0; in reset()
526 .con_putc(&self, i as u16, self.state.y as u32, self.state.x as u32); in add_softcursor()
543 self.state.y as u32, in hide_softcursor()
544 self.state.x as u32, in hide_softcursor()
562 self.state.x = 0; in gotoxy()
565 self.state.x = self.cols - 1; in gotoxy()
[all …]
|
| /DragonOS-0.1.9/docs/kernel/sched/ |
| D | rust_waiting.md | 44 // 唤醒等待队列头部的进程（如果它的state & PROC_INTERRUPTIBLE 不为0）
47 // 唤醒等待队列头部的进程（如果它的state & PROC_UNINTERRUPTIBLE 不为0）
50 // 唤醒等待队列头部的进程（无论它的state是什么）
71   您可以使用`wakeup(state)`函数，唤醒等待队列中的第一个进程。如果这个进程的state与给定的state进行and操作之后，结果不为0,则唤醒它。
|
| D | c_waiting.md | 67 …ue_wakeup(wait_queue_node_t * wait_queue_head, int64_t state);`函数，从指定的等待队列中，唤醒第一个挂起时的状态与指定的`state`…
127 …于在栈上的wait_node,您可以选择`wait_queue_wakeup_on_stack(wait_queue_head_t *q, int64_t state)`来唤醒队列里面的队列头节点。
|
| D | rt.md | 10    RTQueue是用来存放state为running的实时进程的调度队列，每个CPU维护一个RTQueue，主要使用Vec作为主要存储结构来实现。
|
| /DragonOS-0.1.9/kernel/src/driver/base/platform/ |
| D | platform_device.rs | 160 let state = self.inner.lock().state; in is_initialized() localVariable
161 match state { in is_initialized()
173 let state = &mut self.inner.lock().state; in set_state() localVariable
174 *state = set_state; in set_state()
183 let state = self.inner.lock().state; in get_state() localVariable
184 return state; in get_state()
193 state: BusState, // 总线状态 field
211 state: BusState::NotInitialized, in new()
259 fn set_kobj_state(&self, state: KObjectState) { in set_kobj_state()
260 *self.kobj_state.write() = state; in set_kobj_state()
|
| /DragonOS-0.1.9/kernel/src/exception/ |
| D | irqdata.rs | 85 .state in is_level_type()
95 .state in is_wakeup_set()
194 state: IrqStatus::empty(), in new()
215 .state in clear_managed_shutdown()
221 self.inner.lock_irqsave().state.masked() in masked()
227 .state in set_masked()
238 .state in set_inprogress()
245 .state in clear_inprogress()
250 self.inner.lock_irqsave().state.disabled() in disabled()
257 .state in set_disabled()
[all …]
|
| /DragonOS-0.1.9/tools/debugging/logmonitor/src/ |
| D | app.rs | 173 pub state: ListState, field
180 state: ListState::default(), in with_items()
186 let i = match self.state.selected() { in next()
196 self.state.select(Some(i)); in next()
200 let i = match self.state.selected() { in previous()
210 self.state.select(Some(i)); in previous()
|
| /DragonOS-0.1.9/kernel/src/libs/ |
| D | wait_queue.rs | 187 pub fn wakeup(&self, state: Option<ProcessState>) -> bool { in wakeup()
194 if let Some(state) = state { in wakeup()
201 .state() in wakeup()
202 != state in wakeup()
216 pub fn wakeup_all(&self, state: Option<ProcessState>) { in wakeup_all()
227 if let Some(state) = state { in wakeup_all()
228 if to_wakeup.sched_info().inner_lock_read_irqsave().state() == state { in wakeup_all()
|
| D | once.rs | 128 pub fn state(&self) -> OnceState { in state() method
|
| /DragonOS-0.1.9/kernel/src/driver/base/ |
| D | kobject.rs | 57 fn set_kobj_state(&self, state: KObjectState); in set_kobj_state()
65 let mut state = self.kobj_state_mut(); in update_kobj_state() localVariable
66 *state = (*state | insert) & !remove; in update_kobj_state()
98 pub fn new(state: Option<KObjectState>) -> LockedKObjectState { in new()
99 let state = state.unwrap_or(KObjectState::empty()); in new() localVariable
100 LockedKObjectState(RwLock::new(state)) in new()
|
| D | kset.rs | 32 fn hash<H: core::hash::Hasher>(&self, state: &mut H) { in hash()
33 self.self_ref.as_ptr().hash(state); in hash()
34 self.inner.read().name.hash(state); in hash()
202 fn set_kobj_state(&self, state: KObjectState) { in set_kobj_state()
203 *self.kobj_state.write() = state; in set_kobj_state()
|
| D | cpu.rs | 246 fn set_kobj_state(&self, state: KObjectState) { in set_kobj_state()
247 *self.kobj_state_mut() = state; in set_kobj_state()
|
| /DragonOS-0.1.9/kernel/src/process/ |
| D | exit.rs | 157 let state = pcb.sched_info().inner_lock_read_irqsave().state(); in do_wait() localVariable
158 if state.is_exited() { in do_wait()
159 kwo.ret_status = state.exit_code().unwrap() as i32; in do_wait()
183 let state = child_pcb.sched_info().inner_lock_read_irqsave().state(); in do_waitpid() localVariable
185 match state { in do_waitpid()
|
| D | mod.rs | 205 let state = pcb.sched_info().inner_lock_read_irqsave().state(); in wakeup() localVariable
206 if state.is_blocked() { in wakeup()
208 let state = writer.state(); in wakeup() localVariable
209 if state.is_blocked() { in wakeup()
216 } else if state.is_exited() { in wakeup()
221 } else if state.is_exited() { in wakeup()
231 let state = pcb.sched_info().inner_lock_read_irqsave().state(); in wakeup_stop() localVariable
232 if let ProcessState::Stopped = state { in wakeup_stop()
234 let state = writer.state(); in wakeup_stop() localVariable
235 if let ProcessState::Stopped = state { in wakeup_stop()
[all …]
|
| /DragonOS-0.1.9/kernel/src/ipc/ |
| D | signal.rs | 208 let state = pcb.sched_info().inner_lock_read_irqsave().state(); in wants_signal() localVariable
209 if state.is_blocked() && (state.is_blocked_interruptable() == false) { in wants_signal()
296 let state = pcb.sched_info().inner_lock_read_irqsave().state(); in signal_wake_up() localVariable
298 if state.is_blocked_interruptable() { in signal_wake_up()
308 } else if state.is_stopped() { in signal_wake_up()
|
| /DragonOS-0.1.9/kernel/src/sched/ |
| D | core.rs | 118 let state = guard.state(); in do_sched() localVariable
119 if state.is_blocked() { in do_sched()
163 if pcb.sched_info().inner_lock_read_irqsave().state() != ProcessState::Runnable { in sched_enqueue()
|
| D | cfs.rs | 228 let state = ProcessManager::current_pcb() in sched() localVariable
231 .state(); in sched()
232 if (state != ProcessState::Runnable) in sched()
238 if state == ProcessState::Runnable { in sched()
|
| /DragonOS-0.1.9/kernel/src/driver/base/device/ |
| D | mod.rs | 209 state: DeviceState, field
214 pub fn new(id_table: IdTable, state: DeviceState) -> Self { in new()
215 Self { id_table, state } in new()
222 pub fn state(&self) -> DeviceState { in state() method
223 self.state in state()
226 pub fn set_state(&mut self, state: DeviceState) { in set_state()
227 self.state = state; in set_state()
327 fn from(state: u32) -> Self { in from()
328 match state { in from()
338 fn from(state: DeviceState) -> Self { in from()
[all …]
|
| D | bus.rs | 68 fn from(state: u32) -> Self { in from()
69 match state { in from()
79 fn from(state: DeviceState) -> Self { in from()
80 match state { in from()
90 fn from(state: BusState) -> Self { in from()
91 match state { in from()
|
| /DragonOS-0.1.9/kernel/src/smp/cpu/ |
| D | c_adapter.rs | 34 let can_boot = ap.state == acpi::platform::ProcessorState::WaitingForSipi; in rs_smp_get_cpus()
51 processor_info.boot_processor.state == acpi::platform::ProcessorState::WaitingForSipi, in rs_smp_get_cpus()
|
| /DragonOS-0.1.9/kernel/src/driver/input/serio/i8042/ |
| D | i8042_device.rs | 161 fn set_kobj_state(&self, state: KObjectState) { in set_kobj_state()
162 *self.kobj_state.write() = state; in set_kobj_state()
|
| D | i8042_ports.rs | 159 fn set_kobj_state(&self, state: KObjectState) { in set_kobj_state()
160 *self.kobj_state.write() = state; in set_kobj_state()
|
| D | i8042_driver.rs | 187 fn set_kobj_state(&self, state: KObjectState) { in set_kobj_state()
188 *self.kobj_state.write() = state; in set_kobj_state()
|
| /DragonOS-0.1.9/kernel/src/driver/serial/serial8250/ |
| D | mod.rs | 308 fn set_kobj_state(&self, state: KObjectState) { in set_kobj_state()
309 *self.kobj_state.write() = state; in set_kobj_state()
521 fn set_kobj_state(&self, state: KObjectState) { in set_kobj_state()
522 *self.kobj_state.write() = state; in set_kobj_state()
|
| /DragonOS-0.1.9/kernel/src/net/socket/ |
| D | mod.rs | 809 let state = socket.state(); in tcp_poll() localVariable
810 if state != tcp::State::SynSent && state != tcp::State::SynReceived { in tcp_poll()
828 } else if state == tcp::State::SynSent { in tcp_poll()
|