2 files changed, 6 insertions, 24 deletions

diff --git a/src/protocol/pipeline/pull.c b/src/protocol/pipeline/pull.c
index e3c73342..1ebcc4a2 100644
--- a/src/protocol/pipeline/pull.c
+++ b/src/protocol/pipeline/pull.c
@@ -63,20 +63,13 @@ static int
 nni_pull_pipe_init(void **ppp, nni_pipe *pipe, void *psock)
 {
 	nni_pull_pipe *pp;
-	int            rv;
 
 	if ((pp = NNI_ALLOC_STRUCT(pp)) == NULL) {
 		return (NNG_ENOMEM);
 	}
-	if (((rv = nni_aio_init(&pp->putq_aio, nni_pull_putq_cb, pp))) != 0) {
-		NNI_FREE_STRUCT(pp);
-		return (rv);
-	}
-	if (((rv = nni_aio_init(&pp->recv_aio, nni_pull_recv_cb, pp))) != 0) {
-		nni_aio_fini(&pp->putq_aio);
-		NNI_FREE_STRUCT(pp);
-		return (rv);
-	}
+	nni_aio_init(&pp->putq_aio, nni_pull_putq_cb, pp);
+	nni_aio_init(&pp->recv_aio, nni_pull_recv_cb, pp);
+
 	pp->pipe = pipe;
 	pp->pull = psock;
 	*ppp     = pp;
diff --git a/src/protocol/pipeline/push.c b/src/protocol/pipeline/push.c
index 14b3b191..1bc1659c 100644
--- a/src/protocol/pipeline/push.c
+++ b/src/protocol/pipeline/push.c
@@ -93,30 +93,19 @@ static int
 nni_push_pipe_init(void **ppp, nni_pipe *pipe, void *psock)
 {
 	nni_push_pipe *pp;
-	int            rv;
 
 	if ((pp = NNI_ALLOC_STRUCT(pp)) == NULL) {
 		return (NNG_ENOMEM);
 	}
-	if ((rv = nni_aio_init(&pp->aio_recv, nni_push_recv_cb, pp)) != 0) {
-		goto fail;
-	}
-	if ((rv = nni_aio_init(&pp->aio_send, nni_push_send_cb, pp)) != 0) {
-		goto fail;
-	}
-	if ((rv = nni_aio_init(&pp->aio_getq, nni_push_getq_cb, pp)) != 0) {
-		goto fail;
-	}
+	nni_aio_init(&pp->aio_recv, nni_push_recv_cb, pp);
+	nni_aio_init(&pp->aio_send, nni_push_send_cb, pp);
+	nni_aio_init(&pp->aio_getq, nni_push_getq_cb, pp);
 
 	NNI_LIST_NODE_INIT(&pp->node);
 	pp->pipe = pipe;
 	pp->push = psock;
 	*ppp     = pp;
 	return (0);
-
-fail:
-	nni_push_pipe_fini(pp);
-	return (rv);
 }
 
 static int