fuser 0.17.0

Filesystem in Userspace (FUSE) for Rust
Documentation 
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

// Translated from libfuse's example/poll_client.c (using actual
// poll(2) instead of select(2) that one does, since poll(2) is more
// readily available via the nix crate)
//
// Originally:
//    Copyright (C) 2008       SUSE Linux Products GmbH
//    Copyright (C) 2008       Tejun Heo <teheo@suse.de>
//
// Translated to Rust by Zev Weiss <zev@bewilderbeest.net>
//
// Due to the above provenance, unlike the rest of fuser this file is
// licensed under the terms of the GNU GPLv2.

use std::os::fd::AsFd;

use nix::poll;

const NUMFILES: usize = 16;

fn make_nonblock(fd: impl AsFd) {
    use nix::fcntl::FcntlArg;
    use nix::fcntl::OFlag;
    use nix::fcntl::fcntl;
    let arg = FcntlArg::F_SETFL(OFlag::O_NONBLOCK);
    fcntl(fd, arg).expect("failed to set fd nonblocking");
}

fn main() -> std::io::Result<()> {
    let mut files = Vec::with_capacity(NUMFILES);
    for c in "0123456789ABCDEF".chars() {
        let name = format!("{c}");
        let f = std::fs::File::open(name)?;
        make_nonblock(&f);
        files.push(f);
    }
    let mut readbuf = vec![0u8; 4096];

    let mut pollfds = files
        .iter()
        .map(|f| poll::PollFd::new(f.as_fd(), poll::PollFlags::POLLIN))
        .collect::<Vec<_>>();

    for _ in 0..16 {
        poll::poll(pollfds.as_mut_slice(), poll::PollTimeout::NONE)?;

        for (i, pfd) in pollfds.iter().enumerate() {
            let revents = pfd.revents().expect("got unknown poll flag");
            if !revents.intersects(poll::PollFlags::POLLIN) {
                print!("_:   ");
                continue;
            }
            print!("{i:X}:");
            let nbytes = nix::unistd::read(pfd.as_fd(), readbuf.as_mut_slice())?;
            print!("{nbytes:02} ");
        }
        println!();
    }

    Ok(())
}