Struct charts::data::Watcher

pub struct Watcher { /* private fields */ }

Daemon monitoring files.

Implementations

impl Watcher

pub fn spawn(target: impl AsRef<Path>, forever: bool)

Spawns a watcher.

pub fn ctf_run(target: impl AsRef<Path>) -> Res<()>

Runs on a memtrace CTF file.

pub fn run(&mut self, forever: bool) -> Res<()>

Runs the watcher.

impl Watcher

Generic helpers.

pub fn new(dir: impl AsRef<Path>) -> Self

Constructor.

pub fn reset(&mut self)

Resets the watcher’s state.

• clears self.known_files and self.new_diffs;
• adds self.tmp_file and self.init_file to self.known_files.

pub fn reset_run(&mut self, init: Init) -> Res<()>

Restarts the watcher and resets the data.

Called when the init file of the run has changed.

pub fn read_content<Out>(
    &mut self,
    path: impl AsRef<Path>,
    f: impl FnOnce(&str) -> Res<Out>
) -> Res<Out>

Reads the content of a file and applies something to that content.

• clears self.buf once it’s done.
• asserts self.buf.is_empty().

impl Watcher

Init-file related functions.

pub fn try_read_init(&mut self) -> Res<Option<Init>>

Reads the init file in the dump directory.

Returns None when

• init file does not exist, or
• init_last_modified = Some(t) and the init file was modified more recently than t.

This function is used i) during initialization to read the init file, and ii) to check whether it was overwritten by a new run to relaunch everything.

If the result isn’t None, self.init_last_modified is updated to the date of last modification of the init file.

impl Watcher

Diff-related functions.

pub fn register_new_diffs(&mut self, update_progress: bool) -> Res<bool>

Gathers and registers new diffs.

• sleeps for 100 milliseconds if there are no new diffs;
• asserts self.new_diffs.is_empty().
• returns true if something new was discovered.
• update_progress indicates that the crate::data::progress needs to be updated

pub fn gather_new_diffs(
    &mut self,
    upper_bound: Option<SystemTime>
) -> Res<Option<SystemTime>>

Gathers the new diff files.

• diff files to send will be in self.new_diffs.
• assumes self.new_diffs.is_empty().
• returns Some if there was at list one new diff found (equivalent to !self.new_diffs.is_empty())
• returns the most recent date of last modification