Lines Matching refs:path
27 use std::path::{Path, PathBuf};
96 pub(super) fn on_cache_get_async(&self, path: impl AsRef<Path>) { in on_cache_get_async()
97 let event = CacheEvent::OnCacheGet(path.as_ref().to_path_buf()); in on_cache_get_async()
101 pub(super) fn on_cache_update_async(&self, path: impl AsRef<Path>) { in on_cache_update_async()
102 let event = CacheEvent::OnCacheUpdate(path.as_ref().to_path_buf()); in on_cache_update_async()
179 path: PathBuf,
184 path: PathBuf,
190 ($result:expr, $cont:stmt, $err_msg:expr, $path:expr) => {
194 warn!("{}, path: {}, msg: {}", $err_msg, $path.display(), err);
212 CacheEvent::OnCacheGet(path) => self.handle_on_cache_get(path), in run()
213 CacheEvent::OnCacheUpdate(path) => self.handle_on_cache_update(path), in run()
268 fn handle_on_cache_get(&self, path: PathBuf) { in handle_on_cache_get()
269 trace!("handle_on_cache_get() for path: {}", path.display()); in handle_on_cache_get()
272 let filename = path.file_name().unwrap().to_str().unwrap(); in handle_on_cache_get()
273 let stats_path = path.with_file_name(format!("{filename}.stats")); in handle_on_cache_get()
299 path.as_ref(), in handle_on_cache_get()
309 trace!("Trying to recompress file: {}", path.display()); in handle_on_cache_get()
314 fs::read(&path), in handle_on_cache_get()
317 path in handle_on_cache_get()
324 path in handle_on_cache_get()
331 path in handle_on_cache_get()
342 fs::rename(&lock_path, &path), in handle_on_cache_get()
371 path.display() in handle_on_cache_get()
382 path.display() in handle_on_cache_get()
393 trace!("Task finished: recompress file: {}", path.display()); in handle_on_cache_get()
402 fn handle_on_cache_update(&self, path: PathBuf) { in handle_on_cache_update()
403 trace!("handle_on_cache_update() for path: {}", path.display()); in handle_on_cache_update()
408 let filename = path in handle_on_cache_update()
413 let stats_path = path.with_file_name(format!("{filename}.stats")); in handle_on_cache_update()
514 let (result, path, entity) = match item { in handle_on_cache_update()
515 CacheEntry::Recognized { path, .. } in handle_on_cache_update()
517 path, in handle_on_cache_update()
519 } => (fs::remove_file(path), path, "file"), in handle_on_cache_update()
520 CacheEntry::Unrecognized { path, is_dir: true } => { in handle_on_cache_update()
521 (fs::remove_dir_all(path), path, "directory") in handle_on_cache_update()
528 path.display(), in handle_on_cache_update()
547 (file: $path:expr) => { in list_cache_contents()
548 add_unrecognized!(false, $path) in list_cache_contents()
550 (dir: $path:expr) => { in list_cache_contents()
551 add_unrecognized!(true, $path) in list_cache_contents()
553 ($is_dir:expr, $path:expr) => { in list_cache_contents()
555 path: $path.to_path_buf(), in list_cache_contents()
561 ([ $( $ty:ident: $path:expr ),* ], $cont:stmt) => {{ in list_cache_contents()
562 $( add_unrecognized!($ty: $path); )* in list_cache_contents()
571 ($result:expr, $cont:stmt, $err_msg:expr, $path:expr) => { in list_cache_contents()
576 $path in list_cache_contents()
601 let path = entry.path(); in list_cache_contents() localVariable
602 match (level, path.is_dir()) { in list_cache_contents()
603 (0..=1, true) => enter_dir(vec, &path, level + 1, cache_config), in list_cache_contents()
606 && path.file_stem() == Some(OsStr::new(".cleanup")) in list_cache_contents()
607 && path.extension().is_some() in list_cache_contents()
611 &path, in list_cache_contents()
618 add_unrecognized!(file: path); in list_cache_contents()
621 match path.extension().and_then(OsStr::to_str) { in list_cache_contents()
624 cache_files.insert(path, entry); in list_cache_contents()
632 &path, in list_cache_contents()
638 add_unrecognized!(file: path); in list_cache_contents()
643 (_, is_dir) => add_unrecognized!(is_dir, path), in list_cache_contents()
649 for (path, entry) in cache_files.iter() { in list_cache_contents()
651 let (mod_, stats_, is_mod) = match path.extension() { in list_cache_contents()
653 path_buf = path.with_extension(""); in list_cache_contents()
656 Some((path, entry)), in list_cache_contents()
661 path_buf = path.with_extension("stats"); in list_cache_contents()
663 Some((path, entry)), in list_cache_contents()
699 path: mod_path.to_path_buf(), in list_cache_contents()
716 path: mod_path.to_path_buf(), in list_cache_contents()
736 fn read_stats_file(path: &Path) -> Option<ModuleCacheStatistics> { in read_stats_file()
737 fs::read_to_string(path) in read_stats_file()
741 path.display(), in read_stats_file()
749 path.display(), in read_stats_file()
757 fn write_stats_file(path: &Path, stats: &ModuleCacheStatistics) -> bool { in write_stats_file()
762 path.display(), in write_stats_file()
767 fs_write_atomic(path, "stats", serialized.as_bytes()).map_err(|_| ()) in write_stats_file()
815 let path = entry.path(); in acquire_task_fs_lock() localVariable
816 if path.is_dir() || path.file_stem() != task_path.file_stem() { in acquire_task_fs_lock()
821 match path.extension() { in acquire_task_fs_lock()
827 && !is_fs_lock_expired(Some(&entry), &path, timeout, allowed_future_drift) in acquire_task_fs_lock()
859 path: &PathBuf, in is_fs_lock_expired()
864 .map_or_else(|| path.metadata(), |e| e.metadata()) in is_fs_lock_expired()
871 path.display(), in is_fs_lock_expired()
884 path.display(), in is_fs_lock_expired()