mirror of https://github.com/zkat/cacache-rs.git
misc: cargo fmt
This commit is contained in:
parent
323ecacc3b
commit
9c3cf994ec
|
|
@ -2,10 +2,8 @@ use async_std::{fs as afs, task};
|
||||||
use std::fs::{self, File};
|
use std::fs::{self, File};
|
||||||
use std::io::prelude::*;
|
use std::io::prelude::*;
|
||||||
|
|
||||||
|
|
||||||
use criterion::{black_box, criterion_group, criterion_main, Criterion};
|
use criterion::{black_box, criterion_group, criterion_main, Criterion};
|
||||||
|
|
||||||
|
|
||||||
const NUM_REPEATS: usize = 10;
|
const NUM_REPEATS: usize = 10;
|
||||||
|
|
||||||
fn baseline_read_sync(c: &mut Criterion) {
|
fn baseline_read_sync(c: &mut Criterion) {
|
||||||
|
|
|
||||||
16
src/get.rs
16
src/get.rs
|
|
@ -89,7 +89,7 @@ impl Reader {
|
||||||
return Err(Error::EntryNotFound(
|
return Err(Error::EntryNotFound(
|
||||||
cache.as_ref().to_path_buf(),
|
cache.as_ref().to_path_buf(),
|
||||||
key.as_ref().into(),
|
key.as_ref().into(),
|
||||||
))
|
));
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
@ -146,7 +146,7 @@ where
|
||||||
return Err(Error::EntryNotFound(
|
return Err(Error::EntryNotFound(
|
||||||
cache.as_ref().to_path_buf(),
|
cache.as_ref().to_path_buf(),
|
||||||
key.as_ref().into(),
|
key.as_ref().into(),
|
||||||
))
|
));
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
@ -198,7 +198,7 @@ where
|
||||||
return Err(Error::EntryNotFound(
|
return Err(Error::EntryNotFound(
|
||||||
cache.as_ref().to_path_buf(),
|
cache.as_ref().to_path_buf(),
|
||||||
key.as_ref().into(),
|
key.as_ref().into(),
|
||||||
))
|
));
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
@ -240,9 +240,7 @@ where
|
||||||
|
|
||||||
/// Returns true if the given hash exists in the cache.
|
/// Returns true if the given hash exists in the cache.
|
||||||
pub async fn exists<P: AsRef<Path>>(cache: P, sri: &Integrity) -> bool {
|
pub async fn exists<P: AsRef<Path>>(cache: P, sri: &Integrity) -> bool {
|
||||||
read::has_content_async(cache.as_ref(), sri)
|
read::has_content_async(cache.as_ref(), sri).await.is_some()
|
||||||
.await
|
|
||||||
.is_some()
|
|
||||||
}
|
}
|
||||||
|
|
||||||
// ---------------
|
// ---------------
|
||||||
|
|
@ -313,7 +311,7 @@ impl SyncReader {
|
||||||
return Err(Error::EntryNotFound(
|
return Err(Error::EntryNotFound(
|
||||||
cache.as_ref().to_path_buf(),
|
cache.as_ref().to_path_buf(),
|
||||||
key.as_ref().into(),
|
key.as_ref().into(),
|
||||||
))
|
));
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
@ -366,7 +364,7 @@ where
|
||||||
return Err(Error::EntryNotFound(
|
return Err(Error::EntryNotFound(
|
||||||
cache.as_ref().to_path_buf(),
|
cache.as_ref().to_path_buf(),
|
||||||
key.as_ref().into(),
|
key.as_ref().into(),
|
||||||
))
|
));
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
@ -414,7 +412,7 @@ where
|
||||||
return Err(Error::EntryNotFound(
|
return Err(Error::EntryNotFound(
|
||||||
cache.as_ref().to_path_buf(),
|
cache.as_ref().to_path_buf(),
|
||||||
key.as_ref().into(),
|
key.as_ref().into(),
|
||||||
))
|
));
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue