diff --git a/src/arch/x86_64/interrupt/syscall.rs b/src/arch/x86_64/interrupt/syscall.rs
index 847d3afe5986cc48d018a564318ae7c519d3a83b..82beba842759a87aa5844803de6dea9425ebb703 100644
--- a/src/arch/x86_64/interrupt/syscall.rs
+++ b/src/arch/x86_64/interrupt/syscall.rs
@@ -95,7 +95,7 @@ interrupt_stack!(syscall, |stack| {
let context = contexts.current();
if let Some(current) = context {
let current = current.read();
- let name = current.name.lock();
+ let name = current.name.read();
println!("Warning: Context {} used deprecated `int 0x80` construct", core::str::from_utf8(&name).unwrap_or("(invalid utf8)"));
} else {
println!("Warning: Unknown context used deprecated `int 0x80` construct");
diff --git a/src/context/context.rs b/src/context/context.rs
index 1304613f22c602518eead35531020daff000c8e7..15163e57d9e633b80f8e3340b68380cdb4757ad4 100644
--- a/src/context/context.rs
+++ b/src/context/context.rs
@@ -5,7 +5,7 @@ use alloc::collections::VecDeque;
use core::alloc::{GlobalAlloc, Layout};
use core::cmp::Ordering;
use core::mem;
-use spin::Mutex;
+use spin::{Mutex, RwLock};
use crate::arch::{interrupt::InterruptStack, paging::PAGE_SIZE};
use crate::common::unique::Unique;
@@ -120,7 +120,7 @@ pub struct ContextSnapshot {
impl ContextSnapshot {
//TODO: Should this accept &mut Context to ensure name/files will not change?
pub fn new(context: &Context) -> Self {
- let name = context.name.lock().clone();
+ let name = context.name.read().clone();
let mut files = Vec::new();
for descriptor_opt in context.files.lock().iter() {
let description = if let Some(descriptor) = descriptor_opt {
@@ -230,7 +230,7 @@ pub struct Context {
/// User grants
pub grants: Arc<Mutex<UserGrants>>,
/// The name of the context
- pub name: Arc<Mutex<Box<[u8]>>>,
+ pub name: Arc<RwLock<Box<[u8]>>>,
/// The current working directory
pub cwd: Arc<Mutex<Vec<u8>>>,
/// The open files in the scheme
@@ -287,7 +287,7 @@ impl Context {
sigstack: None,
tls: None,
grants: Arc::new(Mutex::new(UserGrants::default())),
- name: Arc::new(Mutex::new(Vec::new().into_boxed_slice())),
+ name: Arc::new(RwLock::new(Vec::new().into_boxed_slice())),
cwd: Arc::new(Mutex::new(Vec::new())),
files: Arc::new(Mutex::new(Vec::new())),
actions: Arc::new(Mutex::new(vec![(
diff --git a/src/context/switch.rs b/src/context/switch.rs
index 634aff32c2aded32d00a2844aeb173ed71d2cfd3..2423d55e418efc959294bf33dbadcc8e56e52fef 100644
--- a/src/context/switch.rs
+++ b/src/context/switch.rs
@@ -13,7 +13,7 @@ unsafe fn update(context: &mut Context, cpu_id: usize) {
// Take ownership if not already owned
if context.cpu_id == None {
context.cpu_id = Some(cpu_id);
- // println!("{}: take {} {}", cpu_id, context.id, ::core::str::from_utf8_unchecked(&context.name.lock()));
+ // println!("{}: take {} {}", cpu_id, context.id, ::core::str::from_utf8_unchecked(&context.name.read()));
}
// Restore from signal, must only be done from another context to avoid overwriting the stack!
diff --git a/src/lib.rs b/src/lib.rs
index aad157f46c3de20960dd0b621f64a9b33cab3429..a18fb2718a772ee9ee34ebcd6cedba7f83dab195 100644
--- a/src/lib.rs
+++ b/src/lib.rs
@@ -279,7 +279,7 @@ pub extern fn ksignal(signal: usize) {
let contexts = context::contexts();
if let Some(context_lock) = contexts.current() {
let context = context_lock.read();
- info!("NAME {}", unsafe { ::core::str::from_utf8_unchecked(&context.name.lock()) });
+ info!("NAME {}", unsafe { ::core::str::from_utf8_unchecked(&context.name.read()) });
}
}
diff --git a/src/scheme/proc.rs b/src/scheme/proc.rs
index 68dbf81af297652c2d97d4ddef26ef0b80337d79..99d19e352162ffb6e42fe183ff9a89fc7ef96cfd 100644
--- a/src/scheme/proc.rs
+++ b/src/scheme/proc.rs
@@ -236,7 +236,7 @@ impl Scheme for ProcScheme {
data = match operation {
Operation::Memory => OperationData::Memory(MemData::default()),
Operation::Trace => OperationData::Trace(TraceData::default()),
- Operation::Static(_) => OperationData::Static(StaticData::new(target.name.lock().clone())),
+ Operation::Static(_) => OperationData::Static(StaticData::new(target.name.read().clone())),
_ => OperationData::Other,
};
diff --git a/src/scheme/sys/block.rs b/src/scheme/sys/block.rs
index 214301665d0b2f47c4b11e82164a79f38fb3e3df..ff9d094453df0b4b34003d37a8fb86cf12b94fd2 100644
--- a/src/scheme/sys/block.rs
+++ b/src/scheme/sys/block.rs
@@ -15,7 +15,7 @@ pub fn resource() -> Result<Vec<u8>> {
let contexts = context::contexts();
for (id, context_lock) in contexts.iter() {
let context = context_lock.read();
- rows.push((*id, context.name.lock().clone(), context.status_reason));
+ rows.push((*id, context.name.read().clone(), context.status_reason));
}
}
diff --git a/src/scheme/sys/context.rs b/src/scheme/sys/context.rs
index 2c949602e884a1a8971f748d82ac9e6822f307cb..df457c875bcac9a2f17193ac0480a10b4ae9398b 100644
--- a/src/scheme/sys/context.rs
+++ b/src/scheme/sys/context.rs
@@ -107,7 +107,7 @@ pub fn resource() -> Result<Vec<u8>> {
format!("{} B", memory)
};
- let name_bytes = context.name.lock();
+ let name_bytes = context.name.read();
let name = str::from_utf8(&name_bytes).unwrap_or("");
string.push_str(&format!("{:<6}{:<6}{:<6}{:<6}{:<6}{:<6}{:<6}{:<6}{:<6}{:<6}{:<6}{:<8}{:<8}{}\n",
diff --git a/src/scheme/sys/exe.rs b/src/scheme/sys/exe.rs
index e4b1a6a6372ecc6566c8f9731cb284e249fcf73d..69e2261fb9f9dccb583a69cd645a2f7508076277 100644
--- a/src/scheme/sys/exe.rs
+++ b/src/scheme/sys/exe.rs
@@ -8,7 +8,7 @@ pub fn resource() -> Result<Vec<u8>> {
let contexts = context::contexts();
let context_lock = contexts.current().ok_or(Error::new(ESRCH))?;
let context = context_lock.read();
- let name = context.name.lock();
+ let name = context.name.read();
name.clone().into_vec()
};
Ok(name)
diff --git a/src/scheme/sys/iostat.rs b/src/scheme/sys/iostat.rs
index e0663873835127ccb7e8174bbf132598dd1e6cf1..3aac16ea83dcbdbd2353f49222e00c08843765aa 100644
--- a/src/scheme/sys/iostat.rs
+++ b/src/scheme/sys/iostat.rs
@@ -16,7 +16,7 @@ pub fn resource() -> Result<Vec<u8>> {
let contexts = context::contexts();
for (id, context_lock) in contexts.iter() {
let context = context_lock.read();
- rows.push((*id, context.name.lock().clone(), context.files.lock().clone()));
+ rows.push((*id, context.name.read().clone(), context.files.lock().clone()));
}
}
diff --git a/src/scheme/sys/syscall.rs b/src/scheme/sys/syscall.rs
index 4d2eea4f2ef600439e3afb94c2cbf18a210cefc7..c458d4e7ff240ecdd5ba6fa7debabf0d59fa3711 100644
--- a/src/scheme/sys/syscall.rs
+++ b/src/scheme/sys/syscall.rs
@@ -16,7 +16,7 @@ pub fn resource() -> Result<Vec<u8>> {
let contexts = context::contexts();
for (id, context_lock) in contexts.iter() {
let context = context_lock.read();
- rows.push((*id, context.name.lock().clone(), context.syscall.clone()));
+ rows.push((*id, context.name.read().clone(), context.syscall.clone()));
}
}
diff --git a/src/syscall/mod.rs b/src/syscall/mod.rs
index 779ac68f416c266d3e784147fc0dd9b2fae2d9f7..eec730020f0e8a0063db5a4c1a3119b06e782652 100644
--- a/src/syscall/mod.rs
+++ b/src/syscall/mod.rs
@@ -82,7 +82,7 @@ pub fn syscall(a: usize, b: usize, c: usize, d: usize, e: usize, f: usize, bp: u
let contexts = crate::context::contexts();
let current = contexts.current().unwrap();
let current = current.read();
- let name = current.name.lock();
+ let name = current.name.read();
println!("{:?} using deprecated fmap(...) call", core::str::from_utf8(&name));
}
file_op(a, fd, c, d)
@@ -92,7 +92,7 @@ pub fn syscall(a: usize, b: usize, c: usize, d: usize, e: usize, f: usize, bp: u
let contexts = crate::context::contexts();
let current = contexts.current().unwrap();
let current = current.read();
- let name = current.name.lock();
+ let name = current.name.read();
println!("{:?} using deprecated funmap(...) call", core::str::from_utf8(&name));
}
funmap_old(b)
@@ -208,7 +208,7 @@ pub fn syscall(a: usize, b: usize, c: usize, d: usize, e: usize, f: usize, bp: u
let contexts = crate::context::contexts();
if let Some(context_lock) = contexts.current() {
let context = context_lock.read();
- let name_raw = context.name.lock();
+ let name_raw = context.name.read();
let name = unsafe { core::str::from_utf8_unchecked(&name_raw) };
if name.contains("redoxfs") {
if a == SYS_CLOCK_GETTIME || a == SYS_YIELD {
@@ -230,7 +230,7 @@ pub fn syscall(a: usize, b: usize, c: usize, d: usize, e: usize, f: usize, bp: u
let contexts = crate::context::contexts();
if let Some(context_lock) = contexts.current() {
let context = context_lock.read();
- print!("{} ({}): ", unsafe { core::str::from_utf8_unchecked(&context.name.lock()) }, context.id.into());
+ print!("{} ({}): ", unsafe { core::str::from_utf8_unchecked(&context.name.read()) }, context.id.into());
}
println!("{}", debug::format_call(a, b, c, d, e, f));
@@ -265,7 +265,7 @@ pub fn syscall(a: usize, b: usize, c: usize, d: usize, e: usize, f: usize, bp: u
let contexts = crate::context::contexts();
if let Some(context_lock) = contexts.current() {
let context = context_lock.read();
- print!("{} ({}): ", unsafe { core::str::from_utf8_unchecked(&context.name.lock()) }, context.id.into());
+ print!("{} ({}): ", unsafe { core::str::from_utf8_unchecked(&context.name.read()) }, context.id.into());
}
print!("{} = ", debug::format_call(a, b, c, d, e, f));
diff --git a/src/syscall/process.rs b/src/syscall/process.rs
index 9adad28330007205b766d7b3f61a06200201c8a0..b034358d456ba088a5304d23585030f6d33024ad 100644
--- a/src/syscall/process.rs
+++ b/src/syscall/process.rs
@@ -5,7 +5,7 @@ use alloc::vec::Vec;
use core::alloc::{GlobalAlloc, Layout};
use core::ops::DerefMut;
use core::{intrinsics, mem};
-use spin::Mutex;
+use spin::{RwLock, Mutex};
use crate::context::file::FileDescriptor;
use crate::context::{ContextId, WaitpidKey};
@@ -244,7 +244,7 @@ pub fn clone(flags: CloneFlags, stack_base: usize) -> Result<ContextId> {
if flags.contains(CLONE_VM) {
name = Arc::clone(&context.name);
} else {
- name = Arc::new(Mutex::new(context.name.lock().clone()));
+ name = Arc::new(RwLock::new(context.name.read().clone()));
}
if flags.contains(CLONE_FS) {
@@ -608,7 +608,7 @@ fn empty(context: &mut context::Context, reaping: bool) {
let grants = mem::replace(&mut *grants, UserGrants::default());
for grant in grants.inner.into_iter() {
if reaping {
- println!("{}: {}: Grant should not exist: {:?}", context.id.into(), unsafe { ::core::str::from_utf8_unchecked(&context.name.lock()) }, grant);
+ println!("{}: {}: Grant should not exist: {:?}", context.id.into(), unsafe { ::core::str::from_utf8_unchecked(&context.name.read()) }, grant);
let mut new_table = unsafe { InactivePageTable::from_address(context.arch.get_page_utable()) };
let mut temporary_page = TemporaryPage::new(Page::containing_address(VirtualAddress::new(crate::USER_TMP_GRANT_OFFSET)));
@@ -652,7 +652,7 @@ fn fexec_noreturn(
ptrace::regs_for(&context).map(|s| s.is_singlestep()).unwrap_or(false)
};
- context.name = Arc::new(Mutex::new(name));
+ context.name = Arc::new(RwLock::new(name));
empty(&mut context, false);
@@ -974,7 +974,7 @@ pub fn fexec_kernel(fd: FileHandle, args: Box<[Box<[u8]>]>, vars: Box<[Box<[u8]>
println!(
"{}: {}: fexec failed to execute {}: {}",
context.id.into(),
- unsafe { ::core::str::from_utf8_unchecked(&context.name.lock()) },
+ unsafe { ::core::str::from_utf8_unchecked(&context.name.read()) },
fd.into(),
err
);