diff options
Diffstat (limited to 'src/transport/inproc')
| -rw-r--r-- | src/transport/inproc/inproc.c | 12 |
1 files changed, 4 insertions, 8 deletions
diff --git a/src/transport/inproc/inproc.c b/src/transport/inproc/inproc.c index 3bc24c41..08cf99a2 100644 --- a/src/transport/inproc/inproc.c +++ b/src/transport/inproc/inproc.c @@ -65,14 +65,9 @@ static nni_inproc_global nni_inproc; static int nni_inproc_init(void) { - int rv; - NNI_LIST_INIT(&nni_inproc.servers, nni_inproc_ep, node); - if ((rv = nni_mtx_init(&nni_inproc.mx)) != 0) { - return (rv); - } - + nni_mtx_init(&nni_inproc.mx); return (0); } @@ -309,8 +304,7 @@ nni_inproc_accept_clients(nni_inproc_ep *server) continue; } - if (((rv = nni_mtx_init(&pair->mx)) != 0) || - ((rv = nni_msgq_init(&pair->q[0], 4)) != 0) || + if (((rv = nni_msgq_init(&pair->q[0], 4)) != 0) || ((rv = nni_msgq_init(&pair->q[1], 4)) != 0)) { nni_inproc_pair_destroy(pair); nni_inproc_conn_finish(caio, rv); @@ -318,6 +312,8 @@ nni_inproc_accept_clients(nni_inproc_ep *server) continue; } + nni_mtx_init(&pair->mx); + pair->pipes[0] = caio->a_pipe; pair->pipes[1] = saio->a_pipe; pair->pipes[0]->rq = pair->pipes[1]->wq = pair->q[0]; |