From 7a9c328c4fd29fa7ba3dce8c8189384cd855d244 Mon Sep 17 00:00:00 2001 From: Garrett D'Amore Date: Wed, 18 Jan 2017 10:11:51 -0800 Subject: Fix leaking notify structs. --- src/core/socket.c | 5 +++++ 1 file changed, 5 insertions(+) (limited to 'src') diff --git a/src/core/socket.c b/src/core/socket.c index a7dfd07f..1b4d1585 100644 --- a/src/core/socket.c +++ b/src/core/socket.c @@ -408,6 +408,7 @@ void nni_sock_close(nni_sock *sock) { int i; + nni_notify *notify; // Shutdown everything if not already done. This operation // is idempotent. @@ -427,6 +428,10 @@ nni_sock_close(nni_sock *sock) for (i = 0; i < NNI_MAXWORKERS; i++) { nni_thr_fini(&sock->s_worker_thr[i]); } + while ((notify = nni_list_first(&sock->s_notify)) != NULL) { + nni_list_remove(&sock->s_notify, notify); + NNI_FREE_STRUCT(notify); + } nni_thr_fini(&sock->s_notifier); nni_thr_fini(&sock->s_reaper); nni_msgq_fini(sock->s_urq); -- cgit v1.2.3-70-g09d2