3 files changed, 13 insertions, 12 deletions

diff --git a/src/protocol/bus/bus.c b/src/protocol/bus/bus.c
index 986d8ed7..02467ffe 100644
--- a/src/protocol/bus/bus.c
+++ b/src/protocol/bus/bus.c
@@ -94,6 +94,7 @@ nni_bus_pipe_fini(void *arg)
 	nni_bus_pipe *ppipe = arg;
 
 	if (ppipe != NULL) {
+		nni_msgq_fini(ppipe->sendq);
 		NNI_FREE_STRUCT(ppipe);
 	}
 }
diff --git a/src/protocol/reqrep/rep.c b/src/protocol/reqrep/rep.c
index 6410e6db..a34f6eea 100644
--- a/src/protocol/reqrep/rep.c
+++ b/src/protocol/reqrep/rep.c
@@ -26,7 +26,7 @@ struct nni_rep_sock {
 	nni_msgq *	urq;
 	int		raw;
 	int		ttl;
-	nni_idhash *	pipes;
+	nni_idhash	pipes;
 	char *		btrace;
 	size_t		btrace_len;
 };
@@ -53,7 +53,7 @@ nni_rep_sock_init(void **repp, nni_sock *sock)
 	rep->raw = 0;
 	rep->btrace = NULL;
 	rep->btrace_len = 0;
-	if ((rv = nni_idhash_create(&rep->pipes)) != 0) {
+	if ((rv = nni_idhash_init(&rep->pipes)) != 0) {
 		NNI_FREE_STRUCT(rep);
 		return (rv);
 	}
@@ -73,7 +73,7 @@ nni_rep_sock_fini(void *arg)
 	nni_rep_sock *rep = arg;
 
 	if (rep != NULL) {
-		nni_idhash_destroy(rep->pipes);
+		nni_idhash_fini(&rep->pipes);
 		if (rep->btrace != NULL) {
 			nni_free(rep->btrace, rep->btrace_len);
 		}
@@ -121,7 +121,7 @@ nni_rep_pipe_add(void *arg)
 	nni_rep_pipe *rp = arg;
 	nni_rep_sock *rep = rp->rep;
 
-	return (nni_idhash_insert(rep->pipes, nni_pipe_id(rp->pipe), rp));
+	return (nni_idhash_insert(&rep->pipes, nni_pipe_id(rp->pipe), rp));
 }
 
 
@@ -131,7 +131,7 @@ nni_rep_pipe_rem(void *arg)
 	nni_rep_pipe *rp = arg;
 	nni_rep_sock *rep = rp->rep;
 
-	nni_idhash_remove(rep->pipes, nni_pipe_id(rp->pipe));
+	nni_idhash_remove(&rep->pipes, nni_pipe_id(rp->pipe));
 }
 
 
@@ -166,7 +166,7 @@ nni_rep_sock_send(void *arg)
 		nni_msg_trim_header(msg, 4);
 
 		nni_mtx_lock(mx);
-		if (nni_idhash_find(rep->pipes, id, (void **) &rp) != 0) {
+		if (nni_idhash_find(&rep->pipes, id, (void **) &rp) != 0) {
 			nni_mtx_unlock(mx);
 			nni_msg_free(msg);
 			continue;
diff --git a/src/protocol/survey/respond.c b/src/protocol/survey/respond.c
index 5603b675..263e023a 100644
--- a/src/protocol/survey/respond.c
+++ b/src/protocol/survey/respond.c
@@ -24,7 +24,7 @@ struct nni_resp_sock {
 	nni_sock *	nsock;
 	int		raw;
 	int		ttl;
-	nni_idhash *	pipes;
+	nni_idhash	pipes;
 	char *		btrace;
 	size_t		btrace_len;
 };
@@ -51,7 +51,7 @@ nni_resp_sock_init(void **pp, nni_sock *nsock)
 	psock->raw = 0;
 	psock->btrace = NULL;
 	psock->btrace_len = 0;
-	if ((rv = nni_idhash_create(&psock->pipes)) != 0) {
+	if ((rv = nni_idhash_init(&psock->pipes)) != 0) {
 		NNI_FREE_STRUCT(psock);
 		return (rv);
 	}
@@ -68,7 +68,7 @@ nni_resp_sock_fini(void *arg)
 	nni_resp_sock *psock = arg;
 
 	if (psock != NULL) {
-		nni_idhash_destroy(psock->pipes);
+		nni_idhash_fini(&psock->pipes);
 		if (psock->btrace != NULL) {
 			nni_free(psock->btrace, psock->btrace_len);
 		}
@@ -117,7 +117,7 @@ nni_resp_pipe_add(void *arg)
 	nni_resp_sock *psock = ppipe->psock;
 	int rv;
 
-	rv = nni_idhash_insert(psock->pipes, nni_pipe_id(ppipe->npipe), ppipe);
+	rv = nni_idhash_insert(&psock->pipes, nni_pipe_id(ppipe->npipe), ppipe);
 	return (rv);
 }
 
@@ -128,7 +128,7 @@ nni_resp_pipe_rem(void *arg)
 	nni_resp_pipe *ppipe = arg;
 	nni_resp_sock *psock = ppipe->psock;
 
-	nni_idhash_remove(psock->pipes, nni_pipe_id(ppipe->npipe));
+	nni_idhash_remove(&psock->pipes, nni_pipe_id(ppipe->npipe));
 }
 
 
@@ -163,7 +163,7 @@ nni_resp_sock_send(void *arg)
 		nni_msg_trim_header(msg, 4);
 
 		nni_mtx_lock(mx);
-		if (nni_idhash_find(psock->pipes, id, (void **) &ppipe) != 0) {
+		if (nni_idhash_find(&psock->pipes, id, (void **) &ppipe) != 0) {
 			nni_mtx_unlock(mx);
 			nni_msg_free(msg);
 			continue;