Compare commits

...

2 Commits

Author SHA1 Message Date
201eaf576a
mikros: Add process wait support 2024-11-08 13:39:13 -06:00
8fa25a4322
mikros: Send main return value to proc_man on exit 2024-11-08 13:38:10 -06:00
2 changed files with 37 additions and 36 deletions

View File

@ -144,7 +144,7 @@ pub fn spawn(
res?; res?;
}; };
syscalls::wake_new(pid).unwrap(); syscalls::wake_new(pid).unwrap();
Ok((Process { dummy: () }, StdioPipes { stdin: None, stdout: None, stderr: None })) Ok((Process { pid }, StdioPipes { stdin: None, stdout: None, stderr: None }))
} }
pub fn output(&mut self) -> io::Result<(ExitStatus, Vec<u8>, Vec<u8>)> { pub fn output(&mut self) -> io::Result<(ExitStatus, Vec<u8>, Vec<u8>)> {
@ -242,15 +242,15 @@ fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
#[derive(PartialEq, Eq, Clone, Copy, Debug, Default)] #[derive(PartialEq, Eq, Clone, Copy, Debug, Default)]
#[non_exhaustive] #[non_exhaustive]
pub struct ExitStatus(); pub struct ExitStatus(u8);
impl ExitStatus { impl ExitStatus {
pub fn exit_ok(&self) -> Result<(), ExitStatusError> { pub fn exit_ok(&self) -> Result<(), ExitStatusError> {
Ok(()) if self.0 == 0 { Ok(()) } else { Err(ExitStatusError(self.0)) }
} }
pub fn code(&self) -> Option<i32> { pub fn code(&self) -> Option<i32> {
Some(0) Some(self.0 as i32)
} }
} }
@ -260,39 +260,18 @@ fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
} }
} }
pub struct ExitStatusError(!); #[derive(Clone, Copy, PartialEq, Eq, Debug)]
pub struct ExitStatusError(u8);
impl Clone for ExitStatusError {
fn clone(&self) -> ExitStatusError {
self.0
}
}
impl Copy for ExitStatusError {}
impl PartialEq for ExitStatusError {
fn eq(&self, _other: &ExitStatusError) -> bool {
self.0
}
}
impl Eq for ExitStatusError {}
impl fmt::Debug for ExitStatusError {
fn fmt(&self, _f: &mut fmt::Formatter<'_>) -> fmt::Result {
self.0
}
}
impl Into<ExitStatus> for ExitStatusError { impl Into<ExitStatus> for ExitStatusError {
fn into(self) -> ExitStatus { fn into(self) -> ExitStatus {
self.0 ExitStatus(self.0)
} }
} }
impl ExitStatusError { impl ExitStatusError {
pub fn code(self) -> Option<NonZero<i32>> { pub fn code(self) -> Option<NonZero<i32>> {
self.0 Some(NonZero::new(self.0 as i32).unwrap())
} }
} }
@ -318,24 +297,46 @@ fn from(code: u8) -> Self {
} }
pub struct Process { pub struct Process {
dummy: (), pid: u64,
} }
impl Process { impl Process {
pub fn id(&self) -> u32 { pub fn id(&self) -> u32 {
todo!() self.pid.try_into().unwrap()
} }
pub fn kill(&mut self) -> io::Result<()> { pub fn kill(&mut self) -> io::Result<()> {
todo!() unsupported()
} }
pub fn wait(&mut self) -> io::Result<ExitStatus> { pub fn wait(&mut self) -> io::Result<ExitStatus> {
todo!() let Some(proc_man_pid) = syscalls::try_get_registered(3) else {
return unsupported();
};
let wait_res: Result<(u64, u8), Errno> = postcard::from_bytes(
&rpc::send_call(proc_man_pid, 8, 5, &postcard::to_allocvec(&(self.pid, true)).unwrap())
.get_return(),
)
.unwrap();
let (_wait_pid, code) = wait_res?;
Ok(ExitStatus(code))
} }
pub fn try_wait(&mut self) -> io::Result<Option<ExitStatus>> { pub fn try_wait(&mut self) -> io::Result<Option<ExitStatus>> {
todo!() let Some(proc_man_pid) = syscalls::try_get_registered(3) else {
return unsupported();
};
let wait_res: Result<(u64, u8), Errno> = postcard::from_bytes(
&rpc::send_call(proc_man_pid, 8, 5, &postcard::to_allocvec(&(self.pid, true)).unwrap())
.get_return(),
)
.unwrap();
let (_wait_pid, code) = match wait_res {
Ok(val) => val,
Err(Errno::EAGAIN) => return Ok(None),
Err(e) => return Err(e.into()),
};
Ok(Some(ExitStatus(code)))
} }
} }

View File

@ -12,7 +12,7 @@ pub extern "C" fn _start() {
let argv; let argv;
unsafe { unsafe {
asm!("int 0x80", in("rax") 19, lateout("rax") argv, lateout("rcx") argc); asm!("int 0x80", in("rax") 19, lateout("rax") argv, lateout("rcx") argc);
main(argc, argv); let code = main(argc, argv);
asm!("int 0x80", in("rax") 1); crate::sys::os::exit(code);
}; };
} }