Method resume

vmm/src/cpu.rs:2637–2662

(&mut self)

    }

    fn resume(&mut self) -> std::result::Result<(), MigratableError> {
        // Ensure that vCPUs keep running after being unpark() in
        // their run vCPU loop.
        self.vcpus_pause_signalled.store(false, Ordering::SeqCst);

        let vcpu_states = self.vcpu_states.lock().unwrap();

        // Unpark all the vCPU threads.
        // Step 1/2: signal each thread
        {
            for state in vcpu_states.iter() {
                state.unpark_thread();
            }
        }
        // Step 2/2: wait for state ACK
        {
            for state in vcpu_states.iter() {
                // wait for vCPU to update state
                while state.paused.load(Ordering::SeqCst) {
                    // To avoid a priority inversion with the vCPU thread
                    thread::sleep(std::time::Duration::from_millis(1));
                }
            }
        }
        Ok(())
    }
}

impl Snapshottable for CpuManager {