ed/Odin
1
0
Fork 0
mirror of https://github.com/Ed94/Odin.git synced 2026-08-05 15:18:49 +00:00
Code Issues Packages Projects Releases Wiki Activity

Add logs to flaky test

Browse Source
This commit is contained in:
Laytan Laats
2024-02-20 23:45:15 +01:00
parent bdd6a86d73
commit 9e417592e3
1 changed files with 33 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files
tests/core/net/test_core_net.odin
+33 -6
View File
@@ -375,6 +375,7 @@ client_sends_server_data :: proc(t: ^testing.T) {
RECV_TIMEOUT :: time.Duration(1 * time.Second) RECV_TIMEOUT :: time.Duration(1 * time.Second)
Thread_Data :: struct { Thread_Data :: struct {
t: ^testing.T,
skt: net.Any_Socket, skt: net.Any_Socket,
err: net.Network_Error, err: net.Network_Error,
tid: ^thread.Thread, tid: ^thread.Thread,
@@ -384,58 +385,84 @@ client_sends_server_data :: proc(t: ^testing.T) {
wg: ^sync.Wait_Group, wg: ^sync.Wait_Group,
} }
thread_data := [2]Thread_Data{}
wg: sync.Wait_Group
thread_data[0].wg = &wg
thread_data[1].wg = &wg
tcp_client :: proc(thread_data: rawptr) { tcp_client :: proc(thread_data: rawptr) {
r := transmute(^Thread_Data)thread_data r := transmute(^Thread_Data)thread_data
log(r.t, "tcp_client entry")
defer log(r.t, "tcp_client exit")
defer sync.wait_group_done(r.wg) defer sync.wait_group_done(r.wg)
log(r.t, "tcp_client dial")
if r.skt, r.err = net.dial_tcp(ENDPOINT); r.err != nil { if r.skt, r.err = net.dial_tcp(ENDPOINT); r.err != nil {
log(r.t, r.err)
return return
} }
net.set_option(r.skt, .Send_Timeout, SEND_TIMEOUT) net.set_option(r.skt, .Send_Timeout, SEND_TIMEOUT)
log(r.t, "tcp_client send")
_, r.err = net.send(r.skt, transmute([]byte)CONTENT) _, r.err = net.send(r.skt, transmute([]byte)CONTENT)
} }
tcp_server :: proc(thread_data: rawptr) { tcp_server :: proc(thread_data: rawptr) {
r := transmute(^Thread_Data)thread_data r := transmute(^Thread_Data)thread_data
log(r.t, "tcp_server entry")
defer log(r.t, "tcp_server exit")
defer sync.wait_group_done(r.wg) defer sync.wait_group_done(r.wg)
log(r.t, "tcp_server listen")
if r.skt, r.err = net.listen_tcp(ENDPOINT); r.err != nil { if r.skt, r.err = net.listen_tcp(ENDPOINT); r.err != nil {
log(r.t, r.err)
return return
} }
log(r.t, "tcp_server accept")
client: net.TCP_Socket client: net.TCP_Socket
if client, _, r.err = net.accept_tcp(r.skt.(net.TCP_Socket)); r.err != nil { if client, _, r.err = net.accept_tcp(r.skt.(net.TCP_Socket)); r.err != nil {
log(r.t, r.err)
return return
} }
defer net.close(client) defer net.close(client)
net.set_option(client, .Receive_Timeout, RECV_TIMEOUT) net.set_option(client, .Receive_Timeout, RECV_TIMEOUT)
log(r.t, "tcp_server recv")
r.length, r.err = net.recv_tcp(client, r.data[:]) r.length, r.err = net.recv_tcp(client, r.data[:])
return return
} }
thread_data := [2]Thread_Data{}
wg: sync.Wait_Group
sync.wait_group_add(&wg, 2) sync.wait_group_add(&wg, 2)
thread_data[0].t = t
thread_data[0].wg = &wg
thread_data[0].tid = thread.create_and_start_with_data(&thread_data[0], tcp_server, context) thread_data[0].tid = thread.create_and_start_with_data(&thread_data[0], tcp_server, context)
thread_data[1].t = t
thread_data[1].wg = &wg
thread_data[1].tid = thread.create_and_start_with_data(&thread_data[1], tcp_client, context) thread_data[1].tid = thread.create_and_start_with_data(&thread_data[1], tcp_client, context)
defer { defer {
log(t, "closing server socket")
net.close(thread_data[0].skt) net.close(thread_data[0].skt)
log(t, "destroying server thread")
thread.destroy(thread_data[0].tid) thread.destroy(thread_data[0].tid)
log(t, "closing client socket")
net.close(thread_data[1].skt) net.close(thread_data[1].skt)
log(t, "destroying client thread")
thread.destroy(thread_data[1].tid) thread.destroy(thread_data[1].tid)
} }
log(t, "waiting for threads to finish")
sync.wait_group_wait(&wg) sync.wait_group_wait(&wg)
log(t, "threads finished")
okay := thread_data[0].err == nil && thread_data[1].err == nil okay := thread_data[0].err == nil && thread_data[1].err == nil
msg := fmt.tprintf("Expected client and server to return `nil`, got %v and %v", thread_data[0].err, thread_data[1].err) msg := fmt.tprintf("Expected client and server to return `nil`, got %v and %v", thread_data[0].err, thread_data[1].err)