use std::ffi::CStr;
use std::io;
use std::mem::size_of;
use std::ops::Deref;
use std::ops::DerefMut;
use base::AsRawDescriptor;
use fuse::filesystem::DirEntry;
use fuse::filesystem::DirectoryIterator;
use zerocopy::AsBytes;
use zerocopy::FromBytes;
use zerocopy::FromZeroes;
#[repr(C, packed)]
#[derive(Clone, Copy, AsBytes, FromZeroes, FromBytes)]
struct LinuxDirent64 {
d_ino: libc::ino64_t,
d_off: libc::off64_t,
d_reclen: libc::c_ushort,
d_ty: libc::c_uchar,
}
pub struct ReadDir<P> {
buf: P,
current: usize,
end: usize,
}
impl<P: DerefMut<Target = [u8]>> ReadDir<P> {
pub fn new<D: AsRawDescriptor>(dir: &D, offset: libc::off64_t, mut buf: P) -> io::Result<Self> {
let res = unsafe { libc::lseek64(dir.as_raw_descriptor(), offset, libc::SEEK_SET) };
if res < 0 {
return Err(io::Error::last_os_error());
}
let res = unsafe {
libc::syscall(
libc::SYS_getdents64,
dir.as_raw_descriptor(),
buf.as_mut_ptr() as *mut LinuxDirent64,
buf.len() as libc::c_int,
)
};
if res < 0 {
return Err(io::Error::last_os_error());
}
Ok(ReadDir {
buf,
current: 0,
end: res as usize,
})
}
}
impl<P> ReadDir<P> {
pub fn remaining(&self) -> usize {
self.end.saturating_sub(self.current)
}
}
impl<P: Deref<Target = [u8]>> DirectoryIterator for ReadDir<P> {
fn next(&mut self) -> Option<DirEntry> {
let rem = &self.buf[self.current..self.end];
if rem.is_empty() {
return None;
}
debug_assert!(
rem.len() >= size_of::<LinuxDirent64>(),
"not enough space left in `rem`"
);
let (front, back) = rem.split_at(size_of::<LinuxDirent64>());
let dirent64 =
LinuxDirent64::read_from(front).expect("unable to get LinuxDirent64 from slice");
let namelen = dirent64.d_reclen as usize - size_of::<LinuxDirent64>();
debug_assert!(namelen <= back.len(), "back is smaller than `namelen`");
let name = strip_padding(&back[..namelen]);
let entry = DirEntry {
ino: dirent64.d_ino,
offset: dirent64.d_off as u64,
type_: dirent64.d_ty as u32,
name,
};
debug_assert!(
rem.len() >= dirent64.d_reclen as usize,
"rem is smaller than `d_reclen`"
);
self.current += dirent64.d_reclen as usize;
Some(entry)
}
}
fn strip_padding(b: &[u8]) -> &CStr {
let pos = b
.iter()
.position(|&c| c == 0)
.expect("`b` doesn't contain any nul bytes");
unsafe { CStr::from_bytes_with_nul_unchecked(&b[..pos + 1]) }
}
#[cfg(test)]
mod test {
use super::*;
#[test]
fn padded_cstrings() {
assert_eq!(strip_padding(b".\0\0\0\0\0\0\0").to_bytes(), b".");
assert_eq!(strip_padding(b"..\0\0\0\0\0\0").to_bytes(), b"..");
assert_eq!(
strip_padding(b"normal cstring\0").to_bytes(),
b"normal cstring"
);
assert_eq!(strip_padding(b"\0\0\0\0").to_bytes(), b"");
assert_eq!(
strip_padding(b"interior\0nul bytes\0\0\0").to_bytes(),
b"interior"
);
}
#[test]
#[should_panic(expected = "`b` doesn't contain any nul bytes")]
fn no_nul_byte() {
strip_padding(b"no nul bytes in string");
}
}