diff --git a/src/imfs/real_fetcher.rs b/src/imfs/real_fetcher.rs index 55b94e2c..814fb704 100644 --- a/src/imfs/real_fetcher.rs +++ b/src/imfs/real_fetcher.rs @@ -58,7 +58,9 @@ impl RealFetcher { let handle = jod_thread::Builder::new() .name("notify message converter".to_owned()) .spawn(move || { + log::trace!("RealFetcher converter thread started"); converter_thread(notify_receiver, sender); + log::trace!("RealFetcher converter thread stopped"); }) .expect("Could not start message converter thread"); @@ -83,8 +85,10 @@ impl RealFetcher { } fn converter_thread(notify_receiver: mpsc::Receiver, sender: Sender) { - notify_receiver.into_iter().for_each(|event| { - use DebouncedEvent::*; + use DebouncedEvent::*; + + for event in notify_receiver { + log::trace!("Notify event: {:?}", event); match event { Create(path) => sender.send(ImfsEvent::Created(path)).unwrap(), @@ -114,7 +118,7 @@ fn converter_thread(notify_receiver: mpsc::Receiver, sender: Sen } NoticeWrite(_) | NoticeRemove(_) | Chmod(_) => {} } - }); + } } impl ImfsFetcher for RealFetcher {