2 files changed, 8 insertions, 8 deletions

diff --git a/src/protocol/pubsub/pub.c b/src/protocol/pubsub/pub.c
index 8ca7f0f9..5ea16d2d 100644
--- a/src/protocol/pubsub/pub.c
+++ b/src/protocol/pubsub/pub.c
@@ -156,9 +156,9 @@ nni_pub_pipe_start(void *arg)
 	nni_list_append(&pub->pipes, pp);
 
 	// Start the receiver and the queue reader.
-	nni_pipe_incref(pp->pipe);
+	nni_pipe_hold(pp->pipe);
 	nni_pipe_aio_recv(pp->pipe, &pp->aio_recv);
-	nni_pipe_incref(pp->pipe);
+	nni_pipe_hold(pp->pipe);
 	nni_msgq_aio_get(pp->sendq, &pp->aio_getq);
 
 	return (0);
@@ -229,7 +229,7 @@ nni_pub_pipe_recv_cb(void *arg)
 
 	if (nni_aio_result(&pp->aio_recv) != 0) {
 		nni_pipe_close(pp->pipe);
-		nni_pipe_decref(pp->pipe);
+		nni_pipe_rele(pp->pipe);
 		return;
 	}
 
@@ -246,7 +246,7 @@ nni_pub_pipe_getq_cb(void *arg)
 
 	if (nni_aio_result(&pp->aio_getq) != 0) {
 		nni_pipe_close(pp->pipe);
-		nni_pipe_decref(pp->pipe);
+		nni_pipe_rele(pp->pipe);
 		return;
 	}
 
@@ -266,7 +266,7 @@ nni_pub_pipe_send_cb(void *arg)
 		nni_msg_free(pp->aio_send.a_msg);
 		pp->aio_send.a_msg = NULL;
 		nni_pipe_close(pp->pipe);
-		nni_pipe_decref(pp->pipe);
+		nni_pipe_rele(pp->pipe);
 		return;
 	}
 
diff --git a/src/protocol/pubsub/sub.c b/src/protocol/pubsub/sub.c
index 7b6e908e..8340da77 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_incref(sp->pipe);
+	nni_pipe_hold(sp->pipe);
 	nni_pipe_aio_recv(sp->pipe, &sp->aio_recv);
 	return (0);
 }
@@ -142,7 +142,7 @@ nni_sub_recv_cb(void *arg)
 
 	if (nni_aio_result(&sp->aio_recv) != 0) {
 		nni_pipe_close(sp->pipe);
-		nni_pipe_decref(sp->pipe);
+		nni_pipe_rele(sp->pipe);
 		return;
 	}
 
@@ -161,7 +161,7 @@ nni_sub_putq_cb(void *arg)
 		nni_msg_free(sp->aio_putq.a_msg);
 		sp->aio_putq.a_msg = NULL;
 		nni_pipe_close(sp->pipe);
-		nni_pipe_decref(sp->pipe);
+		nni_pipe_rele(sp->pipe);
 		return;
 	}