diff options
| author | Laytan Laats <laytanlaats@hotmail.com> | 2024-09-17 22:22:19 +0200 |
|---|---|---|
| committer | Laytan Laats <laytanlaats@hotmail.com> | 2024-09-17 22:22:19 +0200 |
| commit | 652557bfcd64deccf018e96817a001fd9c4d69a1 (patch) | |
| tree | 0f2ba9b19523fd200dcdaaa709b4383f4118a7e6 /tests | |
| parent | 6ef779cd5c8260b2e6979e676d28489fd53dd599 (diff) | |
net: add `bound_endpoint` procedure
Diffstat (limited to 'tests')
| -rw-r--r-- | tests/core/net/test_core_net.odin | 49 |
1 files changed, 27 insertions, 22 deletions
diff --git a/tests/core/net/test_core_net.odin b/tests/core/net/test_core_net.odin index 8a9272882..2ba878080 100644 --- a/tests/core/net/test_core_net.odin +++ b/tests/core/net/test_core_net.odin @@ -217,39 +217,31 @@ IP_Address_Parsing_Test_Vectors :: []IP_Address_Parsing_Test_Vector{ { .IP6, "c0a8", "", ""}, } -ENDPOINT_TWO_SERVERS := net.Endpoint{net.IP4_Address{127, 0, 0, 1}, 9991} -ENDPOINT_CLOSED_PORT := net.Endpoint{net.IP4_Address{127, 0, 0, 1}, 9992} -ENDPOINT_SERVER_SENDS := net.Endpoint{net.IP4_Address{127, 0, 0, 1}, 9993} -ENDPOINT_UDP_ECHO := net.Endpoint{net.IP4_Address{127, 0, 0, 1}, 9994} -ENDPOINT_NONBLOCK := net.Endpoint{net.IP4_Address{127, 0, 0, 1}, 9995} - @(test) two_servers_binding_same_endpoint :: proc(t: ^testing.T) { - skt1, err1 := net.listen_tcp(ENDPOINT_TWO_SERVERS) + skt1, err1 := net.listen_tcp({address=net.IP4_Address{127, 0, 0, 1}, port=0}) defer net.close(skt1) - skt2, err2 := net.listen_tcp(ENDPOINT_TWO_SERVERS) + + ep, perr := net.bound_endpoint(skt1) + + skt2, err2 := net.listen_tcp(ep) defer net.close(skt2) testing.expect(t, err1 == nil, "expected first server binding to endpoint to do so without error") + testing.expect_value(t, perr, nil) testing.expect(t, err2 == net.Bind_Error.Address_In_Use, "expected second server to bind to an endpoint to return .Address_In_Use") } @(test) -client_connects_to_closed_port :: proc(t: ^testing.T) { - - skt, err := net.dial_tcp(ENDPOINT_CLOSED_PORT) - defer net.close(skt) - testing.expect(t, err == net.Dial_Error.Refused, "expected dial of a closed endpoint to return .Refused") -} - - -@(test) client_sends_server_data :: proc(t: ^testing.T) { CONTENT: string: "Hellope!" SEND_TIMEOUT :: time.Duration(1 * time.Second) RECV_TIMEOUT :: time.Duration(1 * time.Second) + @static endpoint: net.Endpoint + endpoint.address = net.IP4_Address{127, 0, 0, 1} + Thread_Data :: struct { t: ^testing.T, skt: net.Any_Socket, @@ -266,7 +258,7 @@ client_sends_server_data :: proc(t: ^testing.T) { defer sync.wait_group_done(r.wg) - if r.skt, r.err = net.dial_tcp(ENDPOINT_SERVER_SENDS); r.err != nil { + if r.skt, r.err = net.dial_tcp(endpoint); r.err != nil { testing.expectf(r.t, false, "[tcp_client:dial_tcp] %v", r.err) return } @@ -281,12 +273,17 @@ client_sends_server_data :: proc(t: ^testing.T) { defer sync.wait_group_done(r.wg) - if r.skt, r.err = net.listen_tcp(ENDPOINT_SERVER_SENDS); r.err != nil { + if r.skt, r.err = net.listen_tcp(endpoint); r.err != nil { sync.wait_group_done(r.wg) testing.expectf(r.t, false, "[tcp_server:listen_tcp] %v", r.err) return } + endpoint, r.err = net.bound_endpoint(r.skt.(net.TCP_Socket)) + if !testing.expect_value(r.t, r.err, nil) { + return + } + sync.wait_group_done(r.wg) client: net.TCP_Socket @@ -524,17 +521,25 @@ join_url_test :: proc(t: ^testing.T) { @test test_udp_echo :: proc(t: ^testing.T) { + endpoint := net.Endpoint{address=net.IP4_Address{127, 0, 0, 1}, port=0} + server, make_server_err := net.make_unbound_udp_socket(.IP4) if !testing.expect_value(t, make_server_err, nil) { return } defer net.close(server) - bind_server_err := net.bind(server, ENDPOINT_UDP_ECHO) + bind_server_err := net.bind(server, endpoint) if !testing.expect_value(t, bind_server_err, nil) { return } + perr: net.Network_Error + endpoint, perr = net.bound_endpoint(server) + if !testing.expect_value(t, perr, nil) { + return + } + client, make_client_err := net.make_unbound_udp_socket(.IP4) if !testing.expect_value(t, make_client_err, nil) { return @@ -544,7 +549,7 @@ test_udp_echo :: proc(t: ^testing.T) { msg := "Hellope world!" buf: [64]u8 - bytes_written, send_err := net.send_udp(client, transmute([]u8)msg[:], ENDPOINT_UDP_ECHO) + bytes_written, send_err := net.send_udp(client, transmute([]u8)msg[:], endpoint) if !testing.expect_value(t, send_err, nil) { return } @@ -600,7 +605,7 @@ test_dns_resolve :: proc(t: ^testing.T) { @test test_nonblocking_option :: proc(t: ^testing.T) { - server, listen_err := net.listen_tcp(ENDPOINT_NONBLOCK) + server, listen_err := net.listen_tcp({address=net.IP4_Address{127, 0, 0, 1}, port=0}) if !testing.expect_value(t, listen_err, nil) { return } |