Struct DataStore 

pub struct DataStore { /* private fields */ }

A unified data store that maps (area, db_number, offset) -> u8.

Supports:

• Arbitrary area codes (PI / PA / MK / DB / TI / CT / …)
• Per-area registration (register_area / unregister_area)
• CPU run-state (cpu_state / set_cpu_state)
• Read / write event callbacks

Implementations

impl DataStore

pub fn new() -> Self

Create a new empty store.

pub fn register_area(&self, area_code: u8, size: usize)

Register a memory area. size is a hint; reads beyond written bytes return zeros.

pub fn unregister_area(&self, area_code: u8)

Unregister a previously registered area.

pub fn is_area_registered(&self, area_code: u8) -> bool

Check whether an area is registered.

pub fn registered_areas(&self) -> Vec<u8>

Return the set of registered area codes.

pub fn lock_area(&self, area_code: u8)

Lock an area: subsequent write_area calls to this area return without modifying data (silently skipped, matching C snap7 Srv_LockArea behaviour).

pub fn unlock_area(&self, area_code: u8)

Unlock an area previously locked with lock_area.

pub fn is_area_locked(&self, area_code: u8) -> bool

Return whether an area is currently locked.

pub fn get_status(&self) -> ServerStatus

Return current server/CPU status and connected client count.

pub fn get_mask(&self) -> u32

Return the current event filter mask.

pub fn set_mask(&self, mask: u32)

Set the event filter mask. Only events whose kind-bit is set are enqueued.

pub fn clear_events(&self)

Drain the event queue.

pub fn pick_event(&self) -> Option<EventInfo>

Pop the oldest event from the queue. Returns None when empty.

pub fn cpu_state(&self) -> CpuState

Current simulated CPU state.

pub fn set_cpu_state(&self, state: CpuState)

Set the simulated CPU state and fire event_callbacks.

pub fn get_clock(&self) -> [u8; 8]

Return the simulated RTC as 8 BCD bytes (S7 DATE_AND_TIME format).

pub fn set_clock(&self, bytes: [u8; 8])

Set the simulated RTC from 8 BCD bytes (S7 DATE_AND_TIME format).

pub fn read_bytes(&self, db: u16, start: u32, count: u32) -> Vec<u8>

Read a contiguous range of bytes.

pub fn read_area(&self, area: u8, db: u16, start: u32, count: u32) -> Vec<u8>

Read from an arbitrary area.

pub fn write_area(&self, area: u8, db: u16, start: u32, data: &[u8])

Write to an arbitrary area.

Silently no-ops if the area is currently locked via lock_area.

pub fn write_bytes(&self, db: u16, start: u32, data: &[u8])

Write to DB area (convenience, retained for backward compat).

pub fn on_read<F>(&self, cb: F)

where F: Fn(&EventInfo) + Send + 'static,

Register a callback fired on every data read.

pub fn on_write<F>(&self, cb: F)

where F: Fn(&EventInfo) + Send + 'static,

Register a callback fired on every data write.

pub fn on_event<F>(&self, cb: F)

where F: Fn(&str) + Send + 'static,

Register a callback fired on CPU state changes and other server events.

Trait Implementations

impl Clone for DataStore

fn clone(&self) -> DataStore

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Default for DataStore

fn default() -> Self

Returns the “default value” for a type.