aboutsummaryrefslogtreecommitdiff
path: root/src/protocol/pubsub/sub.c
diff options
context:
space:
mode:
authorGarrett D'Amore <garrett@damore.org>2017-07-02 15:58:45 -0700
committerGarrett D'Amore <garrett@damore.org>2017-07-02 15:58:45 -0700
commit9f5fa865f252f6d71f2d92181b17c038e2c28a8a (patch)
tree679158fe7ce63fed24994fabcb53f613e9c2de42 /src/protocol/pubsub/sub.c
parente4c65457c4ca9bf350af7da94733fabdc70acaca (diff)
downloadnng-9f5fa865f252f6d71f2d92181b17c038e2c28a8a.tar.gz
nng-9f5fa865f252f6d71f2d92181b17c038e2c28a8a.tar.bz2
nng-9f5fa865f252f6d71f2d92181b17c038e2c28a8a.zip
Remove the extra _aio_ part of pipe send and recv functions.
Diffstat (limited to 'src/protocol/pubsub/sub.c')
-rw-r--r--src/protocol/pubsub/sub.c4
1 files changed, 2 insertions, 2 deletions
diff --git a/src/protocol/pubsub/sub.c b/src/protocol/pubsub/sub.c
index 5733b8f2..9e8fa5a7 100644
--- a/src/protocol/pubsub/sub.c
+++ b/src/protocol/pubsub/sub.c
@@ -117,7 +117,7 @@ nni_sub_pipe_start(void *arg)
{
nni_sub_pipe *sp = arg;
- nni_pipe_aio_recv(sp->pipe, &sp->aio_recv);
+ nni_pipe_recv(sp->pipe, &sp->aio_recv);
return (0);
}
@@ -163,7 +163,7 @@ nni_sub_putq_cb(void *arg)
return;
}
- nni_pipe_aio_recv(sp->pipe, &sp->aio_recv);
+ nni_pipe_recv(sp->pipe, &sp->aio_recv);
}