2 files changed, 2 insertions, 14 deletions
diff --git a/src/sp/protocol/pipeline0/pull.c b/src/sp/protocol/pipeline0/pull.c
index bfd8f6ea..89981b29 100644
--- a/src/sp/protocol/pipeline0/pull.c
+++ b/src/sp/protocol/pipeline0/pull.c
@@ -223,17 +223,11 @@ pull0_sock_recv(void *arg, nni_aio *aio)
 	pull0_sock *s = arg;
 	pull0_pipe *p;
 
-	if (nni_aio_begin(aio) != 0) {
-		return;
-	}
-
 	nni_mtx_lock(&s->m);
 	if ((p = nni_list_first(&s->pl)) == NULL) {
 
-		int rv;
-		if ((rv = nni_aio_schedule(aio, pull0_cancel, s)) != 0) {
+		if (!nni_aio_start(aio, pull0_cancel, s)) {
 			nni_mtx_unlock(&s->m);
-			nni_aio_finish_error(aio, rv);
 			return;
 		}
 
diff --git a/src/sp/protocol/pipeline0/push.c b/src/sp/protocol/pipeline0/push.c
index f99dddc3..bac3f984 100644
--- a/src/sp/protocol/pipeline0/push.c
+++ b/src/sp/protocol/pipeline0/push.c
@@ -269,11 +269,6 @@ push0_sock_send(void *arg, nni_aio *aio)
 	push0_pipe *p;
 	nni_msg    *m;
 	size_t      l;
-	int         rv;
-
-	if (nni_aio_begin(aio) != 0) {
-		return;
-	}
 
 	m = nni_aio_get_msg(aio);
 	l = nni_msg_len(m);
@@ -312,8 +307,7 @@ push0_sock_send(void *arg, nni_aio *aio)
 		return;
 	}
 
-	if ((rv = nni_aio_schedule(aio, push0_cancel, s)) != 0) {
-		nni_aio_finish_error(aio, rv);
+	if (!nni_aio_start(aio, push0_cancel, s)) {
 		nni_mtx_unlock(&s->m);
 		return;
 	}