Skip to content

Commit 14e07fe

Browse files
committed
++ fix unit tests
Signed-off-by: Ivan Mikheykin <ivan.mikheykin@flant.com>
1 parent c173901 commit 14e07fe

3 files changed

Lines changed: 21 additions & 6 deletions

File tree

images/virt-artifact/patches/050-set-migration-configuration-externally.patch renamed to images/virt-artifact/patches/051-set-migration-configuration-externally.patch

File renamed without changes.

images/virtualization-artifact/pkg/controller/livemigration/internal/dynamic_settings_handler_test.go

Lines changed: 18 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -80,14 +80,29 @@ var _ = Describe("TestDynamicSettingsHandler", func() {
8080
return vmop
8181
}
8282

83+
newKVConfig := func() *virtv1.KubeVirt {
84+
return &virtv1.KubeVirt{
85+
TypeMeta: metav1.TypeMeta{
86+
APIVersion: virtv1.SchemeGroupVersion.String(),
87+
Kind: virtv1.KubeVirtGroupVersionKind.Kind,
88+
},
89+
ObjectMeta: metav1.ObjectMeta{
90+
Name: "config",
91+
Namespace: "d8-virtualization",
92+
},
93+
Spec: virtv1.KubeVirtSpec{},
94+
Status: virtv1.KubeVirtStatus{},
95+
}
96+
}
97+
8398
When("Observe KVVMI with migrateState", func() {
8499
It("Should set migrationConfiguration", func() {
85100
vm := newVM()
86101
kvvmi := newKVVMI()
87102

88103
kvvmi.Status.MigrationState = &virtv1.VirtualMachineInstanceMigrationState{}
89104

90-
fakeClient := setupEnvironment(kvvmi, vm)
105+
fakeClient := setupEnvironment(kvvmi, vm, newKVConfig())
91106
h := NewDynamicSettingsHandler(fakeClient, config.NewDefaultLiveMigrationSettings())
92107
_, err := h.Handle(ctx, kvvmi)
93108
Expect(err).NotTo(HaveOccurred())
@@ -105,7 +120,7 @@ var _ = Describe("TestDynamicSettingsHandler", func() {
105120
Completed: true,
106121
}
107122

108-
fakeClient := setupEnvironment(kvvmi, vm)
123+
fakeClient := setupEnvironment(kvvmi, vm, newKVConfig())
109124
h := NewDynamicSettingsHandler(fakeClient, config.NewDefaultLiveMigrationSettings())
110125
_, err := h.Handle(ctx, kvvmi)
111126
Expect(err).NotTo(HaveOccurred())
@@ -124,7 +139,7 @@ var _ = Describe("TestDynamicSettingsHandler", func() {
124139

125140
vmop := newVMOPEvict(force)
126141

127-
fakeClient := setupEnvironment(kvvmi, vm, vmop)
142+
fakeClient := setupEnvironment(kvvmi, vm, vmop, newKVConfig())
128143
h := NewDynamicSettingsHandler(fakeClient, config.NewDefaultLiveMigrationSettings())
129144
_, err := h.Handle(ctx, kvvmi)
130145
Expect(err).NotTo(HaveOccurred())

images/virtualization-artifact/pkg/livemigration/migration_configuration.go

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -40,17 +40,17 @@ const (
4040
func NewMigrationConfiguration(moduleSettings config.LiveMigrationSettings, allowAutoConverge bool, kvconfig virtv1.KubeVirt) *virtv1.MigrationConfiguration {
4141
// TODO rework below section after proper implementation of liveMigration settings in ModuleConfig.
4242
parallelMigrationsPerCluster := ParallelMigrationsPerClusterDefault
43-
if kvconfig.Spec.Configuration.MigrationConfiguration.ParallelMigrationsPerCluster != nil {
43+
if kvconfig.Spec.Configuration.MigrationConfiguration != nil && kvconfig.Spec.Configuration.MigrationConfiguration.ParallelMigrationsPerCluster != nil {
4444
parallelMigrationsPerCluster = *kvconfig.Spec.Configuration.MigrationConfiguration.ParallelMigrationsPerCluster
4545
}
4646
// Reuse default value of MaxMigrationsPerNode as parallelOutboundMigrationsPerNode.
4747
parallelOutboundMigrationsPerNode := uint32(moduleSettings.MaxMigrationsPerNode)
48-
if kvconfig.Spec.Configuration.MigrationConfiguration.ParallelOutboundMigrationsPerNode != nil {
48+
if kvconfig.Spec.Configuration.MigrationConfiguration != nil && kvconfig.Spec.Configuration.MigrationConfiguration.ParallelOutboundMigrationsPerNode != nil {
4949
parallelOutboundMigrationsPerNode = *kvconfig.Spec.Configuration.MigrationConfiguration.ParallelOutboundMigrationsPerNode
5050
}
5151
// Reuse default value of BandwidthPerNode as bandwidthPerMigration.
5252
bandwidthPerMigration := moduleSettings.BandwidthPerNode.DeepCopy()
53-
if kvconfig.Spec.Configuration.MigrationConfiguration.BandwidthPerMigration != nil {
53+
if kvconfig.Spec.Configuration.MigrationConfiguration != nil && kvconfig.Spec.Configuration.MigrationConfiguration.BandwidthPerMigration != nil {
5454
bandwidthPerMigration = kvconfig.Spec.Configuration.MigrationConfiguration.BandwidthPerMigration.DeepCopy()
5555
}
5656

0 commit comments

Comments
 (0)