Struct Line 

pub struct Line { /* private fields */ }

Several servers on one simulated line, as devices share an RS485 pair: every frame reaches all of them, the one it is addressed to answers, and each carries out a broadcast write.

A line is a Peer, so a SerialPort::simulated port with a line on the far end is a bus of devices a Client polls. Each server is kept behind a shared handle, so a program looks at what a write did to it afterward.

Examples

use pamoja_hal::port::{Parity, SerialPort, Settings};
use pamoja_modbus::{Client, Line, Server};

let mut line = Line::new();
let meter = line.attach(Server::new(17)?.with_input_registers(0, &[2301]));
let pump = line.attach(Server::new(18)?.with_coils(0, &[false]));

let settings = Settings::new(19_200).with_parity(Parity::Even);
let mut client = Client::new(SerialPort::simulated(settings, line));
assert_eq!(client.read_input_registers(17, 0, 1)?, [2301]);
client.write_single_coil(18, 0, true)?;

assert_eq!(pump.lock().unwrap().coil(0), Some(true));
assert_eq!(meter.lock().unwrap().served(), 1);

Implementations

impl Line

pub fn new() -> Line

Makes a line with no devices on it.

pub fn attach(&mut self, server: Server) -> Arc<Mutex<Server>>

Puts a device on the line.

Arguments

• server - the device.

Returns

A shared handle to it, for looking at it or changing its tables later.

pub fn attach_shared(&mut self, server: Arc<Mutex<Server>>)

Puts a device the program already shares on the line.

Arguments

• server - the shared device.

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

Returns the unit addresses on the line, in the order they were attached.

Trait Implementations

impl Clone for Line

fn clone(&self) -> Line

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Line

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for Line

fn default() -> Line

Returns the “default value” for a type.

impl Peer for Line

Available on crate feature port only.

fn receive(&mut self, bytes: &[u8]) -> Vec<u8>

Takes the bytes the port wrote and returns the bytes the device sends back.