Virt for qemu:///session

Simple test to see if the machine would even start properly.

Needs more code for qemu:///system, like storage and network.

Signed-off-by: Anders F Björklund <[email protected]>

Author: afbjorklund

pkg/virt/disk.go

@@ -2,8 +2,11 @@ package virt
 
 import (
 	"errors"
+	"fmt"
 	"os"
+	"os/exec"
 	"path/filepath"
+	"strconv"
 
 	"github.com/docker/go-units"
 	"github.com/lima-vm/lima/pkg/driver"
@@ -43,7 +46,14 @@ func EnsureDisk(driver *driver.BaseDriver) error {
 	if err != nil {
 		return err
 	}
-	_ = isBaseDiskISO
-	// TODO
+	args := []string{"create", "-f", "qcow2"}
+	if !isBaseDiskISO {
+		args = append(args, "-b", baseDisk)
+	}
+	args = append(args, diffDisk, strconv.Itoa(int(diskSize)))
+	cmd := exec.Command("qemu-img", args...)
+	if out, err := cmd.CombinedOutput(); err != nil {
+		return fmt.Errorf("failed to run %v: %q: %w", cmd.Args, string(out), err)
+	}
 	return nil
 }

pkg/virt/domain.go

@@ -0,0 +1,122 @@
+package virt
+
+import (
+	"bytes"
+	"os"
+	"path/filepath"
+	"text/template"
+
+	"github.com/lima-vm/lima/pkg/driver"
+	"github.com/lima-vm/lima/pkg/networks"
+	"github.com/lima-vm/lima/pkg/store/filenames"
+)
+
+type DomainConfig struct {
+	Name            string
+	Memory          int64
+	CPUs            int
+	CIDataPath      string
+	DiskPath        string
+	Interface       string
+	QemuCommandline string
+	Network         string
+	SlirpNetwork    string
+	SlirpIPAddress  string
+	SSHLocalPort    int
+}
+
+const domainXMLTemplate = `<domain type='kvm' xmlns:qemu='http://libvirt.org/schemas/domain/qemu/1.0'>
+  <name>{{.Name}}</name><memory unit='B'>{{.Memory}}</memory>
+  <vcpu>{{.CPUs}}</vcpu>
+  <features><acpi/><apic/></features>
+  <cpu mode='host-passthrough'></cpu>
+  <os firmware='efi'>
+    <type>hvm</type>
+    <boot dev='cdrom'/>
+    <boot dev='hd'/>
+    <bootmenu enable='no'/>
+  </os>
+  <devices>
+    <console type='pty'>
+      <target type='serial'/>
+    </console>
+    <disk type='file' device='cdrom'>
+      <driver name='qemu' type='raw'/>
+      <source file='{{.CIDataPath}}'/>
+      <target dev='hdd' bus='sata'/>
+      <readonly/>
+    </disk>
+    <disk type='file' device='disk'>
+      <driver name='qemu' type='qcow2'/>
+      <source file='{{.DiskPath}}'/>
+      <target dev='vda' bus='virtio'/>
+    </disk>
+<!--
+    <graphics type='vnc' autoport='yes' listen='127.0.0.1'>
+      <listen type='address' address='127.0.0.1'/>
+    </graphics>
+-->
+{{.Interface}}
+  </devices>
+{{.QemuCommandline}}
+</domain>`
+
+const interfaceXMLTemplate = `
+    <interface type='user'>
+      <source network='{{.Network}}'/>
+      <model type='virtio'/>
+    </interface>`
+
+const qemuXMLTemplate = `
+    <qemu:commandline>
+        <qemu:arg value='-netdev'/>
+        <qemu:arg value='user,id=net0,net={{.SlirpNetwork}},dhcpstart={{.SlirpIPAddress}},hostfwd=tcp:127.0.0.1:{{.SSHLocalPort}}-:22'/>
+        <qemu:arg value='-device'/>
+        <qemu:arg value='virtio-net-pci,netdev=net0'/>
+        <qemu:arg value='-device'/>
+        <qemu:arg value='virtio-rng-pci'/>
+    </qemu:commandline>`
+
+func DomainXML(driver *driver.BaseDriver) (string, error) {
+	tmpl, err := template.New("domain").Parse(domainXMLTemplate)
+	if err != nil {
+		return "", err
+	}
+	_ = interfaceXMLTemplate
+	qemu, err := template.New("qemu").Parse(qemuXMLTemplate)
+	if err != nil {
+		return "", err
+	}
+	// baseDisk := filepath.Join(driver.Instance.Dir, filenames.BaseDisk)
+	diffDisk := filepath.Join(driver.Instance.Dir, filenames.DiffDisk)
+	ciDataPath := filepath.Join(driver.Instance.Dir, filenames.CIDataISO)
+	cfg := DomainConfig{
+		Name:       "lima-" + driver.Instance.Name,
+		Memory:     driver.Instance.Memory,
+		CPUs:       driver.Instance.CPUs,
+		CIDataPath: ciDataPath,
+		DiskPath:   diffDisk,
+		// Network:        "lima-" + driver.Instance.Name,
+		SlirpNetwork:   networks.SlirpNetwork,
+		SlirpIPAddress: networks.SlirpIPAddress,
+		SSHLocalPort:   driver.SSHLocalPort,
+	}
+	var buf bytes.Buffer
+	err = qemu.Execute(&buf, cfg)
+	if err != nil {
+		return "", err
+	}
+	cfg.QemuCommandline = buf.String()
+
+	var xml bytes.Buffer
+	err = tmpl.Execute(&xml, cfg)
+	if err != nil {
+		return "", err
+	}
+	domainXML := filepath.Join(driver.Instance.Dir, "domain.xml")
+	err = os.WriteFile(domainXML, xml.Bytes(), 0o644)
+	if err != nil {
+		return "", err
+	}
+	return domainXML, nil
+}

pkg/virt/network.go

@@ -0,0 +1,45 @@
+package virt
+
+import (
+	"bytes"
+	"os"
+	"path/filepath"
+	"text/template"
+
+	"github.com/lima-vm/lima/pkg/driver"
+)
+
+type NetworkConfig struct {
+	Name    string
+	Address string
+	Netmask string
+}
+
+const networkXMLTemplate = `<network>
+  <name>{{.Name}}</name>
+  <ip address='{{.Address}}' netmask='{{.Netmask}}'>
+  </ip>
+</network>`
+
+func NetworkXML(driver *driver.BaseDriver) (string, error) {
+	tmpl, err := template.New("network").Parse(networkXMLTemplate)
+	if err != nil {
+		return "", err
+	}
+	cfg := NetworkConfig{
+		Name:    "lima-" + driver.Instance.Name,
+		Address: "192.168.55.15",
+		Netmask: "255.255.255.0",
+	}
+	var xml bytes.Buffer
+	err = tmpl.Execute(&xml, cfg)
+	if err != nil {
+		return "", err
+	}
+	networkXML := filepath.Join(driver.Instance.Dir, "network.xml")
+	err = os.WriteFile(networkXML, xml.Bytes(), 0o644)
+	if err != nil {
+		return "", err
+	}
+	return networkXML, nil
+}

pkg/virt/virt.go

@@ -18,3 +18,19 @@ func Version() (string, error) {
 	}
 	return m[1], nil
 }
+
+const connectString = "qemu:///session"
+
+func virsh(args ...string) error {
+	connect := []string{"--connect", connectString}
+	args = append(connect, args...)
+	return exec.Command("virsh", args...).Run()
+}
+
+func CreateNetwork(xml string) error {
+	return virsh("net-create", xml)
+}
+
+func CreateDomain(xml string) error {
+	return virsh("create", xml)
+}

pkg/virt/virt_driver.go

@@ -39,7 +39,25 @@ func (l *LimaVirtDriver) CreateDisk() error {
 }
 
 func (l *LimaVirtDriver) Start(_ context.Context) (chan error, error) {
-	return nil, errors.New("TODO")
+	/*
+		net, err := NetworkXML(l.BaseDriver)
+		if err != nil {
+			return nil, err
+		}
+		if err := CreateNetwork(net); err != nil {
+			return nil, err
+		}
+	*/
+
+	dom, err := DomainXML(l.BaseDriver)
+	if err != nil {
+		return nil, err
+	}
+	if err := CreateDomain(dom); err != nil {
+		return nil, err
+	}
+
+	return nil, err
 }
 
 func (l *LimaVirtDriver) Stop(_ context.Context) error {