file check bug fixed
parent
54d2b1aaf7
commit
bd5e21fce7
|
|
@ -102,14 +102,16 @@
|
|||
}
|
||||
match &mut self.watcher {
|
||||
Some(notify) => {
|
||||
let mut buffer = [0; 1024];
|
||||
if let Ok(mut notif_events) = notify.read_events(&mut buffer) {
|
||||
// notif_events.into_iter().for_each(|mask| {dbg!(&mask.mask);});
|
||||
// todo!();
|
||||
if let (recreate_watcher, true) = (
|
||||
notif_events.any(|mask| mask.mask == EventMask::DELETE_SELF),
|
||||
notif_events.any(|mask| mask.mask == EventMask::MODIFY)
|
||||
) {
|
||||
let mut buffer = [0; 128];
|
||||
if let Ok(notif_events) = notify.read_events(&mut buffer) {
|
||||
let (need_to_recreate, was_modifired) = notif_events.fold((false, false), |(a, b), mask| {
|
||||
(
|
||||
a || mask.mask == EventMask::DELETE_SELF,
|
||||
b || mask.mask == EventMask::MODIFY,
|
||||
)
|
||||
});
|
||||
|
||||
if let (recreate_watcher, true) = (need_to_recreate, was_modifired) {
|
||||
warn!("File {} ({}) was changed", self.name, &self.path);
|
||||
if recreate_watcher {
|
||||
self.watcher = match create_watcher(&self.name, &self.path) {
|
||||
|
|
|
|||
Loading…
Reference in New Issue