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
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
use crate::{
bindings,
error::{get_errno, Error},
rtos::DataSource,
};
pub struct AdiUltrasonic {
port: bindings::ext_adi_ultrasonic_t,
}
impl AdiUltrasonic {
pub unsafe fn new(
out_port: u8,
in_port: u8,
smart_port: u8,
) -> Result<Self, AdiUltrasonicError> {
match bindings::ext_adi_ultrasonic_init(smart_port, out_port, in_port) {
bindings::PROS_ERR_ => Err(AdiUltrasonicError::from_errno()),
port => Ok(Self { port }),
}
}
pub fn get(&self) -> Result<u32, AdiUltrasonicError> {
match unsafe { bindings::ext_adi_ultrasonic_get(self.port) } {
bindings::PROS_ERR_ => Err(AdiUltrasonicError::from_errno()),
r if r < 0 => Err(AdiUltrasonicError::NoReading),
r => Ok(r as u32),
}
}
}
impl DataSource for AdiUltrasonic {
type Data = u32;
type Error = AdiUltrasonicError;
fn read(&self) -> Result<Self::Data, Self::Error> {
self.get()
}
}
impl Drop for AdiUltrasonic {
fn drop(&mut self) {
if unsafe { bindings::ext_adi_ultrasonic_shutdown(self.port) } == bindings::PROS_ERR_ {
panic!(
"failed to shutdown ADI ultrasonic: {:?}",
AdiUltrasonicError::from_errno()
)
}
}
}
#[derive(Debug)]
pub enum AdiUltrasonicError {
PortsOutOfRange,
PortsNotAdiUltrasonic,
PortNonMatchingExtenders,
NoReading,
Unknown(i32),
}
impl AdiUltrasonicError {
fn from_errno() -> Self {
match get_errno() {
libc::ENXIO => Self::PortsOutOfRange,
libc::EADDRINUSE => Self::PortsNotAdiUltrasonic,
x => Self::Unknown(x),
}
}
}
impl From<AdiUltrasonicError> for Error {
fn from(err: AdiUltrasonicError) -> Self {
match err {
AdiUltrasonicError::PortsOutOfRange => Error::Custom("ports out of range".into()),
AdiUltrasonicError::PortsNotAdiUltrasonic => {
Error::Custom("ports not an adi ultrasonic".into())
}
AdiUltrasonicError::PortNonMatchingExtenders => {
Error::Custom("ports from non-matching extenders".into())
}
AdiUltrasonicError::NoReading => Error::Custom("sensor did not hear an echo".into()),
AdiUltrasonicError::Unknown(n) => Error::System(n),
}
}
}