Function RunUnixShell

common/utils/binary.go:67–139

RunUnixShell 运行UnixShell，支持context

(options *structs.ShellOptions)

// RunUnixShell 运行UnixShell，支持context
func RunUnixShell(options *structs.ShellOptions) (*structs.ShellResult, error) {
	fpath, err := exec.LookPath(options.Name)
	if err != nil {
		return nil, err
	}
	result := structs.ShellResult{}
	proc := exec.Command(fpath, options.Args...)
	proc.SysProcAttr = &syscall.SysProcAttr{Setpgid: true} // 把编译器整个放置在进程组里

	var stderr, stdout bytes.Buffer

	if options.StdWriter != nil && options.StdWriter.Output != nil {
		proc.Stdout = options.StdWriter.Output
	} else {
		proc.Stdout = &stdout
	}
	if options.StdWriter != nil && options.StdWriter.Error != nil {
		proc.Stderr = options.StdWriter.Error
	} else {
		proc.Stderr = &stderr
	}

	if options.StdWriter != nil && options.StdWriter.Input != nil {
		proc.Stdin = options.StdWriter.Input
	} else {
		stdin, err := proc.StdinPipe()
		if err != nil {
			return nil, err
		}
		if options.OnStart != nil {
			err = options.OnStart(stdin)
			if err != nil {
				return nil, err
			}
		}
		_ = stdin.Close()
	}

	// 监听是否超时
	go func() {
		select {
		case <-options.Context.Done():
			// 干掉进程组
			// CommandContext自带的功能没有考虑到这个操作：
			_ = syscall.Kill(-proc.Process.Pid, syscall.SIGKILL)
		}
	}()

	if err = proc.Start(); err != nil {
		return nil, err
	}

	err = proc.Wait()

	if options.StdWriter == nil || options.StdWriter.Output == nil {
		result.Stdout = stdout.String()
	}
	if options.StdWriter == nil || options.StdWriter.Error == nil {