pagers-core 0.1.4

Core library for page cache diagnostics and control on Linux and macOS
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

use crate::mincore::PageMap;

use super::{FileContext, Op};

#[derive(Debug, Clone, Copy, PartialEq, Eq)]
#[cfg_attr(feature = "serde", derive(serde::Serialize, serde::Deserialize))]
pub struct Evict;

impl Op for Evict {
    const LABEL: &str = "evicted";
    const SKIP_RESIDENCY: bool = true;
    const ACTION_SIGN: isize = -1;
    type Output = ();

    fn action_pages(
        _output: &(),
        total_pages: usize,
        pages_in_core_before: Option<usize>,
        pages_in_core_after: usize,
    ) -> usize {
        let before = pages_in_core_before.unwrap_or(total_pages);
        before.saturating_sub(pages_in_core_after)
    }

    fn execute<PM: PageMap + Sync>(&self, ctx: &FileContext<'_, PM>) -> crate::Result<()> {
        tracing::debug!("Evicting {}", ctx.path.display());

        #[cfg(target_os = "linux")]
        {
            use std::os::unix::io::AsFd;
            nix::fcntl::posix_fadvise(
                ctx.file.as_fd(),
                ctx.offset as libc::off_t,
                ctx.len as libc::off_t,
                nix::fcntl::PosixFadviseAdvice::POSIX_FADV_DONTNEED,
            )?;
        }

        #[cfg(target_os = "macos")]
        {
            use nix::sys::mman::{MsFlags, msync};
            use std::ptr::NonNull;

            unsafe {
                let ptr = NonNull::new(ctx.mmap.as_ptr() as *mut _)
                    .expect("mmap pointer should be non-null");
                msync(ptr, ctx.len, MsFlags::MS_INVALIDATE)?;
            }
        }

        Ok(())
    }
}