diff options
Diffstat (limited to 'src/transport/inproc')
| -rw-r--r-- | src/transport/inproc/inproc.c | 7 |
1 files changed, 6 insertions, 1 deletions
diff --git a/src/transport/inproc/inproc.c b/src/transport/inproc/inproc.c index 68490747..226a31ce 100644 --- a/src/transport/inproc/inproc.c +++ b/src/transport/inproc/inproc.c @@ -257,7 +257,12 @@ nni_inproc_conn_finish(nni_aio *aio, int rv) } } } - nni_aio_finish(aio, rv, 0); + if (nni_aio_finish(aio, rv, 0) != 0) { + if (aio->a_pipe != NULL) { + nni_inproc_pipe_fini(aio->a_pipe); + aio->a_pipe = NULL; + } + } } static void |