incusd/instance/qemu: Cap hotplug CPU slots to 64

internal/server/instance/drivers/driver_qemu.go

@@ -807,12 +807,16 @@ func (d *qemu) ovmfPath() string {
 func (d *qemu) killQemuProcess(pid int) error {
 	proc, err := os.FindProcess(pid)
 	if err != nil {
+		if err == os.ErrProcessDone {
+			return nil
+		}
+
 		return err
 	}
 
 	err = proc.Kill()
 	if err != nil {
-		if strings.Contains(err.Error(), "process already finished") {
+		if err == os.ErrProcessDone {
 			return nil
 		}
 

internal/server/instance/drivers/driver_qemu_templates.go

@@ -484,8 +484,16 @@ func qemuCPU(opts *qemuCPUOpts, pinning bool) []cfgSection {
 			return nil
 		}
 
+		// Cap the max number of CPUs to 64 unless directly assigned more.
+		max := 64
+		if int(cpu.Total) < max {
+			max = int(cpu.Total)
+		} else if opts.cpuCount > max {
+			max = opts.cpuCount
+		}
+
 		entries = append(entries, cfgEntry{
-			key: "maxcpus", value: fmt.Sprintf("%d", cpu.Total),
+			key: "maxcpus", value: fmt.Sprintf("%d", max),
 		})
 	}
 

internal/server/storage/drivers/driver_lvm_volumes.go

@@ -185,7 +185,7 @@ func (d *lvm) CreateVolumeFromMigration(vol Volume, conn io.ReadWriteCloser, vol
 						break
 					}
 
-					time.Sleep(10*time.Second)
+					time.Sleep(10 * time.Second)
 				}
 			}(volDevPath)
 

shared/subprocess/proc.go

@@ -8,7 +8,6 @@ import (
 	"io"
 	"os"
 	"os/exec"
-	"strings"
 	"syscall"
 
 	"gopkg.in/yaml.v2"
@@ -59,13 +58,25 @@ func (p *Process) hasApparmor() bool {
 
 // GetPid returns the pid for the given process object.
 func (p *Process) GetPid() (int64, error) {
-	pr, _ := os.FindProcess(int(p.PID))
-	err := pr.Signal(syscall.Signal(0))
-	if err == nil {
-		return p.PID, nil
+	pr, err := os.FindProcess(int(p.PID))
+	if err != nil {
+		if err == os.ErrProcessDone {
+			return 0, ErrNotRunning
+		}
+
+		return 0, err
+	}
+
+	err = pr.Signal(syscall.Signal(0))
+	if err != nil {
+		if err == os.ErrProcessDone {
+			return 0, ErrNotRunning
+		}
+
+		return 0, err
 	}
 
-	return 0, ErrNotRunning
+	return p.PID, nil
 }
 
 // SetApparmor allows setting the AppArmor profile.
@@ -81,10 +92,21 @@ func (p *Process) SetCreds(uid uint32, gid uint32) {
 
 // Stop will stop the given process object.
 func (p *Process) Stop() error {
-	pr, _ := os.FindProcess(int(p.PID))
+	pr, err := os.FindProcess(int(p.PID))
+	if err != nil {
+		if err == os.ErrProcessDone {
+			if p.hasMonitor {
+				<-p.chExit
+			}
+
+			return ErrNotRunning
+		}
+
+		return err
+	}
 
 	// Check if process exists.
-	err := pr.Signal(syscall.Signal(0))
+	err = pr.Signal(syscall.Signal(0))
 	if err == nil {
 		err = pr.Kill()
 		if err == nil {
@@ -97,7 +119,7 @@ func (p *Process) Stop() error {
 	}
 
 	// Check if either the existence check or the kill resulted in an already finished error.
-	if strings.Contains(err.Error(), "process already finished") {
+	if err == os.ErrProcessDone {
 		if p.hasMonitor {
 			<-p.chExit
 		}
@@ -212,16 +234,24 @@ func (p *Process) Restart(ctx context.Context) error {
 
 // Reload sends the SIGHUP signal to the given process object.
 func (p *Process) Reload() error {
-	pr, _ := os.FindProcess(int(p.PID))
-	err := pr.Signal(syscall.Signal(0))
+	pr, err := os.FindProcess(int(p.PID))
+	if err != nil {
+		if err == os.ErrProcessDone {
+			return ErrNotRunning
+		}
+
+		return fmt.Errorf("Could not reload process: %w", err)
+	}
+
+	err = pr.Signal(syscall.Signal(0))
 	if err == nil {
 		err = pr.Signal(syscall.SIGHUP)
 		if err != nil {
 			return fmt.Errorf("Could not reload process: %w", err)
 		}
 
 		return nil
-	} else if strings.Contains(err.Error(), "process already finished") {
+	} else if err == os.ErrProcessDone {
 		return ErrNotRunning
 	}
 
@@ -245,16 +275,24 @@ func (p *Process) Save(path string) error {
 
 // Signal will send a signal to the given process object given a signal value.
 func (p *Process) Signal(signal int64) error {
-	pr, _ := os.FindProcess(int(p.PID))
-	err := pr.Signal(syscall.Signal(0))
+	pr, err := os.FindProcess(int(p.PID))
+	if err != nil {
+		if err == os.ErrProcessDone {
+			return ErrNotRunning
+		}
+
+		return err
+	}
+
+	err = pr.Signal(syscall.Signal(0))
 	if err == nil {
 		err = pr.Signal(syscall.Signal(signal))
 		if err != nil {
 			return fmt.Errorf("Could not signal process: %w", err)
 		}
 
 		return nil
-	} else if strings.Contains(err.Error(), "process already finished") {
+	} else if err == os.ErrProcessDone {
 		return ErrNotRunning
 	}