use md5::{Digest, Md5};
use sha1::Sha1;
use sha2::Sha256;
+use sha2::Sha512;
use std::error::Error;
use std::fs::File;
use std::io::prelude::*;
senders.push(s);
handles.push(sha256_digest(r));
}
+ if algorithms.contains(&Algorithm::Sha512) {
+ let (s, r) = channel();
+ senders.push(s);
+ handles.push(sha512_digest(r));
+ }
// 64 KB chunks will be read from the input at 64 KB and supplied to all hashing threads at once
// Right now that could be up to three threads. If CPU-bound, the other threads will mostly block while the slowest one finishes
})
}
+/// Calculate the sha512 digest of some data on the given channel
+fn sha512_digest(rx: Receiver<Arc<Vec<u8>>>) -> JoinHandle<(Algorithm, Vec<u8>)> {
+ thread::spawn(move || {
+ let mut sha512 = Sha512::new();
+ while let Ok(chunk) = rx.recv() {
+ sha512.update(&*chunk);
+ }
+ let result = sha512.finalize();
+ (Algorithm::Sha512, result.to_vec())
+ })
+}
+
#[cfg(test)]
mod tests {
use super::*;
"b9193853f7798e92e2f6b82eda336fa7d6fc0fa90fdefe665f372b0bad8cdf8c";
fn verify_digest(alg: Algorithm, data: &'static [u8], hash: &str) {
- let reader = Cursor::new(&*data);
+ let reader = Cursor::new(data);
let digests = create_digests(&[alg], Box::new(reader)).unwrap();
assert_eq!(digests.len(), 1);
assert_eq!(digests[0], (alg, hex::decode(hash).unwrap()));