diff options
author | Matthias Beyer <matthias.beyer@atos.net> | 2021-02-01 10:10:13 +0100 |
---|---|---|
committer | Matthias Beyer <matthias.beyer@atos.net> | 2021-02-02 09:30:26 +0100 |
commit | b30fd5da992fb6a183db386373b6f23290a2d6a9 (patch) | |
tree | 1a8c1685f20a1b7dd4b4b482c4aa1f51255d86e6 /src/source | |
parent | 79ef89fc1ba76577cbce5312205610062b070b7d (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.rs | 19 |
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> { |