#![allow(unused)] use core::ops::{Bound, Range, RangeBounds}; use embedded_storage::nor_flash::{ErrorType, NorFlash, NorFlashError, NorFlashErrorKind, ReadNorFlash}; #[cfg(feature = "nightly")] use embedded_storage_async::nor_flash::{NorFlash as AsyncNorFlash, ReadNorFlash as AsyncReadNorFlash}; pub struct MemFlash { pub mem: [u8; SIZE], pub pending_write_successes: Option, } #[derive(Debug)] pub struct MemFlashError; impl MemFlash { pub const fn new(fill: u8) -> Self { Self { mem: [fill; SIZE], pending_write_successes: None, } } #[cfg(test)] pub fn random() -> Self { let mut mem = [0; SIZE]; for byte in mem.iter_mut() { *byte = rand::random::(); } Self { mem, pending_write_successes: None, } } pub fn program(&mut self, offset: u32, bytes: &[u8]) -> Result<(), MemFlashError> { let offset = offset as usize; assert!(bytes.len() % WRITE_SIZE == 0); assert!(offset % WRITE_SIZE == 0); assert!(offset + bytes.len() <= SIZE); self.mem[offset..offset + bytes.len()].copy_from_slice(bytes); Ok(()) } pub fn assert_eq(&self, offset: u32, expectation: &[u8]) { for i in 0..expectation.len() { assert_eq!(self.mem[offset as usize + i], expectation[i], "Index {}", i); } } } impl Default for MemFlash { fn default() -> Self { Self::new(0xFF) } } impl ErrorType for MemFlash { type Error = MemFlashError; } impl NorFlashError for MemFlashError { fn kind(&self) -> NorFlashErrorKind { NorFlashErrorKind::Other } } impl ReadNorFlash for MemFlash { const READ_SIZE: usize = 1; fn read(&mut self, offset: u32, bytes: &mut [u8]) -> Result<(), Self::Error> { let len = bytes.len(); bytes.copy_from_slice(&self.mem[offset as usize..offset as usize + len]); Ok(()) } fn capacity(&self) -> usize { SIZE } } impl NorFlash for MemFlash { const WRITE_SIZE: usize = WRITE_SIZE; const ERASE_SIZE: usize = ERASE_SIZE; fn erase(&mut self, from: u32, to: u32) -> Result<(), Self::Error> { let from = from as usize; let to = to as usize; assert!(from % ERASE_SIZE == 0); assert!(to % ERASE_SIZE == 0, "To: {}, erase size: {}", to, ERASE_SIZE); for i in from..to { self.mem[i] = 0xFF; } Ok(()) } fn write(&mut self, offset: u32, bytes: &[u8]) -> Result<(), Self::Error> { let offset = offset as usize; assert!(bytes.len() % WRITE_SIZE == 0); assert!(offset % WRITE_SIZE == 0); assert!(offset + bytes.len() <= SIZE); if let Some(pending_successes) = self.pending_write_successes { if pending_successes > 0 { self.pending_write_successes = Some(pending_successes - 1); } else { return Err(MemFlashError); } } for ((offset, mem_byte), new_byte) in self .mem .iter_mut() .enumerate() .skip(offset) .take(bytes.len()) .zip(bytes) { assert_eq!(0xFF, *mem_byte, "Offset {} is not erased", offset); *mem_byte = *new_byte; } Ok(()) } } #[cfg(feature = "nightly")] impl AsyncReadNorFlash for MemFlash { const READ_SIZE: usize = 1; async fn read(&mut self, offset: u32, bytes: &mut [u8]) -> Result<(), Self::Error> { ::read(self, offset, bytes) } fn capacity(&self) -> usize { ::capacity(self) } } #[cfg(feature = "nightly")] impl AsyncNorFlash for MemFlash { const WRITE_SIZE: usize = WRITE_SIZE; const ERASE_SIZE: usize = ERASE_SIZE; async fn erase(&mut self, from: u32, to: u32) -> Result<(), Self::Error> { ::erase(self, from, to) } async fn write(&mut self, offset: u32, bytes: &[u8]) -> Result<(), Self::Error> { ::write(self, offset, bytes) } }