mirror of
https://github.com/go-sylixos/elvish.git
synced 2024-12-05 03:17:50 +08:00
90 lines
1.7 KiB
Go
90 lines
1.7 KiB
Go
// +build !windows,!plan9
|
|
|
|
package eval
|
|
|
|
import (
|
|
"errors"
|
|
"os"
|
|
"os/exec"
|
|
"strconv"
|
|
"syscall"
|
|
|
|
"github.com/elves/elvish/pkg/eval/vals"
|
|
"github.com/elves/elvish/pkg/sys"
|
|
)
|
|
|
|
// ErrNotInSameProcessGroup is thrown when the process IDs passed to fg are not
|
|
// in the same process group.
|
|
var ErrNotInSameProcessGroup = errors.New("not in the same process group")
|
|
|
|
func execFn(fm *Frame, args ...interface{}) error {
|
|
var argstrings []string
|
|
if len(args) == 0 {
|
|
argstrings = []string{"elvish"}
|
|
} else {
|
|
argstrings = make([]string, len(args))
|
|
for i, a := range args {
|
|
argstrings[i] = vals.ToString(a)
|
|
}
|
|
}
|
|
|
|
var err error
|
|
argstrings[0], err = exec.LookPath(argstrings[0])
|
|
if err != nil {
|
|
return err
|
|
}
|
|
|
|
preExit(fm)
|
|
|
|
return syscall.Exec(argstrings[0], argstrings, os.Environ())
|
|
}
|
|
|
|
func fg(pids ...int) error {
|
|
if len(pids) == 0 {
|
|
return ErrArgs
|
|
}
|
|
var thepgid int
|
|
for i, pid := range pids {
|
|
pgid, err := syscall.Getpgid(pid)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
if i == 0 {
|
|
thepgid = pgid
|
|
} else if pgid != thepgid {
|
|
return ErrNotInSameProcessGroup
|
|
}
|
|
}
|
|
|
|
err := sys.Tcsetpgrp(0, thepgid)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
|
|
errors := make([]*Exception, len(pids))
|
|
|
|
for i, pid := range pids {
|
|
err := syscall.Kill(pid, syscall.SIGCONT)
|
|
if err != nil {
|
|
errors[i] = &Exception{err, nil}
|
|
}
|
|
}
|
|
|
|
for i, pid := range pids {
|
|
if errors[i] != nil {
|
|
continue
|
|
}
|
|
var ws syscall.WaitStatus
|
|
_, err = syscall.Wait4(pid, &ws, syscall.WUNTRACED, nil)
|
|
if err != nil {
|
|
errors[i] = &Exception{err, nil}
|
|
} else {
|
|
// TODO find command name
|
|
errors[i] = &Exception{NewExternalCmdExit(
|
|
"[pid "+strconv.Itoa(pid)+"]", ws, pid), nil}
|
|
}
|
|
}
|
|
|
|
return makePipelineError(errors)
|
|
}
|