eck 0.0.3

A fast, simple file & folder encryption manager, written in Rust
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

use std::{
    marker::PhantomData,
    sync::{
        Arc, Mutex,
        mpsc::{Receiver, Sender},
    },
    thread::{self, JoinHandle},
};

use crate::{
    errors::EnkryptitError,
    parallelism::{EnkryptitJob, executable::EnkryptitExecutable},
};

pub struct EnkryptitWorker<T: EnkryptitExecutable> {
    _id: usize,
    _thread: JoinHandle<()>,
    _phantom: PhantomData<T>,
}

impl<T: EnkryptitExecutable + Send + 'static> EnkryptitWorker<T> {
    pub fn new(
        id: usize,
        receiver: Arc<Mutex<Receiver<EnkryptitJob<T>>>>,
        sender: Sender<Result<T::Output, EnkryptitError>>,
    ) -> Self {
        let thread = thread::spawn(move || {
            loop {
                let job = match receiver.lock().unwrap().recv() {
                    Ok(job) => job,
                    Err(_) => break,
                };

                let result = job.execute();

                if sender.send(result).is_err() {
                    break;
                }
            }
        });

        Self {
            _id: id,
            _thread: thread,
            _phantom: PhantomData,
        }
    }
}