jwalk 0.8.1

Filesystem walk performed in parallel with streamed and sorted results.
Documentation 
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

use std::sync::atomic::{AtomicBool, Ordering as AtomicOrdering};
use std::sync::Arc;

use super::{ClientState, Ordered, OrderedQueue, ReadDir, ReadDirCallback, ReadDirSpec};
use crate::Result;

pub(crate) struct RunContext<C: ClientState> {
    pub(crate) stop: Arc<AtomicBool>,
    pub(crate) read_dir_spec_queue: OrderedQueue<ReadDirSpec<C>>,
    pub(crate) read_dir_result_queue: OrderedQueue<Result<ReadDir<C>>>,
    pub(crate) core_read_dir_callback: Arc<ReadDirCallback<C>>,
}

impl<C: ClientState> RunContext<C> {
    pub(crate) fn stop(&self) {
        self.stop.store(true, AtomicOrdering::SeqCst);
    }

    pub(crate) fn schedule_read_dir_spec(&self, ordered_read_dir: Ordered<ReadDirSpec<C>>) -> bool {
        self.read_dir_spec_queue.push(ordered_read_dir).is_ok()
    }

    pub(crate) fn send_read_dir_result(
        &self,
        read_dir_result: Ordered<Result<ReadDir<C>>>,
    ) -> bool {
        self.read_dir_result_queue.push(read_dir_result).is_ok()
    }

    pub(crate) fn complete_item(&self) {
        self.read_dir_spec_queue.complete_item()
    }
}

impl<C: ClientState> Clone for RunContext<C> {
    fn clone(&self) -> Self {
        RunContext {
            stop: self.stop.clone(),
            read_dir_spec_queue: self.read_dir_spec_queue.clone(),
            read_dir_result_queue: self.read_dir_result_queue.clone(),
            core_read_dir_callback: self.core_read_dir_callback.clone(),
        }
    }
}