• Home
  • Raw
  • Download

Lines Matching refs:vm

104         for vm in vms {  in dump()
105 writeln!(file, "VM CID: {}", vm.cid).or(Err(StatusCode::UNKNOWN_ERROR))?; in dump()
106 writeln!(file, "\tState: {:?}", vm.vm_state.lock().unwrap()) in dump()
108 writeln!(file, "\tPayload state {:?}", vm.payload_state()) in dump()
110 writeln!(file, "\tProtected: {}", vm.protected).or(Err(StatusCode::UNKNOWN_ERROR))?; in dump()
111 writeln!(file, "\ttemporary_directory: {}", vm.temporary_directory.to_string_lossy()) in dump()
113 writeln!(file, "\trequester_uid: {}", vm.requester_uid) in dump()
115 writeln!(file, "\trequester_sid: {}", vm.requester_sid) in dump()
117 writeln!(file, "\trequester_debug_pid: {}", vm.requester_debug_pid) in dump()
231 .map(|vm| VirtualMachineDebugInfo { in debugListVms()
232 cid: vm.cid as i32, in debugListVms()
233 temporaryDirectory: vm.temporary_directory.to_string_lossy().to_string(), in debugListVms()
234 requesterUid: vm.requester_uid as i32, in debugListVms()
235 requesterSid: vm.requester_sid.clone(), in debugListVms()
236 requesterPid: vm.requester_debug_pid, in debugListVms()
237 state: get_state(&vm), in debugListVms()
524 if let Some(vm) = state.lock().unwrap().get_vm(cid) { in handle_stream_connection_from_vm()
525 *vm.stream.lock().unwrap() = Some(stream); in handle_stream_connection_from_vm()
900 fn add_vm(&mut self, vm: Weak<VmInstance>) { in add_vm()
902 self.vms.retain(|vm| vm.strong_count() > 0); in add_vm()
905 self.vms.push(vm); in add_vm()
910 self.vms().into_iter().find(|vm| vm.cid == cid) in get_vm()
914 fn debug_hold_vm(&mut self, vm: Strong<dyn IVirtualMachine>) { in debug_hold_vm()
915 self.debug_held_vms.push(vm); in debug_hold_vm()
920 let pos = self.debug_held_vms.iter().position(|vm| vm.getCid() == Ok(cid))?; in debug_drop_vm()
921 let vm = self.debug_held_vms.swap_remove(pos); in debug_drop_vm() localVariable
922 Some(vm) in debug_drop_vm()
1022 if let Some(vm) = self.state.lock().unwrap().get_vm(cid) { in notifyPayloadStarted()
1024 vm.update_payload_state(PayloadState::Started) in notifyPayloadStarted()
1026 let stream = vm.stream.lock().unwrap().take(); in notifyPayloadStarted()
1027 vm.callbacks.notify_payload_started(cid, stream); in notifyPayloadStarted()
1040 if let Some(vm) = self.state.lock().unwrap().get_vm(cid) { in notifyPayloadReady()
1042 vm.update_payload_state(PayloadState::Ready) in notifyPayloadReady()
1044 vm.callbacks.notify_payload_ready(cid); in notifyPayloadReady()
1057 if let Some(vm) = self.state.lock().unwrap().get_vm(cid) { in notifyPayloadFinished()
1059 vm.update_payload_state(PayloadState::Finished) in notifyPayloadFinished()
1061 vm.callbacks.notify_payload_finished(cid, exit_code); in notifyPayloadFinished()
1074 if let Some(vm) = self.state.lock().unwrap().get_vm(cid) { in notifyError()
1076 vm.update_payload_state(PayloadState::Finished) in notifyError()
1078 vm.callbacks.notify_error(cid, error_code, message); in notifyError()
1098 if let Some(vm) = state.lock().unwrap().get_vm(cid) { in factory()
1099 let mut vm_service = vm.vm_service.lock().unwrap(); in factory()