Function read_events 

pub fn read_events(fd: &Fd) -> Result<Vec<InotifyEvent>, CoreError>

Read all available inotify events from the descriptor.

This function drains the inotify file descriptor until no more events are available (EAGAIN). It is safe to use with edge-triggered reactors.

Edge Cases

• Zero-length read: If the descriptor is non-blocking and no data is ready, this returns Ok(Vec::new()) (via EAGAIN mapping).
• Partial read: This function ensures that only complete event structures are decoded from the buffer.

Errors

• EBADF: The provided file descriptor is invalid.
• EFAULT: The internal buffer points outside the process’s address space.
• EINVAL: Internal buffer is too small for even one event (should not happen).
• EIO: Low-level I/O error.

Examples found in repository

examples/watch_temp.rs (line 23)

fn main() -> Result<(), Box<dyn std::error::Error>> {
    let mut reactor = Reactor::new()?;
    let (inotify_fd, inotify_token) = reactor.setup_inotify()?;

    let temp_dir = std::env::temp_dir();
    let temp_dir_str = temp_dir.to_string_lossy().into_owned();

    println!("Watching {} for modifications...", temp_dir_str);
    add_watch(&inotify_fd, &temp_dir_str, MODIFY_MASK)?;

    let mut events = Vec::new();
    // Monitor for 10 seconds
    let start = std::time::Instant::now();
    while start.elapsed() < Duration::from_secs(10) {
        let n = reactor.wait(&mut events, 64, 1000)?;
        if n > 0 {
            for ev in &events {
                if ev.token == inotify_token {
                    let in_events = read_events(&inotify_fd)?;
                    for ie in in_events {
                        if let Some(name) = ie.name {
                            println!("File modified: {}", String::from_utf8_lossy(&name));
                        } else {
                            println!("Directory modified (wd={})", ie.wd);
                        }
                    }
                }
            }
        }
    }

    println!("Finished watching.");
    Ok(())
}