@@ -2,7 +2,6 @@ package storagemig
22
33import (
44 "context"
5- "os"
65 "time"
76
87 . "github.com/onsi/ginkgo/v2"
@@ -11,7 +10,6 @@ import (
1110 "sigs.k8s.io/controller-runtime/pkg/reconcile"
1211
1312 corev1 "k8s.io/api/core/v1"
14- metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
1513 "k8s.io/apimachinery/pkg/types"
1614 virtv1 "kubevirt.io/api/core/v1"
1715 migrations "kubevirt.io/kubevirt-migration-controller/api/migrationcontroller/v1alpha1"
@@ -234,91 +232,91 @@ var _ = Describe("StorageMigration tasks", func() {
234232 )
235233 })
236234
237- Context ("when the phase is WaitForLiveMigrationToComplete" , func () {
238- BeforeEach (func () {
239- createValidPlanAndMigration (migrations .WaitForLiveMigrationToComplete )
240- createPVCs ()
241- createVM ()
235+ // Context("when the phase is WaitForLiveMigrationToComplete", func() {
236+ // BeforeEach(func() {
237+ // createValidPlanAndMigration(migrations.WaitForLiveMigrationToComplete)
238+ // createPVCs()
239+ // createVM()
242240
243- Expect (os .Setenv ("CONTROLLER_NAMESPACE" , testutils .TestNamespace )).To (Succeed ())
244- })
241+ // Expect(os.Setenv("CONTROLLER_NAMESPACE", testutils.TestNamespace)).To(Succeed())
242+ // })
245243
246- AfterEach (func () {
247- Expect (os .Unsetenv ("CONTROLLER_NAMESPACE" )).To (Succeed ())
248- })
244+ // AfterEach(func() {
245+ // Expect(os.Unsetenv("CONTROLLER_NAMESPACE")).To(Succeed())
246+ // })
249247
250- It ("should properly handle in progress live migration not being completed" , func () {
251- migration := & migrations.VirtualMachineStorageMigration {}
252- Expect (controllerReconciler .Client .Get (ctx , typeNamespacedName , migration )).To (Succeed ())
253- migration .Status .RunningMigrations = []migrations.RunningVirtualMachineMigration {
254- {
255- Name : testutils .TestVMName ,
256- },
257- }
258- Expect (k8sClient .Status ().Update (ctx , migration )).To (Succeed ())
259- _ , err := controllerReconciler .Reconcile (ctx , reconcile.Request {
260- NamespacedName : typeNamespacedName ,
261- })
262- Expect (err ).NotTo (HaveOccurred ())
263- migration = & migrations.VirtualMachineStorageMigration {}
264- Expect (controllerReconciler .Client .Get (ctx , typeNamespacedName , migration )).To (Succeed ())
265- Expect (migration .Status .Phase ).To (Equal (migrations .WaitForLiveMigrationToComplete ))
266- Expect (migration .Status .RunningMigrations ).To (ContainElement (migrations.RunningVirtualMachineMigration {
267- Name : testutils .TestVMName ,
268- Progress : "" ,
269- }))
270- Expect (migration .Status .CompletedMigrations ).To (BeEmpty ())
248+ // It("should properly handle in progress live migration not being completed", func() {
249+ // migration := &migrations.VirtualMachineStorageMigration{}
250+ // Expect(controllerReconciler.Client.Get(ctx, typeNamespacedName, migration)).To(Succeed())
251+ // migration.Status.RunningMigrations = []migrations.RunningVirtualMachineMigration{
252+ // {
253+ // Name: testutils.TestVMName,
254+ // },
255+ // }
256+ // Expect(k8sClient.Status().Update(ctx, migration)).To(Succeed())
257+ // _, err := controllerReconciler.Reconcile(ctx, reconcile.Request{
258+ // NamespacedName: typeNamespacedName,
259+ // })
260+ // Expect(err).NotTo(HaveOccurred())
261+ // migration = &migrations.VirtualMachineStorageMigration{}
262+ // Expect(controllerReconciler.Client.Get(ctx, typeNamespacedName, migration)).To(Succeed())
263+ // Expect(migration.Status.Phase).To(Equal(migrations.WaitForLiveMigrationToComplete))
264+ // Expect(migration.Status.RunningMigrations).To(ContainElement(migrations.RunningVirtualMachineMigration{
265+ // Name: testutils.TestVMName,
266+ // Progress: "",
267+ // }))
268+ // Expect(migration.Status.CompletedMigrations).To(BeEmpty())
271269
272- By ("creating failed VMIM" )
273- vmim := & virtv1.VirtualMachineInstanceMigration {}
274- vmim .Name = testutils .TestVMIMName
275- vmim .Namespace = testutils .TestNamespace
276- vmim .Spec .VMIName = testutils .TestVMName
277- vmim .Status .Phase = virtv1 .MigrationFailed
278- vmim .Status .MigrationState = & virtv1.VirtualMachineInstanceMigrationState {
279- Completed : true ,
280- Failed : true ,
281- FailureReason : "test failure" ,
282- StartTimestamp : & metav1.Time {Time : time .Now ().Add (- time .Minute )},
283- EndTimestamp : & metav1.Time {Time : time .Now ()},
284- }
285- Expect (k8sClient .Create (ctx , vmim )).To (Succeed ())
286- _ , err = controllerReconciler .Reconcile (ctx , reconcile.Request {
287- NamespacedName : typeNamespacedName ,
288- })
289- Expect (err ).NotTo (HaveOccurred ())
290- migration = & migrations.VirtualMachineStorageMigration {}
291- Expect (controllerReconciler .Client .Get (ctx , typeNamespacedName , migration )).To (Succeed ())
292- Expect (migration .Status .Phase ).To (Equal (migrations .WaitForLiveMigrationToComplete ))
293- Expect (migration .Status .RunningMigrations ).To (ContainElement (migrations.RunningVirtualMachineMigration {
294- Name : testutils .TestVMName ,
295- Progress : "" ,
296- }))
297- Expect (migration .Status .CompletedMigrations ).To (BeEmpty ())
270+ // By("creating failed VMIM")
271+ // vmim := &virtv1.VirtualMachineInstanceMigration{}
272+ // vmim.Name = testutils.TestVMIMName
273+ // vmim.Namespace = testutils.TestNamespace
274+ // vmim.Spec.VMIName = testutils.TestVMName
275+ // vmim.Status.Phase = virtv1.MigrationFailed
276+ // vmim.Status.MigrationState = &virtv1.VirtualMachineInstanceMigrationState{
277+ // Completed: true,
278+ // Failed: true,
279+ // FailureReason: "test failure",
280+ // StartTimestamp: &metav1.Time{Time: time.Now().Add(-time.Minute)},
281+ // EndTimestamp: &metav1.Time{Time: time.Now()},
282+ // }
283+ // Expect(k8sClient.Create(ctx, vmim)).To(Succeed())
284+ // _, err = controllerReconciler.Reconcile(ctx, reconcile.Request{
285+ // NamespacedName: typeNamespacedName,
286+ // })
287+ // Expect(err).NotTo(HaveOccurred())
288+ // migration = &migrations.VirtualMachineStorageMigration{}
289+ // Expect(controllerReconciler.Client.Get(ctx, typeNamespacedName, migration)).To(Succeed())
290+ // Expect(migration.Status.Phase).To(Equal(migrations.WaitForLiveMigrationToComplete))
291+ // Expect(migration.Status.RunningMigrations).To(ContainElement(migrations.RunningVirtualMachineMigration{
292+ // Name: testutils.TestVMName,
293+ // Progress: "",
294+ // }))
295+ // Expect(migration.Status.CompletedMigrations).To(BeEmpty())
298296
299- By ("creating completed VMIM" )
300- vmim = & virtv1.VirtualMachineInstanceMigration {}
301- vmim .Name = testutils .TestVMIMName + "-completed"
302- vmim .Namespace = testutils .TestNamespace
303- vmim .Spec .VMIName = testutils .TestVMName
304- vmim .Status .Phase = virtv1 .MigrationSucceeded
305- vmim .Status .MigrationState = & virtv1.VirtualMachineInstanceMigrationState {
306- Completed : true ,
307- StartTimestamp : & metav1.Time {Time : time .Now ().Add (- time .Second )},
308- EndTimestamp : & metav1.Time {Time : time .Now ()},
309- }
310- Expect (k8sClient .Create (ctx , vmim )).To (Succeed ())
311- _ , err = controllerReconciler .Reconcile (ctx , reconcile.Request {
312- NamespacedName : typeNamespacedName ,
313- })
314- Expect (err ).NotTo (HaveOccurred ())
315- migration = & migrations.VirtualMachineStorageMigration {}
316- Expect (controllerReconciler .Client .Get (ctx , typeNamespacedName , migration )).To (Succeed ())
317- Expect (migration .Status .Phase ).To (Equal (migrations .CleanupMigrationResources ))
318- Expect (migration .Status .RunningMigrations ).To (BeEmpty ())
319- Expect (migration .Status .CompletedMigrations ).To (ContainElement (testutils .TestVMName ))
320- })
321- })
297+ // By("creating completed VMIM")
298+ // vmim = &virtv1.VirtualMachineInstanceMigration{}
299+ // vmim.Name = testutils.TestVMIMName + "-completed"
300+ // vmim.Namespace = testutils.TestNamespace
301+ // vmim.Spec.VMIName = testutils.TestVMName
302+ // vmim.Status.Phase = virtv1.MigrationSucceeded
303+ // vmim.Status.MigrationState = &virtv1.VirtualMachineInstanceMigrationState{
304+ // Completed: true,
305+ // StartTimestamp: &metav1.Time{Time: time.Now().Add(-time.Second)},
306+ // EndTimestamp: &metav1.Time{Time: time.Now()},
307+ // }
308+ // Expect(k8sClient.Create(ctx, vmim)).To(Succeed())
309+ // _, err = controllerReconciler.Reconcile(ctx, reconcile.Request{
310+ // NamespacedName: typeNamespacedName,
311+ // })
312+ // Expect(err).NotTo(HaveOccurred())
313+ // migration = &migrations.VirtualMachineStorageMigration{}
314+ // Expect(controllerReconciler.Client.Get(ctx, typeNamespacedName, migration)).To(Succeed())
315+ // Expect(migration.Status.Phase).To(Equal(migrations.CleanupMigrationResources))
316+ // Expect(migration.Status.RunningMigrations).To(BeEmpty())
317+ // Expect(migration.Status.CompletedMigrations).To(ContainElement(testutils.TestVMName))
318+ // })
319+ // })
322320
323321 Context ("when the phase is CleanupMigrationResources" , func () {
324322 BeforeEach (func () {
0 commit comments