From 44fadb7042fbfdf75f20572c59e410f406bb82f4 Mon Sep 17 00:00:00 2001 From: Edward Rudd Date: Wed, 29 Dec 2021 10:13:09 -0500 Subject: don't use deprecated functions in tests (#1560) --- src/sp/protocol/bus0/bus_test.c | 12 ++-- src/sp/protocol/pair0/pair0_test.c | 66 ++++++++++----------- src/sp/protocol/pair1/pair1_poly_test.c | 70 +++++++++++----------- src/sp/protocol/pair1/pair1_test.c | 102 ++++++++++++++++---------------- src/sp/protocol/pipeline0/push_test.c | 22 +++---- src/sp/protocol/reqrep0/req_test.c | 4 +- src/sp/protocol/survey0/respond_test.c | 82 ++++++++++++------------- 7 files changed, 179 insertions(+), 179 deletions(-) (limited to 'src/sp/protocol') diff --git a/src/sp/protocol/bus0/bus_test.c b/src/sp/protocol/bus0/bus_test.c index 77d2b4d6..6a214972 100644 --- a/src/sp/protocol/bus0/bus_test.c +++ b/src/sp/protocol/bus0/bus_test.c @@ -43,9 +43,9 @@ test_bus_star(void) NUTS_PASS(nng_bus0_open(&s2)); NUTS_PASS(nng_bus0_open(&s3)); - NUTS_PASS(nng_setopt_ms(s1, NNG_OPT_RECVTIMEO, SECOND)); - NUTS_PASS(nng_setopt_ms(s2, NNG_OPT_RECVTIMEO, SECOND)); - NUTS_PASS(nng_setopt_ms(s3, NNG_OPT_RECVTIMEO, SECOND)); + NUTS_PASS(nng_socket_set_ms(s1, NNG_OPT_RECVTIMEO, SECOND)); + NUTS_PASS(nng_socket_set_ms(s2, NNG_OPT_RECVTIMEO, SECOND)); + NUTS_PASS(nng_socket_set_ms(s3, NNG_OPT_RECVTIMEO, SECOND)); NUTS_MARRY(s1, s2); NUTS_MARRY(s1, s3); @@ -77,9 +77,9 @@ test_bus_device(void) NUTS_PASS(nng_bus0_open(&s3)); NUTS_PASS(nng_aio_alloc(&aio, NULL, NULL)); - NUTS_PASS(nng_setopt_ms(s1, NNG_OPT_RECVTIMEO, SECOND)); - NUTS_PASS(nng_setopt_ms(s2, NNG_OPT_RECVTIMEO, SECOND)); - NUTS_PASS(nng_setopt_ms(s3, NNG_OPT_RECVTIMEO, SECOND)); + NUTS_PASS(nng_socket_set_ms(s1, NNG_OPT_RECVTIMEO, SECOND)); + NUTS_PASS(nng_socket_set_ms(s2, NNG_OPT_RECVTIMEO, SECOND)); + NUTS_PASS(nng_socket_set_ms(s3, NNG_OPT_RECVTIMEO, SECOND)); NUTS_MARRY(s1, s2); NUTS_MARRY(s1, s3); diff --git a/src/sp/protocol/pair0/pair0_test.c b/src/sp/protocol/pair0/pair0_test.c index 20acc200..0bce1bb7 100644 --- a/src/sp/protocol/pair0/pair0_test.c +++ b/src/sp/protocol/pair0/pair0_test.c @@ -81,10 +81,10 @@ test_faithful(void) NUTS_PASS(nng_pair0_open(&s1)); NUTS_PASS(nng_pair0_open(&c1)); NUTS_PASS(nng_pair0_open(&c2)); - NUTS_PASS(nng_setopt_ms(s1, NNG_OPT_RECVTIMEO, SECOND / 4)); - NUTS_PASS(nng_setopt_ms(c1, NNG_OPT_SENDTIMEO, SECOND)); - NUTS_PASS(nng_setopt_ms(c2, NNG_OPT_SENDTIMEO, SECOND)); - NUTS_PASS(nng_setopt_int(c2, NNG_OPT_SENDBUF, 2)); + NUTS_PASS(nng_socket_set_ms(s1, NNG_OPT_RECVTIMEO, SECOND / 4)); + NUTS_PASS(nng_socket_set_ms(c1, NNG_OPT_SENDTIMEO, SECOND)); + NUTS_PASS(nng_socket_set_ms(c2, NNG_OPT_SENDTIMEO, SECOND)); + NUTS_PASS(nng_socket_set_int(c2, NNG_OPT_SENDBUF, 2)); NUTS_PASS(nng_listen(s1, addr, NULL, 0)); NUTS_MARRY(s1, c1); @@ -121,10 +121,10 @@ test_back_pressure(void) NUTS_PASS(nng_pair0_open(&s1)); NUTS_PASS(nng_pair0_open(&c1)); - NUTS_PASS(nng_setopt_int(s1, NNG_OPT_RECVBUF, 1)); - NUTS_PASS(nng_setopt_int(s1, NNG_OPT_SENDBUF, 1)); - NUTS_PASS(nng_setopt_int(c1, NNG_OPT_RECVBUF, 1)); - NUTS_PASS(nng_setopt_ms(s1, NNG_OPT_SENDTIMEO, to)); + NUTS_PASS(nng_socket_set_int(s1, NNG_OPT_RECVBUF, 1)); + NUTS_PASS(nng_socket_set_int(s1, NNG_OPT_SENDBUF, 1)); + NUTS_PASS(nng_socket_set_int(c1, NNG_OPT_RECVBUF, 1)); + NUTS_PASS(nng_socket_set_ms(s1, NNG_OPT_SENDTIMEO, to)); NUTS_MARRY(s1, c1); @@ -151,7 +151,7 @@ test_send_no_peer(void) nng_duration to = 100; NUTS_PASS(nng_pair0_open(&s1)); - NUTS_PASS(nng_setopt_ms(s1, NNG_OPT_SENDTIMEO, to)); + NUTS_PASS(nng_socket_set_ms(s1, NNG_OPT_SENDTIMEO, to)); NUTS_PASS(nng_msg_alloc(&msg, 0)); NUTS_FAIL(nng_sendmsg(s1, msg, 0), NNG_ETIMEDOUT); @@ -170,8 +170,8 @@ test_raw_exchange(void) NUTS_PASS(nng_pair0_open_raw(&s1)); NUTS_PASS(nng_pair0_open_raw(&c1)); - NUTS_PASS(nng_setopt_ms(s1, NNG_OPT_RECVTIMEO, SECOND)); - NUTS_PASS(nng_setopt_ms(c1, NNG_OPT_RECVTIMEO, SECOND)); + NUTS_PASS(nng_socket_set_ms(s1, NNG_OPT_RECVTIMEO, SECOND)); + NUTS_PASS(nng_socket_set_ms(c1, NNG_OPT_RECVTIMEO, SECOND)); NUTS_MARRY(s1, c1); nng_pipe p = NNG_PIPE_INITIALIZER; @@ -226,15 +226,15 @@ test_pair0_raw(void) bool raw; NUTS_PASS(nng_pair0_open(&s1)); - NUTS_PASS(nng_getopt_bool(s1, NNG_OPT_RAW, &raw)); + NUTS_PASS(nng_socket_get_bool(s1, NNG_OPT_RAW, &raw)); NUTS_TRUE(raw == false); - NUTS_FAIL(nng_setopt_bool(s1, NNG_OPT_RAW, true), NNG_EREADONLY); + NUTS_FAIL(nng_socket_set_bool(s1, NNG_OPT_RAW, true), NNG_EREADONLY); NUTS_PASS(nng_close(s1)); NUTS_PASS(nng_pair0_open_raw(&s1)); - NUTS_PASS(nng_getopt_bool(s1, NNG_OPT_RAW, &raw)); + NUTS_PASS(nng_socket_get_bool(s1, NNG_OPT_RAW, &raw)); NUTS_TRUE(raw == true); - NUTS_FAIL(nng_setopt_bool(s1, NNG_OPT_RAW, false), NNG_EREADONLY); + NUTS_FAIL(nng_socket_set_bool(s1, NNG_OPT_RAW, false), NNG_EREADONLY); NUTS_PASS(nng_close(s1)); } @@ -288,17 +288,17 @@ test_pair0_send_buffer(void) size_t sz; NUTS_PASS(nng_pair0_open(&s)); - NUTS_PASS(nng_getopt_int(s, NNG_OPT_SENDBUF, &v)); + NUTS_PASS(nng_socket_get_int(s, NNG_OPT_SENDBUF, &v)); NUTS_TRUE(v == 0); - NUTS_FAIL(nng_getopt_bool(s, NNG_OPT_SENDBUF, &b), NNG_EBADTYPE); + NUTS_FAIL(nng_socket_get_bool(s, NNG_OPT_SENDBUF, &b), NNG_EBADTYPE); sz = 1; - NUTS_FAIL(nng_getopt(s, NNG_OPT_SENDBUF, &b, &sz), NNG_EINVAL); - NUTS_FAIL(nng_setopt_int(s, NNG_OPT_SENDBUF, -1), NNG_EINVAL); - NUTS_FAIL(nng_setopt_int(s, NNG_OPT_SENDBUF, 100000), NNG_EINVAL); - NUTS_FAIL(nng_setopt_bool(s, NNG_OPT_SENDBUF, false), NNG_EBADTYPE); - NUTS_FAIL(nng_setopt(s, NNG_OPT_SENDBUF, &b, 1), NNG_EINVAL); - NUTS_PASS(nng_setopt_int(s, NNG_OPT_SENDBUF, 100)); - NUTS_PASS(nng_getopt_int(s, NNG_OPT_SENDBUF, &v)); + NUTS_FAIL(nng_socket_get(s, NNG_OPT_SENDBUF, &b, &sz), NNG_EINVAL); + NUTS_FAIL(nng_socket_set_int(s, NNG_OPT_SENDBUF, -1), NNG_EINVAL); + NUTS_FAIL(nng_socket_set_int(s, NNG_OPT_SENDBUF, 100000), NNG_EINVAL); + NUTS_FAIL(nng_socket_set_bool(s, NNG_OPT_SENDBUF, false), NNG_EBADTYPE); + NUTS_FAIL(nng_socket_set(s, NNG_OPT_SENDBUF, &b, 1), NNG_EINVAL); + NUTS_PASS(nng_socket_set_int(s, NNG_OPT_SENDBUF, 100)); + NUTS_PASS(nng_socket_get_int(s, NNG_OPT_SENDBUF, &v)); NUTS_TRUE(v == 100); NUTS_CLOSE(s); } @@ -312,17 +312,17 @@ test_pair0_recv_buffer(void) size_t sz; NUTS_PASS(nng_pair0_open(&s)); - NUTS_PASS(nng_getopt_int(s, NNG_OPT_RECVBUF, &v)); + NUTS_PASS(nng_socket_get_int(s, NNG_OPT_RECVBUF, &v)); NUTS_TRUE(v == 0); - NUTS_FAIL(nng_getopt_bool(s, NNG_OPT_RECVBUF, &b), NNG_EBADTYPE); + NUTS_FAIL(nng_socket_get_bool(s, NNG_OPT_RECVBUF, &b), NNG_EBADTYPE); sz = 1; - NUTS_FAIL(nng_getopt(s, NNG_OPT_RECVBUF, &b, &sz), NNG_EINVAL); - NUTS_FAIL(nng_setopt_int(s, NNG_OPT_RECVBUF, -1), NNG_EINVAL); - NUTS_FAIL(nng_setopt_int(s, NNG_OPT_RECVBUF, 100000), NNG_EINVAL); - NUTS_FAIL(nng_setopt_bool(s, NNG_OPT_RECVBUF, false), NNG_EBADTYPE); - NUTS_FAIL(nng_setopt(s, NNG_OPT_RECVBUF, &b, 1), NNG_EINVAL); - NUTS_PASS(nng_setopt_int(s, NNG_OPT_RECVBUF, 100)); - NUTS_PASS(nng_getopt_int(s, NNG_OPT_RECVBUF, &v)); + NUTS_FAIL(nng_socket_get(s, NNG_OPT_RECVBUF, &b, &sz), NNG_EINVAL); + NUTS_FAIL(nng_socket_set_int(s, NNG_OPT_RECVBUF, -1), NNG_EINVAL); + NUTS_FAIL(nng_socket_set_int(s, NNG_OPT_RECVBUF, 100000), NNG_EINVAL); + NUTS_FAIL(nng_socket_set_bool(s, NNG_OPT_RECVBUF, false), NNG_EBADTYPE); + NUTS_FAIL(nng_socket_set(s, NNG_OPT_RECVBUF, &b, 1), NNG_EINVAL); + NUTS_PASS(nng_socket_set_int(s, NNG_OPT_RECVBUF, 100)); + NUTS_PASS(nng_socket_get_int(s, NNG_OPT_RECVBUF, &v)); NUTS_TRUE(v == 100); NUTS_CLOSE(s); } diff --git a/src/sp/protocol/pair1/pair1_poly_test.c b/src/sp/protocol/pair1/pair1_poly_test.c index dd59e29c..3aabb248 100644 --- a/src/sp/protocol/pair1/pair1_poly_test.c +++ b/src/sp/protocol/pair1/pair1_poly_test.c @@ -48,10 +48,10 @@ test_poly_best_effort(void) NUTS_PASS(nng_pair1_open_poly(&s1)); NUTS_PASS(nng_pair1_open(&c1)); - NUTS_PASS(nng_setopt_int(s1, NNG_OPT_RECVBUF, 1)); - NUTS_PASS(nng_setopt_int(s1, NNG_OPT_SENDBUF, 1)); - NUTS_PASS(nng_setopt_int(c1, NNG_OPT_RECVBUF, 1)); - NUTS_PASS(nng_setopt_ms(s1, NNG_OPT_SENDTIMEO, SECOND)); + NUTS_PASS(nng_socket_set_int(s1, NNG_OPT_RECVBUF, 1)); + NUTS_PASS(nng_socket_set_int(s1, NNG_OPT_SENDBUF, 1)); + NUTS_PASS(nng_socket_set_int(c1, NNG_OPT_RECVBUF, 1)); + NUTS_PASS(nng_socket_set_ms(s1, NNG_OPT_SENDTIMEO, SECOND)); NUTS_MARRY(s1, c1); @@ -78,14 +78,14 @@ test_poly_cooked(void) NUTS_PASS(nng_pair1_open_poly(&s1)); NUTS_PASS(nng_pair1_open(&c1)); NUTS_PASS(nng_pair1_open(&c2)); - NUTS_PASS(nng_setopt_ms(s1, NNG_OPT_SENDTIMEO, SECOND)); - NUTS_PASS(nng_setopt_ms(c1, NNG_OPT_SENDTIMEO, SECOND)); - NUTS_PASS(nng_setopt_ms(c2, NNG_OPT_SENDTIMEO, SECOND)); - NUTS_PASS(nng_setopt_ms(s1, NNG_OPT_RECVTIMEO, SECOND / 10)); - NUTS_PASS(nng_setopt_ms(c1, NNG_OPT_RECVTIMEO, SECOND / 10)); - NUTS_PASS(nng_setopt_ms(c2, NNG_OPT_RECVTIMEO, SECOND / 10)); - - NUTS_PASS(nng_getopt_bool(s1, NNG_OPT_PAIR1_POLY, &v)); + NUTS_PASS(nng_socket_set_ms(s1, NNG_OPT_SENDTIMEO, SECOND)); + NUTS_PASS(nng_socket_set_ms(c1, NNG_OPT_SENDTIMEO, SECOND)); + NUTS_PASS(nng_socket_set_ms(c2, NNG_OPT_SENDTIMEO, SECOND)); + NUTS_PASS(nng_socket_set_ms(s1, NNG_OPT_RECVTIMEO, SECOND / 10)); + NUTS_PASS(nng_socket_set_ms(c1, NNG_OPT_RECVTIMEO, SECOND / 10)); + NUTS_PASS(nng_socket_set_ms(c2, NNG_OPT_RECVTIMEO, SECOND / 10)); + + NUTS_PASS(nng_socket_get_bool(s1, NNG_OPT_PAIR1_POLY, &v)); NUTS_TRUE(v); NUTS_MARRY(s1, c1); @@ -151,9 +151,9 @@ test_poly_default(void) NUTS_PASS(nng_pair1_open_poly(&s1)); NUTS_PASS(nng_pair1_open(&c1)); NUTS_PASS(nng_pair1_open(&c2)); - NUTS_PASS(nng_setopt_ms(s1, NNG_OPT_SENDTIMEO, SECOND)); - NUTS_PASS(nng_setopt_ms(c1, NNG_OPT_SENDTIMEO, SECOND)); - NUTS_PASS(nng_setopt_ms(c2, NNG_OPT_SENDTIMEO, SECOND)); + NUTS_PASS(nng_socket_set_ms(s1, NNG_OPT_SENDTIMEO, SECOND)); + NUTS_PASS(nng_socket_set_ms(c1, NNG_OPT_SENDTIMEO, SECOND)); + NUTS_PASS(nng_socket_set_ms(c2, NNG_OPT_SENDTIMEO, SECOND)); NUTS_MARRY(s1, c1); NUTS_MARRY(s1, c2); @@ -190,10 +190,10 @@ test_poly_close_abort(void) NUTS_PASS(nng_pair1_open_poly(&s)); NUTS_PASS(nng_pair1_open(&c)); - NUTS_PASS(nng_setopt_ms(s, NNG_OPT_RECVTIMEO, 100)); - NUTS_PASS(nng_setopt_ms(s, NNG_OPT_SENDTIMEO, 200)); - NUTS_PASS(nng_setopt_int(s, NNG_OPT_RECVBUF, 1)); - NUTS_PASS(nng_setopt_int(c, NNG_OPT_SENDBUF, 20)); + NUTS_PASS(nng_socket_set_ms(s, NNG_OPT_RECVTIMEO, 100)); + NUTS_PASS(nng_socket_set_ms(s, NNG_OPT_SENDTIMEO, 200)); + NUTS_PASS(nng_socket_set_int(s, NNG_OPT_RECVBUF, 1)); + NUTS_PASS(nng_socket_set_int(c, NNG_OPT_SENDBUF, 20)); NUTS_MARRY(c, s); @@ -215,9 +215,9 @@ test_poly_recv_no_header(void) NUTS_PASS(nng_pair1_open_poly(&s)); NUTS_PASS(nng_pair1_open(&c)); - NUTS_PASS(nng_setopt_bool(c, "pair1_test_inject_header", true)); - NUTS_PASS(nng_setopt_ms(s, NNG_OPT_RECVTIMEO, 100)); - NUTS_PASS(nng_setopt_ms(s, NNG_OPT_SENDTIMEO, 200)); + NUTS_PASS(nng_socket_set_bool(c, "pair1_test_inject_header", true)); + NUTS_PASS(nng_socket_set_ms(s, NNG_OPT_RECVTIMEO, 100)); + NUTS_PASS(nng_socket_set_ms(s, NNG_OPT_SENDTIMEO, 200)); NUTS_MARRY(c, s); @@ -238,9 +238,9 @@ test_poly_recv_garbage(void) NUTS_PASS(nng_pair1_open_poly(&s)); NUTS_PASS(nng_pair1_open(&c)); - NUTS_PASS(nng_setopt_bool(c, "pair1_test_inject_header", true)); - NUTS_PASS(nng_setopt_ms(s, NNG_OPT_RECVTIMEO, 100)); - NUTS_PASS(nng_setopt_ms(s, NNG_OPT_SENDTIMEO, 200)); + NUTS_PASS(nng_socket_set_bool(c, "pair1_test_inject_header", true)); + NUTS_PASS(nng_socket_set_ms(s, NNG_OPT_RECVTIMEO, 100)); + NUTS_PASS(nng_socket_set_ms(s, NNG_OPT_SENDTIMEO, 200)); NUTS_MARRY(c, s); @@ -265,21 +265,21 @@ test_poly_ttl(void) NUTS_PASS(nng_pair1_open_poly(&s1)); NUTS_PASS(nng_pair1_open_raw(&c1)); - NUTS_PASS(nng_setopt_ms(s1, NNG_OPT_RECVTIMEO, SECOND / 5)); - NUTS_PASS(nng_setopt_ms(c1, NNG_OPT_RECVTIMEO, SECOND / 5)); + NUTS_PASS(nng_socket_set_ms(s1, NNG_OPT_RECVTIMEO, SECOND / 5)); + NUTS_PASS(nng_socket_set_ms(c1, NNG_OPT_RECVTIMEO, SECOND / 5)); // cannot set insane TTLs - NUTS_FAIL(nng_setopt_int(s1, NNG_OPT_MAXTTL, 0), NNG_EINVAL); - NUTS_FAIL(nng_setopt_int(s1, NNG_OPT_MAXTTL, 1000), NNG_EINVAL); + NUTS_FAIL(nng_socket_set_int(s1, NNG_OPT_MAXTTL, 0), NNG_EINVAL); + NUTS_FAIL(nng_socket_set_int(s1, NNG_OPT_MAXTTL, 1000), NNG_EINVAL); ttl = 8; - NUTS_FAIL(nng_setopt(s1, NNG_OPT_MAXTTL, &ttl, 1), NNG_EINVAL); - NUTS_FAIL(nng_setopt_bool(s1, NNG_OPT_MAXTTL, true), NNG_EBADTYPE); + NUTS_FAIL(nng_socket_set(s1, NNG_OPT_MAXTTL, &ttl, 1), NNG_EINVAL); + NUTS_FAIL(nng_socket_set_bool(s1, NNG_OPT_MAXTTL, true), NNG_EBADTYPE); NUTS_MARRY(s1, c1); // Let's check enforcement of TTL - NUTS_PASS(nng_setopt_int(s1, NNG_OPT_MAXTTL, 4)); - NUTS_PASS(nng_getopt_int(s1, NNG_OPT_MAXTTL, &ttl)); + NUTS_PASS(nng_socket_set_int(s1, NNG_OPT_MAXTTL, 4)); + NUTS_PASS(nng_socket_get_int(s1, NNG_OPT_MAXTTL, &ttl)); NUTS_TRUE(ttl == 4); // Bad TTL bounces @@ -301,7 +301,7 @@ test_poly_ttl(void) nng_msg_free(msg); // Large TTL passes - NUTS_PASS(nng_setopt_int(s1, NNG_OPT_MAXTTL, 15)); + NUTS_PASS(nng_socket_set_int(s1, NNG_OPT_MAXTTL, 15)); NUTS_PASS(nng_msg_alloc(&msg, 0)); NUTS_PASS(nng_msg_append_u32(msg, 1234)); NUTS_PASS(nng_msg_header_append_u32(msg, 14)); @@ -314,7 +314,7 @@ test_poly_ttl(void) nng_msg_free(msg); // Max TTL fails - NUTS_PASS(nng_setopt_int(s1, NNG_OPT_MAXTTL, 15)); + NUTS_PASS(nng_socket_set_int(s1, NNG_OPT_MAXTTL, 15)); NUTS_PASS(nng_msg_alloc(&msg, 0)); NUTS_PASS(nng_msg_header_append_u32(msg, 15)); NUTS_PASS(nng_sendmsg(c1, msg, 0)); diff --git a/src/sp/protocol/pair1/pair1_test.c b/src/sp/protocol/pair1/pair1_test.c index 3185a3a4..83c96478 100644 --- a/src/sp/protocol/pair1/pair1_test.c +++ b/src/sp/protocol/pair1/pair1_test.c @@ -81,10 +81,10 @@ test_mono_faithful(void) NUTS_PASS(nng_pair1_open(&s1)); NUTS_PASS(nng_pair1_open(&c1)); NUTS_PASS(nng_pair1_open(&c2)); - NUTS_PASS(nng_setopt_ms(s1, NNG_OPT_RECVTIMEO, SECOND / 4)); - NUTS_PASS(nng_setopt_ms(c1, NNG_OPT_SENDTIMEO, SECOND)); - NUTS_PASS(nng_setopt_ms(c2, NNG_OPT_SENDTIMEO, SECOND)); - NUTS_PASS(nng_setopt_int(c2, NNG_OPT_SENDBUF, 2)); + NUTS_PASS(nng_socket_set_ms(s1, NNG_OPT_RECVTIMEO, SECOND / 4)); + NUTS_PASS(nng_socket_set_ms(c1, NNG_OPT_SENDTIMEO, SECOND)); + NUTS_PASS(nng_socket_set_ms(c2, NNG_OPT_SENDTIMEO, SECOND)); + NUTS_PASS(nng_socket_set_int(c2, NNG_OPT_SENDBUF, 2)); NUTS_PASS(nng_listen(s1, addr, NULL, 0)); NUTS_MARRY(s1, c1); @@ -121,10 +121,10 @@ test_mono_back_pressure(void) NUTS_PASS(nng_pair1_open(&s1)); NUTS_PASS(nng_pair1_open(&c1)); - NUTS_PASS(nng_setopt_int(s1, NNG_OPT_RECVBUF, 1)); - NUTS_PASS(nng_setopt_int(s1, NNG_OPT_SENDBUF, 1)); - NUTS_PASS(nng_setopt_int(c1, NNG_OPT_RECVBUF, 1)); - NUTS_PASS(nng_setopt_ms(s1, NNG_OPT_SENDTIMEO, to)); + NUTS_PASS(nng_socket_set_int(s1, NNG_OPT_RECVBUF, 1)); + NUTS_PASS(nng_socket_set_int(s1, NNG_OPT_SENDBUF, 1)); + NUTS_PASS(nng_socket_set_int(c1, NNG_OPT_RECVBUF, 1)); + NUTS_PASS(nng_socket_set_ms(s1, NNG_OPT_SENDTIMEO, to)); NUTS_MARRY(s1, c1); @@ -151,7 +151,7 @@ test_send_no_peer(void) nng_duration to = 100; NUTS_PASS(nng_pair1_open(&s1)); - NUTS_PASS(nng_setopt_ms(s1, NNG_OPT_SENDTIMEO, to)); + NUTS_PASS(nng_socket_set_ms(s1, NNG_OPT_SENDTIMEO, to)); NUTS_PASS(nng_msg_alloc(&msg, 0)); NUTS_FAIL(nng_sendmsg(s1, msg, 0), NNG_ETIMEDOUT); @@ -171,8 +171,8 @@ test_mono_raw_exchange(void) NUTS_PASS(nng_pair1_open_raw(&s1)); NUTS_PASS(nng_pair1_open_raw(&c1)); - NUTS_PASS(nng_setopt_ms(s1, NNG_OPT_RECVTIMEO, SECOND)); - NUTS_PASS(nng_setopt_ms(c1, NNG_OPT_RECVTIMEO, SECOND)); + NUTS_PASS(nng_socket_set_ms(s1, NNG_OPT_RECVTIMEO, SECOND)); + NUTS_PASS(nng_socket_set_ms(c1, NNG_OPT_RECVTIMEO, SECOND)); NUTS_MARRY(s1, c1); nng_pipe p = NNG_PIPE_INITIALIZER; @@ -220,8 +220,8 @@ test_mono_raw_header(void) NUTS_PASS(nng_pair1_open_raw(&s1)); NUTS_PASS(nng_pair1_open_raw(&c1)); - NUTS_PASS(nng_setopt_ms(s1, NNG_OPT_RECVTIMEO, SECOND / 5)); - NUTS_PASS(nng_setopt_ms(c1, NNG_OPT_RECVTIMEO, SECOND / 5)); + NUTS_PASS(nng_socket_set_ms(s1, NNG_OPT_RECVTIMEO, SECOND / 5)); + NUTS_PASS(nng_socket_set_ms(c1, NNG_OPT_RECVTIMEO, SECOND / 5)); NUTS_MARRY(s1, c1); // Missing bits in the header @@ -292,15 +292,15 @@ test_pair1_raw(void) bool raw; NUTS_PASS(nng_pair1_open(&s1)); - NUTS_PASS(nng_getopt_bool(s1, NNG_OPT_RAW, &raw)); + NUTS_PASS(nng_socket_get_bool(s1, NNG_OPT_RAW, &raw)); NUTS_TRUE(raw == false); - NUTS_FAIL(nng_setopt_bool(s1, NNG_OPT_RAW, true), NNG_EREADONLY); + NUTS_FAIL(nng_socket_set_bool(s1, NNG_OPT_RAW, true), NNG_EREADONLY); NUTS_PASS(nng_close(s1)); NUTS_PASS(nng_pair1_open_raw(&s1)); - NUTS_PASS(nng_getopt_bool(s1, NNG_OPT_RAW, &raw)); + NUTS_PASS(nng_socket_get_bool(s1, NNG_OPT_RAW, &raw)); NUTS_TRUE(raw == true); - NUTS_FAIL(nng_setopt_bool(s1, NNG_OPT_RAW, false), NNG_EREADONLY); + NUTS_FAIL(nng_socket_set_bool(s1, NNG_OPT_RAW, false), NNG_EREADONLY); NUTS_PASS(nng_close(s1)); } @@ -315,21 +315,21 @@ test_pair1_ttl(void) NUTS_PASS(nng_pair1_open_raw(&s1)); NUTS_PASS(nng_pair1_open_raw(&c1)); - NUTS_PASS(nng_setopt_ms(s1, NNG_OPT_RECVTIMEO, SECOND / 5)); - NUTS_PASS(nng_setopt_ms(c1, NNG_OPT_RECVTIMEO, SECOND / 5)); + NUTS_PASS(nng_socket_set_ms(s1, NNG_OPT_RECVTIMEO, SECOND / 5)); + NUTS_PASS(nng_socket_set_ms(c1, NNG_OPT_RECVTIMEO, SECOND / 5)); // cannot set insane TTLs - NUTS_FAIL(nng_setopt_int(s1, NNG_OPT_MAXTTL, 0), NNG_EINVAL); - NUTS_FAIL(nng_setopt_int(s1, NNG_OPT_MAXTTL, 1000), NNG_EINVAL); + NUTS_FAIL(nng_socket_set_int(s1, NNG_OPT_MAXTTL, 0), NNG_EINVAL); + NUTS_FAIL(nng_socket_set_int(s1, NNG_OPT_MAXTTL, 1000), NNG_EINVAL); ttl = 8; - NUTS_FAIL(nng_setopt(s1, NNG_OPT_MAXTTL, &ttl, 1), NNG_EINVAL); - NUTS_FAIL(nng_setopt_bool(s1, NNG_OPT_MAXTTL, true), NNG_EBADTYPE); + NUTS_FAIL(nng_socket_set(s1, NNG_OPT_MAXTTL, &ttl, 1), NNG_EINVAL); + NUTS_FAIL(nng_socket_set_bool(s1, NNG_OPT_MAXTTL, true), NNG_EBADTYPE); NUTS_MARRY(s1, c1); // Let's check enforcement of TTL - NUTS_PASS(nng_setopt_int(s1, NNG_OPT_MAXTTL, 4)); - NUTS_PASS(nng_getopt_int(s1, NNG_OPT_MAXTTL, &ttl)); + NUTS_PASS(nng_socket_set_int(s1, NNG_OPT_MAXTTL, 4)); + NUTS_PASS(nng_socket_get_int(s1, NNG_OPT_MAXTTL, &ttl)); NUTS_TRUE(ttl == 4); // Bad TTL bounces @@ -351,7 +351,7 @@ test_pair1_ttl(void) nng_msg_free(msg); // Large TTL passes - NUTS_PASS(nng_setopt_int(s1, NNG_OPT_MAXTTL, 15)); + NUTS_PASS(nng_socket_set_int(s1, NNG_OPT_MAXTTL, 15)); NUTS_PASS(nng_msg_alloc(&msg, 0)); NUTS_PASS(nng_msg_append_u32(msg, 1234)); NUTS_PASS(nng_msg_header_append_u32(msg, 14)); @@ -364,7 +364,7 @@ test_pair1_ttl(void) nng_msg_free(msg); // Max TTL fails - NUTS_PASS(nng_setopt_int(s1, NNG_OPT_MAXTTL, 15)); + NUTS_PASS(nng_socket_set_int(s1, NNG_OPT_MAXTTL, 15)); NUTS_PASS(nng_msg_alloc(&msg, 0)); NUTS_PASS(nng_msg_header_append_u32(msg, 15)); NUTS_PASS(nng_sendmsg(c1, msg, 0)); @@ -413,9 +413,9 @@ test_pair1_recv_no_header(void) NUTS_PASS(nng_pair1_open(&s)); NUTS_PASS(nng_pair1_open(&c)); - NUTS_PASS(nng_setopt_bool(c, "pair1_test_inject_header", true)); - NUTS_PASS(nng_setopt_ms(s, NNG_OPT_RECVTIMEO, 100)); - NUTS_PASS(nng_setopt_ms(s, NNG_OPT_SENDTIMEO, 200)); + NUTS_PASS(nng_socket_set_bool(c, "pair1_test_inject_header", true)); + NUTS_PASS(nng_socket_set_ms(s, NNG_OPT_RECVTIMEO, 100)); + NUTS_PASS(nng_socket_set_ms(s, NNG_OPT_SENDTIMEO, 200)); NUTS_MARRY(c, s); @@ -436,9 +436,9 @@ test_pair1_recv_garbage(void) NUTS_PASS(nng_pair1_open(&s)); NUTS_PASS(nng_pair1_open(&c)); - NUTS_PASS(nng_setopt_bool(c, "pair1_test_inject_header", true)); - NUTS_PASS(nng_setopt_ms(s, NNG_OPT_RECVTIMEO, 100)); - NUTS_PASS(nng_setopt_ms(s, NNG_OPT_SENDTIMEO, 200)); + NUTS_PASS(nng_socket_set_bool(c, "pair1_test_inject_header", true)); + NUTS_PASS(nng_socket_set_ms(s, NNG_OPT_RECVTIMEO, 100)); + NUTS_PASS(nng_socket_set_ms(s, NNG_OPT_SENDTIMEO, 200)); NUTS_MARRY(c, s); @@ -472,17 +472,17 @@ test_pair1_send_buffer(void) size_t sz; NUTS_PASS(nng_pair1_open(&s)); - NUTS_PASS(nng_getopt_int(s, NNG_OPT_SENDBUF, &v)); + NUTS_PASS(nng_socket_get_int(s, NNG_OPT_SENDBUF, &v)); NUTS_TRUE(v == 0); - NUTS_FAIL(nng_getopt_bool(s, NNG_OPT_SENDBUF, &b), NNG_EBADTYPE); + NUTS_FAIL(nng_socket_get_bool(s, NNG_OPT_SENDBUF, &b), NNG_EBADTYPE); sz = 1; - NUTS_FAIL(nng_getopt(s, NNG_OPT_SENDBUF, &b, &sz), NNG_EINVAL); - NUTS_FAIL(nng_setopt_int(s, NNG_OPT_SENDBUF, -1), NNG_EINVAL); - NUTS_FAIL(nng_setopt_int(s, NNG_OPT_SENDBUF, 100000), NNG_EINVAL); - NUTS_FAIL(nng_setopt_bool(s, NNG_OPT_SENDBUF, false), NNG_EBADTYPE); - NUTS_FAIL(nng_setopt(s, NNG_OPT_SENDBUF, &b, 1), NNG_EINVAL); - NUTS_PASS(nng_setopt_int(s, NNG_OPT_SENDBUF, 100)); - NUTS_PASS(nng_getopt_int(s, NNG_OPT_SENDBUF, &v)); + NUTS_FAIL(nng_socket_get(s, NNG_OPT_SENDBUF, &b, &sz), NNG_EINVAL); + NUTS_FAIL(nng_socket_set_int(s, NNG_OPT_SENDBUF, -1), NNG_EINVAL); + NUTS_FAIL(nng_socket_set_int(s, NNG_OPT_SENDBUF, 100000), NNG_EINVAL); + NUTS_FAIL(nng_socket_set_bool(s, NNG_OPT_SENDBUF, false), NNG_EBADTYPE); + NUTS_FAIL(nng_socket_set(s, NNG_OPT_SENDBUF, &b, 1), NNG_EINVAL); + NUTS_PASS(nng_socket_set_int(s, NNG_OPT_SENDBUF, 100)); + NUTS_PASS(nng_socket_get_int(s, NNG_OPT_SENDBUF, &v)); NUTS_TRUE(v == 100); NUTS_CLOSE(s); } @@ -496,17 +496,17 @@ test_pair1_recv_buffer(void) size_t sz; NUTS_PASS(nng_pair1_open(&s)); - NUTS_PASS(nng_getopt_int(s, NNG_OPT_RECVBUF, &v)); + NUTS_PASS(nng_socket_get_int(s, NNG_OPT_RECVBUF, &v)); NUTS_TRUE(v == 0); - NUTS_FAIL(nng_getopt_bool(s, NNG_OPT_RECVBUF, &b), NNG_EBADTYPE); + NUTS_FAIL(nng_socket_get_bool(s, NNG_OPT_RECVBUF, &b), NNG_EBADTYPE); sz = 1; - NUTS_FAIL(nng_getopt(s, NNG_OPT_RECVBUF, &b, &sz), NNG_EINVAL); - NUTS_FAIL(nng_setopt_int(s, NNG_OPT_RECVBUF, -1), NNG_EINVAL); - NUTS_FAIL(nng_setopt_int(s, NNG_OPT_RECVBUF, 100000), NNG_EINVAL); - NUTS_FAIL(nng_setopt_bool(s, NNG_OPT_RECVBUF, false), NNG_EBADTYPE); - NUTS_FAIL(nng_setopt(s, NNG_OPT_RECVBUF, &b, 1), NNG_EINVAL); - NUTS_PASS(nng_setopt_int(s, NNG_OPT_RECVBUF, 100)); - NUTS_PASS(nng_getopt_int(s, NNG_OPT_RECVBUF, &v)); + NUTS_FAIL(nng_socket_get(s, NNG_OPT_RECVBUF, &b, &sz), NNG_EINVAL); + NUTS_FAIL(nng_socket_set_int(s, NNG_OPT_RECVBUF, -1), NNG_EINVAL); + NUTS_FAIL(nng_socket_set_int(s, NNG_OPT_RECVBUF, 100000), NNG_EINVAL); + NUTS_FAIL(nng_socket_set_bool(s, NNG_OPT_RECVBUF, false), NNG_EBADTYPE); + NUTS_FAIL(nng_socket_set(s, NNG_OPT_RECVBUF, &b, 1), NNG_EINVAL); + NUTS_PASS(nng_socket_set_int(s, NNG_OPT_RECVBUF, 100)); + NUTS_PASS(nng_socket_get_int(s, NNG_OPT_RECVBUF, &v)); NUTS_TRUE(v == 100); NUTS_CLOSE(s); } diff --git a/src/sp/protocol/pipeline0/push_test.c b/src/sp/protocol/pipeline0/push_test.c index d22ccaa4..9bdd9635 100644 --- a/src/sp/protocol/pipeline0/push_test.c +++ b/src/sp/protocol/pipeline0/push_test.c @@ -387,7 +387,7 @@ test_push_send_late_buffered(void) NUTS_PASS(nng_push0_open(&s)); NUTS_PASS(nng_pull0_open(&pull)); NUTS_PASS(nng_aio_alloc(&aio, NULL, NULL)); - NUTS_PASS(nng_setopt_int(s, NNG_OPT_SENDBUF, 2)); + NUTS_PASS(nng_socket_set_int(s, NNG_OPT_SENDBUF, 2)); NUTS_PASS(nng_msg_alloc(&m, 0)); NUTS_PASS(nng_msg_append(m, "123\0", 4)); @@ -429,7 +429,7 @@ test_push_load_balance_buffered(void) NUTS_PASS(nng_pull0_open(&pull1)); NUTS_PASS(nng_pull0_open(&pull2)); NUTS_PASS(nng_pull0_open(&pull3)); - NUTS_PASS(nng_setopt_int(s, NNG_OPT_SENDBUF, 4)); + NUTS_PASS(nng_socket_set_int(s, NNG_OPT_SENDBUF, 4)); NUTS_MARRY(s, pull1); NUTS_MARRY(s, pull2); NUTS_MARRY(s, pull3); @@ -486,17 +486,17 @@ test_push_send_buffer(void) size_t sz; NUTS_PASS(nng_push0_open(&s)); - NUTS_PASS(nng_getopt_int(s, NNG_OPT_SENDBUF, &v)); + NUTS_PASS(nng_socket_get_int(s, NNG_OPT_SENDBUF, &v)); NUTS_TRUE(v == 0); - NUTS_FAIL(nng_getopt_bool(s, NNG_OPT_SENDBUF, &b), NNG_EBADTYPE); + NUTS_FAIL(nng_socket_get_bool(s, NNG_OPT_SENDBUF, &b), NNG_EBADTYPE); sz = 1; - NUTS_FAIL(nng_getopt(s, NNG_OPT_SENDBUF, &b, &sz), NNG_EINVAL); - NUTS_FAIL(nng_setopt_int(s, NNG_OPT_SENDBUF, -1), NNG_EINVAL); - NUTS_FAIL(nng_setopt_int(s, NNG_OPT_SENDBUF, 100000), NNG_EINVAL); - NUTS_FAIL(nng_setopt_bool(s, NNG_OPT_SENDBUF, false), NNG_EBADTYPE); - NUTS_FAIL(nng_setopt(s, NNG_OPT_SENDBUF, &b, 1), NNG_EINVAL); - NUTS_PASS(nng_setopt_int(s, NNG_OPT_SENDBUF, 100)); - NUTS_PASS(nng_getopt_int(s, NNG_OPT_SENDBUF, &v)); + NUTS_FAIL(nng_socket_get(s, NNG_OPT_SENDBUF, &b, &sz), NNG_EINVAL); + NUTS_FAIL(nng_socket_set_int(s, NNG_OPT_SENDBUF, -1), NNG_EINVAL); + NUTS_FAIL(nng_socket_set_int(s, NNG_OPT_SENDBUF, 100000), NNG_EINVAL); + NUTS_FAIL(nng_socket_set_bool(s, NNG_OPT_SENDBUF, false), NNG_EBADTYPE); + NUTS_FAIL(nng_socket_set(s, NNG_OPT_SENDBUF, &b, 1), NNG_EINVAL); + NUTS_PASS(nng_socket_set_int(s, NNG_OPT_SENDBUF, 100)); + NUTS_PASS(nng_socket_get_int(s, NNG_OPT_SENDBUF, &v)); NUTS_TRUE(v == 100); NUTS_CLOSE(s); } diff --git a/src/sp/protocol/reqrep0/req_test.c b/src/sp/protocol/reqrep0/req_test.c index fb78efa0..347ba61e 100644 --- a/src/sp/protocol/reqrep0/req_test.c +++ b/src/sp/protocol/reqrep0/req_test.c @@ -669,8 +669,8 @@ test_req_ctx_no_poll(void) NUTS_PASS(nng_req0_open(&req)); NUTS_PASS(nng_ctx_open(&ctx, req)); - NUTS_FAIL(nng_ctx_getopt_int(ctx, NNG_OPT_SENDFD, &fd), NNG_ENOTSUP); - NUTS_FAIL(nng_ctx_getopt_int(ctx, NNG_OPT_RECVFD, &fd), NNG_ENOTSUP); + NUTS_FAIL(nng_ctx_get_int(ctx, NNG_OPT_SENDFD, &fd), NNG_ENOTSUP); + NUTS_FAIL(nng_ctx_get_int(ctx, NNG_OPT_RECVFD, &fd), NNG_ENOTSUP); NUTS_PASS(nng_ctx_close(ctx)); NUTS_CLOSE(req); } diff --git a/src/sp/protocol/survey0/respond_test.c b/src/sp/protocol/survey0/respond_test.c index 51844c76..15762f05 100644 --- a/src/sp/protocol/survey0/respond_test.c +++ b/src/sp/protocol/survey0/respond_test.c @@ -196,9 +196,9 @@ test_resp_close_pipe_before_send(void) NUTS_PASS(nng_respondent0_open(&resp)); NUTS_PASS(nng_surveyor0_open(&surv)); - NUTS_PASS(nng_setopt_ms(resp, NNG_OPT_RECVTIMEO, 1000)); - NUTS_PASS(nng_setopt_ms(resp, NNG_OPT_SENDTIMEO, 1000)); - NUTS_PASS(nng_setopt_ms(surv, NNG_OPT_SENDTIMEO, 1000)); + NUTS_PASS(nng_socket_set_ms(resp, NNG_OPT_RECVTIMEO, 1000)); + NUTS_PASS(nng_socket_set_ms(resp, NNG_OPT_SENDTIMEO, 1000)); + NUTS_PASS(nng_socket_set_ms(surv, NNG_OPT_SENDTIMEO, 1000)); NUTS_PASS(nng_aio_alloc(&aio1, NULL, NULL)); NUTS_MARRY(surv, resp); @@ -227,13 +227,13 @@ test_resp_close_pipe_during_send(void) NUTS_PASS(nng_respondent0_open(&resp)); NUTS_PASS(nng_surveyor0_open_raw(&surv)); - NUTS_PASS(nng_setopt_ms(resp, NNG_OPT_RECVTIMEO, 1000)); - NUTS_PASS(nng_setopt_ms(resp, NNG_OPT_SENDTIMEO, 200)); - NUTS_PASS(nng_setopt_ms(surv, NNG_OPT_SENDTIMEO, 1000)); - NUTS_PASS(nng_setopt_int(resp, NNG_OPT_SENDBUF, 20)); - NUTS_PASS(nng_setopt_int(resp, NNG_OPT_RECVBUF, 20)); - NUTS_PASS(nng_setopt_int(surv, NNG_OPT_SENDBUF, 20)); - NUTS_PASS(nng_setopt_int(surv, NNG_OPT_RECVBUF, 1)); + NUTS_PASS(nng_socket_set_ms(resp, NNG_OPT_RECVTIMEO, 1000)); + NUTS_PASS(nng_socket_set_ms(resp, NNG_OPT_SENDTIMEO, 200)); + NUTS_PASS(nng_socket_set_ms(surv, NNG_OPT_SENDTIMEO, 1000)); + NUTS_PASS(nng_socket_set_int(resp, NNG_OPT_SENDBUF, 20)); + NUTS_PASS(nng_socket_set_int(resp, NNG_OPT_RECVBUF, 20)); + NUTS_PASS(nng_socket_set_int(surv, NNG_OPT_SENDBUF, 20)); + NUTS_PASS(nng_socket_set_int(surv, NNG_OPT_RECVBUF, 1)); NUTS_MARRY(surv, resp); @@ -291,13 +291,13 @@ test_resp_close_pipe_context_send(void) NUTS_PASS(nng_respondent0_open(&resp)); NUTS_PASS(nng_surveyor0_open_raw(&surv)); - NUTS_PASS(nng_setopt_ms(resp, NNG_OPT_RECVTIMEO, 1000)); - NUTS_PASS(nng_setopt_ms(resp, NNG_OPT_SENDTIMEO, 1000)); - NUTS_PASS(nng_setopt_ms(surv, NNG_OPT_SENDTIMEO, 1000)); - NUTS_PASS(nng_setopt_int(resp, NNG_OPT_SENDBUF, 1)); - NUTS_PASS(nng_setopt_int(resp, NNG_OPT_RECVBUF, 1)); - NUTS_PASS(nng_setopt_int(surv, NNG_OPT_SENDBUF, 1)); - NUTS_PASS(nng_setopt_int(surv, NNG_OPT_RECVBUF, 1)); + NUTS_PASS(nng_socket_set_ms(resp, NNG_OPT_RECVTIMEO, 1000)); + NUTS_PASS(nng_socket_set_ms(resp, NNG_OPT_SENDTIMEO, 1000)); + NUTS_PASS(nng_socket_set_ms(surv, NNG_OPT_SENDTIMEO, 1000)); + NUTS_PASS(nng_socket_set_int(resp, NNG_OPT_SENDBUF, 1)); + NUTS_PASS(nng_socket_set_int(resp, NNG_OPT_RECVBUF, 1)); + NUTS_PASS(nng_socket_set_int(surv, NNG_OPT_SENDBUF, 1)); + NUTS_PASS(nng_socket_set_int(surv, NNG_OPT_RECVBUF, 1)); for (i = 0; i < 10; i++) { NUTS_PASS(nng_ctx_open(&ctx[i], resp)); NUTS_PASS(nng_aio_alloc(&aio[i], NULL, NULL)); @@ -350,13 +350,13 @@ test_resp_close_context_send(void) NUTS_PASS(nng_respondent0_open(&resp)); NUTS_PASS(nng_surveyor0_open_raw(&surv)); - NUTS_PASS(nng_setopt_ms(resp, NNG_OPT_RECVTIMEO, 1000)); - NUTS_PASS(nng_setopt_ms(resp, NNG_OPT_SENDTIMEO, 1000)); - NUTS_PASS(nng_setopt_ms(surv, NNG_OPT_SENDTIMEO, 1000)); - NUTS_PASS(nng_setopt_int(resp, NNG_OPT_SENDBUF, 1)); - NUTS_PASS(nng_setopt_int(resp, NNG_OPT_RECVBUF, 1)); - NUTS_PASS(nng_setopt_int(surv, NNG_OPT_SENDBUF, 1)); - NUTS_PASS(nng_setopt_int(surv, NNG_OPT_RECVBUF, 1)); + NUTS_PASS(nng_socket_set_ms(resp, NNG_OPT_RECVTIMEO, 1000)); + NUTS_PASS(nng_socket_set_ms(resp, NNG_OPT_SENDTIMEO, 1000)); + NUTS_PASS(nng_socket_set_ms(surv, NNG_OPT_SENDTIMEO, 1000)); + NUTS_PASS(nng_socket_set_int(resp, NNG_OPT_SENDBUF, 1)); + NUTS_PASS(nng_socket_set_int(resp, NNG_OPT_RECVBUF, 1)); + NUTS_PASS(nng_socket_set_int(surv, NNG_OPT_SENDBUF, 1)); + NUTS_PASS(nng_socket_set_int(surv, NNG_OPT_RECVBUF, 1)); for (i = 0; i < 10; i++) { NUTS_PASS(nng_ctx_open(&ctx[i], resp)); NUTS_PASS(nng_aio_alloc(&aio[i], NULL, NULL)); @@ -425,9 +425,9 @@ test_resp_ctx_send_nonblock(void) NUTS_PASS(nng_surveyor0_open(&surv)); NUTS_PASS(nng_respondent0_open(&resp)); - NUTS_PASS(nng_setopt_ms(surv, NNG_OPT_SENDTIMEO, 1000)); - NUTS_PASS(nng_setopt_ms(resp, NNG_OPT_RECVTIMEO, 1000)); - NUTS_PASS(nng_setopt_ms(resp, NNG_OPT_SENDTIMEO, 1000)); + NUTS_PASS(nng_socket_set_ms(surv, NNG_OPT_SENDTIMEO, 1000)); + NUTS_PASS(nng_socket_set_ms(resp, NNG_OPT_RECVTIMEO, 1000)); + NUTS_PASS(nng_socket_set_ms(resp, NNG_OPT_SENDTIMEO, 1000)); NUTS_PASS(nng_ctx_open(&ctx, resp)); NUTS_PASS(nng_aio_alloc(&aio, NULL, NULL)); NUTS_MARRY(surv, resp); @@ -459,9 +459,9 @@ test_resp_recv_garbage(void) NUTS_PASS(nng_respondent0_open(&resp)); NUTS_PASS(nng_surveyor0_open_raw(&surv)); - NUTS_PASS(nng_setopt_ms(resp, NNG_OPT_RECVTIMEO, 200)); - NUTS_PASS(nng_setopt_ms(resp, NNG_OPT_SENDTIMEO, 200)); - NUTS_PASS(nng_setopt_ms(surv, NNG_OPT_SENDTIMEO, 1000)); + NUTS_PASS(nng_socket_set_ms(resp, NNG_OPT_RECVTIMEO, 200)); + NUTS_PASS(nng_socket_set_ms(resp, NNG_OPT_SENDTIMEO, 200)); + NUTS_PASS(nng_socket_set_ms(surv, NNG_OPT_SENDTIMEO, 1000)); NUTS_MARRY(surv, resp); @@ -485,12 +485,12 @@ test_resp_ttl_option(void) NUTS_PASS(nng_respondent0_open(&resp)); - NUTS_PASS(nng_setopt_int(resp, opt, 1)); - NUTS_FAIL(nng_setopt_int(resp, opt, 0), NNG_EINVAL); - NUTS_FAIL(nng_setopt_int(resp, opt, -1), NNG_EINVAL); - NUTS_FAIL(nng_setopt_int(resp, opt, 16), NNG_EINVAL); - NUTS_FAIL(nng_setopt_int(resp, opt, 256), NNG_EINVAL); - NUTS_PASS(nng_setopt_int(resp, opt, 3)); + NUTS_PASS(nng_socket_set_int(resp, opt, 1)); + NUTS_FAIL(nng_socket_set_int(resp, opt, 0), NNG_EINVAL); + NUTS_FAIL(nng_socket_set_int(resp, opt, -1), NNG_EINVAL); + NUTS_FAIL(nng_socket_set_int(resp, opt, 16), NNG_EINVAL); + NUTS_FAIL(nng_socket_set_int(resp, opt, 256), NNG_EINVAL); + NUTS_PASS(nng_socket_set_int(resp, opt, 3)); NUTS_PASS(nng_socket_get_int(resp, opt, &v)); NUTS_TRUE(v == 3); v = 0; @@ -499,10 +499,10 @@ test_resp_ttl_option(void) NUTS_TRUE(v == 3); NUTS_TRUE(sz == sizeof(v)); - NUTS_FAIL(nng_setopt(resp, opt, "", 1), NNG_EINVAL); + NUTS_FAIL(nng_socket_set(resp, opt, "", 1), NNG_EINVAL); sz = 1; NUTS_FAIL(nng_socket_get(resp, opt, &v, &sz), NNG_EINVAL); - NUTS_FAIL(nng_setopt_bool(resp, opt, true), NNG_EBADTYPE); + NUTS_FAIL(nng_socket_set_bool(resp, opt, true), NNG_EBADTYPE); NUTS_FAIL(nng_socket_get_bool(resp, opt, &b), NNG_EBADTYPE); NUTS_CLOSE(resp); @@ -517,9 +517,9 @@ test_resp_ttl_drop(void) NUTS_PASS(nng_respondent0_open(&resp)); NUTS_PASS(nng_surveyor0_open_raw(&surv)); - NUTS_PASS(nng_setopt_int(resp, NNG_OPT_MAXTTL, 3)); - NUTS_PASS(nng_setopt_ms(resp, NNG_OPT_RECVTIMEO, 200)); - NUTS_PASS(nng_setopt_ms(surv, NNG_OPT_SENDTIMEO, 1000)); + NUTS_PASS(nng_socket_set_int(resp, NNG_OPT_MAXTTL, 3)); + NUTS_PASS(nng_socket_set_ms(resp, NNG_OPT_RECVTIMEO, 200)); + NUTS_PASS(nng_socket_set_ms(surv, NNG_OPT_SENDTIMEO, 1000)); NUTS_MARRY(surv, resp); -- cgit v1.2.3-70-g09d2