Skip to content

Commit

Permalink
fix more staticcheck errors
Browse files Browse the repository at this point in the history
  • Loading branch information
winkingturtle-vmw committed Sep 30, 2024
1 parent ff3766c commit 70e6274
Showing 1 changed file with 14 additions and 19 deletions.
33 changes: 14 additions & 19 deletions invoker/pgroup_invoker.go
Original file line number Diff line number Diff line change
Expand Up @@ -31,10 +31,7 @@ func (r *pgroupInvoker) Invoke(env dockerdriver.Env, executable string, cmdArgs
cmdHandle.Stdout = &stdOutBuffer
cmdHandle.Stderr = &stdErrBuffer
if len(envVars) > 0 {
allEnvVars := os.Environ()
for _, envVar := range envVars {
allEnvVars = append(allEnvVars, envVar)
}
allEnvVars := append(os.Environ(), envVars...)
cmdHandle.Env = allEnvVars
}
err := cmdHandle.Start()
Expand All @@ -51,21 +48,19 @@ func (r *pgroupInvoker) Invoke(env dockerdriver.Env, executable string, cmdArgs
var cmdDone = false

go func() {
select {
case <-env.Context().Done():
if cmdDone {
logger.Info("not killing process due to already finished")
return
}
logger.Info("command-sigkill", lager.Data{"exe": executable, "pid": -cmdHandle.Process.Pid})
err := syscall.Kill(-cmdHandle.Process.Pid, syscall.SIGKILL)
if err != nil {
logger.Info("command-sigkill-error", lager.Data{"desc": err.Error()})
}
err = cmdHandle.Wait()
if err != nil {
logger.Info("command-sigkill-wait-error", lager.Data{"desc": err.Error()})
}
<-env.Context().Done()
if cmdDone {
logger.Info("not killing process due to already finished")
return
}
logger.Info("command-sigkill", lager.Data{"exe": executable, "pid": -cmdHandle.Process.Pid})
err := syscall.Kill(-cmdHandle.Process.Pid, syscall.SIGKILL)
if err != nil {
logger.Info("command-sigkill-error", lager.Data{"desc": err.Error()})
}
err = cmdHandle.Wait()
if err != nil {
logger.Info("command-sigkill-wait-error", lager.Data{"desc": err.Error()})
}
}()

Expand Down

0 comments on commit 70e6274

Please sign in to comment.