Add support for users to specify rootDisk in multiboot VM.

Signed-off-by: Bella Khizgiyaev <[email protected]>

operator/config/crd/bases/forklift.konveyor.io_migrations.yaml

@@ -508,6 +508,10 @@ spec:
                     restorePowerState:
                       description: Source VM power state before migration.
                       type: string
+                    rootDisk:
+                      description: Choose the primary disk the VM boots from
+                      format: int32
+                      type: integer
                     started:
                       description: Started timestamp.
                       format: date-time

operator/config/crd/bases/forklift.konveyor.io_plans.yaml

@@ -1012,6 +1012,10 @@ spec:
                         restorePowerState:
                           description: Source VM power state before migration.
                           type: string
+                        rootDisk:
+                          description: Choose the primary disk the VM boots from
+                          format: int32
+                          type: integer
                         started:
                           description: Started timestamp.
                           format: date-time

pkg/apis/forklift/v1beta1/plan/vm.go

@@ -66,7 +66,8 @@ type VMStatus struct {
 	Firmware string `json:"firmware,omitempty"`
 	// The Operating System detected by virt-v2v.
 	OperatingSystem string `json:"operatingSystem,omitempty"`
-
+	//Choose the primary disk the VM boots from
+	RootDisk int32 `json:"rootDisk,omitempty"`
 	// Conditions.
 	libcnd.Conditions `json:",inline"`
 }

pkg/controller/plan/kubevirt.go

@@ -38,6 +38,7 @@ import (
 	"github.com/konveyor/forklift-controller/pkg/controller/plan/adapter"
 	ovfparser "github.com/konveyor/forklift-controller/pkg/controller/plan/adapter/ova"
 	plancontext "github.com/konveyor/forklift-controller/pkg/controller/plan/context"
+	model "github.com/konveyor/forklift-controller/pkg/controller/provider/web/vsphere"
 	libcnd "github.com/konveyor/forklift-controller/pkg/lib/condition"
 	liberr "github.com/konveyor/forklift-controller/pkg/lib/error"
 	core "k8s.io/api/core/v1"
@@ -1607,6 +1608,30 @@ func (r *KubeVirt) guestConversionPod(vm *plan.VMStatus, vmVolumes []cnv.Volume,
 	if err != nil {
 		return
 	}
+
+	if vm.RootDisk > 0 {
+		vmInventory := &model.VM{}
+		err = r.Source.Inventory.Find(vmInventory, vm.Ref)
+		if err != nil {
+			err = liberr.Wrap(err, "vm", vm.Ref.String())
+			return
+		}
+
+		var rootDisk string
+		for diskNum, disk := range vmInventory.Disks {
+			if disk.Number == vm.RootDisk {
+				rootDisk = fmt.Sprintf("/dev/sd%c", 'a'+(diskNum)%26)
+			}
+		}
+
+		if rootDisk != "" {
+			environment = append(environment,
+				core.EnvVar{
+					Name:  "V2V_RootDisk",
+					Value: rootDisk,
+				})
+		}
+	}
 	// pod annotations
 	annotations := map[string]string{}
 	if r.Plan.Spec.TransferNetwork != nil {

pkg/controller/provider/container/vsphere/model.go

@@ -701,6 +701,7 @@ func (v *VmAdapter) Apply(u types.ObjectUpdate) {
 // Update virtual disk devices.
 func (v *VmAdapter) updateDisks(devArray *types.ArrayOfVirtualDevice) {
 	disks := []model.Disk{}
+	var diskNum int32 = 1
 	for _, dev := range devArray.VirtualDevice {
 		switch dev.(type) {
 		case *types.VirtualDisk:
@@ -712,6 +713,7 @@ func (v *VmAdapter) updateDisks(devArray *types.ArrayOfVirtualDevice) {
 					File:     backing.FileName,
 					Capacity: disk.CapacityInBytes,
 					Mode:     backing.DiskMode,
+					Number:   diskNum,
 				}
 				if backing.Datastore != nil {
 					datastoreId, _ := sanitize(backing.Datastore.Value)
@@ -721,13 +723,15 @@ func (v *VmAdapter) updateDisks(devArray *types.ArrayOfVirtualDevice) {
 					}
 				}
 				disks = append(disks, md)
+				diskNum++
 			case *types.VirtualDiskFlatVer2BackingInfo:
 				md := model.Disk{
 					Key:      disk.Key,
 					File:     backing.FileName,
 					Capacity: disk.CapacityInBytes,
 					Shared:   backing.Sharing != "sharingNone",
 					Mode:     backing.DiskMode,
+					Number:   diskNum,
 				}
 				if backing.Datastore != nil {
 					datastoreId, _ := sanitize(backing.Datastore.Value)
@@ -737,6 +741,7 @@ func (v *VmAdapter) updateDisks(devArray *types.ArrayOfVirtualDevice) {
 					}
 				}
 				disks = append(disks, md)
+				diskNum++
 			case *types.VirtualDiskRawDiskMappingVer1BackingInfo:
 				md := model.Disk{
 					Key:      disk.Key,
@@ -745,6 +750,7 @@ func (v *VmAdapter) updateDisks(devArray *types.ArrayOfVirtualDevice) {
 					Shared:   backing.Sharing != "sharingNone",
 					Mode:     backing.DiskMode,
 					RDM:      true,
+					Number:   diskNum,
 				}
 				if backing.Datastore != nil {
 					datastoreId, _ := sanitize(backing.Datastore.Value)
@@ -754,15 +760,18 @@ func (v *VmAdapter) updateDisks(devArray *types.ArrayOfVirtualDevice) {
 					}
 				}
 				disks = append(disks, md)
+				diskNum++
 			case *types.VirtualDiskRawDiskVer2BackingInfo:
 				md := model.Disk{
 					Key:      disk.Key,
 					File:     backing.DescriptorFileName,
 					Capacity: disk.CapacityInBytes,
 					Shared:   backing.Sharing != "sharingNone",
 					RDM:      true,
+					Number:   diskNum,
 				}
 				disks = append(disks, md)
+				diskNum++
 			}
 		}
 	}

pkg/controller/provider/model/vsphere/model.go

@@ -279,6 +279,7 @@ type Disk struct {
 	Shared    bool   `json:"shared"`
 	RDM       bool   `json:"rdm"`
 	Mode      string `json:"mode,omitempty"`
+	Number    int32  `json:"number,omitempty"`
 }
 
 // Virtual Device.

virt-v2v/cold/entrypoint.go

@@ -98,7 +98,12 @@ func buildCommand() []string {
 	fmt.Println("Preparing virt-v2v")
 	switch source {
 	case vSphere:
-		virtV2vArgs = append(virtV2vArgs, "--root", "first", "-i", "libvirt", "-ic", os.Getenv("V2V_libvirtURL"))
+		if checkEnvVariablesSet("V2V_RootDisk") {
+			virtV2vArgs = append(virtV2vArgs, "--root", os.Getenv("V2V_RootDisk"))
+		} else {
+			virtV2vArgs = append(virtV2vArgs, "--root", "first")
+		}
+		virtV2vArgs = append(virtV2vArgs, "-i", "libvirt", "-ic", os.Getenv("V2V_libvirtURL"))
 	case OVA:
 		virtV2vArgs = append(virtV2vArgs, "-i", "ova", os.Getenv("V2V_diskPath"))
 	}