diff options
| -rw-r--r-- | src/transport/inproc/inproc.c | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/src/transport/inproc/inproc.c b/src/transport/inproc/inproc.c index e7253f7b..82f46fc4 100644 --- a/src/transport/inproc/inproc.c +++ b/src/transport/inproc/inproc.c @@ -292,8 +292,8 @@ nni_inproc_accept_clients(nni_inproc_ep *srv) spipe = cpipe = NULL; if (((rv = nni_inproc_pipe_init(&cpipe, cli)) != 0) || ((rv = nni_inproc_pipe_init(&spipe, srv)) != 0) || - ((rv = nni_msgq_init(&pair->q[0], 4)) != 0) || - ((rv = nni_msgq_init(&pair->q[1], 4)) != 0)) { + ((rv = nni_msgq_init(&pair->q[0], 1)) != 0) || + ((rv = nni_msgq_init(&pair->q[1], 1)) != 0)) { if (cpipe != NULL) { nni_inproc_pipe_fini(cpipe); |