thePR0M3TH3AN/Marlin
1
0
Fork 0
mirror of https://github.com/PR0M3TH3AN/Marlin.git synced 2025-09-07 14:48:44 +00:00
Code Issues Packages Projects Releases Wiki Activity

Format watcher module

Browse Source
This commit is contained in:
thePR0M3TH3AN
2025-05-22 17:49:56 -04:00
parent 1c68e15fd2
commit 84d5e04ce7
1 changed files with 6 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
libmarlin/src/watcher.rs
View File

@@ -520,15 +520,16 @@ impl FileWatcher {
let _ = h.join();
}
*self
.state
.lock()
.map_err(|_| anyhow::anyhow!("state"))? = WatcherState::Stopped;
*self.state.lock().map_err(|_| anyhow::anyhow!("state"))? = WatcherState::Stopped;
Ok(())
}
pub fn status(&self) -> Result<WatcherStatus> {
let st = self.state.lock().map_err(|_| anyhow::anyhow!("state"))?.clone();
let st = self
.state
.lock()
.map_err(|_| anyhow::anyhow!("state"))?
.clone();
Ok(WatcherStatus {
state: st,
events_processed: self.events_processed.load(Ordering::SeqCst),