xxx

Author: phip1611

vm-migration/src/lib.rs

@@ -3,6 +3,8 @@
 // SPDX-License-Identifier: Apache-2.0 AND BSD-3-Clause
 //
 
+pub use progress::MigrationProgressAndStatus;
+
 use anyhow::anyhow;
 use serde::{Deserialize, Serialize};
 use thiserror::Error;
@@ -11,6 +13,8 @@ use crate::protocol::MemoryRangeTable;
 
 mod bitpos_iterator;
 pub mod protocol;
+mod progress;
+
 
 #[derive(Error, Debug)]
 pub enum MigratableError {

vm-migration/src/progress.rs

@@ -0,0 +1,91 @@
+// Copyright © 2025 Cyberus Technology GmbH
+//
+// SPDX-License-Identifier: Apache-2.0
+
+//! Module for reporting of the live-migration progress.
+
+
+/// Type holding the progress and status information of an ongoing live
+/// migration.
+///
+/// The states correspond to the [live-migration protocol].
+///
+/// [live-migration protocol]: super::protocol
+#[derive(Clone, Debug, serde::Serialize, serde::Deserialize)]
+pub enum MigrationProgressAndStatus {
+    /// The migration starts. Handshake and transfer of VM config.
+    Starting {
+
+    },
+    /// Transfer of VM memory in precopy mode.
+    ///
+    /// Not used for local migrations.
+    MemoryPrecopy {
+        downtime_target_ms: u64,
+        downtime_expected_ms: u64,
+        /// The current memory iteration
+        iteration: u64,
+        memory_bytes_total: u64,
+        memory_bytes_transmitted: u64,
+        memory_4k_pages_transmitted: u64,
+        memory_bytes_remaining_iteration: u64,
+        memory_bytes_remaining_total: u64,
+    },
+    /// Transfer of VM memory in postcopy mode.
+    ///
+    /// Not used for local migrations.
+    MemoryPostcopy {
+
+    },
+
+    FinalState {
+
+    },
+    Completed {
+
+    },
+    Failed {
+
+    },
+    Cancelled {
+
+    }
+}
+
+#[cfg(test)]
+mod tests {
+    use super::*;
+
+    #[test]
+    fn print_json() {
+        let starting = MigrationProgressAndStatus::Starting {
+
+        };
+        let memory_precopy = MigrationProgressAndStatus::Memory {
+            total_memory_b: 0,
+            iteration: 0,
+        };
+        let memory_postcopy = MigrationProgressAndStatus::MemoryPostcopy {
+
+        };
+        let finishing = MigrationProgressAndStatus::Completing {
+
+        };
+        let completed = MigrationProgressAndStatus::Completed {
+
+        };
+        let failed = MigrationProgressAndStatus::Failed {
+
+        };
+        let cancelled = MigrationProgressAndStatus::Cancelled {
+
+        };
+
+        let vals = [
+            starting, memory_precopy, memory_postcopy, finishing, completed, failed, cancelled ]
+            ;
+        for val in vals {
+            println!("{}", serde_json::to_string(&val).unwrap());
+        }
+    }
+}