initial work to adhere spec in handling memory access faults

wip/its-not-my-fault
ondra05 2023-06-21 01:56:26 +02:00
parent 47b645157c
commit 19313942dd
No known key found for this signature in database
GPG Key ID: 0DA6D2BB2285E881
2 changed files with 55 additions and 38 deletions

View File

@ -52,7 +52,7 @@ impl Memory {
} }
/// Load value from an address /// Load value from an address
pub unsafe fn load(&self, addr: u64, target: *mut u8, count: usize) -> Result<(), ()> { pub unsafe fn load(&self, addr: u64, target: *mut u8, count: usize) -> Result<(), AccessFault> {
self.memory_access( self.memory_access(
addr, addr,
target, target,
@ -68,7 +68,12 @@ impl Memory {
} }
/// Store value to an address /// Store value to an address
pub unsafe fn store(&mut self, addr: u64, source: *const u8, count: usize) -> Result<(), ()> { pub unsafe fn store(
&mut self,
addr: u64,
source: *const u8,
count: usize,
) -> Result<(), AccessFault> {
self.memory_access( self.memory_access(
addr, addr,
source.cast_mut(), source.cast_mut(),
@ -80,7 +85,7 @@ impl Memory {
/// Copy a block of memory /// Copy a block of memory
pub unsafe fn block_copy(&mut self, src: u64, dst: u64, count: u64) -> Result<(), ()> { pub unsafe fn block_copy(&mut self, src: u64, dst: u64, count: u64) -> Result<(), ()> {
let count = usize::try_from(count).expect("?conradluget a better CPU"); /* let count = usize::try_from(count).expect("?conradluget a better CPU");
let mut srcs = PageSplitter::new(src, count, self.root_pt); let mut srcs = PageSplitter::new(src, count, self.root_pt);
let mut dsts = PageSplitter::new(dst, count, self.root_pt); let mut dsts = PageSplitter::new(dst, count, self.root_pt);
@ -107,7 +112,9 @@ impl Memory {
(Some(src), Some(dst)) => (c_src, c_dst) = (src, dst), (Some(src), Some(dst)) => (c_src, c_dst) = (src, dst),
_ => return Err(()), _ => return Err(()),
} }
} } */
todo!("Block memory copy")
} }
#[inline] #[inline]
@ -127,10 +134,11 @@ impl Memory {
len: usize, len: usize,
permission_check: impl Fn(Permission) -> bool, permission_check: impl Fn(Permission) -> bool,
action: impl Fn(*mut u8, *mut u8, usize), action: impl Fn(*mut u8, *mut u8, usize),
) -> Result<(), ()> { ) -> Result<(), AccessFault> {
for PageSplitResult { ptr, size, perm } in PageSplitter::new(src, len, self.root_pt) { for item in PageSplitter::new(src, len, self.root_pt) {
let PageSplitResult { ptr, size, perm } = item?;
if !permission_check(perm) { if !permission_check(perm) {
return Err(()); return Err(AccessFault::Permission);
} }
action(ptr, dst, size); action(ptr, dst, size);
@ -141,6 +149,7 @@ impl Memory {
} }
} }
#[derive(Debug)]
struct PageSplitResult { struct PageSplitResult {
ptr: *mut u8, ptr: *mut u8,
size: usize, size: usize,
@ -164,7 +173,7 @@ impl PageSplitter {
} }
impl Iterator for PageSplitter { impl Iterator for PageSplitter {
type Item = PageSplitResult; type Item = Result<PageSplitResult, AccessFault>;
fn next(&mut self) -> Option<Self::Item> { fn next(&mut self) -> Option<Self::Item> {
if self.size == 0 { if self.size == 0 {
@ -182,7 +191,12 @@ impl Iterator for PageSplitter {
let ptr = entry.ptr(); let ptr = entry.ptr();
match entry.permission() { match entry.permission() {
Permission::Empty => return None, Permission::Empty => {
return Some(Err(AccessFault::NoPage {
addr: self.addr,
remaining: self.size,
}))
}
Permission::Node => current_pt = ptr as _, Permission::Node => current_pt = ptr as _,
perm => { perm => {
break 'a ( break 'a (
@ -192,7 +206,7 @@ impl Iterator for PageSplitter {
0 => 4096, 0 => 4096,
1 => 1024_usize.pow(2) * 2, 1 => 1024_usize.pow(2) * 2,
2 => 1024_usize.pow(3), 2 => 1024_usize.pow(3),
_ => return None, _ => return Some(Err(AccessFault::TooShallow)),
}, },
self.addr as usize & ((1 << (lvl * 9 + 12)) - 1), self.addr as usize & ((1 << (lvl * 9 + 12)) - 1),
) )
@ -200,16 +214,25 @@ impl Iterator for PageSplitter {
} }
} }
} }
return None; return Some(Err(AccessFault::TooDeep));
}; };
extern crate std;
let avail = (size - offset).clamp(0, self.size); let avail = (size - offset).clamp(0, self.size);
self.addr += size as u64; self.addr += size as u64;
self.size = self.size.saturating_sub(size); self.size = self.size.saturating_sub(size);
Some(PageSplitResult { std::dbg!(Some(Ok(PageSplitResult {
ptr: unsafe { base.add(offset) }, ptr: unsafe { base.add(offset) },
size: avail, size: avail,
perm, perm,
}) })))
} }
} }
#[derive(Clone, Copy, Debug, PartialEq, Eq)]
pub enum AccessFault {
NoPage { addr: u64, remaining: usize },
Permission,
TooShallow,
TooDeep,
}

View File

@ -11,6 +11,8 @@
// program size. If you are (rightfully) worried about the UB, for now just // program size. If you are (rightfully) worried about the UB, for now just
// append your program with 11 zeroes. // append your program with 11 zeroes.
use self::mem::AccessFault;
mod mem; mod mem;
mod value; mod value;
@ -196,30 +198,22 @@ impl<'a> Vm<'a> {
_ => 0, _ => 0,
}; };
if self if let Err(e) = self.memory.load(
.memory self.read_reg(base).as_u64() + off + n as u64,
.load( self.registers.as_mut_ptr().add(usize::from(dst) + n).cast(),
self.read_reg(base).as_u64() + off + n as u64, usize::from(count).saturating_sub(n),
self.registers.as_mut_ptr().add(usize::from(dst) + n).cast(), ) {
usize::from(count).saturating_sub(n), return HaltReason::LoadAccessEx(e);
)
.is_err()
{
return HaltReason::LoadAccessEx;
} }
} }
ST => { ST => {
let ParamBBDH(dst, base, off, count) = param!(self, ParamBBDH); let ParamBBDH(dst, base, off, count) = param!(self, ParamBBDH);
if self if let Err(e) = self.memory.store(
.memory self.read_reg(base).as_u64() + off,
.store( self.registers.as_ptr().add(usize::from(dst)).cast(),
self.read_reg(base).as_u64() + off, count.into(),
self.registers.as_ptr().add(usize::from(dst)).cast(), ) {
count.into(), return HaltReason::StoreAccessEx(e);
)
.is_err()
{
return HaltReason::LoadAccessEx;
} }
} }
BMC => { BMC => {
@ -233,7 +227,7 @@ impl<'a> Vm<'a> {
) )
.is_err() .is_err()
{ {
return HaltReason::LoadAccessEx; todo!("Block memory copy fault");
} }
} }
BRC => { BRC => {
@ -274,7 +268,7 @@ impl<'a> Vm<'a> {
} }
ADDFI => binary_op_imm!(self, as_f64, ops::Add::add), ADDFI => binary_op_imm!(self, as_f64, ops::Add::add),
MULFI => binary_op_imm!(self, as_f64, ops::Mul::mul), MULFI => binary_op_imm!(self, as_f64, ops::Mul::mul),
_ => return HaltReason::InvalidOpcode, op => return HaltReason::InvalidOpEx(op),
} }
} }
} }
@ -302,7 +296,7 @@ impl<'a> Vm<'a> {
pub enum HaltReason { pub enum HaltReason {
ProgramEnd, ProgramEnd,
Ecall, Ecall,
InvalidOpcode, InvalidOpEx(u8),
LoadAccessEx, LoadAccessEx(AccessFault),
StoreAccessEx, StoreAccessEx(AccessFault),
} }