TheCloud/v
1
0
Fork 0
mirror of https://github.com/vlang/v.git synced 2025-09-09 07:15:50 -04:00
Code Issues Packages Projects Releases Wiki Activity

net.unix: make unix_socket_test.v trace its actions more thoroughly

Browse Source
This commit is contained in:
Delyan Angelov 2025-02-17 22:26:53 +02:00
parent dbc96b22ec
commit da093882f7
No known key found for this signature in database
GPG Key ID: 66886C0F12D595ED
2 changed files with 97 additions and 63 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

97
vlib/net/unix/unix_socket_test.v Normal file
View File

@ -0,0 +1,97 @@
import os
import log
import time
import net.unix
const tfolder = os.join_path(os.temp_dir(), 'unix_socket_${os.getpid()}')
const socket_path = os.join_path(tfolder, 'v_unix.sock')
fn testsuite_begin() {
os.mkdir_all(tfolder) or {}
}
fn testsuite_end() {
os.rmdir_all(tfolder) or {}
}
fn handle_conn(mut c unix.StreamConn) {
log.warn(' handle_conn ${voidptr(c)} start')
for {
mut buf := []u8{len: 100, init: 0}
log.warn(' handle_conn ${voidptr(c)}, reading data...')
read := c.read(mut buf) or {
log.warn(' handle_conn ${voidptr(c)}, reading failed, connection was dropped.')
return
}
log.warn(' handle_conn ${voidptr(c)}, read: ${read} bytes')
written := c.write(buf[..read]) or {
log.warn(' handle_conn ${voidptr(c)}, writing failed, connection was dropped.')
return
}
log.warn(' handle_conn ${voidptr(c)}, written: ${written} bytes')
}
}
fn echo_server(mut l unix.StreamListener) ! {
log.warn('echo_server l: ${voidptr(l)}, start')
for {
log.warn('echo_server l: ${voidptr(l)}, waiting for connections...')
mut new_conn := l.accept() or { continue }
log.warn('echo_server l: ${voidptr(l)}, accepted new connection: ${voidptr(new_conn)}, spawning a new thread to handle it...')
spawn handle_conn(mut new_conn)
time.sleep(10 * time.millisecond)
}
}
fn echo() ! {
log.info('echo: connecting to ${socket_path}...')
mut c := unix.connect_stream(socket_path)!
defer {
log.info('echo: closing ${voidptr(c)} ...')
c.close() or {}
}
data := 'Hello from vlib/net!'
log.info('echo: writing `${data}` to ${voidptr(c)} ...')
c.write_string(data)!
mut buf := []u8{len: 4096}
read := c.read(mut buf)!
log.info('echo: read ${read} bytes from ${voidptr(c)} ...')
assert read == data.len
for i := 0; i < read; i++ {
assert buf[i] == data[i]
}
log.info('echo: got `${buf.bytestr()}` back from ${voidptr(c)}.')
return
}
fn test_tcp() {
log.use_stdout()
unbuffer_stdout()
os.rm(socket_path) or {}
assert os.exists(socket_path) == false
log.info('${@LOCATION}, setup complete')
log.info('>>> create listening socket at ${socket_path}...')
mut l := unix.listen_stream(socket_path) or { panic(err) }
log.info('>>> listening socket at ${socket_path} is ${voidptr(l)}.')
println('')
log.info('>>> spawning server with connection ${voidptr(l)}...')
spawn echo_server(mut l)
println('')
for i in 0 .. 3 {
log.info('>>> start echo to server, i: ${i}...')
echo()!
println('')
}
log.info('>>> closing listening socket ${voidptr(l)}...')
l.close() or {}
println('')
// test if socket file is removed/unlinked
assert os.exists(socket_path) == false
log.info('${@LOCATION}, done')
}

63
vlib/net/unix/unix_test.v
View File

@ -1,63 +0,0 @@
import os
import net.unix
const tfolder = os.join_path(os.temp_dir(), 'unix_${os.getpid()}')
const socket_path = os.join_path(tfolder, 'v_unix.sock')
fn testsuite_begin() {
os.mkdir_all(tfolder) or {}
}
fn testsuite_end() {
os.rmdir_all(tfolder) or {}
}
fn handle_conn(mut c unix.StreamConn) {
for {
mut buf := []u8{len: 100, init: 0}
read := c.read(mut buf) or {
println('Server read: connection dropped')
return
}
c.write(buf[..read]) or {
println('Server write: connection dropped')
return
}
}
}
fn echo_server(mut l unix.StreamListener) ! {
for {
mut new_conn := l.accept() or { continue }
spawn handle_conn(mut new_conn)
}
}
fn echo() ! {
mut c := unix.connect_stream(socket_path)!
defer {
c.close() or {}
}
data := 'Hello from vlib/net!'
c.write_string(data)!
mut buf := []u8{len: 4096}
read := c.read(mut buf)!
assert read == data.len
for i := 0; i < read; i++ {
assert buf[i] == data[i]
}
println('Got "${buf.bytestr()}"')
return
}
fn test_tcp() {
assert os.exists(socket_path) == false
mut l := unix.listen_stream(socket_path) or { panic(err) }
spawn echo_server(mut l)
echo() or { panic(err) }
l.close() or {}
// test if socket file is removed/unlinked
assert os.exists(socket_path) == false
}