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

Update UniversalExecutor to have string identifiers

Browse Source
This commit is contained in:
Alex Dadgar
2015-09-19 19:00:34 -07:00
parent 5ac6c3b73d
commit c88f93ca71
1 changed files with 12 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

18
client/executor/exec_universal.go
View File

@@ -5,6 +5,7 @@ package executor
import (
"fmt"
"os"
"strconv"
"github.com/hashicorp/nomad/nomad/structs"
)
@@ -29,10 +30,15 @@ func (e *UniversalExecutor) Start() error {
return e.cmd.Start()
}
func (e *UniversalExecutor) Open(pid int) error {
process, err := os.FindProcess(pid)
func (e *UniversalExecutor) Open(pid string) error {
pidNum, err := strconv.Atoi(pid)
if err != nil {
return fmt.Errorf("Failed to reopen pid %d: %s", pid, err)
return fmt.Errorf("Failed to parse pid %v: %v", pid, err)
}
process, err := os.FindProcess(pidNum)
if err != nil {
return fmt.Errorf("Failed to reopen pid %d: %v", pidNum, err)
}
e.Process = process
return nil
@@ -43,11 +49,11 @@ func (e *UniversalExecutor) Wait() error {
return e.cmd.Wait()
}
func (e *UniversalExecutor) Pid() (int, error) {
func (e *UniversalExecutor) ID() (string, error) {
if e.cmd.Process != nil {
return e.cmd.Process.Pid, nil
return strconv.Itoa(e.cmd.Process.Pid), nil
} else {
return 0, fmt.Errorf("Process has finished or was never started")
return "", fmt.Errorf("Process has finished or was never started")
}
}