| /DragonOS/kernel/src/driver/tty/virtual_terminal/ |
| H A D | virtual_console.rs | 45 pub state: VirtualConsoleInfo, field
158 state: VirtualConsoleInfo::new(0, 0), in new()
231 self.pos = self.cols * self.state.y + self.state.x; in init()
297 self.state.x = 0; in reset()
298 self.state.y = 0; in reset()
540 .con_putc(self, i as u16, self.state.y as u32, self.state.x as u32); in add_softcursor()
557 self.state.y as u32, in hide_softcursor()
558 self.state.x as u32, in hide_softcursor()
576 self.state.x = 0; in gotoxy()
578 self.state.x = self.cols - 1; in gotoxy()
[all …]
|
| /DragonOS/docs/kernel/sched/ |
| H A D | rust_waiting.md | 44 // 唤醒等待队列头部的进程（如果它的state & PROC_INTERRUPTIBLE 不为0）
47 // 唤醒等待队列头部的进程（如果它的state & PROC_UNINTERRUPTIBLE 不为0）
50 // 唤醒等待队列头部的进程（无论它的state是什么）
71   您可以使用`wakeup(state)`函数，唤醒等待队列中的第一个进程。如果这个进程的state与给定的state进行and操作之后，结果不为0,则唤醒它。
|
| H A 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)`来唤醒队列里面的队列头节点。
|
| H A D | rt.md | 10    RTQueue是用来存放state为running的实时进程的调度队列，每个CPU维护一个RTQueue，主要使用Vec作为主要存储结构来实现。
|
| /DragonOS/kernel/src/driver/base/platform/ |
| H A D | platform_device.rs | 162 let state = self.inner.lock().state; in is_initialized() localVariable
163 matches!(state, BusState::Initialized) in is_initialized()
172 let state = &mut self.inner.lock().state; in set_state() localVariable
173 *state = set_state; in set_state()
182 let state = self.inner.lock().state; in get_state() localVariable
183 return state; in get_state()
196 state: BusState, // 总线状态 field
206 state: BusState::NotInitialized, in new()
250 fn set_kobj_state(&self, state: KObjectState) { in set_kobj_state()
251 *self.kobj_state.write() = state; in set_kobj_state()
|
| /DragonOS/kernel/src/exception/ |
| H A D | irqdata.rs | 99 .state in is_level_type()
109 .state in is_wakeup_set()
210 state: IrqStatus::empty(), in new()
232 .state in clear_managed_shutdown()
238 self.inner.lock_irqsave().state.masked() in masked()
244 .state in set_masked()
255 .state in set_inprogress()
262 .state in clear_inprogress()
267 self.inner.lock_irqsave().state.disabled() in disabled()
274 .state in set_disabled()
[all …]
|
| /DragonOS/kernel/src/driver/net/ |
| H A D | mod.rs | 78 fn set_net_state(&self, state: NetDeivceState); in set_net_state()
82 fn set_operstate(&self, state: Operstate); in set_operstate()
93 pub state: NetDeivceState, field
103 state: NetDeivceState::empty(), in default()
|
| H A D | loopback.rs | 366 fn set_kobj_state(&self, state: KObjectState) { in set_kobj_state()
367 *self.locked_kobj_state.write() = state; in set_kobj_state()
522 return self.inner().netdevice_common.state; in net_state()
525 fn set_net_state(&self, state: NetDeivceState) { in set_net_state()
526 self.inner().netdevice_common.state |= state; in set_net_state()
533 fn set_operstate(&self, state: Operstate) { in set_operstate()
534 self.inner().netdevice_common.operstate = state; in set_operstate()
|
| H A D | virtio_net.rs | 180 fn set_kobj_state(&self, state: KObjectState) { in set_kobj_state()
181 *self.locked_kobj_state.write() = state; in set_kobj_state()
691 return self.inner().netdevice_common.state; in net_state()
694 fn set_net_state(&self, state: NetDeivceState) { in set_net_state()
695 self.inner().netdevice_common.state |= state; in set_net_state()
702 fn set_operstate(&self, state: Operstate) { in set_operstate()
703 self.inner().netdevice_common.operstate = state; in set_operstate()
756 fn set_kobj_state(&self, state: KObjectState) { in set_kobj_state()
757 *self.locked_kobj_state.write() = state; in set_kobj_state()
961 fn set_kobj_state(&self, state: KObjectState) { in set_kobj_state()
[all …]
|
| /DragonOS/tools/debugging/logmonitor/src/ |
| H A 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/kernel/src/libs/ |
| H A D | wait_queue.rs | 219 pub fn wakeup(&self, state: Option<ProcessState>) -> bool { in wakeup()
226 if let Some(state) = state { in wakeup()
233 .state() in wakeup()
234 != state in wakeup()
248 pub fn wakeup_all(&self, state: Option<ProcessState>) { in wakeup_all()
259 if let Some(state) = state { in wakeup_all()
260 if to_wakeup.sched_info().inner_lock_read_irqsave().state() == state { in wakeup_all()
|
| H A D | once.rs | 128 pub fn state(&self) -> OnceState { in state() method
|
| /DragonOS/kernel/src/driver/base/ |
| H A D | kobject.rs | 58 fn set_kobj_state(&self, state: KObjectState); in set_kobj_state()
66 let mut state = self.kobj_state_mut(); in update_kobj_state() localVariable
67 *state = (*state | insert) & !remove; in update_kobj_state()
114 pub fn new(state: Option<KObjectState>) -> LockedKObjectState { in new()
115 let state = state.unwrap_or(KObjectState::empty()); in new() localVariable
116 LockedKObjectState(RwLock::new(state)) in new()
|
| H A 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()
|
| /DragonOS/kernel/src/process/ |
| H A D | exit.rs | 158 let state = pcb.sched_info().inner_lock_read_irqsave().state(); in do_wait() localVariable
159 if state.is_exited() { in do_wait()
160 kwo.ret_status = state.exit_code().unwrap() as i32; in do_wait()
184 let state = child_pcb.sched_info().inner_lock_read_irqsave().state(); in do_waitpid() localVariable
186 match state { in do_waitpid()
|
| H A D | mod.rs | 230 let state = pcb.sched_info().inner_lock_read_irqsave().state(); in wakeup() localVariable
231 if state.is_blocked() { in wakeup()
233 let state = writer.state(); in wakeup() localVariable
234 if state.is_blocked() { in wakeup()
255 } else if state.is_exited() { in wakeup()
260 } else if state.is_exited() { in wakeup()
270 let state = pcb.sched_info().inner_lock_read_irqsave().state(); in wakeup_stop() localVariable
271 if let ProcessState::Stopped = state { in wakeup_stop()
273 let state = writer.state(); in wakeup_stop() localVariable
274 if let ProcessState::Stopped = state { in wakeup_stop()
[all …]
|
| /DragonOS/kernel/src/ipc/ |
| H A D | signal.rs | 234 let state = pcb.sched_info().inner_lock_read_irqsave().state(); in wants_signal() localVariable
235 if state.is_blocked() && (!state.is_blocked_interruptable()) { in wants_signal()
318 let state = pcb.sched_info().inner_lock_read_irqsave().state(); in signal_wake_up() localVariable
320 if state.is_blocked_interruptable() { in signal_wake_up()
330 } else if state.is_stopped() { in signal_wake_up()
|
| /DragonOS/kernel/src/smp/cpu/ |
| H A D | mod.rs | 45 state: CpuHpState, field
60 state: CpuHpState::Offline, in new()
180 let old_state = p.state; in set_cpuhp_state()
182 let bringup = target_state > p.state; in set_cpuhp_state()
221 let cpu_state = self.cpuhp_state(cpu_id).state; in cpu_up()
234 let cpu_state = self.cpuhp_state(cpu_id).state; in cpu_up()
|
| /DragonOS/kernel/src/driver/base/device/ |
| H A D | mod.rs | 276 state: DeviceState, field
281 pub fn new(id_table: IdTable, state: DeviceState) -> Self { in new()
282 Self { id_table, state } in new()
289 pub fn state(&self) -> DeviceState { in state() method
290 self.state in state()
293 pub fn set_state(&mut self, state: DeviceState) { in set_state()
294 self.state = state; in set_state()
395 fn from(state: u32) -> Self { in from()
396 match state { in from()
406 fn from(state: DeviceState) -> Self { in from()
[all …]
|
| /DragonOS/kernel/src/driver/net/e1000e/ |
| H A D | e1000e_driver.rs | 363 return self.inner().netdevice_common.state; in net_state()
366 fn set_net_state(&self, state: NetDeivceState) { in set_net_state()
367 self.inner().netdevice_common.state |= state; in set_net_state()
374 fn set_operstate(&self, state: Operstate) { in set_operstate()
375 self.inner().netdevice_common.operstate = state; in set_operstate()
428 fn set_kobj_state(&self, state: KObjectState) { in set_kobj_state()
429 *self.locked_kobj_state.write() = state; in set_kobj_state()
|
| /DragonOS/kernel/src/filesystem/vfs/ |
| H A D | utils.rs | 96 fn hash<H: core::hash::Hasher>(&self, state: &mut H) { in hash()
97 self.0.hash(state) in hash()
|
| /DragonOS/kernel/src/driver/pci/test/ |
| H A D | pt_driver.rs | 168 fn set_kobj_state(&self, state: KObjectState) { in set_kobj_state()
169 *self.kobj_state.write() = state; in set_kobj_state()
|
| /DragonOS/kernel/src/driver/input/serio/i8042/ |
| H A D | i8042_ports.rs | 170 fn set_kobj_state(&self, state: KObjectState) { in set_kobj_state()
171 *self.kobj_state.write() = state; in set_kobj_state()
|
| H A D | i8042_device.rs | 173 fn set_kobj_state(&self, state: KObjectState) { in set_kobj_state()
174 *self.kobj_state.write() = state; in set_kobj_state()
|
| /DragonOS/kernel/src/net/socket/ |
| H A D | mod.rs | 811 let state = socket.state(); in tcp_poll() localVariable
813 if shutdown == ShutdownType::SHUTDOWN_MASK || state == tcp::State::Closed { in tcp_poll()
824 if state != tcp::State::SynSent && state != tcp::State::SynReceived { in tcp_poll()
842 } else if state == tcp::State::SynSent { in tcp_poll()
|