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

use crate::client::Client;
use crate::ifs::workspace_manager::ext_workspace_group_handle_v1::ExtWorkspaceGroupHandleV1;
use crate::ifs::workspace_manager::ext_workspace_manager_v1::ExtWorkspaceManagerV1;
use crate::ifs::workspace_manager::ext_workspace_manager_v1::WorkspaceManagerId;
use crate::ifs::workspace_manager::ext_workspace_manager_v1::WorkspaceManagerIds;
use crate::state::State;
use crate::tree::OutputNode;
use crate::tree::WorkspaceNode;
use crate::utils::copyhashmap::CopyHashMap;
use crate::utils::opt::Opt;
use crate::utils::queue::AsyncQueue;
use std::rc::Rc;

pub mod ext_workspace_group_handle_v1;
pub mod ext_workspace_handle_v1;
pub mod ext_workspace_manager_v1;

#[derive(Default)]
pub struct WorkspaceManagerState {
    queue: AsyncQueue<Rc<Opt<ExtWorkspaceManagerV1>>>,
    dangling_group: Rc<Opt<ExtWorkspaceGroupHandleV1>>,
    ids: WorkspaceManagerIds,
    managers: CopyHashMap<WorkspaceManagerId, Rc<ExtWorkspaceManagerV1>>,
}

impl WorkspaceManagerState {
    pub fn clear(&self) {
        self.managers.clear();
        self.queue.clear();
    }

    pub fn announce_output(&self, on: &OutputNode) {
        for manager in self.managers.lock().values() {
            manager.announce_output(on);
        }
    }

    pub fn announce_workspace(&self, output: &OutputNode, ws: &WorkspaceNode) {
        for manager in self.managers.lock().values() {
            manager.announce_workspace(output, ws);
        }
    }
}

pub async fn workspace_manager_done(state: Rc<State>) {
    loop {
        let manager = state.workspace_managers.queue.pop().await;
        if let Some(manager) = manager.get() {
            manager.send_done();
        }
    }
}

fn group_or_dangling(
    client: &Client,
    group: Option<&ExtWorkspaceGroupHandleV1>,
) -> Rc<Opt<ExtWorkspaceGroupHandleV1>> {
    group
        .map(|g| g.opt.clone())
        .unwrap_or_else(|| client.state.workspace_managers.dangling_group.clone())
}