| 683 | } |
| 684 | |
| 685 | async fn cache_stats(pri_cache: ArcDiskCache<PathBuf, Status>) { |
| 686 | // let zero = CacheStats::default(); |
| 687 | loop { |
| 688 | let stats = pri_cache.view_stats(); |
| 689 | warn!("cache stats - {:?}", stats); |
| 690 | // stats.change_since(&zero)); |
| 691 | if cfg!(debug_assertions) { |
| 692 | sleep(Duration::from_secs(5)).await; |
| 693 | } else { |
| 694 | sleep(Duration::from_secs(300)).await; |
| 695 | } |
| 696 | } |
| 697 | } |
| 698 | |
| 699 | fn cache_mgr(mut submit_rx: Receiver<CacheMeta>, pri_cache: ArcDiskCache<PathBuf, Status>) { |
| 700 | // Wait on the channel, and when we get something proceed from there. |