From 38ae9a92c528e2497c73bde26d94ccfb071f0003 Mon Sep 17 00:00:00 2001 From: Garrett D'Amore Date: Mon, 9 Apr 2018 14:13:52 -0700 Subject: fixes #336 inproc queue depths are too long --- src/transport/inproc/inproc.c | 4 ++-- 1 file 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); -- cgit v1.2.3-70-g09d2