aboutsummaryrefslogtreecommitdiff
path: root/src/sp/protocol/pubsub0/pub.c
diff options
context:
space:
mode:
authorGarrett D'Amore <garrett@damore.org>2024-12-26 16:44:00 -0800
committerGarrett D'Amore <garrett@damore.org>2024-12-26 18:21:22 -0800
commitb353de37e99a5a4c5f2e0077a8b68acfa2cf790e (patch)
tree039c68be45d773a73e6265f1f0172f9fe1922b6a /src/sp/protocol/pubsub0/pub.c
parenteaa1b679271b4d07507b8ba4a80ee7bc0448da67 (diff)
downloadnng-b353de37e99a5a4c5f2e0077a8b68acfa2cf790e.tar.gz
nng-b353de37e99a5a4c5f2e0077a8b68acfa2cf790e.tar.bz2
nng-b353de37e99a5a4c5f2e0077a8b68acfa2cf790e.zip
pub sub: use nni_aio_start
Diffstat (limited to 'src/sp/protocol/pubsub0/pub.c')
-rw-r--r--src/sp/protocol/pubsub0/pub.c4
1 files changed, 1 insertions, 3 deletions
diff --git a/src/sp/protocol/pubsub0/pub.c b/src/sp/protocol/pubsub0/pub.c
index c40725f7..371782a0 100644
--- a/src/sp/protocol/pubsub0/pub.c
+++ b/src/sp/protocol/pubsub0/pub.c
@@ -214,9 +214,7 @@ static void
pub0_sock_recv(void *arg, nni_aio *aio)
{
NNI_ARG_UNUSED(arg);
- if (nni_aio_begin(aio) == 0) {
- nni_aio_finish_error(aio, NNG_ENOTSUP);
- }
+ nni_aio_finish_error(aio, NNG_ENOTSUP);
}
static void