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
77
78
79
80
81
82
83
84
85
86
87
|
use std::collections::HashMap;
use super::{TerminalId, TerminalRuntime};
/// Server-owned live terminal runtimes, keyed by durable terminal id.
///
/// This sits outside `AppState` so pure state can stay focused on workspace,
/// pane, and terminal metadata while the server/application layer owns PTYs,
/// parser backends, detector tasks, and channels.
#[derive(Default)]
pub(crate) struct TerminalRuntimeRegistry {
runtimes: HashMap<TerminalId, TerminalRuntime>,
}
impl TerminalRuntimeRegistry {
pub(crate) fn new() -> Self {
Self::default()
}
pub(crate) fn get(&self, terminal_id: &TerminalId) -> Option<&TerminalRuntime> {
self.runtimes.get(terminal_id)
}
pub(crate) fn insert(
&mut self,
terminal_id: TerminalId,
runtime: TerminalRuntime,
) -> Option<TerminalRuntime> {
self.runtimes.insert(terminal_id, runtime)
}
pub(crate) fn remove(&mut self, terminal_id: &TerminalId) -> Option<TerminalRuntime> {
self.runtimes.remove(terminal_id)
}
pub(crate) fn values(&self) -> impl Iterator<Item = &TerminalRuntime> {
self.runtimes.values()
}
#[cfg(unix)]
pub(crate) fn iter(&self) -> impl Iterator<Item = (&TerminalId, &TerminalRuntime)> {
self.runtimes.iter()
}
#[cfg(unix)]
pub(crate) fn set_handoff_readers_paused(&self, paused: bool) {
for runtime in self.runtimes.values() {
runtime.set_handoff_reader_paused(paused);
}
}
#[cfg(unix)]
pub(crate) fn assume_handoff_ownership(&mut self) {
for runtime in self.runtimes.values_mut() {
runtime.assume_handoff_ownership();
}
}
pub(crate) fn len(&self) -> usize {
self.runtimes.len()
}
#[cfg(unix)]
pub(crate) fn nudge_child_redraw_after_handoff(&self) {
for runtime in self.runtimes.values() {
runtime.nudge_child_redraw_after_handoff();
}
}
#[cfg(unix)]
pub(crate) fn drain_for_handoff(
&mut self,
) -> impl Iterator<Item = (TerminalId, TerminalRuntime)> + '_ {
self.runtimes.drain()
}
#[cfg(test)]
pub(crate) fn drain(&mut self) -> impl Iterator<Item = (TerminalId, TerminalRuntime)> + '_ {
self.runtimes.drain()
}
}
impl From<HashMap<TerminalId, TerminalRuntime>> for TerminalRuntimeRegistry {
fn from(runtimes: HashMap<TerminalId, TerminalRuntime>) -> Self {
Self { runtimes }
}
}
|
