ciruela 0.6.12

A peer-to-peer synchronization software for servers in datacenters.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40

use std::path::{PathBuf, Path};

use {VPath};
use metadata::dir::Dir;
use metadata::{Meta, Error};



fn scan_dir<F>(dir: &Dir, virtual_path: PathBuf, level: usize,
    add_dir: &mut F)
    -> Result<(), Error>
    where F: FnMut(VPath),
{
    if level > 1 {
        for item in dir.list_dirs()? {
            if let Some(sub_dir) = dir.dir_if_exists(&item)? {
                scan_dir(&sub_dir,
                    virtual_path.join(item), level-1, add_dir)?;
            }
        }
    } else {
        add_dir(VPath::from(virtual_path));
    }
    Ok(())
}

pub fn scan<F>(meta: &Meta, mut add_dir: F)
    -> Result<(), Error>
    where F: FnMut(VPath),
{
    // TODO(tailhook) throttle maybe?
    let root = meta.signatures()?;
    for (virtual_name, ref cfg) in &meta.0.config.dirs {
        if let Some(dir) = root.dir_if_exists(virtual_name)? {
            let vpath = Path::new("/").join(virtual_name);
            scan_dir(&dir, vpath, cfg.num_levels, &mut add_dir)?;
        }
    }
    Ok(())
}