mart-w/kanidm
1
0
Fork 0
mirror of https://github.com/kanidm/kanidm.git synced 2025-05-22 17:03:55 +02:00
Code Issues Actions10 Packages Projects Releases Wiki Activity

Update inotify

Browse source
This commit is contained in:
William Brown 2025-03-13 13:20:22 +10:00
parent 24f253567c
commit 0ad2025155
1 changed files with 23 additions and 3 deletions

26
unix_integration/resolver/src/bin/kanidm_unixd.rs
View file

@ -1089,9 +1089,29 @@ async fn main() -> ExitCode {
// ====== setup an inotify watcher to reload on changes to system files ======
let (inotify_tx, mut inotify_rx) = channel(4);
let watcher = new_debouncer(Duration::from_secs(2), None, move |_event| {
debug!(?_event, "Sending inotify event");
let _ = inotify_tx.try_send(true);
let watcher = new_debouncer(Duration::from_secs(4), None, move |event| {
match event {
Ok(array_event) => {
let mut was_changed = false;
for event in array_event {
if event.kind.is_create() || event.kind.is_modify() || event.kind.is_remove() {
debug!(?event, "Handling inotify modification event");
was_changed = true
}
}
if was_changed {
let _ = inotify_tx.try_send(true);
}
}
Err(array_errors) => {
for err in array_errors {
error!(?err, "inotify debounce error");
}
}
}
})
.and_then(|mut debouncer| {
debouncer.watch(Path::new("/etc/passwd"), RecursiveMode::NonRecursive)