1
0
mirror of https://github.com/vlang/v.git synced 2023-08-10 21:13:21 +03:00
v/vlib/os/process_test.v

105 lines
2.7 KiB
V
Raw Normal View History

// vtest flaky: true
// vtest retry: 3
2020-11-16 19:32:50 +03:00
import os
import time
2021-04-04 17:05:06 +03:00
const (
vexe = os.getenv('VEXE')
vroot = os.dir(vexe)
tfolder = os.join_path(os.vtmp_dir(), 'v', 'tests', 'os_process')
test_os_process = os.join_path(tfolder, 'test_os_process.exe')
2021-04-04 17:05:06 +03:00
test_os_process_source = os.join_path(vroot, 'cmd/tools/test_os_process.v')
)
fn testsuite_begin() {
os.rmdir_all(tfolder) or {}
os.mkdir_all(tfolder)!
2021-04-04 17:05:06 +03:00
if os.getenv('WINE_TEST_OS_PROCESS_EXE') != '' {
// Make it easier to run the test under wine emulation, by just
2021-04-04 17:05:06 +03:00
// prebuilding the executable with:
// v -os windows -o x.exe cmd/tools/test_os_process.v
// WINE_TEST_OS_PROCESS_EXE=x.exe ./v -os windows vlib/os/process_test.v
os.cp(os.getenv('WINE_TEST_OS_PROCESS_EXE'), test_os_process)!
2021-04-04 17:05:06 +03:00
} else {
os.system('${os.quoted_path(vexe)} -o ${os.quoted_path(test_os_process)} ${os.quoted_path(test_os_process_source)}')
2021-04-04 17:05:06 +03:00
}
assert os.exists(test_os_process)
}
fn testsuite_end() {
os.rmdir_all(tfolder) or {}
}
2020-11-16 19:32:50 +03:00
fn test_getpid() {
pid := os.getpid()
eprintln('current pid: ${pid}')
2020-11-16 19:32:50 +03:00
assert pid != 0
}
fn test_run() {
mut p := os.new_process(test_os_process)
p.set_args(['-timeout_ms', '150', '-period_ms', '50'])
2020-11-16 19:32:50 +03:00
p.run()
assert p.status == .running
assert p.pid > 0
assert p.pid != os.getpid()
mut i := 0
for {
if !p.is_alive() {
break
}
$if trace_process_output ? {
os.system('ps -opid= -oppid= -ouser= -onice= -of= -ovsz= -orss= -otime= -oargs= -p ${p.pid}')
}
2021-02-27 20:41:06 +03:00
time.sleep(50 * time.millisecond)
2020-11-16 19:32:50 +03:00
i++
}
p.wait()
assert p.code == 0
assert p.status == .exited
//
eprintln('polling iterations: ${i}')
assert i < 50
p.close()
2020-11-16 19:32:50 +03:00
}
fn test_wait() {
mut p := os.new_process(test_os_process)
assert p.status != .exited
2020-11-16 19:32:50 +03:00
p.wait()
assert p.status == .exited
assert p.code == 0
assert p.pid != os.getpid()
p.close()
2020-11-16 19:32:50 +03:00
}
fn test_slurping_output() {
mut p := os.new_process(test_os_process)
p.set_args(['-timeout_ms', '500', '-period_ms', '50'])
2020-11-16 19:32:50 +03:00
p.set_redirect_stdio()
assert p.status != .exited
2020-11-16 19:32:50 +03:00
p.wait()
assert p.status == .exited
assert p.code == 0
2020-11-16 19:32:50 +03:00
output := p.stdout_slurp().trim_space()
errors := p.stderr_slurp().trim_space()
p.close()
$if trace_process_output ? {
eprintln('---------------------------')
eprintln('p output: "${output}"')
eprintln('p errors: "${errors}"')
eprintln('---------------------------')
}
2021-04-04 17:05:06 +03:00
// dump(output)
assert output.contains('stdout, 1')
assert output.contains('stdout, 2')
assert output.contains('stdout, 3')
assert output.contains('stdout, 4')
2021-04-04 17:05:06 +03:00
//
// dump(errors)
assert errors.contains('stderr, 1')
assert errors.contains('stderr, 2')
assert errors.contains('stderr, 3')
assert errors.contains('stderr, 4')
2020-11-16 19:32:50 +03:00
}