kata-containers/src/runtime/virtcontainers/qemu_arm64_test.go

//go:build linux

// Copyright (c) 2018 IBM
//
// SPDX-License-Identifier: Apache-2.0
//

package virtcontainers

import (
	"context"
	"fmt"
	"os"
	"testing"

	"github.com/kata-containers/kata-containers/src/runtime/pkg/govmm"
	govmmQemu "github.com/kata-containers/kata-containers/src/runtime/pkg/govmm/qemu"
	"github.com/stretchr/testify/assert"
)

func qemuConfig(machineType string) HypervisorConfig {
	return HypervisorConfig{
		HypervisorMachineType: machineType,
	}
}

func newTestQemu(assert *assert.Assertions, machineType string) qemuArch {
	config := qemuConfig(machineType)
	arch, err := newQemuArch(config)
	assert.NoError(err)
	return arch
}

func TestQemuArm64CPUModel(t *testing.T) {
	assert := assert.New(t)
	arm64 := newTestQemu(assert, QemuVirt)

	expectedOut := defaultCPUModel
	model := arm64.cpuModel()
	assert.Equal(expectedOut, model)
}

func TestQemuArm64MemoryTopology(t *testing.T) {
	assert := assert.New(t)
	arm64 := newTestQemu(assert, QemuVirt)
	memoryOffset := uint64(1024)

	hostMem := uint64(4096)
	mem := uint64(1024)
	slots := uint8(3)
	expectedMemory := govmmQemu.Memory{
		Size:   fmt.Sprintf("%dM", mem),
		Slots:  slots,
		MaxMem: fmt.Sprintf("%dM", hostMem+memoryOffset),
	}

	m := arm64.memoryTopology(mem, hostMem, slots)
	assert.Equal(expectedMemory, m)
}

func TestMaxVCPUs(t *testing.T) {
	assert := assert.New(t)

	vCPUs := govmm.MaxVCPUs()
	assert.Equal(uint32(123), vCPUs)
}

func TestQemuArm64AppendBridges(t *testing.T) {
	var devices []govmmQemu.Device
	assert := assert.New(t)

	arm64 := newTestQemu(assert, QemuVirt)

	arm64.bridges(1)
	bridges := arm64.getBridges()
	assert.Len(bridges, 1)

	devices = []govmmQemu.Device{}
	devices = arm64.appendBridges(devices)
	assert.Len(devices, 1)

	expectedOut := []govmmQemu.Device{
		govmmQemu.BridgeDevice{
			Type:          govmmQemu.PCIBridge,
			Bus:           defaultBridgeBus,
			ID:            bridges[0].ID,
			Chassis:       1,
			SHPC:          false,
			Addr:          "2",
			IOReserve:     "4k",
			MemReserve:    "1m",
			Pref64Reserve: "1m",
		},
	}

	assert.Equal(expectedOut, devices)
}

func TestQemuArm64AppendImage(t *testing.T) {
	var devices []govmmQemu.Device
	assert := assert.New(t)

	f, err := os.CreateTemp("", "img")
	assert.NoError(err)
	defer func() { _ = f.Close() }()
	defer func() { _ = os.Remove(f.Name()) }()

	imageStat, err := f.Stat()
	assert.NoError(err)

	cfg := qemuConfig(QemuVirt)
	cfg.ImagePath = f.Name()
	arm64, err := newQemuArch(cfg)
	assert.NoError(err)
	assert.Contains(arm64.machine().Options, qemuNvdimmOption)

	expectedOut := []govmmQemu.Device{
		govmmQemu.Object{
			Driver:   govmmQemu.NVDIMM,
			Type:     govmmQemu.MemoryBackendFile,
			DeviceID: "nv0",
			ID:       "mem0",
			MemPath:  f.Name(),
			Size:     (uint64)(imageStat.Size()),
		},
	}

	devices, err = arm64.appendImage(context.Background(), devices, f.Name())
	assert.NoError(err)
	assert.Equal(expectedOut, devices)
}

func TestQemuArm64AppendNvdimmImage(t *testing.T) {
	var devices []govmmQemu.Device
	assert := assert.New(t)

	f, err := os.CreateTemp("", "img")
	assert.NoError(err)
	defer func() { _ = f.Close() }()
	defer func() { _ = os.Remove(f.Name()) }()

	imageStat, err := f.Stat()
	assert.NoError(err)

	cfg := qemuConfig(QemuVirt)
	cfg.ImagePath = f.Name()
	arm64, err := newQemuArch(cfg)
	assert.NoError(err)

	expectedOut := []govmmQemu.Device{
		govmmQemu.Object{
			Driver:   govmmQemu.NVDIMM,
			Type:     govmmQemu.MemoryBackendFile,
			DeviceID: "nv0",
			ID:       "mem0",
			MemPath:  f.Name(),
			Size:     (uint64)(imageStat.Size()),
		},
	}

	devices, err = arm64.appendNvdimmImage(devices, f.Name())
	assert.NoError(err)
	assert.Equal(expectedOut, devices)
}

func TestQemuArm64WithInitrd(t *testing.T) {
	assert := assert.New(t)

	cfg := qemuConfig(QemuVirt)
	cfg.InitrdPath = "dummy-initrd"
	arm64, err := newQemuArch(cfg)
	assert.NoError(err)

	assert.NotContains(arm64.machine().Options, qemuNvdimmOption)
}

func TestQemuArm64AppendProtectionDevice(t *testing.T) {
	assert := assert.New(t)
	arm64 := newTestQemu(assert, QemuVirt)

	var devices []govmmQemu.Device
	var bios, firmware string
	var err error

	// no protection
	devices, bios, err = arm64.appendProtectionDevice(devices, firmware, "", []byte(nil))
	assert.Empty(devices)
	assert.Empty(bios)
	assert.NoError(err)

	// PEF protection
	arm64.(*qemuArm64).protection = pefProtection
	devices, bios, err = arm64.appendProtectionDevice(devices, firmware, "", []byte(nil))
	assert.Empty(devices)
	assert.Empty(bios)
	assert.NoError(err)

	// Secure Execution protection
	arm64.(*qemuArm64).protection = seProtection
	devices, bios, err = arm64.appendProtectionDevice(devices, firmware, "", []byte(nil))
	assert.Empty(devices)
	assert.Empty(bios)
	assert.NoError(err)

	// SEV protection
	arm64.(*qemuArm64).protection = sevProtection
	devices, bios, err = arm64.appendProtectionDevice(devices, firmware, "", []byte(nil))
	assert.Empty(devices)
	assert.Empty(bios)
	assert.NoError(err)

	// SNP protection
	arm64.(*qemuArm64).protection = snpProtection
	devices, bios, err = arm64.appendProtectionDevice(devices, firmware, "", []byte(nil))
	assert.Empty(devices)
	assert.Empty(bios)
	assert.NoError(err)

	// TDX protection
	arm64.(*qemuArm64).protection = tdxProtection
	devices, bios, err = arm64.appendProtectionDevice(devices, firmware, "", []byte(nil))
	assert.Empty(devices)
	assert.Empty(bios)
	assert.NoError(err)
}