aboutsummaryrefslogtreecommitdiff
path: root/demo
diff options
context:
space:
mode:
authorGarrett D'Amore <garrett@damore.org>2025-01-03 12:46:33 -0800
committerGarrett D'Amore <garrett@damore.org>2025-01-04 09:48:44 -0800
commit57e736b5be2052484eec44889586bd89a2724c71 (patch)
treef579d2863d7d31e202f083ab6d5f5fe85651e64c /demo
parentcefc6e1995f7f8e53e16db745eac7a86c2ebffd3 (diff)
downloadnng-57e736b5be2052484eec44889586bd89a2724c71.tar.gz
nng-57e736b5be2052484eec44889586bd89a2724c71.tar.bz2
nng-57e736b5be2052484eec44889586bd89a2724c71.zip
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.
Diffstat (limited to 'demo')
-rw-r--r--demo/raw/raw.c12
1 files changed, 6 insertions, 6 deletions
diff --git a/demo/raw/raw.c b/demo/raw/raw.c
index 3cb02169..222e4a48 100644
--- a/demo/raw/raw.c
+++ b/demo/raw/raw.c
@@ -67,17 +67,17 @@ server_cb(void *arg)
switch (work->state) {
case INIT:
work->state = RECV;
- nng_recv_aio(work->sock, work->aio);
+ nng_socket_recv(work->sock, work->aio);
break;
case RECV:
if ((rv = nng_aio_result(work->aio)) != 0) {
- fatal("nng_recv_aio", rv);
+ fatal("nng_socket_recv", rv);
}
msg = nng_aio_get_msg(work->aio);
if ((rv = nng_msg_trim_u32(msg, &when)) != 0) {
// bad message, just ignore it.
nng_msg_free(msg);
- nng_recv_aio(work->sock, work->aio);
+ nng_socket_recv(work->sock, work->aio);
return;
}
work->msg = msg;
@@ -89,15 +89,15 @@ server_cb(void *arg)
nng_aio_set_msg(work->aio, work->msg);
work->msg = NULL;
work->state = SEND;
- nng_send_aio(work->sock, work->aio);
+ nng_socket_send(work->sock, work->aio);
break;
case SEND:
if ((rv = nng_aio_result(work->aio)) != 0) {
nng_msg_free(work->msg);
- fatal("nng_send_aio", rv);
+ fatal("nng_socket_send", rv);
}
work->state = RECV;
- nng_recv_aio(work->sock, work->aio);
+ nng_socket_recv(work->sock, work->aio);
break;
default:
fatal("bad state!", NNG_ESTATE);