spvirit-server 0.1.5

PVAccess server library for EPICS
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

//! Example: linked PVs with automatic recomputation.
//!
//! Demonstrates `.link()` — whenever an input PV changes, the output PV
//! is recomputed automatically. Monitor clients on the output PV see
//! updates without any extra code.
//!
//! PVs:
//!   CALC:A      (ao) — writable input A
//!   CALC:B      (ao) — writable input B
//!   CALC:SUM    (ai) — A + B  (auto-computed)
//!   CALC:PROD   (ai) — A × B  (auto-computed)
//!   CALC:MEAN   (ai) — (A + B) / 2  (auto-computed)
//!
//! Try it:
//!   cargo run -p spvirit-server --example linked_calc
//!
//! Then from another terminal:
//!   pvput CALC:A 10
//!   pvput CALC:B 3
//!   pvget CALC:SUM      # → 13
//!   pvget CALC:PROD     # → 30
//!   pvget CALC:MEAN     # → 6.5
//!   pvmonitor CALC:SUM  # live updates whenever A or B changes

use spvirit_server::PvaServer;
use spvirit_types::ScalarValue;

fn f64_of(v: &ScalarValue) -> f64 {
    match v {
        ScalarValue::F64(x) => *x,
        _ => 0.0,
    }
}

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
    let server = PvaServer::builder()
        // Writable inputs
        .ao("CALC:A", 0.0)
        .ao("CALC:B", 0.0)
        // Computed outputs (read-only)
        .ai("CALC:SUM", 0.0)
        .ai("CALC:PROD", 0.0)
        .ai("CALC:MEAN", 0.0)
        // Links: recomputed whenever CALC:A or CALC:B changes
        .link("CALC:SUM", &["CALC:A", "CALC:B"], |v| {
            ScalarValue::F64(f64_of(&v[0]) + f64_of(&v[1]))
        })
        .link("CALC:PROD", &["CALC:A", "CALC:B"], |v| {
            ScalarValue::F64(f64_of(&v[0]) * f64_of(&v[1]))
        })
        .link("CALC:MEAN", &["CALC:A", "CALC:B"], |v| {
            ScalarValue::F64((f64_of(&v[0]) + f64_of(&v[1])) / 2.0)
        })
        .build();

    server.run().await
}