1 | use std::ffi::{OsStr, OsString}; |
2 | use std::io; |
3 | use std::mem; |
4 | use std::os::unix::ffi::OsStrExt; |
5 | use std::os::unix::io::BorrowedFd; |
6 | use std::path::Path; |
7 | |
8 | use rustix::fs as rfs; |
9 | use rustix::path::Arg; |
10 | |
11 | use crate::util::allocate_loop; |
12 | |
13 | use std::os::raw::c_char; |
14 | |
15 | #[cfg (not(target_os = "macos" ))] |
16 | pub const ENOATTR: i32 = rustix::io::Errno::NODATA.raw_os_error(); |
17 | |
18 | #[cfg (target_os = "macos" )] |
19 | pub const ENOATTR: i32 = rustix::io::Errno::NOATTR.raw_os_error(); |
20 | |
21 | // Convert an `&mut [u8]` to an `&mut [c_char]` |
22 | #[inline ] |
23 | fn as_listxattr_buffer(buf: &mut [u8]) -> &mut [c_char] { |
24 | // SAFETY: u8 and i8 have the same size and alignment |
25 | unsafe { &mut *(buf as *mut [u8] as *mut [c_char]) } |
26 | } |
27 | |
28 | /// An iterator over a set of extended attributes names. |
29 | #[derive (Default)] |
30 | pub struct XAttrs { |
31 | data: Box<[u8]>, |
32 | offset: usize, |
33 | } |
34 | |
35 | impl Clone for XAttrs { |
36 | fn clone(&self) -> Self { |
37 | XAttrs { |
38 | data: Vec::from(&*self.data).into_boxed_slice(), |
39 | offset: self.offset, |
40 | } |
41 | } |
42 | fn clone_from(&mut self, other: &XAttrs) { |
43 | self.offset = other.offset; |
44 | |
45 | let mut data: Vec = mem::replace(&mut self.data, src:Box::new([])).into_vec(); |
46 | data.extend(iter:other.data.iter().cloned()); |
47 | self.data = data.into_boxed_slice(); |
48 | } |
49 | } |
50 | |
51 | // Yes, I could avoid these allocations on linux/macos. However, if we ever want to be freebsd |
52 | // compatible, we need to be able to prepend the namespace to the extended attribute names. |
53 | // Furthermore, borrowing makes the API messy. |
54 | impl Iterator for XAttrs { |
55 | type Item = OsString; |
56 | fn next(&mut self) -> Option<OsString> { |
57 | let data: &[u8] = &self.data[self.offset..]; |
58 | if data.is_empty() { |
59 | None |
60 | } else { |
61 | // always null terminated (unless empty). |
62 | let end: usize = data.iter().position(|&b: u8| b == 0u8).unwrap(); |
63 | self.offset += end + 1; |
64 | Some(OsStr::from_bytes(&data[..end]).to_owned()) |
65 | } |
66 | } |
67 | |
68 | fn size_hint(&self) -> (usize, Option<usize>) { |
69 | if self.data.len() == self.offset { |
70 | (0, Some(0)) |
71 | } else { |
72 | (1, None) |
73 | } |
74 | } |
75 | } |
76 | |
77 | pub fn get_fd(fd: BorrowedFd<'_>, name: &OsStr) -> io::Result<Vec<u8>> { |
78 | allocate_loop(|buf: &mut [u8]| rfs::fgetxattr(fd, name, value:buf)) |
79 | } |
80 | |
81 | pub fn set_fd(fd: BorrowedFd<'_>, name: &OsStr, value: &[u8]) -> io::Result<()> { |
82 | rfs::fsetxattr(fd, name, value, flags:rfs::XattrFlags::empty())?; |
83 | Ok(()) |
84 | } |
85 | |
86 | pub fn remove_fd(fd: BorrowedFd<'_>, name: &OsStr) -> io::Result<()> { |
87 | rfs::fremovexattr(fd, name)?; |
88 | Ok(()) |
89 | } |
90 | |
91 | pub fn list_fd(fd: BorrowedFd<'_>) -> io::Result<XAttrs> { |
92 | let vec: Vec = allocate_loop(|buf: &mut [u8]| rfs::flistxattr(fd, list:as_listxattr_buffer(buf)))?; |
93 | Ok(XAttrs { |
94 | data: vec.into_boxed_slice(), |
95 | offset: 0, |
96 | }) |
97 | } |
98 | |
99 | pub fn get_path(path: &Path, name: &OsStr, deref: bool) -> io::Result<Vec<u8>> { |
100 | let path: Cow<'_, CStr> = path.into_c_str()?; |
101 | let name: Cow<'_, CStr> = name.into_c_str()?; |
102 | |
103 | allocate_loop(|buf: &mut [u8]| { |
104 | let getxattr_func: fn(&CStr, &CStr, &mut [u8]) -> Result<…, …> = if deref { rfs::getxattr } else { rfs::lgetxattr }; |
105 | let size: usize = getxattr_func(&*path, &*name, buf)?; |
106 | io::Result::Ok(size) |
107 | }) |
108 | } |
109 | |
110 | pub fn set_path(path: &Path, name: &OsStr, value: &[u8], deref: bool) -> io::Result<()> { |
111 | let setxattr_func: fn(&Path, &OsStr, &[u8], XattrFlags) -> … = if deref { rfs::setxattr } else { rfs::lsetxattr }; |
112 | setxattr_func(path, name, value, rfs::XattrFlags::empty())?; |
113 | Ok(()) |
114 | } |
115 | |
116 | pub fn remove_path(path: &Path, name: &OsStr, deref: bool) -> io::Result<()> { |
117 | let removexattr_func: fn(&Path, &OsStr) -> Result<…, …> = if deref { |
118 | rfs::removexattr |
119 | } else { |
120 | rfs::lremovexattr |
121 | }; |
122 | removexattr_func(path, name)?; |
123 | Ok(()) |
124 | } |
125 | |
126 | pub fn list_path(path: &Path, deref: bool) -> io::Result<XAttrs> { |
127 | let listxattr_func: fn(&CStr, &mut [i8]) -> Result<…, …> = if deref { |
128 | rfs::listxattr |
129 | } else { |
130 | rfs::llistxattr |
131 | }; |
132 | let path: Cow<'_, CStr> = path.as_cow_c_str()?; |
133 | let vec: Vec = allocate_loop(|buf: &mut [u8]| listxattr_func(&*path, as_listxattr_buffer(buf)))?; |
134 | Ok(XAttrs { |
135 | data: vec.into_boxed_slice(), |
136 | offset: 0, |
137 | }) |
138 | } |
139 | |