From 57e736b5be2052484eec44889586bd89a2724c71 Mon Sep 17 00:00:00 2001 From: Garrett D'Amore Date: Fri, 3 Jan 2025 12:46:33 -0800 Subject: api: rename nng_send_aio and nng_recv_aio to nng_socket_send and nng_socket_recv This aligns more closely with the nng_ctx functions. --- src/sp/protocol/bus0/bus_test.c | 10 +++++----- src/sp/protocol/pair0/pair0_test.c | 8 ++++---- src/sp/protocol/pair1/pair1_test.c | 12 ++++++------ src/sp/protocol/pipeline0/pull_test.c | 10 +++++----- src/sp/protocol/pipeline0/push_test.c | 14 +++++++------- src/sp/protocol/pubsub0/sub_test.c | 2 +- src/sp/protocol/pubsub0/xsub_test.c | 12 ++++++------ src/sp/protocol/reqrep0/rep_test.c | 18 +++++++++--------- src/sp/protocol/reqrep0/req_test.c | 6 +++--- src/sp/protocol/reqrep0/reqstress_test.c | 16 ++++++++-------- src/sp/protocol/reqrep0/xrep_test.c | 6 +++--- src/sp/protocol/reqrep0/xreq_test.c | 4 ++-- src/sp/protocol/survey0/respond_test.c | 6 +++--- src/sp/protocol/survey0/survey_test.c | 2 +- src/sp/protocol/survey0/xrespond_test.c | 6 +++--- src/sp/protocol/survey0/xsurvey_test.c | 2 +- 16 files changed, 67 insertions(+), 67 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 55231770..d8b71c63 100644 --- a/src/sp/protocol/bus0/bus_test.c +++ b/src/sp/protocol/bus0/bus_test.c @@ -153,7 +153,7 @@ test_bus_recv_cancel(void) NUTS_PASS(nng_aio_alloc(&aio, NULL, NULL)); nng_aio_set_timeout(aio, SECOND); - nng_recv_aio(s1, aio); + nng_socket_recv(s1, aio); nng_aio_abort(aio, NNG_ECANCELED); nng_aio_wait(aio); @@ -172,7 +172,7 @@ test_bus_close_recv_abort(void) NUTS_PASS(nng_aio_alloc(&aio, NULL, NULL)); nng_aio_set_timeout(aio, SECOND); - nng_recv_aio(s1, aio); + nng_socket_recv(s1, aio); NUTS_CLOSE(s1); nng_aio_wait(aio); @@ -195,12 +195,12 @@ test_bus_aio_stopped(void) nng_aio_stop(aio1); nng_aio_stop(aio2); - nng_recv_aio(s1, aio1); + nng_socket_recv(s1, aio1); nng_aio_wait(aio1); NUTS_FAIL(nng_aio_result(aio1), NNG_ESTOPPED); nng_aio_set_msg(aio2, msg); - nng_send_aio(s1, aio2); + nng_socket_send(s1, aio2); nng_aio_wait(aio2); NUTS_FAIL(nng_aio_result(aio2), NNG_ESTOPPED); @@ -221,7 +221,7 @@ test_bus_aio_canceled(void) NUTS_PASS(nng_msg_alloc(&msg, 0)); NUTS_PASS(nng_aio_alloc(&aio, NULL, NULL)); - nng_recv_aio(s1, aio); + nng_socket_recv(s1, aio); nng_aio_cancel(aio); nng_aio_wait(aio); NUTS_FAIL(nng_aio_result(aio), NNG_ECANCELED); diff --git a/src/sp/protocol/pair0/pair0_test.c b/src/sp/protocol/pair0/pair0_test.c index dc3264be..6a530e99 100644 --- a/src/sp/protocol/pair0/pair0_test.c +++ b/src/sp/protocol/pair0/pair0_test.c @@ -210,7 +210,7 @@ test_pair0_send_stopped_aio(void) NUTS_PASS(nng_pair0_open(&s1)); nng_aio_set_msg(aio, msg); nng_aio_stop(aio); - nng_send_aio(s1, aio); + nng_socket_send(s1, aio); nng_aio_wait(aio); NUTS_FAIL(nng_aio_result(aio), NNG_ESTOPPED); nng_msg_free(msg); @@ -229,7 +229,7 @@ test_pair0_send_canceled_aio(void) NUTS_PASS(nng_msg_alloc(&msg, 0)); NUTS_PASS(nng_pair0_open(&s1)); nng_aio_set_msg(aio, msg); - nng_send_aio(s1, aio); + nng_socket_send(s1, aio); nng_aio_cancel(aio); nng_aio_wait(aio); NUTS_FAIL(nng_aio_result(aio), NNG_ECANCELED); @@ -247,7 +247,7 @@ test_pair0_recv_stopped_aio(void) NUTS_PASS(nng_aio_alloc(&aio, NULL, NULL)); NUTS_PASS(nng_pair0_open(&s1)); nng_aio_stop(aio); - nng_recv_aio(s1, aio); + nng_socket_recv(s1, aio); nng_aio_wait(aio); NUTS_FAIL(nng_aio_result(aio), NNG_ESTOPPED); nng_aio_free(aio); @@ -262,7 +262,7 @@ test_pair0_recv_canceled_aio(void) NUTS_PASS(nng_aio_alloc(&aio, NULL, NULL)); NUTS_PASS(nng_pair0_open(&s1)); - nng_recv_aio(s1, aio); + nng_socket_recv(s1, aio); nng_aio_cancel(aio); nng_aio_wait(aio); NUTS_FAIL(nng_aio_result(aio), NNG_ECANCELED); diff --git a/src/sp/protocol/pair1/pair1_test.c b/src/sp/protocol/pair1/pair1_test.c index 8ed6ccbf..8baf139b 100644 --- a/src/sp/protocol/pair1/pair1_test.c +++ b/src/sp/protocol/pair1/pair1_test.c @@ -1,5 +1,5 @@ // -// Copyright 2024 Staysail Systems, Inc. +// Copyright 2025 Staysail Systems, Inc. // Copyright 2017 Capitar IT Group BV // // This software is supplied under the terms of the MIT License, a @@ -9,7 +9,7 @@ // #include "nng/nng.h" -#include +#include "nuts.h" #define SECOND 1000 @@ -276,7 +276,7 @@ test_pair1_send_stopped_aio(void) NUTS_PASS(nng_pair1_open(&s1)); nng_aio_set_msg(aio, msg); nng_aio_stop(aio); - nng_send_aio(s1, aio); + nng_socket_send(s1, aio); nng_aio_wait(aio); NUTS_FAIL(nng_aio_result(aio), NNG_ESTOPPED); nng_msg_free(msg); @@ -295,7 +295,7 @@ test_pair1_send_canceled_aio(void) NUTS_PASS(nng_msg_alloc(&msg, 0)); NUTS_PASS(nng_pair1_open(&s1)); nng_aio_set_msg(aio, msg); - nng_send_aio(s1, aio); + nng_socket_send(s1, aio); nng_aio_cancel(aio); nng_aio_wait(aio); NUTS_FAIL(nng_aio_result(aio), NNG_ECANCELED); @@ -313,7 +313,7 @@ test_pair1_recv_stopped_aio(void) NUTS_PASS(nng_aio_alloc(&aio, NULL, NULL)); NUTS_PASS(nng_pair1_open(&s1)); nng_aio_stop(aio); - nng_recv_aio(s1, aio); + nng_socket_recv(s1, aio); nng_aio_wait(aio); NUTS_FAIL(nng_aio_result(aio), NNG_ESTOPPED); nng_aio_free(aio); @@ -328,7 +328,7 @@ test_pair1_recv_canceled_aio(void) NUTS_PASS(nng_aio_alloc(&aio, NULL, NULL)); NUTS_PASS(nng_pair1_open(&s1)); - nng_recv_aio(s1, aio); + nng_socket_recv(s1, aio); nng_aio_cancel(aio); nng_aio_wait(aio); NUTS_FAIL(nng_aio_result(aio), NNG_ECANCELED); diff --git a/src/sp/protocol/pipeline0/pull_test.c b/src/sp/protocol/pipeline0/pull_test.c index 131ff92c..8ed9cc0e 100644 --- a/src/sp/protocol/pipeline0/pull_test.c +++ b/src/sp/protocol/pipeline0/pull_test.c @@ -173,7 +173,7 @@ test_pull_recv_aio_stopped(void) NUTS_PASS(nng_aio_alloc(&aio, NULL, NULL)); nng_aio_stop(aio); - nng_recv_aio(s, aio); + nng_socket_recv(s, aio); nng_aio_wait(aio); NUTS_FAIL(nng_aio_result(aio), NNG_ESTOPPED); NUTS_CLOSE(s); @@ -189,7 +189,7 @@ test_pull_recv_aio_canceled(void) NUTS_PASS(nng_pull0_open(&s)); NUTS_PASS(nng_aio_alloc(&aio, NULL, NULL)); - nng_recv_aio(s, aio); + nng_socket_recv(s, aio); nng_aio_cancel(aio); nng_aio_wait(aio); NUTS_FAIL(nng_aio_result(aio), NNG_ECANCELED); @@ -206,7 +206,7 @@ test_pull_close_recv(void) NUTS_PASS(nng_pull0_open(&s)); NUTS_PASS(nng_aio_alloc(&aio, NULL, NULL)); nng_aio_set_timeout(aio, 1000); - nng_recv_aio(s, aio); + nng_socket_recv(s, aio); NUTS_CLOSE(s); nng_aio_wait(aio); NUTS_FAIL(nng_aio_result(aio), NNG_ECLOSED); @@ -224,7 +224,7 @@ test_pull_recv_nonblock(void) NUTS_PASS(nng_aio_alloc(&aio, NULL, NULL)); nng_aio_set_timeout(aio, 0); // Instant timeout - nng_recv_aio(s, aio); + nng_socket_recv(s, aio); nng_aio_wait(aio); NUTS_FAIL(nng_aio_result(aio), NNG_ETIMEDOUT); @@ -242,7 +242,7 @@ test_pull_recv_abort(void) NUTS_PASS(nng_aio_alloc(&aio, NULL, NULL)); nng_aio_set_timeout(aio, 1000); - nng_recv_aio(s, aio); + nng_socket_recv(s, aio); nng_aio_abort(aio, NNG_EAMBIGUOUS); nng_aio_wait(aio); diff --git a/src/sp/protocol/pipeline0/push_test.c b/src/sp/protocol/pipeline0/push_test.c index 579178b5..c2a99fb5 100644 --- a/src/sp/protocol/pipeline0/push_test.c +++ b/src/sp/protocol/pipeline0/push_test.c @@ -250,7 +250,7 @@ test_push_send_aio_stopped(void) nng_aio_set_msg(aio, m); nng_aio_stop(aio); - nng_send_aio(s, aio); + nng_socket_send(s, aio); nng_aio_wait(aio); NUTS_FAIL(nng_aio_result(aio), NNG_ESTOPPED); NUTS_CLOSE(s); @@ -270,7 +270,7 @@ test_push_close_send(void) NUTS_PASS(nng_msg_alloc(&m, 0)); nng_aio_set_timeout(aio, 1000); nng_aio_set_msg(aio, m); - nng_send_aio(s, aio); + nng_socket_send(s, aio); NUTS_CLOSE(s); nng_aio_wait(aio); NUTS_FAIL(nng_aio_result(aio), NNG_ECLOSED); @@ -292,7 +292,7 @@ test_push_send_nonblock(void) nng_aio_set_timeout(aio, 0); // Instant timeout nng_aio_set_msg(aio, m); - nng_send_aio(s, aio); + nng_socket_send(s, aio); nng_aio_wait(aio); NUTS_FAIL(nng_aio_result(aio), NNG_ETIMEDOUT); @@ -314,7 +314,7 @@ test_push_send_timeout(void) nng_aio_set_timeout(aio, 10); nng_aio_set_msg(aio, m); - nng_send_aio(s, aio); + nng_socket_send(s, aio); nng_aio_wait(aio); NUTS_FAIL(nng_aio_result(aio), NNG_ETIMEDOUT); @@ -336,7 +336,7 @@ test_push_send_cancel(void) nng_aio_set_timeout(aio, 1000); nng_aio_set_msg(aio, m); - nng_send_aio(s, aio); + nng_socket_send(s, aio); nng_aio_abort(aio, NNG_ECANCELED); nng_aio_wait(aio); @@ -362,7 +362,7 @@ test_push_send_late_unbuffered(void) nng_aio_set_timeout(aio, 1000); nng_aio_set_msg(aio, m); - nng_send_aio(s, aio); + nng_socket_send(s, aio); NUTS_MARRY(s, pull); @@ -391,7 +391,7 @@ test_push_send_late_buffered(void) nng_aio_set_timeout(aio, 1000); nng_aio_set_msg(aio, m); - nng_send_aio(s, aio); + nng_socket_send(s, aio); NUTS_MARRY(s, pull); diff --git a/src/sp/protocol/pubsub0/sub_test.c b/src/sp/protocol/pubsub0/sub_test.c index 6899d47d..5c72b8bd 100644 --- a/src/sp/protocol/pubsub0/sub_test.c +++ b/src/sp/protocol/pubsub0/sub_test.c @@ -140,7 +140,7 @@ test_sub_recv_late(void) NUTS_MARRY(pub, sub); NUTS_TRUE(nuts_poll_fd(fd) == false); - nng_recv_aio(sub, aio); + nng_socket_recv(sub, aio); // But once we send messages, it is. // We have to send a request, in order to send a reply. diff --git a/src/sp/protocol/pubsub0/xsub_test.c b/src/sp/protocol/pubsub0/xsub_test.c index fd26467d..618703b5 100644 --- a/src/sp/protocol/pubsub0/xsub_test.c +++ b/src/sp/protocol/pubsub0/xsub_test.c @@ -111,7 +111,7 @@ test_xsub_recv_late(void) NUTS_MARRY(pub, sub); NUTS_TRUE(nuts_poll_fd(fd) == false); - nng_recv_aio(sub, aio); + nng_socket_recv(sub, aio); // But once we send messages, it is. // We have to send a request, in order to send a reply. @@ -182,7 +182,7 @@ test_xsub_recv_closed(void) NUTS_PASS(nng_sub0_open_raw(&sub)); NUTS_PASS(nng_aio_alloc(&aio, NULL, NULL)); NUTS_CLOSE(sub); - nng_recv_aio(sub, aio); + nng_socket_recv(sub, aio); nng_aio_wait(aio); NUTS_FAIL(nng_aio_result(aio), NNG_ECLOSED); nng_aio_free(aio); @@ -197,7 +197,7 @@ test_xsub_close_recv(void) NUTS_PASS(nng_sub0_open_raw(&sub)); NUTS_PASS(nng_aio_alloc(&aio, NULL, NULL)); nng_aio_set_timeout(aio, 1000); - nng_recv_aio(sub, aio); + nng_socket_recv(sub, aio); NUTS_CLOSE(sub); nng_aio_wait(aio); NUTS_FAIL(nng_aio_result(aio), NNG_ECLOSED); @@ -215,7 +215,7 @@ test_xsub_recv_nonblock(void) NUTS_PASS(nng_aio_alloc(&aio, NULL, NULL)); nng_aio_set_timeout(aio, 0); // Instant timeout - nng_recv_aio(sub, aio); + nng_socket_recv(sub, aio); nng_aio_wait(aio); NUTS_FAIL(nng_aio_result(aio), NNG_ETIMEDOUT); @@ -335,7 +335,7 @@ test_xsub_recv_aio_stopped(void) NUTS_PASS(nng_aio_alloc(&aio, NULL, NULL)); nng_aio_stop(aio); - nng_recv_aio(sub, aio); + nng_socket_recv(sub, aio); nng_aio_wait(aio); NUTS_FAIL(nng_aio_result(aio), NNG_ESTOPPED); NUTS_CLOSE(sub); @@ -351,7 +351,7 @@ test_xsub_recv_aio_canceled(void) NUTS_PASS(nng_sub0_open_raw(&sub)); NUTS_PASS(nng_aio_alloc(&aio, NULL, NULL)); - nng_recv_aio(sub, aio); + nng_socket_recv(sub, aio); nng_aio_cancel(aio); nng_aio_wait(aio); NUTS_FAIL(nng_aio_result(aio), NNG_ECANCELED); diff --git a/src/sp/protocol/reqrep0/rep_test.c b/src/sp/protocol/reqrep0/rep_test.c index 29c5ee4c..7c788d96 100644 --- a/src/sp/protocol/reqrep0/rep_test.c +++ b/src/sp/protocol/reqrep0/rep_test.c @@ -163,8 +163,8 @@ test_rep_double_recv(void) NUTS_PASS(nng_aio_alloc(&aio1, NULL, NULL)); NUTS_PASS(nng_aio_alloc(&aio2, NULL, NULL)); - nng_recv_aio(s1, aio1); - nng_recv_aio(s1, aio2); + nng_socket_recv(s1, aio1); + nng_socket_recv(s1, aio2); nng_aio_wait(aio2); NUTS_FAIL(nng_aio_result(aio2), NNG_ESTATE); @@ -203,12 +203,12 @@ test_rep_huge_send(void) NUTS_SEND(req, "R"); NUTS_RECV(rep, "R"); nng_aio_set_msg(aio, m); - nng_send_aio(rep, aio); + nng_socket_send(rep, aio); nng_aio_wait(aio); NUTS_PASS(nng_aio_result(aio)); nng_aio_set_msg(aio, NULL); m = NULL; - nng_recv_aio(req, aio); + nng_socket_recv(req, aio); nng_aio_wait(aio); NUTS_PASS(nng_aio_result(aio)); m = nng_aio_get_msg(aio); @@ -260,12 +260,12 @@ test_rep_huge_send_socket(void) NUTS_SEND(req, "R"); NUTS_RECV(rep, "R"); nng_aio_set_msg(aio, m); - nng_send_aio(rep, aio); + nng_socket_send(rep, aio); nng_aio_wait(aio); NUTS_PASS(nng_aio_result(aio)); nng_aio_set_msg(aio, NULL); m = NULL; - nng_recv_aio(req, aio); + nng_socket_recv(req, aio); nng_aio_wait(aio); NUTS_PASS(nng_aio_result(aio)); m = nng_aio_get_msg(aio); @@ -306,7 +306,7 @@ test_rep_close_pipe_before_send(void) NUTS_MARRY(req, rep); NUTS_SEND(req, "test"); - nng_recv_aio(rep, aio1); + nng_socket_recv(rep, aio1); nng_aio_wait(aio1); NUTS_PASS(nng_aio_result(aio1)); NUTS_TRUE((m = nng_aio_get_msg(aio1)) != NULL); @@ -531,7 +531,7 @@ test_rep_close_recv(void) NUTS_MARRY(req, rep); NUTS_PASS(nng_aio_alloc(&aio, NULL, NULL)); - nng_recv_aio(rep, aio); + nng_socket_recv(rep, aio); NUTS_CLOSE(rep); NUTS_CLOSE(req); nng_aio_wait(aio); @@ -580,7 +580,7 @@ test_rep_close_recv_cb(void) NUTS_MARRY(req, rep); NUTS_PASS(nng_aio_alloc(&state.aio, rep_close_recv_cb, &state)); - nng_recv_aio(rep, state.aio); + nng_socket_recv(rep, state.aio); NUTS_CLOSE(rep); NUTS_CLOSE(req); nng_mtx_lock(state.mtx); diff --git a/src/sp/protocol/reqrep0/req_test.c b/src/sp/protocol/reqrep0/req_test.c index 13bab6ec..17378c89 100644 --- a/src/sp/protocol/reqrep0/req_test.c +++ b/src/sp/protocol/reqrep0/req_test.c @@ -337,7 +337,7 @@ test_req_disconnect_abort(void) NUTS_MARRY(rep1, req); NUTS_SEND(req, "ping"); NUTS_RECV(rep1, "ping"); - nng_recv_aio(req, aio); + nng_socket_recv(req, aio); NUTS_MARRY(rep2, req); NUTS_CLOSE(rep1); @@ -433,7 +433,7 @@ test_req_cancel_abort_recv(void) NUTS_SLEEP(100); nng_aio_set_timeout(aio, 5 * SECOND); - nng_recv_aio(req, aio); + nng_socket_recv(req, aio); // Give time for this recv to post properly. NUTS_SLEEP(100); @@ -565,7 +565,7 @@ test_req_poll_contention(void) NUTS_TRUE(nuts_poll_fd(fd) == false); nng_aio_set_msg(aio, msg); - nng_send_aio(req, aio); + nng_socket_send(req, aio); for (int i = 0; i < 5; i++) { nng_aio_set_msg(ctx_aio[i], ctx_msg[i]); nng_ctx_send(ctx[i], ctx_aio[i]); diff --git a/src/sp/protocol/reqrep0/reqstress_test.c b/src/sp/protocol/reqrep0/reqstress_test.c index 9c0861d8..2b2e1980 100644 --- a/src/sp/protocol/reqrep0/reqstress_test.c +++ b/src/sp/protocol/reqrep0/reqstress_test.c @@ -1,5 +1,5 @@ // -// Copyright 2024 Staysail Systems, Inc. +// Copyright 2025 Staysail Systems, Inc. // Copyright 2018 Capitar IT Group BV // // This software is supplied under the terms of the MIT License, a @@ -12,9 +12,9 @@ #include #include -#include +#include "nng/nng.h" -#include +#include "nuts.h" #ifdef NDEBUG #define dprintf(...) @@ -114,7 +114,7 @@ rep_recv_cb(void *arg) c->nrecv++; nng_aio_set_msg(c->send_aio, nng_aio_get_msg(c->recv_aio)); nng_aio_set_msg(c->recv_aio, NULL); - nng_send_aio(c->socket, c->send_aio); + nng_socket_send(c->socket, c->send_aio); } static void @@ -130,7 +130,7 @@ rep_send_cb(void *arg) return; } c->nsend++; - nng_recv_aio(c->socket, c->recv_aio); + nng_socket_recv(c->socket, c->recv_aio); } static void @@ -153,7 +153,7 @@ req_time_cb(void *arg) return; } nng_aio_set_msg(c->send_aio, msg); - nng_send_aio(c->socket, c->send_aio); + nng_socket_send(c->socket, c->send_aio); } static void @@ -196,7 +196,7 @@ req_send_cb(void *arg) return; } c->nsend++; - nng_recv_aio(c->socket, c->recv_aio); + nng_socket_recv(c->socket, c->recv_aio); } void @@ -224,7 +224,7 @@ reqrep_test(int ntests) fatal("nng_aio_alloc", rv); } - nng_recv_aio(srv->socket, srv->recv_aio); + nng_socket_recv(srv->socket, srv->recv_aio); for (i = 1; i < ntests; i++) { cli = &cases[curcase++]; diff --git a/src/sp/protocol/reqrep0/xrep_test.c b/src/sp/protocol/reqrep0/xrep_test.c index a00f78f7..d4e4ce26 100644 --- a/src/sp/protocol/reqrep0/xrep_test.c +++ b/src/sp/protocol/reqrep0/xrep_test.c @@ -171,7 +171,7 @@ test_xrep_close_pipe_before_send(void) NUTS_MARRY(req, rep); NUTS_SEND(req, "test"); - nng_recv_aio(rep, aio1); + nng_socket_recv(rep, aio1); nng_aio_wait(aio1); NUTS_PASS(nng_aio_result(aio1)); NUTS_TRUE((m = nng_aio_get_msg(aio1)) != NULL); @@ -265,7 +265,7 @@ test_xrep_recv_aio_stopped(void) NUTS_PASS(nng_aio_alloc(&aio, NULL, NULL)); nng_aio_stop(aio); - nng_recv_aio(rep, aio); + nng_socket_recv(rep, aio); nng_aio_wait(aio); NUTS_FAIL(nng_aio_result(aio), NNG_ESTOPPED); NUTS_CLOSE(rep); @@ -281,7 +281,7 @@ test_xrep_recv_aio_canceled(void) NUTS_PASS(nng_rep0_open_raw(&rep)); NUTS_PASS(nng_aio_alloc(&aio, NULL, NULL)); - nng_recv_aio(rep, aio); + nng_socket_recv(rep, aio); nng_aio_cancel(aio); nng_aio_wait(aio); NUTS_FAIL(nng_aio_result(aio), NNG_ECANCELED); diff --git a/src/sp/protocol/reqrep0/xreq_test.c b/src/sp/protocol/reqrep0/xreq_test.c index 28c79a26..7969ff0f 100644 --- a/src/sp/protocol/reqrep0/xreq_test.c +++ b/src/sp/protocol/reqrep0/xreq_test.c @@ -171,7 +171,7 @@ test_xreq_recv_aio_stopped(void) NUTS_PASS(nng_aio_alloc(&aio, NULL, NULL)); nng_aio_stop(aio); - nng_recv_aio(req, aio); + nng_socket_recv(req, aio); nng_aio_wait(aio); NUTS_FAIL(nng_aio_result(aio), NNG_ESTOPPED); NUTS_CLOSE(req); @@ -190,7 +190,7 @@ test_xreq_send_aio_canceled(void) NUTS_PASS(nng_aio_alloc(&aio, NULL, NULL)); nng_aio_set_msg(aio, msg); - nng_send_aio(req, aio); + nng_socket_send(req, aio); nng_aio_cancel(aio); nng_aio_wait(aio); NUTS_FAIL(nng_aio_result(aio), NNG_ECANCELED); diff --git a/src/sp/protocol/survey0/respond_test.c b/src/sp/protocol/survey0/respond_test.c index 0725efb7..5b4bcff9 100644 --- a/src/sp/protocol/survey0/respond_test.c +++ b/src/sp/protocol/survey0/respond_test.c @@ -163,8 +163,8 @@ test_resp_double_recv(void) NUTS_PASS(nng_aio_alloc(&aio1, NULL, NULL)); NUTS_PASS(nng_aio_alloc(&aio2, NULL, NULL)); - nng_recv_aio(s1, aio1); - nng_recv_aio(s1, aio2); + nng_socket_recv(s1, aio1); + nng_socket_recv(s1, aio2); nng_aio_wait(aio2); NUTS_FAIL(nng_aio_result(aio2), NNG_ESTATE); @@ -194,7 +194,7 @@ test_resp_close_pipe_before_send(void) NUTS_MARRY(surv, resp); NUTS_SEND(surv, "test"); - nng_recv_aio(resp, aio1); + nng_socket_recv(resp, aio1); nng_aio_wait(aio1); NUTS_PASS(nng_aio_result(aio1)); NUTS_TRUE((m = nng_aio_get_msg(aio1)) != NULL); diff --git a/src/sp/protocol/survey0/survey_test.c b/src/sp/protocol/survey0/survey_test.c index 1be9dee4..bf6fbb08 100644 --- a/src/sp/protocol/survey0/survey_test.c +++ b/src/sp/protocol/survey0/survey_test.c @@ -232,7 +232,7 @@ test_surv_cancel_abort_recv(void) NUTS_SLEEP(100); nng_aio_set_timeout(aio, 5 * SECOND); - nng_recv_aio(surv, aio); + nng_socket_recv(surv, aio); // Give time for this recv to post properly. NUTS_SLEEP(100); diff --git a/src/sp/protocol/survey0/xrespond_test.c b/src/sp/protocol/survey0/xrespond_test.c index 03ac5fc1..bda924c3 100644 --- a/src/sp/protocol/survey0/xrespond_test.c +++ b/src/sp/protocol/survey0/xrespond_test.c @@ -171,7 +171,7 @@ test_xresp_close_pipe_before_send(void) NUTS_MARRY(surv, resp); NUTS_SEND(surv, "test"); - nng_recv_aio(resp, aio1); + nng_socket_recv(resp, aio1); nng_aio_wait(aio1); NUTS_PASS(nng_aio_result(aio1)); NUTS_TRUE((m = nng_aio_get_msg(aio1)) != NULL); @@ -265,7 +265,7 @@ test_xresp_recv_aio_stopped(void) NUTS_PASS(nng_aio_alloc(&aio, NULL, NULL)); nng_aio_stop(aio); - nng_recv_aio(resp, aio); + nng_socket_recv(resp, aio); nng_aio_wait(aio); NUTS_FAIL(nng_aio_result(aio), NNG_ESTOPPED); NUTS_CLOSE(resp); @@ -281,7 +281,7 @@ test_xresp_recv_aio_canceled(void) NUTS_PASS(nng_respondent0_open_raw(&resp)); NUTS_PASS(nng_aio_alloc(&aio, NULL, NULL)); - nng_recv_aio(resp, aio); + nng_socket_recv(resp, aio); nng_aio_cancel(aio); nng_aio_wait(aio); NUTS_FAIL(nng_aio_result(aio), NNG_ECANCELED); diff --git a/src/sp/protocol/survey0/xsurvey_test.c b/src/sp/protocol/survey0/xsurvey_test.c index 44b2c990..1b9c52fd 100644 --- a/src/sp/protocol/survey0/xsurvey_test.c +++ b/src/sp/protocol/survey0/xsurvey_test.c @@ -170,7 +170,7 @@ test_xsurvey_recv_aio_stopped(void) NUTS_PASS(nng_aio_alloc(&aio, NULL, NULL)); nng_aio_stop(aio); - nng_recv_aio(surv, aio); + nng_socket_recv(surv, aio); nng_aio_wait(aio); NUTS_FAIL(nng_aio_result(aio), NNG_ESTOPPED); NUTS_CLOSE(surv); -- cgit v1.2.3-70-g09d2