aljaz/kata-containers
1
0
Fork 0
mirror of https://github.com/aljazceru/kata-containers.git synced 2025-12-18 23:04:20 +01:00
Code Issues Packages Projects Releases Wiki Activity

qemu: Add maxcpus attribute to -smp

Browse Source 
maxcpus is used to specify how many cpus a VM can have.
This attribute must be specified to enable the hotplugging CPUs capability,
otherwise the maximum number of CPU will be defined by the number of CPU
in -smp.

Signed-off-by: Julio Montes <julio.montes@intel.com>
This commit is contained in:
Julio Montes
2017-12-12 07:32:31 -06:00
parent eacde4d37d
commit 8fe572367a
2 changed files with 40 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

21
qemu/qemu.go
View File

@@ -980,6 +980,10 @@ type SMP struct {
// Sockets is the number of sockets made available to qemu.
Sockets uint32
// MaxCPUs is the maximum number of VCPUs that a VM can have.
// This value, if non-zero, MUST BE equal to or greater than CPUs
MaxCPUs uint32
}
// Memory is the guest memory configuration structure.
@@ -1203,7 +1207,7 @@ func (config *Config) appendMemory() {
}
}
func (config *Config) appendCPUs() {
func (config *Config) appendCPUs() error {
if config.SMP.CPUs > 0 {
var SMPParams []string
@@ -1221,9 +1225,19 @@ func (config *Config) appendCPUs() {
SMPParams = append(SMPParams, fmt.Sprintf(",sockets=%d", config.SMP.Sockets))
}
if config.SMP.MaxCPUs > 0 {
if config.SMP.MaxCPUs < config.SMP.CPUs {
return fmt.Errorf("MaxCPUs %d must be equal to or greater than CPUs %d",
config.SMP.MaxCPUs, config.SMP.CPUs)
}
SMPParams = append(SMPParams, fmt.Sprintf(",maxcpus=%d", config.SMP.MaxCPUs))
}
config.qemuParams = append(config.qemuParams, "-smp")
config.qemuParams = append(config.qemuParams, strings.Join(SMPParams, ""))
}
return nil
}
func (config *Config) appendRTC() {
@@ -1360,7 +1374,6 @@ func LaunchQemu(config Config, logger QMPLog) (string, error) {
config.appendCPUModel()
config.appendQMPSockets()
config.appendMemory()
config.appendCPUs()
config.appendDevices()
config.appendRTC()
config.appendGlobalParam()
@@ -1369,6 +1382,10 @@ func LaunchQemu(config Config, logger QMPLog) (string, error) {
config.appendKernel()
config.appendBios()
if err := config.appendCPUs(); err != nil {
return "", err
}
return LaunchCustomQemu(config.Ctx, config.Path, config.qemuParams,
config.fds, nil, logger)
}