Struct InMemoryStorage

Source

pub struct InMemoryStorage { /* private fields */ }

Expand description

In-memory storage with deterministic fault injection.

This struct represents a simulated storage device that can inject various faults at read time while keeping pristine data intact.

§Design

data: Pristine storage contents
written: Tracks which sectors have been written (unwritten sectors return random data)
faults: Tracks which sectors have faults (faulted sectors return corrupted data)
overlays: Temporary data overlays for misdirected write simulation
pending_writes: Writes that haven’t been synced yet (may be lost on crash)

§Example

use moonpool_sim::storage::memory::{InMemoryStorage, SECTOR_SIZE};

let mut storage = InMemoryStorage::new(4096, 42);
storage.write(0, b"Hello, World!", true)?;

let mut buf = vec![0u8; 13];
storage.read(0, &mut buf)?;
assert_eq!(&buf, b"Hello, World!");

Implementations§

Source §

impl InMemoryStorage

Source

pub fn new(size: u64, seed: u64) -> Self

Create a new in-memory storage with the given size and seed.

§Arguments

size - Total size of the storage in bytes
seed - Seed for deterministic random generation (used for unwritten sector fill)

§Panics

Panics if size does not fit in usize.

Source

pub fn size(&self) -> u64

Get the total size of the storage in bytes.

Source

pub fn resize(&mut self, new_size: u64)

Resize the storage to a new size.

If the new size is larger, the storage is extended with zeros. If the new size is smaller, the storage is truncated.

§Panics

Panics if size does not fit in usize.

Source

pub fn read(&self, offset: u64, buf: &mut [u8]) -> Result<()>

Read data from storage, applying faults as needed.

§Fault Application

Unwritten sectors are filled with deterministic random data
Faulted sectors have deterministic corruption applied
Active overlays are applied on top

§Arguments

offset - Starting byte offset
buf - Buffer to read into

§Errors

Returns an error if the read would go past the end of storage.

§Panics

Panics if size does not fit in usize.

Source

pub fn write(&mut self, offset: u64, data: &[u8], is_synced: bool) -> Result<()>

Write data to storage.

The storage automatically extends to accommodate writes past the current size, similar to how real file systems work.

§Arguments

offset - Starting byte offset
data - Data to write
is_synced - If false, write is added to pending writes (may be lost on crash)

§Errors

Returns an error on overflow.

§Panics

Panics if size does not fit in usize.

Source

pub fn sync(&mut self)

Sync all pending writes, making them durable.

After sync, pending writes are cleared and won’t be affected by crash simulation.

Source

pub fn apply_misdirected_write( &mut self, intended_offset: u64, mistaken_offset: u64, data: &[u8], ) -> Result<()>

Apply a misdirected write.

Simulates a write that lands at the wrong location. Uses the TigerBeetle 2-overlay pattern:

Overlay 1: intended target shows old data on read
Overlay 2: mistaken target shows new data on read
Pristine memory is updated at intended target

§Arguments

intended_offset - Where the write should have gone
mistaken_offset - Where the write actually went
data - The data that was written

§Errors

Returns an error on overflow.

§Panics

Panics if size does not fit in usize.

Source

pub fn record_phantom_write(&mut self, offset: u64, data: &[u8])

Record a phantom write.

A phantom write appears to succeed but the data is never actually persisted. The data is added to pending writes with is_phantom: true, meaning it will be lost on crash without corrupting other data.

§Arguments

offset - Starting byte offset
data - Data that “appeared” to be written

Source

pub fn apply_crash(&mut self, crash_fault_probability: f64)

Apply crash simulation to pending writes.

For each pending non-phantom write, there’s a chance that a sector in the write range gets marked as faulted (simulating a torn write). Phantom writes simply disappear.