fs4/
unix.rs

1macro_rules! lock_impl {
2    ($file: ty) => {
3        #[cfg(not(target_os = "wasi"))]
4        pub fn lock_shared(file: &$file) -> std::io::Result<()> {
5            flock(file, rustix::fs::FlockOperation::LockShared)
6        }
7
8        #[cfg(not(target_os = "wasi"))]
9        pub fn lock_exclusive(file: &$file) -> std::io::Result<()> {
10            flock(file, rustix::fs::FlockOperation::LockExclusive)
11        }
12
13        #[cfg(not(target_os = "wasi"))]
14        pub fn try_lock_shared(file: &$file) -> std::io::Result<()> {
15            flock(file, rustix::fs::FlockOperation::NonBlockingLockShared)
16        }
17
18        #[cfg(not(target_os = "wasi"))]
19        pub fn try_lock_exclusive(file: &$file) -> std::io::Result<()> {
20            flock(file, rustix::fs::FlockOperation::NonBlockingLockExclusive)
21        }
22
23        #[cfg(not(target_os = "wasi"))]
24        pub fn unlock(file: &$file) -> std::io::Result<()> {
25            flock(file, rustix::fs::FlockOperation::Unlock)
26        }
27
28        #[cfg(not(target_os = "wasi"))]
29        fn flock(file: &$file, flag: rustix::fs::FlockOperation) -> std::io::Result<()> {
30            let borrowed_fd = unsafe { rustix::fd::BorrowedFd::borrow_raw(file.as_raw_fd()) };
31
32            match rustix::fs::flock(borrowed_fd, flag) {
33                Ok(_) => Ok(()),
34                Err(e) => Err(std::io::Error::from_raw_os_error(e.raw_os_error())),
35            }
36        }
37    };
38}
39
40#[cfg(any(
41    feature = "smol",
42    feature = "async-std",
43    feature = "tokio",
44    feature = "fs-err-tokio"
45))]
46pub(crate) mod async_impl;
47#[cfg(any(feature = "sync", feature = "fs-err"))]
48pub(crate) mod sync_impl;
49
50use crate::FsStats;
51
52use std::io::{Error, Result};
53use std::path::Path;
54
55pub fn lock_error() -> Error {
56    Error::from_raw_os_error(rustix::io::Errno::WOULDBLOCK.raw_os_error())
57}
58
59pub fn statvfs(path: impl AsRef<Path>) -> Result<FsStats> {
60    match rustix::fs::statvfs(path.as_ref()) {
61        Ok(stat) => Ok(FsStats {
62            free_space: stat.f_frsize * stat.f_bfree,
63            available_space: stat.f_frsize * stat.f_bavail,
64            total_space: stat.f_frsize * stat.f_blocks,
65            allocation_granularity: stat.f_frsize,
66        }),
67        Err(e) => Err(std::io::Error::from_raw_os_error(e.raw_os_error())),
68    }
69}
fs4/unix.rs

fs4/
unix.rs
