Searched refs:control_tube (Results 1 – 7 of 7) sorted by relevance
| /external/crosvm/devices/src/usb/host_backend/ |
| D | host_backend_device_provider.rs | 30 Created { control_tube: Mutex<Tube> },
39 let (child_tube, control_tube) = Tube::pair().map_err(Error::CreateControlTube)?; in new()
40 control_tube in new()
43 control_tube in new()
48 control_tube: Mutex::new(child_tube), in new()
50 Ok((control_tube, provider)) in new()
60 HostBackendDeviceProvider::Created { control_tube } => { in start_helper()
67 control_tube, in start_helper()
73 &*inner.control_tube.lock(), in start_helper()
105 HostBackendDeviceProvider::Created { control_tube } => { in keep_rds()
[all …]
|
| /external/crosvm/devices/src/virtio/ |
| D | block.rs | 260 control_tube: Option<Tube>, field
409 if let Some(control_tube) = self.control_tube.as_ref() { in run()
410 pc.add(control_tube, Token::ControlRequest)? in run()
451 let control_tube = match self.control_tube.as_ref() { in run() localVariable
458 let req = match control_tube.recv() { in run()
477 if let Err(e) = self.control_tube.as_ref().unwrap().send(&resp) { in run()
507 control_tube: Option<Tube>, field
535 control_tube: Option<Tube>, in new()
584 control_tube, in new()
759 if let Some(control_tube) = &self.control_tube { in keep_rds()
[all …]
|
| D | block_async.rs | 482 control_tube: &Option<AsyncTube>, in run_worker()
534 let control = handle_command_tube(control_tube, interrupt.clone(), disk_state.clone()); in run_worker()
575 control_tube: Option<Tube>, field
604 control_tube: Option<Tube>, in new()
654 control_tube, in new()
846 if let Some(control_tube) = &self.control_tube { in keep_rds()
847 keep_rds.push(control_tube.as_raw_descriptor()); in keep_rds()
894 let control_tube = self.control_tube.take(); in activate() localVariable
900 let async_control = control_tube in activate()
962 Ok((disk_image, control_tube)) => { in reset()
[all …]
|
| /external/crosvm/vm_control/src/ |
| D | lib.rs | 789 pub control_tube: Tube, field
1068 let res = battery.control_tube.send(cmd); in execute()
1074 match battery.control_tube.recv() { in execute()
|
| /external/crosvm/arch/src/ |
| D | lib.rs | 461 let (control_tube, response_tube) = in add_goldfish_battery()
508 Ok(control_tube) in add_goldfish_battery()
|
| /external/crosvm/x86_64/src/ |
| D | lib.rs | 1087 let control_tube = arch::add_goldfish_battery( in setup_acpi_devices() localVariable
1098 control_tube, in setup_acpi_devices()
|
| /external/crosvm/src/ |
| D | linux.rs | 1015 control_tube: Tube, in create_wayland_device()
1029 control_tube, in create_wayland_device()
|