diff options
| author | Garrett D'Amore <garrett@damore.org> | 2024-11-22 18:50:54 -0800 |
|---|---|---|
| committer | Garrett D'Amore <garrett@damore.org> | 2024-11-22 18:50:54 -0800 |
| commit | 744f448347f9b3ff92cec7be1f2e53c28ed5d212 (patch) | |
| tree | 799bcf65b47a28769b4a373621619256e0f090c7 /src/sp | |
| parent | dacb9629b9161cbd09de533842bb05ee0b0cad48 (diff) | |
| download | nng-744f448347f9b3ff92cec7be1f2e53c28ed5d212.tar.gz nng-744f448347f9b3ff92cec7be1f2e53c28ed5d212.tar.bz2 nng-744f448347f9b3ff92cec7be1f2e53c28ed5d212.zip | |
Convert UDP test to use URL functions.
Diffstat (limited to 'src/sp')
| -rw-r--r-- | src/sp/transport/udp/udp_tran_test.c | 35 |
1 files changed, 23 insertions, 12 deletions
diff --git a/src/sp/transport/udp/udp_tran_test.c b/src/sp/transport/udp/udp_tran_test.c index 781c6ad9..654df1e2 100644 --- a/src/sp/transport/udp/udp_tran_test.c +++ b/src/sp/transport/udp/udp_tran_test.c @@ -58,27 +58,38 @@ test_udp_local_address_connect(void) void test_udp_port_zero_bind(void) { - nng_socket s1; - nng_socket s2; - nng_sockaddr sa; - nng_listener l; - char *addr; - int port; + nng_socket s1; + nng_socket s2; + nng_sockaddr sa; + nng_listener l; + nng_dialer d; + char addr[NNG_MAXADDRSTRLEN]; + int port; + const nng_url *u1; + const nng_url *u2; NUTS_OPEN(s1); NUTS_OPEN(s2); NUTS_PASS(nng_listen(s1, "udp://127.0.0.1:0", &l, 0)); nng_msleep(100); - NUTS_PASS(nng_listener_get_string(l, NNG_OPT_URL, &addr)); - NUTS_TRUE(memcmp(addr, "udp://", 6) == 0); + NUTS_PASS(nng_listener_get_url(l, &u1)); + NUTS_TRUE(nng_url_port(u1) != 0); + NUTS_MATCH(nng_url_scheme(u1), "udp"); + NUTS_MATCH(nng_url_hostname(u1), "127.0.0.1"); + NUTS_MATCH(nng_url_path(u1), ""); + nng_url_sprintf(addr, sizeof(addr), u1); NUTS_PASS(nng_listener_get_addr(l, NNG_OPT_LOCADDR, &sa)); NUTS_TRUE(sa.s_in.sa_family == NNG_AF_INET); - NUTS_TRUE(sa.s_in.sa_port != 0); + NUTS_TRUE(sa.s_in.sa_port == nuts_be16(nng_url_port(u1))); NUTS_TRUE(sa.s_in.sa_addr == nuts_be32(0x7f000001)); - NUTS_PASS(nng_dial(s2, addr, NULL, 0)); + NUTS_PASS(nng_dial(s2, addr, &d, 0)); + NUTS_PASS(nng_dialer_get_url(d, &u2)); + NUTS_MATCH(nng_url_scheme(u1), nng_url_scheme(u2)); + NUTS_MATCH(nng_url_hostname(u1), nng_url_hostname(u2)); + NUTS_MATCH(nng_url_path(u1), nng_url_path(u2)); + NUTS_TRUE(nng_url_port(u1) == nng_url_port(u2)); NUTS_PASS(nng_listener_get_int(l, NNG_OPT_TCP_BOUND_PORT, &port)); - NUTS_TRUE(port == nuts_be16(sa.s_in.sa_port)); - nng_strfree(addr); + NUTS_TRUE(port == (int) nng_url_port(u1)); NUTS_CLOSE(s2); NUTS_CLOSE(s1); |