/DragonOS/tools/debugging/logmonitor/src/backend/ |
H A D | mod.rs | 4 thread::JoinHandle, 21 main_thread: RwLock<Option<std::thread::JoinHandle<()>>>, 43 std::thread::spawn(move || { in new() 100 std::thread::sleep(std::time::Duration::from_secs(1)); in run_main() 108 let handle = std::thread::spawn(move || { in run_mm_monitor()
|
/DragonOS/tools/debugging/logmonitor/src/ |
H A D | event.rs | 5 use std::thread; 31 handler: thread::JoinHandle<()>, 41 thread::spawn(move || { in new()
|
/DragonOS/kernel/src/smp/cpu/ |
H A D | mod.rs | 49 thread: Option<Arc<ProcessControlBlock>>, field 62 thread: None, in new() 69 pub const fn thread(&self) -> &Option<Arc<ProcessControlBlock>> { in thread() method 70 &self.thread in thread() 94 hpstate.thread = Some(ProcessManager::idle_pcb()[i as usize].clone()); in new() 259 let pcb = cpu_state.thread.as_ref().ok_or(SystemError::EINVAL)?; in do_cpuhp_kick_ap() 264 ProcessManager::wakeup(cpu_state.thread.as_ref().unwrap())?; in do_cpuhp_kick_ap()
|
/DragonOS/user/apps/test-for-robustfutex/src/ |
H A D | main.rs | 10 thread, 106 fn futex_wait(futexes: Futex, thread: &str, offset_futex: isize, lock: Lock, offset_count: isize) { in futex_wait() 122 println!("{} wating...", thread); in futex_wait() 156 fn futex_wake(futexes: Futex, thread: &str, offset_futex: isize, lock: Lock, offset_count: isize) { in futex_wake() 188 println!("{} waked", thread); in futex_wake() 361 let thread1 = thread::spawn(move || { in test02() 363 thread::sleep(Duration::from_secs(2)); in test02() 367 thread::sleep(Duration::from_secs(3)); in test02()
|
/DragonOS/user/apps/test_socket/src/ |
H A D | test_unix_stream.rs | 3 use std::thread; 24 let client_thread = thread::spawn(move || client()); in test_unix_stream()
|
/DragonOS/kernel/src/exception/ |
H A D | handle.rs | 214 let thread = action_inner.thread(); in do_irq_wake_thread() localVariable 216 if thread.is_none() { in do_irq_wake_thread() 220 let thread = thread.unwrap(); in do_irq_wake_thread() localVariable 221 if thread.flags().contains(ProcessFlags::EXITING) { in do_irq_wake_thread() 235 ProcessManager::wakeup(&thread).ok(); in do_irq_wake_thread()
|
H A D | irqdesc.rs | 656 thread: None, in new() 690 thread: Option<Arc<ProcessControlBlock>>, field 732 pub fn thread(&self) -> Option<Arc<ProcessControlBlock>> { in thread() method 733 self.thread.clone() in thread() 736 pub fn set_thread(&mut self, thread: Option<Arc<ProcessControlBlock>>) { in set_thread() 737 self.thread = thread; in set_thread()
|
H A D | manage.rs | 174 if let Some(thread_pcb) = action_guard.thread() { in inner_setup_irq() 181 if let Some(thread_pcb) = secondary_guard.thread() { in inner_setup_irq() 606 if action_guard.thread().is_none() { in wake_up_and_wait_for_irq_thread_ready() 610 ProcessManager::wakeup(&action_guard.thread().unwrap()).ok(); in wake_up_and_wait_for_irq_thread_ready()
|
/DragonOS/user/apps/test_tokio/ |
H A D | Cargo.toml | 10 "rt-multi-thread",
|
/DragonOS/tools/debugging/logmonitor/src/backend/monitor/ |
H A D | mm.rs | 7 thread::JoinHandle, 124 let handle = std::thread::spawn(move || { in create_threads() 165 std::thread::sleep(std::time::Duration::from_secs(1)); in run() 256 std::thread::sleep(std::time::Duration::from_secs(1)); in load_header()
|
/DragonOS/docs/kernel/locking/ |
H A D | rwlock.md | 195 let r2=thread::spawn(t_read2); 196 let r1 = thread::spawn(t_read1); 197 let t1 = thread::spawn(t_write); 198 let g1 = thread::spawn(t_upgrade);
|
/DragonOS/kernel/src/process/ |
H A D | fork.rs | 414 pcb.thread.write_irqsave().clear_child_tid = Some(clone_args.child_tid); in copy_process() 419 pcb.thread.write_irqsave().set_child_tid = Some(clone_args.child_tid); in copy_process() 493 pcb.thread.write_irqsave().group_leader = in copy_process() 494 current_pcb.thread.read_irqsave().group_leader.clone(); in copy_process() 500 pcb.thread.write_irqsave().group_leader = Arc::downgrade(pcb); in copy_process() 515 let leader = current_pcb.thread.read_irqsave().group_leader(); in copy_process()
|
H A D | mod.rs | 403 let thread = pcb.thread.write_irqsave(); in exit() localVariable 404 if let Some(addr) = thread.set_child_tid { in exit() 408 if let Some(addr) = thread.clear_child_tid { in exit() 419 if thread.vfork_done.is_some() { in exit() 420 thread.vfork_done.as_ref().unwrap().complete_all(); in exit() 422 drop(thread); in exit() 654 thread: RwLock<ThreadInfo>, field 749 thread: RwLock::new(ThreadInfo::new()), in do_create_pcb()
|
H A D | syscall.rs | 254 pcb.thread.write_irqsave().vfork_done = Some(vfork.clone()); in clone() 257 if pcb.thread.read_irqsave().set_child_tid.is_some() { in clone() 258 let addr = pcb.thread.read_irqsave().set_child_tid.unwrap(); in clone() 286 pcb.thread.write_irqsave().clear_child_tid = Some(VirtAddr::new(ptr)); in set_tid_address()
|
/DragonOS/user/apps/test_ebpf/ |
H A D | Cargo.toml | 12 tokio = { version = "1.25", features = ["macros", "rt", "rt-multi-thread", "net", "signal", "time"]…
|
/DragonOS/docs/kernel/debug/ |
H A D | debug-kernel-with-gdb.md | 280 backtrace thread <thread_id> #显示指定线程的回溯信息。 298   您可以使用`thread <thread_id>`命令切换到指定的核心上下文,以便查看和调试特定核心的状态。例如: 301 (gdb) thread 1 302 [Switching to thread 1 (Thread 1.1)]
|
/DragonOS/kernel/src/arch/x86_64/smp/ |
H A D | mod.rs | 52 .thread() in smp_ap_start()
|
/DragonOS/docs/community/ChangeLog/V0.1.x/ |
H A D | V0.1.7.md | 74 - 修复由于DragonOS不支持TLS(thread local storage)导致errno变量无法正常工作的问题. (#8)
|
H A D | V0.1.10.md | 56 - feat(process/riscv): 实现copy-thread (#696) 653 riscv: copy-thread (#696)
|
H A D | V0.1.9.md | 1294 添加thread和futex机制 (#411) 2006 * 能跑到initial kernel thread
|