mediamtx/internal/externalcmd/externalcmd_unix.go

// +build !windows

package externalcmd

import (
	"os"
	"os/exec"
)

func (e *ExternalCmd) runInner() bool {
	cmd := exec.Command("/bin/sh", "-c", "exec "+e.cmdstr)

	cmd.Env = append(os.Environ(),
		"RTSP_PATH="+e.env.Path,
		"RTSP_PORT="+e.env.Port,
	)

	cmd.Stdout = os.Stdout
	cmd.Stderr = os.Stderr

	err := cmd.Start()
	if err != nil {
		return true
	}

	cmdDone := make(chan struct{})
	go func() {
		defer close(cmdDone)
		cmd.Wait()
	}()

	select {
	case <-e.terminate:
		cmd.Process.Signal(os.Interrupt)
		<-cmdDone
		return false

	case <-cmdDone:
		return true
	}
}