Lines Matching refs:tube
362 Fs(tube) | Vm(tube) | VmMemory(tube) | VmIrq(tube) | VmMsync(tube) => tube, in as_ref()
762 fn create_balloon_device(cfg: &Config, tube: Tube) -> DeviceResult { in create_balloon_device()
763 let dev = virtio::Balloon::new(virtio::base_features(cfg.protected_vm), tube) in create_balloon_device()
2588 for (handle, tube) in vcpu_handles { in kick_all_vcpus()
2589 if let Err(e) = tube.send(VcpuControl::RunState(run_mode.clone())) { in kick_all_vcpus()
3034 TaggedControlTube::Vm(tube) => match tube.recv::<VmRequest>() { in run_control()
3044 if let Err(e) = tube.send(&response) { in run_control()
3074 TaggedControlTube::VmMemory(tube) => { in run_control()
3075 match tube.recv::<VmMemoryRequest>() { in run_control()
3083 if let Err(e) = tube.send(&response) { in run_control()
3096 TaggedControlTube::VmIrq(tube) => match tube.recv::<VmIrqRequest>() { in run_control()
3129 if let Err(e) = tube.send(&response) { in run_control()
3141 TaggedControlTube::VmMsync(tube) => { in run_control()
3142 match tube.recv::<VmMsyncRequest>() { in run_control()
3145 if let Err(e) = tube.send(&response) { in run_control()
3158 TaggedControlTube::Fs(tube) => match tube.recv::<FsMappingRequest>() { in run_control()
3162 if let Err(e) = tube.send(&response) { in run_control()
3226 if let Some(tube) = control_tubes.get(index) { in run_control()
3228 .modify(tube, EventType::Read, Token::VmControl { index }) in run_control()