aboutsummaryrefslogtreecommitdiff
path: root/v_windows/v/old/vlib/os/process_test.v
diff options
context:
space:
mode:
authorIndrajith K L2022-12-03 17:00:20 +0530
committerIndrajith K L2022-12-03 17:00:20 +0530
commitf5c4671bfbad96bf346bd7e9a21fc4317b4959df (patch)
tree2764fc62da58f2ba8da7ed341643fc359873142f /v_windows/v/old/vlib/os/process_test.v
downloadcli-tools-windows-f5c4671bfbad96bf346bd7e9a21fc4317b4959df.tar.gz
cli-tools-windows-f5c4671bfbad96bf346bd7e9a21fc4317b4959df.tar.bz2
cli-tools-windows-f5c4671bfbad96bf346bd7e9a21fc4317b4959df.zip
Adds most of the toolsHEADmaster
Diffstat (limited to 'v_windows/v/old/vlib/os/process_test.v')
-rw-r--r--v_windows/v/old/vlib/os/process_test.v96
1 files changed, 96 insertions, 0 deletions
diff --git a/v_windows/v/old/vlib/os/process_test.v b/v_windows/v/old/vlib/os/process_test.v
new file mode 100644
index 0000000..5301472
--- /dev/null
+++ b/v_windows/v/old/vlib/os/process_test.v
@@ -0,0 +1,96 @@
+import os
+import time
+
+const (
+ vexe = os.getenv('VEXE')
+ vroot = os.dir(vexe)
+ test_os_process = os.join_path(os.temp_dir(), 'v', 'test_os_process.exe')
+ test_os_process_source = os.join_path(vroot, 'cmd/tools/test_os_process.v')
+)
+
+fn testsuite_begin() ? {
+ os.rm(test_os_process) or {}
+ if os.getenv('WINE_TEST_OS_PROCESS_EXE') != '' {
+ // Make it easier to run the test under wine emulation, by just
+ // 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) ?
+ } else {
+ os.system('$vexe -o $test_os_process $test_os_process_source')
+ }
+ assert os.exists(test_os_process)
+}
+
+fn test_getpid() {
+ pid := os.getpid()
+ eprintln('current pid: $pid')
+ assert pid != 0
+}
+
+fn test_run() {
+ mut p := os.new_process(test_os_process)
+ p.set_args(['-timeout_ms', '150', '-period_ms', '50'])
+ 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')
+ }
+ time.sleep(50 * time.millisecond)
+ i++
+ }
+ p.wait()
+ assert p.code == 0
+ assert p.status == .exited
+ //
+ eprintln('polling iterations: $i')
+ assert i < 50
+ p.close()
+}
+
+fn test_wait() {
+ mut p := os.new_process(test_os_process)
+ assert p.status != .exited
+ p.wait()
+ assert p.status == .exited
+ assert p.code == 0
+ assert p.pid != os.getpid()
+ p.close()
+}
+
+fn test_slurping_output() {
+ mut p := os.new_process(test_os_process)
+ p.set_args(['-timeout_ms', '500', '-period_ms', '50'])
+ p.set_redirect_stdio()
+ assert p.status != .exited
+ p.wait()
+ assert p.status == .exited
+ assert p.code == 0
+ 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('---------------------------')
+ }
+ // dump(output)
+ assert output.contains('stdout, 1')
+ assert output.contains('stdout, 2')
+ assert output.contains('stdout, 3')
+ assert output.contains('stdout, 4')
+ //
+ // dump(errors)
+ assert errors.contains('stderr, 1')
+ assert errors.contains('stderr, 2')
+ assert errors.contains('stderr, 3')
+ assert errors.contains('stderr, 4')
+}