rusty-modbus-server 0.1.0

Async Modbus server with pluggable DataStore backend
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73

//! Server configuration types.

use std::net::SocketAddr;
use std::time::Duration;

use rusty_modbus_tcp::config::TcpServerConfig;
use rusty_modbus_types::UnitId;

/// Server configuration.
#[derive(Debug, Clone)]
pub struct ServerConfig {
    /// Address to listen on.
    pub listen_addr: SocketAddr,
    /// This server's Unit ID. Default: `UnitId(1)`.
    pub unit_id: UnitId,
    /// Maximum concurrent connections. Default: 64.
    pub max_connections: usize,
    /// Maximum concurrent transactions per connection. Default: 16.
    pub max_transactions: u16,
    /// Shutdown timeout. Default: 10s.
    pub shutdown_timeout: Duration,
    /// Device identification for FC 0x2B/0x0E.
    pub device_id: DeviceIdentification,
    /// Underlying TCP server config.
    pub tcp_config: TcpServerConfig,
}

impl Default for ServerConfig {
    fn default() -> Self {
        Self {
            listen_addr: "0.0.0.0:502".parse().unwrap(),
            unit_id: UnitId(1),
            max_connections: 64,
            max_transactions: 16,
            shutdown_timeout: Duration::from_secs(10),
            device_id: DeviceIdentification::default(),
            tcp_config: TcpServerConfig::default(),
        }
    }
}

/// Device identification for Read Device ID (FC 0x2B/0x0E).
#[derive(Debug, Clone)]
pub struct DeviceIdentification {
    /// Vendor name (mandatory, object 0x00).
    pub vendor_name: String,
    /// Product code (mandatory, object 0x01).
    pub product_code: String,
    /// Major/minor revision (mandatory, object 0x02).
    pub major_minor_revision: String,
    /// Vendor URL (optional).
    pub vendor_url: Option<String>,
    /// Product name (optional).
    pub product_name: Option<String>,
    /// Model name (optional).
    pub model_name: Option<String>,
    /// User application name (optional).
    pub user_application_name: Option<String>,
}

impl Default for DeviceIdentification {
    fn default() -> Self {
        Self {
            vendor_name: String::from("rusty-modbus"),
            product_code: String::from("RMOD"),
            major_minor_revision: String::from("0.1.0"),
            vendor_url: None,
            product_name: None,
            model_name: None,
            user_application_name: None,
        }
    }
}