jay-compositor 1.15.0

The Jay compositor
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
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76

use crate::client::Client;
use crate::ifs::jay_debugfs_mount_request::JayDebugfsMountRequest;
use crate::ifs::jay_debugfs_snapshot::JayDebugfsSnapshot;
use crate::leaks::Tracker;
use crate::object::Version;
use crate::utils::errorfmt::ErrorFmt;
use crate::utils::fuse::fuse_error::FuseError;
use crate::wire::JayDebugfsId;
use crate::wire::jay_debugfs::*;
use jay_proc::Object;
use std::rc::Rc;
use thiserror::Error;

#[derive(Object)]
pub struct JayDebugfs {
    pub id: JayDebugfsId,
    pub client: Rc<Client>,
    pub tracker: Tracker<Self>,
    pub version: Version,
}

impl JayDebugfsRequestHandler for JayDebugfs {
    type Error = JayDebugfsError;

    fn destroy(&self, _req: Destroy, _slf: &Rc<Self>) -> Result<(), Self::Error> {
        self.client.remove_obj(self);
        Ok(())
    }

    fn create_snapshot(&self, req: CreateSnapshot<'_>, _slf: &Rc<Self>) -> Result<(), Self::Error> {
        let obj = Rc::new(JayDebugfsSnapshot {
            id: req.id,
            client: self.client.clone(),
            tracker: Default::default(),
            version: self.version,
        });
        track!(self.client, obj);
        self.client.add_client_obj(&obj);
        let res = self
            .client
            .state
            .snapshot_debugfs(req.root, req.json)
            .map_err(JayDebugfsError::Snapshot);
        match res {
            Ok(fd) => obj.send_success(&fd),
            Err(e) => obj.send_failure(&ErrorFmt(e).to_string()),
        }
        Ok(())
    }

    fn mount(&self, req: Mount, _slf: &Rc<Self>) -> Result<(), Self::Error> {
        let obj = Rc::new(JayDebugfsMountRequest {
            id: req.id,
            client: self.client.clone(),
            tracker: Default::default(),
            version: self.version,
            request: Default::default(),
        });
        track!(self.client, obj);
        self.client.add_client_obj(&obj);
        let request = self.client.state.mount_debugfs(obj.clone());
        obj.request.set(Some(request));
        Ok(())
    }

    fn unmount(&self, _req: Unmount, _slf: &Rc<Self>) -> Result<(), Self::Error> {
        self.client.state.unmount_debugfs();
        Ok(())
    }
}

#[derive(Debug, Error)]
pub enum JayDebugfsError {
    #[error("Could not create a snapshot")]
    Snapshot(#[source] FuseError),
}