| /external/crosvm/base/src/sys/unix/ |
| D | tube.rs | 37 pub struct Tube { struct
41 impl Tube { implementation
44 pub fn pair() -> Result<(Tube, Tube)> { in pair()
47 let tube1 = Tube::new(socket1)?; in pair()
48 let tube2 = Tube::new(socket2)?; in pair()
55 pub fn new(socket: StreamChannel) -> Result<Tube> { in new() argument
57 FramingMode::Message => Ok(Tube { socket }), in new()
64 pub fn new_from_unix_seqpacket(sock: UnixSeqpacket) -> Tube { in new_from_unix_seqpacket() argument
65 Tube { in new_from_unix_seqpacket()
76 .map(Tube::new) in try_clone()
[all …]
|
| /external/crosvm/src/sys/windows/ |
| D | generic.rs | 16 use base::Tube;
100 pub(super) fn handle_pvclock_request(tube: &Option<Tube>, command: PvClockCommand) -> Result<()> { in handle_pvclock_request() argument
114 ) -> Result<Option<Tube>> { in create_snd_state_tube() argument
118 pub(super) fn create_snd_mute_tube_pair() -> Result<(Option<Tube>, Option<Tube>)> { in create_snd_mute_tube_pair()
126 ) -> Result<(Option<Tube>, Option<ProtoTube>, Option<()>)> { in start_service_ipc_listener() argument
132 virtio_snd_host_mute_tube: &mut Option<Tube>, in handle_tagged_control_tube_event() argument
134 ipc_main_loop_tube: Option<&Tube>, in handle_tagged_control_tube_event() argument
135 ac97_host_tubes: &[Tube], in handle_tagged_control_tube_event() argument
141 ipc_tube: &'a Option<Tube>, in push_triggers() argument
154 _ac97_host_tubes: &[Tube], in handle_received_token() argument
[all …]
|
| /external/crosvm/base/src/sys/windows/ |
| D | tube.rs | 58 pub struct Tube { struct
105 impl Tube { implementation
109 pub fn pair() -> Result<(Tube, Tube)> { in pair()
113 Ok((Tube::new(socket1), Tube::new(socket2))) in pair()
119 pub fn pair_with_buffer_size(buffer_size: usize) -> Result<(Tube, Tube)> { in pair_with_buffer_size() argument
126 let tube1 = Tube::new(socket1); in pair_with_buffer_size()
127 let tube2 = Tube::new(socket2); in pair_with_buffer_size()
132 pub fn new(socket: StreamChannel) -> Tube { in new() argument
133 Tube { in new()
140 Ok(Tube { in try_clone()
[all …]
|
| /external/crosvm/cros_async/src/sys/unix/ |
| D | async_types.rs | 8 use base::Tube;
17 inner: IoSource<Tube>,
21 pub fn new(ex: &Executor, tube: Tube) -> io::Result<AsyncTube> { in new()
38 type Target = Tube;
45 impl From<AsyncTube> for Tube { implementation
46 fn from(at: AsyncTube) -> Tube { in from() argument
|
| /external/crosvm/base/tests/unix/ |
| D | tube.rs | 17 use base::Tube;
31 let tube_send = Tube::new(sock_send).unwrap(); in test_serialize_tube_new()
32 let tube_recv = Tube::new(sock_recv).unwrap(); in test_serialize_tube_new()
44 let tube_deserialized: Tube = deserialize_with_descriptors( in test_serialize_tube_new()
70 let tube_send = Tube::new_from_unix_seqpacket(sock_send); in test_send_recv_new_from_seqpacket()
71 let tube_recv = Tube::new_from_unix_seqpacket(sock_recv); in test_send_recv_new_from_seqpacket()
93 let tube_error = Tube::new(sock_byte_mode); in test_tube_new_byte_mode_error()
|
| /external/crosvm/src/sys/ |
| D | windows.rs | 67 use base::Tube;
228 Vm(Tube),
229 VmMemory(Tube),
244 fn create_vhost_user_block_device(cfg: &Config, disk_device_tube: Tube) -> DeviceResult { in create_vhost_user_block_device()
259 fn create_block_device(cfg: &Config, disk: &DiskOption, disk_device_tube: Tube) -> DeviceResult { in create_block_device()
283 fn create_vhost_user_gpu_device(base_features: u64, vhost_user_tube: Tube) -> DeviceResult { in create_vhost_user_gpu_device()
302 resource_bridges: Vec<Tube>, in create_gpu_device() argument
343 fn create_vhost_user_snd_device(base_features: u64, vhost_user_tube: Tube) -> DeviceResult { in create_vhost_user_snd_device()
390 fn create_vhost_user_net_device(cfg: &Config, net_device_tube: Tube) -> DeviceResult { in create_vhost_user_net_device()
430 balloon_device_tube: Tube, in create_balloon_device() argument
[all …]
|
| /external/crosvm/tube_transporter/src/ |
| D | packed_tube.rs | 15 use base::Tube;
35 tube: Tube,
52 pub unsafe fn pack(tube: Tube, receiver_pid: u32) -> PackedTubeResult<SafeDescriptor> { in pack() argument
81 pub unsafe fn unpack(descriptor: SafeDescriptor) -> PackedTubeResult<Tube> { in unpack() argument
96 use base::Tube;
103 let (tube_server, tube_client) = Tube::pair().unwrap(); in test_pack_unpack()
|
| D | lib.rs | 24 use base::Tube;
38 pub tube: Tube,
70 dh_tube: Option<Tube>,
89 dh_tube: Option<Tube>, in new() argument
113 pub fn push_tube(&mut self, tube: Tube, tube_token: TubeToken) { in push_tube() argument
169 pub fn get_tube(&mut self, token: TubeToken) -> TransportTubeResult<Tube> { in get_tube() argument
231 let (main_tube_1, device_tube_1) = Tube::pair().unwrap(); in test_send_tubes_through_tube_transporter()
232 let (main_tube_2, device_tube_2) = Tube::pair().unwrap(); in test_send_tubes_through_tube_transporter()
|
| /external/crosvm/x86_64/tests/integration/ |
| D | main.rs | 20 use base::Tube;
60 VmMemory(Tube),
61 VmIrq(Tube),
62 Vm(Tube),
76 FI: FnOnce(V, /* vcpu_count: */ usize, Tube) -> I, in simple_vm_test()
108 let (irqchip_tube, device_tube) = Tube::pair().expect("failed to create irq tube"); in simple_vm_test()
114 let (exit_evt_wrtube, _) = Tube::directional_pair().unwrap(); in simple_vm_test()
122 let (disk_host_tube, disk_device_tube) = Tube::pair().unwrap(); in simple_vm_test()
126 let (gpu_host_tube, _gpu_device_tube) = Tube::pair().unwrap(); in simple_vm_test()
146 let (pcibus_exit_evt_wrtube, _) = Tube::directional_pair().unwrap(); in simple_vm_test()
[all …]
|
| /external/crosvm/cros_async/src/sys/windows/ |
| D | async_types.rs | 11 use base::Tube;
22 inner: Arc<Mutex<Tube>>,
26 pub fn new(_ex: &Executor, tube: Tube) -> io::Result<AsyncTube> { in new()
58 impl From<AsyncTube> for Tube { implementation
59 fn from(at: AsyncTube) -> Tube { in from() argument
|
| /external/crosvm/metrics/src/ |
| D | controller.rs | 11 use base::Tube;
25 pub(crate) agents: Vec<Tube>,
40 pub fn new(agents: Vec<Tube>) -> Self { in new()
56 pub(crate) fn on_tube_readable(&self, client: &Tube) { in on_tube_readable() argument
|
| /external/crosvm/devices/src/virtio/iommu/ |
| D | ipc_memory_mapper.rs | 19 use base::Tube;
69 request_tx: Tube,
70 response_rx: Tube,
89 pub fn new(request_tx: Tube, response_rx: Tube, endpoint_id: u32) -> Self { in new() argument
155 pub response_tx: Tube,
167 pub fn create_ipc_mapper(endpoint_id: u32, request_tx: Tube) -> CreateIpcMapperRet { in create_ipc_mapper()
168 let (response_tx, response_rx) = Tube::pair().expect("failed to create tube pair"); in create_ipc_mapper()
336 let (request_tx, request_rx) = Tube::pair().expect("failed to create tube pair"); in test()
|
| /external/crosvm/base/src/ |
| D | tube.rs | 20 impl Tube { impl
41 pub struct SendTube(Tube);
66 pub fn into_tube(self) -> Tube { in into_tube() argument
74 pub struct RecvTube(Tube);
92 pub fn into_tube(self) -> Tube { in into_tube() argument
|
| /external/crosvm/base/tests/ |
| D | tube.rs | 20 use base::Tube;
47 let (s1, s2) = Tube::pair().unwrap(); in send_recv_no_fd()
64 let (s1, s2) = Tube::pair().unwrap(); in send_recv_one_fd()
119 let (tube_send, tube_recv) = Tube::pair().unwrap(); in test_serialize_tube_pair()
131 let tube_deserialized: Tube = deserialize_with_descriptors( in test_serialize_tube_pair()
156 let (p1, consumer) = Tube::directional_pair().unwrap(); in send_recv_mpsc()
175 let (s1, s2) = Tube::pair().unwrap(); in send_recv_hash_map()
|
| D | process.rs | 13 use base::Tube;
17 let (tube, fork_tube) = Tube::pair().expect("failed to create tube"); in pid_diff()
37 let (tube, fork_tube) = Tube::pair().expect("failed to create tube"); in thread_name()
60 let (tube, fork_tube) = Tube::pair().expect("failed to create tube"); in thread_name_trimmed()
|
| /external/crosvm/src/crosvm/sys/unix/ |
| D | device_helpers.rs | 84 Fs(Tube),
85 Vm(Tube),
87 tube: Tube,
91 VmMsync(Tube),
94 impl AsRef<Tube> for TaggedControlTube {
95 fn as_ref(&self) -> &Tube { in as_ref() argument
205 device_tube: Option<Tube>,
209 pub fn new(disk: &'a DiskOption, device_tube: Option<Tube>) -> Self { in new()
391 tube: Tube, in create_vvu_proxy_device() argument
707 tube: Tube, in create_balloon_device() argument
[all …]
|
| /external/crosvm/src/crosvm/sys/ |
| D | unix.rs | 211 #[cfg(feature = "balloon")] balloon_device_tube: Option<Tube>, in create_virtio_devices()
212 #[cfg(feature = "balloon")] balloon_wss_device_tube: Option<Tube>, in create_virtio_devices()
213 #[cfg(feature = "balloon")] balloon_inflate_tube: Option<Tube>, in create_virtio_devices()
215 disk_device_tubes: &mut Vec<Tube>, in create_virtio_devices() argument
216 pmem_device_tubes: &mut Vec<Tube>, in create_virtio_devices() argument
217 fs_device_tubes: &mut Vec<Tube>, in create_virtio_devices() argument
218 #[cfg(feature = "gpu")] gpu_control_tube: Tube, in create_virtio_devices()
220 vvu_proxy_device_tubes: &mut Vec<Tube>, in create_virtio_devices() argument
241 let mut resource_bridges = Vec::<Tube>::new(); in create_virtio_devices()
245 let mut wl_resource_bridge = None::<Tube>; in create_virtio_devices()
[all …]
|
| /external/crosvm/devices/src/virtio/ |
| D | balloon.rs | 24 use base::Tube;
258 release_memory_tube: Option<&Tube>, in release_ranges() argument
298 release_memory_tube: Option<&Tube>, in handle_address_chain() argument
350 release_memory_tube: Option<&Tube>, in handle_queue() argument
377 release_memory_tube: Option<&Tube>, in handle_reported_buffer() argument
401 release_memory_tube: Option<&Tube>, in handle_reporting_queue() argument
882 command_tube: Tube, in run_worker() argument
883 wss_op_tube: Option<Tube>, in run_worker() argument
884 #[cfg(windows)] dynamic_mapping_tube: Tube, in run_worker() argument
885 release_memory_tube: Option<Tube>, in run_worker() argument
[all …]
|
| D | pmem.rs | 16 use base::Tube;
90 pmem_device_tube: &Tube, in execute_request() argument
131 pmem_device_tube: &Tube, in handle_request() argument
157 pmem_device_tube: Tube, in handle_queue() argument
191 pmem_device_tube: Tube, in run_worker() argument
234 pmem_device_tube: Option<Tube>,
244 pmem_device_tube: Option<Tube>, in new() argument
|
| /external/crosvm/metrics/src/noop/ |
| D | client.rs | 5 use base::Tube;
13 pub fn initialize(_: Tube) {} in initialize() argument
15 pub fn force_initialize(_: Tube) {} in force_initialize() argument
|
| /external/crosvm/devices/src/virtio/balloon/sys/ |
| D | windows.rs | 6 use base::Tube;
14 dynamic_mapping_tube: &Tube, in free_memory() argument
38 dynamic_mapping_tube: &Tube, in reclaim_memory() argument
|
| /external/crosvm/third_party/vmm_vhost/src/connection/ |
| D | tube.rs | 18 use base::Tube;
44 tube: Tube,
49 pub(crate) fn get_tube(&self) -> &Tube { in get_tube() argument
54 impl<R: Req> From<Tube> for TubeEndpoint<R> {
55 fn from(tube: Tube) -> Self { in from()
188 use base::Tube;
197 let (master_tube, slave_tube) = Tube::pair().unwrap(); in create_pair()
|
| /external/crosvm/devices/src/usb/host_backend/ |
| D | host_backend_device_provider.rs | 16 use base::Tube;
39 Created { control_tube: Mutex<Tube> },
47 pub fn new() -> Result<(Tube, HostBackendDeviceProvider)> { in new()
48 let (child_tube, control_tube) = Tube::pair().map_err(Error::CreateControlTube)?; in new()
132 control_tube: Mutex<Tube>,
149 control_tube: Mutex<Tube>, in new() argument
|
| /external/crosvm/devices/src/virtio/fs/ |
| D | worker.rs | 18 use base::Tube;
67 tube: Arc<Mutex<Tube>>,
72 fn new(tube: Arc<Mutex<Tube>>, slot: u32) -> Self { in new() argument
148 tube: Arc<Mutex<Tube>>,
157 tube: &Arc<Mutex<Tube>>, in process_fs_queue() argument
182 tube: Arc<Mutex<Tube>>, in new() argument
|
| /external/crosvm/third_party/vmm_vhost/src/sys/ |
| D | windows.rs | 6 use base::Tube;
9 pub type SystemStream = Tube;
|