149b0297a4
* Fire up multiple processors * Use IPIs to wake up secondary processors * Much better exception information * Modifications to show more information on fault * WIP: Use real libstd * Add TLS (not complete) * Add random function, export getpid, cleanup * Do not spin APs until new context * Update rust * Update rust * Use rd/wrfsbase * Implement TLS * Implement compiler builtins and update rust * Update rust * Back to Redox libstd * Update rust
75 lines
1.9 KiB
Rust
75 lines
1.9 KiB
Rust
//! Context management
|
|
use alloc::boxed::Box;
|
|
use core::sync::atomic::{AtomicUsize, ATOMIC_USIZE_INIT, Ordering};
|
|
use spin::{Once, RwLock, RwLockReadGuard, RwLockWriteGuard};
|
|
|
|
pub use self::context::{Context, Status};
|
|
pub use self::list::ContextList;
|
|
pub use self::switch::switch;
|
|
|
|
/// Context struct
|
|
mod context;
|
|
|
|
/// Context list
|
|
mod list;
|
|
|
|
/// Context switch function
|
|
mod switch;
|
|
|
|
/// Event handling
|
|
pub mod event;
|
|
|
|
/// File struct - defines a scheme and a file number
|
|
pub mod file;
|
|
|
|
/// Memory struct - contains a set of pages for a context
|
|
pub mod memory;
|
|
|
|
/// Limit on number of contexts
|
|
pub const CONTEXT_MAX_CONTEXTS: usize = 65536;
|
|
|
|
/// Maximum context files
|
|
pub const CONTEXT_MAX_FILES: usize = 65536;
|
|
|
|
/// Contexts list
|
|
static CONTEXTS: Once<RwLock<ContextList>> = Once::new();
|
|
|
|
#[thread_local]
|
|
static CONTEXT_ID: AtomicUsize = ATOMIC_USIZE_INIT;
|
|
|
|
pub fn init() {
|
|
let mut contexts = contexts_mut();
|
|
let context_lock = contexts.new_context().expect("could not initialize first context");
|
|
let mut context = context_lock.write();
|
|
let mut fx = unsafe { Box::from_raw(::alloc::heap::allocate(512, 16) as *mut [u8; 512]) };
|
|
for b in fx.iter_mut() {
|
|
*b = 0;
|
|
}
|
|
|
|
context.arch.set_fx(fx.as_ptr() as usize);
|
|
context.kfx = Some(fx);
|
|
context.status = Status::Runnable;
|
|
context.running = true;
|
|
context.cpu_id = Some(::cpu_id());
|
|
CONTEXT_ID.store(context.id, Ordering::SeqCst);
|
|
}
|
|
|
|
/// Initialize contexts, called if needed
|
|
fn init_contexts() -> RwLock<ContextList> {
|
|
RwLock::new(ContextList::new())
|
|
}
|
|
|
|
/// Get the global schemes list, const
|
|
pub fn contexts() -> RwLockReadGuard<'static, ContextList> {
|
|
CONTEXTS.call_once(init_contexts).read()
|
|
}
|
|
|
|
/// Get the global schemes list, mutable
|
|
pub fn contexts_mut() -> RwLockWriteGuard<'static, ContextList> {
|
|
CONTEXTS.call_once(init_contexts).write()
|
|
}
|
|
|
|
pub fn context_id() -> usize {
|
|
CONTEXT_ID.load(Ordering::SeqCst)
|
|
}
|