mirror of
https://github.com/vlang/v.git
synced 2023-08-10 21:13:21 +03:00
163 lines
3.8 KiB
V
163 lines
3.8 KiB
V
module os
|
|
|
|
fn C.setpgid(pid int, pgid int) int
|
|
|
|
fn (mut p Process) unix_spawn_process() int {
|
|
mut pipeset := [6]int{}
|
|
if p.use_stdio_ctl {
|
|
mut dont_care := C.pipe(&pipeset[0]) // pipe read end 0 <- 1 pipe write end
|
|
dont_care = C.pipe(&pipeset[2]) // pipe read end 2 <- 3 pipe write end
|
|
dont_care = C.pipe(&pipeset[4]) // pipe read end 4 <- 5 pipe write end
|
|
_ = dont_care // using `_` directly on each above `pipe` fails to avoid C compiler generate an `-Wunused-result` warning
|
|
}
|
|
pid := fork()
|
|
if pid != 0 {
|
|
// This is the parent process after the fork.
|
|
// Note: pid contains the process ID of the child process
|
|
if p.use_stdio_ctl {
|
|
p.stdio_fd[0] = pipeset[1] // store the write end of child's in
|
|
p.stdio_fd[1] = pipeset[2] // store the read end of child's out
|
|
p.stdio_fd[2] = pipeset[4] // store the read end of child's err
|
|
// close the rest of the pipe fds, the parent does not need them
|
|
fd_close(pipeset[0])
|
|
fd_close(pipeset[3])
|
|
fd_close(pipeset[5])
|
|
}
|
|
return pid
|
|
}
|
|
//
|
|
// Here, we are in the child process.
|
|
// It still shares file descriptors with the parent process,
|
|
// but it is otherwise independent and can do stuff *without*
|
|
// affecting the parent process.
|
|
//
|
|
if p.use_pgroup {
|
|
C.setpgid(0, 0)
|
|
}
|
|
if p.use_stdio_ctl {
|
|
// Redirect the child standart in/out/err to the pipes that
|
|
// were created in the parent.
|
|
// Close the parent's pipe fds, the child do not need them:
|
|
fd_close(pipeset[1])
|
|
fd_close(pipeset[2])
|
|
fd_close(pipeset[4])
|
|
// redirect the pipe fds to the child's in/out/err fds:
|
|
C.dup2(pipeset[0], 0)
|
|
C.dup2(pipeset[3], 1)
|
|
C.dup2(pipeset[5], 2)
|
|
// close the pipe fdsx after the redirection
|
|
fd_close(pipeset[0])
|
|
fd_close(pipeset[3])
|
|
fd_close(pipeset[5])
|
|
}
|
|
if p.work_folder != '' {
|
|
if !is_abs_path(p.filename) {
|
|
// Ensure p.filename contains an absolute path, so it
|
|
// can be located reliably, even after changing the
|
|
// current folder in the child process:
|
|
p.filename = abs_path(p.filename)
|
|
}
|
|
chdir(p.work_folder) or {}
|
|
}
|
|
execve(p.filename, p.args, p.env) or {
|
|
eprintln(err)
|
|
exit(1)
|
|
}
|
|
return 0
|
|
}
|
|
|
|
fn (mut p Process) unix_stop_process() {
|
|
C.kill(p.pid, C.SIGSTOP)
|
|
}
|
|
|
|
fn (mut p Process) unix_resume_process() {
|
|
C.kill(p.pid, C.SIGCONT)
|
|
}
|
|
|
|
fn (mut p Process) unix_kill_process() {
|
|
C.kill(p.pid, C.SIGKILL)
|
|
}
|
|
|
|
fn (mut p Process) unix_kill_pgroup() {
|
|
C.kill(-p.pid, C.SIGKILL)
|
|
}
|
|
|
|
fn (mut p Process) unix_wait() {
|
|
cstatus := 0
|
|
mut ret := -1
|
|
$if !emscripten ? {
|
|
ret = C.waitpid(p.pid, &cstatus, 0)
|
|
}
|
|
if ret == -1 {
|
|
p.err = posix_get_error_msg(C.errno)
|
|
return
|
|
}
|
|
pret, is_signaled := posix_wait4_to_exit_status(cstatus)
|
|
if is_signaled {
|
|
p.status = .aborted
|
|
p.err = 'Terminated by signal ${ret:2d} (${sigint_to_signal_name(pret)})'
|
|
} else {
|
|
p.status = .exited
|
|
}
|
|
p.code = pret
|
|
}
|
|
|
|
fn (mut p Process) unix_is_alive() bool {
|
|
cstatus := 0
|
|
mut ret := -1
|
|
$if !emscripten ? {
|
|
ret = C.waitpid(p.pid, &cstatus, C.WNOHANG)
|
|
}
|
|
if ret == -1 {
|
|
p.err = posix_get_error_msg(C.errno)
|
|
return false
|
|
}
|
|
if ret == 0 {
|
|
return true
|
|
}
|
|
pret, is_signaled := posix_wait4_to_exit_status(cstatus)
|
|
if is_signaled {
|
|
p.status = .aborted
|
|
p.err = 'Terminated by signal ${ret:2d} (${sigint_to_signal_name(pret)})'
|
|
} else {
|
|
p.status = .exited
|
|
}
|
|
p.code = pret
|
|
return false
|
|
}
|
|
|
|
// these are here to make v_win.c/v.c generation work in all cases:
|
|
fn (mut p Process) win_spawn_process() int {
|
|
return 0
|
|
}
|
|
|
|
fn (mut p Process) win_stop_process() {
|
|
}
|
|
|
|
fn (mut p Process) win_resume_process() {
|
|
}
|
|
|
|
fn (mut p Process) win_kill_process() {
|
|
}
|
|
|
|
fn (mut p Process) win_kill_pgroup() {
|
|
}
|
|
|
|
fn (mut p Process) win_wait() {
|
|
}
|
|
|
|
fn (mut p Process) win_is_alive() bool {
|
|
return false
|
|
}
|
|
|
|
fn (mut p Process) win_write_string(idx int, s string) {
|
|
}
|
|
|
|
fn (mut p Process) win_read_string(idx int, maxbytes int) (string, int) {
|
|
return '', 0
|
|
}
|
|
|
|
fn (mut p Process) win_slurp(idx int) string {
|
|
return ''
|
|
}
|