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
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57

use std::io::{Read, BufReader};
use std::fs::File;

use index::{ImageId};
use index_cache::IndexData;
use metadata::{Meta, Error};
use dir_signature::v1::Parser;


pub fn read_bytes(image_id: &ImageId, meta: &Meta) -> Result<Vec<u8>, Error> {
    // TODO(tailhook) assert on thread name
    let hex_id = image_id.to_string();
    let filename = format!("{}.ds1", &hex_id);
    let base = meta.indexes()?
        .dir_if_exists(&hex_id[..2])?
        .ok_or(Error::IndexNotFound)?;
    let mut buf = Vec::with_capacity(4096);
    base.read_file(&filename, |mut f| f.read_to_end(&mut buf))?
        .ok_or(Error::IndexNotFound)?;
    Ok(buf)
}

pub fn read(image_id: &ImageId, meta: &Meta) -> Result<IndexData, Error> {
    // TODO(tailhook) assert on thread name
    let hex_id = image_id.to_string();
    let filename = format!("{}.ds1", &hex_id);
    let base = meta.indexes()?
        .dir_if_exists(&hex_id[..2])?
        .ok_or(Error::IndexNotFound)?;
    let file_res = base.read_file(&filename, |f| {
        IndexData::parse(image_id, BufReader::new(f))
    });
    let index = match file_res {
        Ok(Some(data)) => data,
        Ok(None) => return Err(Error::IndexNotFound),
        Err(e @ Error::Decode(..)) => {
            base.rename_broken_file(&filename,
                format_args!("Error reading index: {}", e));
            return Err(Error::IndexNotFound);
        }
        Err(e) => return Err(e),
    };
    Ok(index)
}

pub fn open(image_id: &ImageId, meta: &Meta)
    -> Result<Parser<BufReader<File>>, Error>
{
    let hex_id = image_id.to_string();
    let filename = format!("{}.ds1", &hex_id);
    let base = meta.indexes()?
        .dir_if_exists(&hex_id[..2])?
        .ok_or(Error::IndexNotFound)?;
    let parser = Parser::new(BufReader::new(base.open_file(&filename)?
        .ok_or(Error::IndexNotFound)?))?;
    Ok(parser)
}