aboutsummaryrefslogtreecommitdiff
path: root/src/sp/transport/inproc
diff options
context:
space:
mode:
authorGarrett D'Amore <garrett@damore.org>2023-11-26 09:53:40 -0800
committerGarrett D'Amore <garrett@damore.org>2023-11-26 09:53:40 -0800
commit759a2e9d65bd093ac9740d2cf0aa38a0212c5c23 (patch)
treeeab1df58753bc40e89cfdcf25a9963a928ddd2ec /src/sp/transport/inproc
parent003f0556a61f3e7225f4f0d0087bdf08af5b632a (diff)
downloadnng-759a2e9d65bd093ac9740d2cf0aa38a0212c5c23.tar.gz
nng-759a2e9d65bd093ac9740d2cf0aa38a0212c5c23.tar.bz2
nng-759a2e9d65bd093ac9740d2cf0aa38a0212c5c23.zip
fixes #1713 SP pipe_send leaks message if aio is canceled
Diffstat (limited to 'src/sp/transport/inproc')
-rw-r--r--src/sp/transport/inproc/inproc.c6
1 files changed, 5 insertions, 1 deletions
diff --git a/src/sp/transport/inproc/inproc.c b/src/sp/transport/inproc/inproc.c
index 2ab8b0b9..978b6679 100644
--- a/src/sp/transport/inproc/inproc.c
+++ b/src/sp/transport/inproc/inproc.c
@@ -1,5 +1,5 @@
//
-// Copyright 2020 Staysail Systems, Inc. <info@staysail.tech>
+// Copyright 2023 Staysail Systems, Inc. <info@staysail.tech>
// Copyright 2018 Capitar IT Group BV <info@capitar.com>
// Copyright 2018 Devolutions <info@devolutions.net>
//
@@ -207,6 +207,10 @@ inproc_pipe_send(void *arg, nni_aio *aio)
int rv;
if (nni_aio_begin(aio) != 0) {
+ // No way to give the message back to the protocol, so
+ // we just discard it silently to prevent it from leaking.
+ nni_msg_free(nni_aio_get_msg(aio));
+ nni_aio_set_msg(aio, NULL);
return;
}