aboutsummaryrefslogtreecommitdiff
path: root/src/core/pipe.c
diff options
context:
space:
mode:
authorGarrett D'Amore <garrett@damore.org>2016-12-13 22:41:35 -0800
committerGarrett D'Amore <garrett@damore.org>2016-12-13 22:41:35 -0800
commitec9f917101371baaae34ca10ae952392c2c2343d (patch)
tree9ad7b85748d4d70248c7e720e5e3045ef2d77f6b /src/core/pipe.c
parent4919519754a0b5aee826add75273c291c33c4b5f (diff)
downloadnng-ec9f917101371baaae34ca10ae952392c2c2343d.tar.gz
nng-ec9f917101371baaae34ca10ae952392c2c2343d.tar.bz2
nng-ec9f917101371baaae34ca10ae952392c2c2343d.zip
More comments, and detection of fork-reentrancy. Much effort was spent
trying to come to a fork-safe solution, but ultimately we gave up.
Diffstat (limited to 'src/core/pipe.c')
-rw-r--r--src/core/pipe.c2
1 files changed, 2 insertions, 0 deletions
diff --git a/src/core/pipe.c b/src/core/pipe.c
index 408964ab..40a810c8 100644
--- a/src/core/pipe.c
+++ b/src/core/pipe.c
@@ -63,6 +63,8 @@ nni_pipe_recv(nng_pipe_t p, nng_msg_t *msgp)
void
nni_pipe_close(nng_pipe_t p)
{
+ /* XXX: we need to unregister from the parent socket. */
+ /* XXX: also unregister from the protocol. */
return (p->p_ops.p_close(p->p_tran));
}