Lines Matching full:ports
26 pub(crate) ports: Vec<ConsolePort>, field
33 pub(super) ports: Vec<ConsolePortSnapshot>, field
41 ports: vec![port], in new_single_port()
49 ports: Vec<ConsolePort>, in new_multi_port()
52 assert!(!ports.is_empty()); in new_multi_port()
58 ports, in new_multi_port()
68 self.ports.len() in max_ports()
75 let num_queues = self.ports.len().max(1); in max_queues()
95 self.ports.iter().flat_map(ConsolePort::keep_rds).collect() in keep_rds()
100 let ports = self in ensure_worker_started() localVariable
101 .ports in ensure_worker_started()
105 WorkerHandle::new(ports).expect("failed to create console worker") in ensure_worker_started()
111 let ports = worker.stop(); in ensure_worker_stopped() localVariable
112 for (worker_port, port) in ports.into_iter().zip(self.ports.iter_mut()) { in ensure_worker_stopped()
139 for port in self.ports.iter_mut() { in start_input_threads()
145 for port in self.ports.iter_mut() { in stop_input_threads()
151 let mut ports = Vec::new(); in snapshot() localVariable
152 for port in &mut self.ports { in snapshot()
153 ports.push(port.snapshot()); in snapshot()
158 ports, in snapshot()
170 for (port, port_snap) in self.ports.iter_mut().zip(snap.ports.iter()) { in restore()