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
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
use std::{fmt, path::Path, str::FromStr};
use nix::libc::{dev_t, major, makedev, minor};
use nix::sys::stat::{self, SFlag};
use crate::{
core::errors,
result::{DmError, DmResult},
};
#[derive(Debug, PartialEq, Eq, Clone, Copy, Hash)]
pub struct Device {
pub major: u32,
pub minor: u32,
}
impl fmt::Display for Device {
fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
write!(f, "{}:{}", self.major, self.minor)
}
}
impl FromStr for Device {
type Err = DmError;
fn from_str(s: &str) -> Result<Device, DmError> {
let vals = s.split(':').collect::<Vec<_>>();
if vals.len() != 2 {
let err_msg = format!("value \"{}\" split into wrong number of fields", s);
return Err(DmError::Core(errors::Error::InvalidArgument(err_msg)));
}
let major = vals[0].parse::<u32>().map_err(|_| {
DmError::Core(errors::Error::InvalidArgument(format!(
"could not parse \"{}\" to obtain major number",
vals[0]
)))
})?;
let minor = vals[1].parse::<u32>().map_err(|_| {
DmError::Core(errors::Error::InvalidArgument(format!(
"could not parse \"{}\" to obtain minor number",
vals[1]
)))
})?;
Ok(Device { major, minor })
}
}
impl From<dev_t> for Device {
fn from(val: dev_t) -> Device {
let major = unsafe { major(val) };
#[cfg(target_os = "android")]
let major = major as u32;
let minor = unsafe { minor(val) };
#[cfg(target_os = "android")]
let minor = minor as u32;
Device { major, minor }
}
}
impl From<Device> for dev_t {
fn from(dev: Device) -> dev_t {
#[cfg(target_os = "android")]
#[allow(unused_unsafe)] #[allow(clippy::useless_conversion)] unsafe {
makedev(
dev.major
.try_into()
.expect("value is smaller than max positive i32"),
dev.minor
.try_into()
.expect("value is smaller than max positive i32"),
)
}
#[cfg(not(target_os = "android"))]
#[allow(unused_unsafe)] unsafe {
makedev(dev.major, dev.minor)
}
}
}
impl Device {
pub fn from_kdev_t(val: u32) -> Device {
Device {
major: (val & 0xf_ff00) >> 8,
minor: (val & 0xff) | ((val >> 12) & 0xf_ff00),
}
}
pub fn to_kdev_t(self) -> Option<u32> {
if self.major > 0xfff || self.minor > 0xf_ffff {
return None;
}
Some((self.minor & 0xff) | (self.major << 8) | ((self.minor & !0xff) << 12))
}
}
pub fn devnode_to_devno(path: &Path) -> DmResult<Option<u64>> {
match stat::stat(path) {
Ok(metadata) => Ok(
if metadata.st_mode & SFlag::S_IFMT.bits() == SFlag::S_IFBLK.bits() {
Some(metadata.st_rdev)
} else {
None
},
),
Err(err) if err == nix::Error::ENOENT => Ok(None),
Err(err) => Err(DmError::Core(errors::Error::MetadataIo(
path.to_owned(),
err.to_string(),
))),
}
}
#[cfg(test)]
mod tests {
use super::*;
#[test]
fn test_dev_t_conversion() {
let test_devt_1: dev_t = 0xabcd_ef12_3456_7890;
let dev1 = Device::from(test_devt_1);
assert_eq!(dev1.major, 0xabcd_e678);
assert_eq!(dev1.minor, 0xf123_4590);
let test_devt_2: dev_t = dev_t::from(dev1);
assert_eq!(test_devt_1, test_devt_2);
}
#[test]
fn test_kdev_t_conversion() {
let test_devt_1: u32 = 0x1234_5678;
let dev1 = Device::from_kdev_t(test_devt_1);
assert_eq!(dev1.major, 0x456);
assert_eq!(dev1.minor, 0x1_2378);
let test_devt_2: u32 = dev1.to_kdev_t().unwrap();
assert_eq!(test_devt_1, test_devt_2);
let dev2 = Device::from(0xabcd_ef12_3456_7890);
assert_eq!(dev2.to_kdev_t(), None);
}
}