phidget 0.4.1

Phidget library for Rust.
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

// phidget-rs/examples/servermon.rs
//
// Copyright (c) 2023, Frank Pagliughi
//
// This file is an example application for the 'phidget-rs' library.
//
// Licensed under the MIT license:
//   <LICENSE or http://opensource.org/licenses/MIT>
// This file may not be copied, modified, or distributed except according
// to those terms.
//

//! Rust Phidget example application to monitor server additions and
//! removals.
//!
//! This assumes a server running on localhost.
//!
//! After starting this monitor, try disconnecting or shutting down the
//! server then restarting it.
//!
//! Note that on Linx, this seems to require superuser privilege to detect
//! server "add" event. And it uses significant CPU resources.

use phidget::net::{Server as PhidgetServer, ServerType as PhidgetServerType};
use std::{process, thread};

// Handler for when a server was added
fn on_server_added(srvr: PhidgetServer) {
    println!("Server added: {:?}", srvr);
}

// Handler for when a server was removed
fn on_server_removed(srvr: PhidgetServer) {
    println!("Server removed: {:?}", srvr);
}

fn main() -> anyhow::Result<()> {
    println!("Phidget server monitor.\n");

    // Register the handlers
    phidget::net::set_on_server_added_handler(on_server_added)?;
    phidget::net::set_on_server_removed_handler(on_server_removed)?;

    // Start the discovery
    if let Err(err) = phidget::net::enable_server_discovery(PhidgetServerType::DeviceRemote) {
        eprintln!("{}", err);
        process::exit(1);
    }

    // ^C handler wakes up the main thread
    ctrlc::set_handler({
        let thr = thread::current();
        move || {
            println!("\nExiting...");
            thr.unpark();
        }
    })
    .expect("Error setting Ctrl-C handler");

    // Block until a ^C wakes us up to exit.
    thread::park();
    Ok(())
}