libstratis 2.4.2

Stratis daemon
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
49
50
51
52
53
54

// This Source Code Form is subject to the terms of the Mozilla Public
// License, v. 2.0. If a copy of the MPL was not distributed with this
// file, You can obtain one at http://mozilla.org/MPL/2.0/.

use tokio::{
    select,
    sync::{broadcast::Sender, mpsc::UnboundedReceiver},
    task::JoinHandle,
};

use crate::{
    engine::{LockableEngine, UdevEngineEvent},
    jsonrpc::run_server,
    stratis::{StratisError, StratisResult},
};

fn handle_udev(
    engine: LockableEngine,
    mut recv: UnboundedReceiver<UdevEngineEvent>,
) -> JoinHandle<()> {
    tokio::spawn(async move {
        loop {
            let udev_event = match recv.recv().await {
                Some(u) => u,
                None => {
                    error!("Channel from udev handler to JSON RPC handler was shut");
                    return;
                }
            };
            let mut lock = engine.lock().await;
            let _ = lock.handle_event(&udev_event);
        }
    })
}

pub async fn setup(
    engine: LockableEngine,
    recv: UnboundedReceiver<UdevEngineEvent>,
    _: Sender<()>,
) -> StratisResult<()> {
    let mut udev_join = handle_udev(engine.clone(), recv);
    let mut server_join = run_server(engine);

    select! {
        res = &mut udev_join => {
            error!("The JSON RPC udev handling thread exited...");
            res.map_err(|e| StratisError::Error(e.to_string()))
        }
        res = &mut server_join => {
            error!("The server handler thread exited...");
            res.map_err(|e| StratisError::Error(e.to_string()))
        }
    }
}