summaryrefslogtreecommitdiffstats
path: root/src/source
diff options
context:
space:
mode:
authorMatthias Beyer <matthias.beyer@atos.net>2021-02-01 10:10:13 +0100
committerMatthias Beyer <matthias.beyer@atos.net>2021-02-02 09:30:26 +0100
commitb30fd5da992fb6a183db386373b6f23290a2d6a9 (patch)
tree1a8c1685f20a1b7dd4b4b482c4aa1f51255d86e6 /src/source
parent79ef89fc1ba76577cbce5312205610062b070b7d (diff)
Make source verification completely async
Signed-off-by: Matthias Beyer <matthias.beyer@atos.net>
Diffstat (limited to 'src/source')
-rw-r--r--src/source/mod.rs19
1 files changed, 9 insertions, 10 deletions
diff --git a/src/source/mod.rs b/src/source/mod.rs
index 1c97a87..bebd68a 100644
--- a/src/source/mod.rs
+++ b/src/source/mod.rs
@@ -101,20 +101,19 @@ impl SourceEntry {
let p = self.source_file_path();
trace!("Verifying : {}", p.display());
- let path = p.clone();
- let reader = tokio::task::spawn_blocking(move || {
- std::fs::OpenOptions::new()
- .create(false)
- .create_new(false)
- .read(true)
- .open(path)
- .map(std::io::BufReader::new)
- })
- .await??;
+ let reader = tokio::fs::OpenOptions::new()
+ .create(false)
+ .create_new(false)
+ .read(true)
+ .open(&p)
+ .await
+ .map(tokio::io::BufReader::new)?;
+ trace!("Reader constructed for path: {}", p.display());
self.package_source
.hash()
.matches_hash_of(reader)
+ .await
}
pub async fn create(&self) -> Result<tokio::fs::File> {