2 files changed, 21 insertions, 67 deletions

diff --git a/src/protocol/reqrep/rep.c b/src/protocol/reqrep/rep.c
index 4319cbf8..09f2b285 100644
--- a/src/protocol/reqrep/rep.c
+++ b/src/protocol/reqrep/rep.c
@@ -74,20 +74,18 @@ nni_rep_sock_init(void **repp, nni_sock *sock)
 	if ((rep = NNI_ALLOC_STRUCT(rep)) == NULL) {
 		return (NNG_ENOMEM);
 	}
+	if ((rv = nni_idhash_init(&rep->pipes)) != 0) {
+		NNI_FREE_STRUCT(rep);
+		return (rv);
+	}
+
 	rep->ttl        = 8; // Per RFC
 	rep->sock       = sock;
 	rep->raw        = 0;
 	rep->btrace     = NULL;
 	rep->btrace_len = 0;
 
-	if ((rv = nni_idhash_init(&rep->pipes)) != 0) {
-		goto fail;
-	}
-
-	rv = nni_aio_init(&rep->aio_getq, nni_rep_sock_getq_cb, rep);
-	if (rv != 0) {
-		goto fail;
-	}
+	nni_aio_init(&rep->aio_getq, nni_rep_sock_getq_cb, rep);
 
 	rep->uwq = nni_sock_sendq(sock);
 	rep->urq = nni_sock_recvq(sock);
@@ -96,10 +94,6 @@ nni_rep_sock_init(void **repp, nni_sock *sock)
 	nni_sock_senderr(sock, NNG_ESTATE);
 
 	return (0);
-
-fail:
-	nni_rep_sock_fini(rep);
-	return (rv);
 }
 
 static void
@@ -128,32 +122,18 @@ nni_rep_pipe_init(void **rpp, nni_pipe *pipe, void *rsock)
 		return (NNG_ENOMEM);
 	}
 	if ((rv = nni_msgq_init(&rp->sendq, 2)) != 0) {
-		goto fail;
-	}
-	if ((rv = nni_aio_init(&rp->aio_getq, nni_rep_pipe_getq_cb, rp)) !=
-	    0) {
-		goto fail;
-	}
-	if ((rv = nni_aio_init(&rp->aio_send, nni_rep_pipe_send_cb, rp)) !=
-	    0) {
-		goto fail;
-	}
-	if ((rv = nni_aio_init(&rp->aio_recv, nni_rep_pipe_recv_cb, rp)) !=
-	    0) {
-		goto fail;
-	}
-	if ((rv = nni_aio_init(&rp->aio_putq, nni_rep_pipe_putq_cb, rp)) !=
-	    0) {
-		goto fail;
+		NNI_FREE_STRUCT(rp);
+		return (rv);
 	}
+	nni_aio_init(&rp->aio_getq, nni_rep_pipe_getq_cb, rp);
+	nni_aio_init(&rp->aio_send, nni_rep_pipe_send_cb, rp);
+	nni_aio_init(&rp->aio_recv, nni_rep_pipe_recv_cb, rp);
+	nni_aio_init(&rp->aio_putq, nni_rep_pipe_putq_cb, rp);
+
 	rp->pipe = pipe;
 	rp->rep  = rsock;
 	*rpp     = rp;
 	return (0);
-
-fail:
-	nni_rep_pipe_fini(rp);
-	return (rv);
 }
 
 static void
diff --git a/src/protocol/reqrep/req.c b/src/protocol/reqrep/req.c
index fdf29fd9..bab81331 100644
--- a/src/protocol/reqrep/req.c
+++ b/src/protocol/reqrep/req.c
@@ -75,19 +75,12 @@ static int
 nni_req_sock_init(void **reqp, nni_sock *sock)
 {
 	nni_req_sock *req;
-	int           rv;
 
 	if ((req = NNI_ALLOC_STRUCT(req)) == NULL) {
 		return (NNG_ENOMEM);
 	}
-	if ((rv = nni_mtx_init(&req->mtx)) != 0) {
-		NNI_FREE_STRUCT(req);
-		return (rv);
-	}
-	if ((rv = nni_cv_init(&req->cv, &req->mtx)) != 0) {
-		nni_mtx_fini(&req->mtx);
-		NNI_FREE_STRUCT(req);
-	}
+	nni_mtx_init(&req->mtx);
+	nni_cv_init(&req->cv, &req->mtx);
 
 	NNI_LIST_INIT(&req->readypipes, nni_req_pipe, node);
 	NNI_LIST_INIT(&req->busypipes, nni_req_pipe, node);
@@ -152,41 +145,22 @@ static int
 nni_req_pipe_init(void **rpp, nni_pipe *pipe, void *rsock)
 {
 	nni_req_pipe *rp;
-	int           rv;
 
 	if ((rp = NNI_ALLOC_STRUCT(rp)) == NULL) {
 		return (NNG_ENOMEM);
 	}
-	if ((rv = nni_mtx_init(&rp->mtx)) != 0) {
-		goto failed;
-	}
-	if ((rv = nni_aio_init(&rp->aio_getq, nni_req_getq_cb, rp)) != 0) {
-		goto failed;
-	}
-	if ((rv = nni_aio_init(&rp->aio_putq, nni_req_putq_cb, rp)) != 0) {
-		goto failed;
-	}
-	if ((rv = nni_aio_init(&rp->aio_recv, nni_req_recv_cb, rp)) != 0) {
-		goto failed;
-	}
-	rv = nni_aio_init(&rp->aio_sendraw, nni_req_sendraw_cb, rp);
-	if (rv != 0) {
-		goto failed;
-	}
-	rv = nni_aio_init(&rp->aio_sendcooked, nni_req_sendcooked_cb, rp);
-	if (rv != 0) {
-		goto failed;
-	}
+	nni_mtx_init(&rp->mtx);
+	nni_aio_init(&rp->aio_getq, nni_req_getq_cb, rp);
+	nni_aio_init(&rp->aio_putq, nni_req_putq_cb, rp);
+	nni_aio_init(&rp->aio_recv, nni_req_recv_cb, rp);
+	nni_aio_init(&rp->aio_sendraw, nni_req_sendraw_cb, rp);
+	nni_aio_init(&rp->aio_sendcooked, nni_req_sendcooked_cb, rp);
 
 	NNI_LIST_NODE_INIT(&rp->node);
 	rp->pipe = pipe;
 	rp->req  = rsock;
 	*rpp     = rp;
 	return (0);
-
-failed:
-	nni_req_pipe_fini(rp);
-	return (rv);
 }
 
 static void