diff options
| author | Garrett D'Amore <garrett@damore.org> | 2018-04-09 14:13:52 -0700 |
|---|---|---|
| committer | Garrett D'Amore <garrett@damore.org> | 2018-04-10 15:40:06 -0700 |
| commit | 38ae9a92c528e2497c73bde26d94ccfb071f0003 (patch) | |
| tree | 148334387abfe31a90ad1d2c7fe06e4685cf5859 | |
| parent | 2bf076297f4105c76bfbee0320231e70d0b2b583 (diff) | |
| download | nng-38ae9a92c528e2497c73bde26d94ccfb071f0003.tar.gz nng-38ae9a92c528e2497c73bde26d94ccfb071f0003.tar.bz2 nng-38ae9a92c528e2497c73bde26d94ccfb071f0003.zip | |
fixes #336 inproc queue depths are too long
| -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); |