secop-modules 0.1.3

A Rust framework for a hardware server speaking the SECoP protocol (modules package)
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

// -----------------------------------------------------------------------------
// Rust SECoP playground
//
// This program is free software; you can redistribute it and/or modify it under
// the terms of the GNU General Public License as published by the Free Software
// Foundation; either version 2 of the License, or (at your option) any later
// version.
//
// This program is distributed in the hope that it will be useful, but WITHOUT
// ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS
// FOR A PARTICULAR PURPOSE.  See the GNU General Public License for more
// details.
//
// You should have received a copy of the GNU General Public License along with
// this program; if not, write to the Free Software Foundation, Inc.,
// 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
//
// Module authors:
//   Georg Brandl <g.brandl@fz-juelich.de>
//
// -----------------------------------------------------------------------------
//
//! Module dispatcher.

#[macro_use]
extern crate secop_core;

mod simcryo;
mod serial;
mod tcp;
mod toellner;

pub(crate) mod support;

use std::panic::catch_unwind;
use std::error::Error as StdError;
use std::time::Duration;
use std::thread::{Builder, sleep};
use log::*;

use secop_core::module::{Module, ModInternals};


/// Inner (generic) implementation of `run_module`.
fn inner_run<T: Module>(internals: ModInternals) {
    let name = internals.name().to_owned();
    Builder::new().name(name.clone()).spawn(move || loop {
        if catch_unwind(|| {
            T::create(internals.clone()).expect("init failed").run()
        }).is_err() {
            error!("module {} panicked, waiting...", name);
            // remove all pending requests
            internals.req_receiver().try_iter().count();
            // wait for another request to arrive
            while internals.req_receiver().is_empty() {
                sleep(Duration::from_millis(100));
            }
            info!("now restarting module {}", name);
        }
    }).expect("could not start thread");
}


/// Start the module's own thread.
pub fn run_module(internals: ModInternals) -> Result<(), Box<dyn StdError>> {
    Ok(match &*internals.class() {
        "SimCryo" => inner_run::<simcryo::SimCryo>(internals),
        "SerialComm" => inner_run::<serial::SerialComm>(internals),
        "TcpComm" => inner_run::<tcp::TcpComm>(internals),
        "ToellnerPS" => inner_run::<toellner::ToellnerPS>(internals),
        _ => return Err(format!("no such module class: {}", internals.class()).into())
    })
}