From cd138a3a1b98720017bcb0656777977748ba5ca9 Mon Sep 17 00:00:00 2001 From: Philipp Oppermann Date: Thu, 23 Jan 2020 09:18:00 +0100 Subject: [PATCH] Rename multitasking module to `threads` --- src/interrupts.rs | 2 +- src/lib.rs | 2 +- src/main.rs | 2 +- src/{multitasking.rs => threads.rs} | 9 +++++++-- 4 files changed, 10 insertions(+), 5 deletions(-) rename src/{multitasking.rs => threads.rs} (93%) diff --git a/src/interrupts.rs b/src/interrupts.rs index 35ab3d66..089d0884 100644 --- a/src/interrupts.rs +++ b/src/interrupts.rs @@ -77,7 +77,7 @@ extern "x86-interrupt" fn timer_interrupt_handler(_stack_frame: &mut InterruptSt PICS.lock() .notify_end_of_interrupt(InterruptIndex::Timer.as_u8()); } - crate::multitasking::scheduler(); + crate::threads::scheduler(); } extern "x86-interrupt" fn keyboard_interrupt_handler(_stack_frame: &mut InterruptStackFrame) { diff --git a/src/lib.rs b/src/lib.rs index 8670e75e..ca194021 100644 --- a/src/lib.rs +++ b/src/lib.rs @@ -22,8 +22,8 @@ pub mod allocator; pub mod gdt; pub mod interrupts; pub mod memory; -pub mod multitasking; pub mod serial; +pub mod threads; pub mod vga_buffer; pub fn init() { diff --git a/src/main.rs b/src/main.rs index 5da8d70f..999bb2cf 100644 --- a/src/main.rs +++ b/src/main.rs @@ -54,7 +54,7 @@ fn kernel_main(boot_info: &'static BootInfo) -> ! { #[cfg(test)] test_main(); - use blog_os::multitasking::{create_thread, create_thread_from_closure}; + use blog_os::threads::{create_thread, create_thread_from_closure}; create_thread(thread_1, 1, &mut mapper, &mut frame_allocator); create_thread(thread_2, 1, &mut mapper, &mut frame_allocator); diff --git a/src/multitasking.rs b/src/threads.rs similarity index 93% rename from src/multitasking.rs rename to src/threads.rs index 9be2a0bd..97b17bbb 100644 --- a/src/multitasking.rs +++ b/src/threads.rs @@ -17,7 +17,9 @@ pub unsafe fn context_switch(stack_pointer: VirtAddr) { pub fn scheduler() { let next = PAUSED_THREADS.try_lock().and_then(|mut paused_threads| { - paused_threads.as_mut().and_then(|threads| threads.pop_front()) + paused_threads + .as_mut() + .and_then(|threads| threads.pop_front()) }); if let Some(next) = next { unsafe { context_switch(next) }; @@ -32,7 +34,10 @@ fn add_paused_thread(stack_pointer: VirtAddr) { } fn add_thread(stack_pointer: VirtAddr) { - PAUSED_THREADS.lock().get_or_insert_with(VecDeque::new).push_back(stack_pointer); + PAUSED_THREADS + .lock() + .get_or_insert_with(VecDeque::new) + .push_back(stack_pointer); } pub fn create_thread(