kemko/nomad
1
0
Fork 0
mirror of https://github.com/kemko/nomad.git synced 2026-01-01 16:05:42 +03:00
Code Issues Packages Projects Releases Wiki Activity

qemu: fix log lines to use correct QEMU capitalization. (#17961)

Browse Source
This commit is contained in:
James Rasell
2023-07-19 15:21:15 +01:00
committed by GitHub
parent 81c14dee3c
commit 81aa274551
1 changed files with 7 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
drivers/qemu/driver.go
View File

@@ -432,7 +432,7 @@ func (d *Driver) StartTask(cfg *drivers.TaskConfig) (*drivers.TaskHandle, *drive
mb := cfg.Resources.NomadResources.Memory.MemoryMB
if mb < 128 || mb > 4000000 {
return nil, nil, fmt.Errorf("Qemu memory assignment out of bounds")
return nil, nil, fmt.Errorf("QEMU memory assignment out of bounds")
}
mem := fmt.Sprintf("%dM", mb)
@@ -556,7 +556,7 @@ func (d *Driver) StartTask(cfg *drivers.TaskConfig) (*drivers.TaskHandle, *drive
)
}
}
d.logger.Debug("starting QemuVM command ", "args", strings.Join(args, " "))
d.logger.Debug("starting QEMU VM command ", "args", strings.Join(args, " "))
pluginLogFile := filepath.Join(cfg.TaskDir().Dir, fmt.Sprintf("%s-executor.out", cfg.Name))
executorConfig := &executor.ExecutorConfig{
@@ -586,7 +586,7 @@ func (d *Driver) StartTask(cfg *drivers.TaskConfig) (*drivers.TaskHandle, *drive
pluginClient.Kill()
return nil, nil, err
}
d.logger.Debug("started new QemuVM", "ID", vmID)
d.logger.Debug("started new QEMU VM", "id", vmID)
h := &taskHandle{
exec: execImpl,
@@ -709,12 +709,12 @@ func (d *Driver) TaskEvents(ctx context.Context) (<-chan *drivers.TaskEvent, err
return d.eventer.TaskEvents(ctx)
}
func (d *Driver) SignalTask(taskID string, signal string) error {
return fmt.Errorf("Qemu driver can't signal commands")
func (d *Driver) SignalTask(_ string, _ string) error {
return fmt.Errorf("QEMU driver can't signal commands")
}
func (d *Driver) ExecTask(taskID string, cmdArgs []string, timeout time.Duration) (*drivers.ExecTaskResult, error) {
return nil, fmt.Errorf("Qemu driver can't execute commands")
func (d *Driver) ExecTask(_ string, _ []string, _ time.Duration) (*drivers.ExecTaskResult, error) {
return nil, fmt.Errorf("QEMU driver can't execute commands")
}