utils-system/darakian.ddh
1
0
Fork 0
mirror of https://github.com/darakian/ddh.git synced 2026-09-10 07:06:21 -04:00
Code Issues Actions Packages Projects Releases Wiki Activity

New traverse code compiles

Browse source
This commit is contained in:
Jon Moroney 2018-02-19 12:12:19 +01:00
parent 454c92ed26
commit f59e58d780
1 changed files with 17 additions and 13 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

30
src/main.rs
View file

@ -177,19 +177,23 @@ fn hash_and_send(file_path: &Path, sender: Sender<Fileinfo>) -> (){
}
}
// fn traverse_and_spawn(current_path: &Path, sender: Sender<Fileinfo>) -> (){
// if current_path.is_file(){
// hash_and_send(current_path, sender.clone());
// } else if current_path.is_dir() {
// vec![fs::read_dir(current_path).unwrap().unwrap().collect::<std::fs::DirEntry>()].par_iter().map(|dir_entry|{
// if dir_entry.is_dir(){
// traverse_and_spawn(dir_entry, sender.clone());
// } else if dir_entry.is_file(){
// hash_and_send(dir_entry, sender.clone());
// }
// });
// }
// }
fn traverse_and_spawn(current_path: &Path, sender: Sender<Fileinfo>) -> (){
if current_path.is_file(){
hash_and_send(current_path, sender.clone());
} else if current_path.is_dir() {
let paths: Vec<_> = fs::read_dir(current_path).unwrap().map(|r| r.unwrap()).collect();;
paths.par_iter().for_each_with(sender.clone(), |s, dir_entry| {
if dir_entry.path().is_dir(){
traverse_and_spawn(dir_entry.path().as_path(), s.clone());
} else if dir_entry.path().is_file(){
hash_and_send(dir_entry.path().as_path(), s.clone());
}
});
// .map(|dir_entry| {
//
// });
}
}
fn collect_files(current_path: &Path, mut file_set: Vec<Fileinfo>, pool: ThreadPool, collection_sender: Sender<Vec<Fileinfo>>) -> Vec<Fileinfo> {
//println!("Entering {:?}", current_path.to_str());