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
|
use std::io::{self, Write};
use std::time::Duration;
use clap::{Arg, Command};
fn main() {
let matches = Command::new("Serialport Example - Receive Data")
.about("Reads data from a serial port and echoes it to stdout")
.disable_version_flag(true)
.arg(
Arg::new("port")
.help("The device path to a serial port")
.use_value_delimiter(false)
.required(true),
)
.arg(
Arg::new("baud")
.help("The baud rate to connect at")
.use_value_delimiter(false)
.required(true)
.validator(valid_baud),
)
.get_matches();
let port_name = matches.value_of("port").unwrap();
let baud_rate = matches.value_of("baud").unwrap().parse::<u32>().unwrap();
let port = serialport::new(port_name, baud_rate)
.timeout(Duration::from_millis(10))
.open();
match port {
Ok(mut port) => {
let mut serial_buf: Vec<u8> = vec![0; 1000];
println!("Receiving data on {} at {} baud:", &port_name, &baud_rate);
loop {
match port.read(serial_buf.as_mut_slice()) {
Ok(t) => {
io::stdout().write_all(&serial_buf[..t]).unwrap();
io::stdout().flush().unwrap();
}
Err(ref e) if e.kind() == io::ErrorKind::TimedOut => (),
Err(e) => eprintln!("{:?}", e),
}
}
}
Err(e) => {
eprintln!("Failed to open \"{}\". Error: {}", port_name, e);
::std::process::exit(1);
}
}
}
fn valid_baud(val: &str) -> Result<(), String> {
val.parse::<u32>()
.map(|_| ())
.map_err(|_| format!("Invalid baud rate '{}' specified", val))
}
|
