Struct S7Server 

pub struct S7Server { /* private fields */ }

TCP listener that accepts connections and runs the full S7 pipeline per connection.

Implementations

impl S7Server

pub async fn bind(config: ServerConfig) -> Result<Self>

Bind a TCP listener at config.bind_addr.

pub async fn start_to(addr: &str, max_connections: usize) -> Result<Self>

Bind to a specific address string (e.g. "0.0.0.0:102").

pub fn local_addr(&self) -> Result<SocketAddr>

Return the local address the server is listening on.

pub async fn serve(self, store: DataStore) -> Result<()>

Accept connections and serve them against store until an accept error occurs.

pub fn get_status(store: &DataStore) -> ServerStatus

Return server/CPU status and connected client count.

pub fn set_cpu_status(store: &DataStore, state: CpuState)

Set the simulated CPU state.

pub fn lock_area(store: &DataStore, area_code: u8)

Lock an area: writes to this area are silently ignored until unlocked.

pub fn unlock_area(store: &DataStore, area_code: u8)

Unlock a previously locked area.

pub fn clear_events(store: &DataStore)

Drain the event queue.

pub fn pick_event(store: &DataStore) -> Option<EventInfo>

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

pub fn get_mask(store: &DataStore) -> u32

Get the current event filter mask.

pub fn set_mask(store: &DataStore, mask: u32)

Set the event filter mask.