This is an automated email from the ASF dual-hosted git repository.
gmurthy pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/qpid-dispatch.git
The following commit(s) were added to refs/heads/main by this push:
new b74533c DISPATCH-2058: Added code in core free to remove and free
everything in the core->delivery_cleanup_list. This closes #1130.
b74533c is described below
commit b74533cc84892189bc9b7f799939c2243987d8c8
Author: Ganesh Murthy <gmur...@apache.org>
AuthorDate: Fri Apr 16 10:27:03 2021 -0400
DISPATCH-2058: Added code in core free to remove and free everything in the
core->delivery_cleanup_list. This closes #1130.
---
src/router_core/router_core.c | 14 ++++++++++++++
1 file changed, 14 insertions(+)
diff --git a/src/router_core/router_core.c b/src/router_core/router_core.c
index eb95e06..b49a1aa 100644
--- a/src/router_core/router_core.c
+++ b/src/router_core/router_core.c
@@ -258,6 +258,20 @@ void qdr_core_free(qdr_core_t *core)
link = DEQ_HEAD(core->open_links);
}
+ //
+ // Clean up any qdr_delivery_cleanup_t's that are still left in the
core->delivery_cleanup_list
+ //
+ qdr_delivery_cleanup_t *cleanup = DEQ_HEAD(core->delivery_cleanup_list);
+ while (cleanup) {
+ DEQ_REMOVE_HEAD(core->delivery_cleanup_list);
+ if (cleanup->msg)
+ qd_message_free(cleanup->msg);
+ if (cleanup->iter)
+ qd_iterator_free(cleanup->iter);
+ free_qdr_delivery_cleanup_t(cleanup);
+ cleanup = DEQ_HEAD(core->delivery_cleanup_list);
+ }
+
qdr_connection_t *conn = DEQ_HEAD(core->open_connections);
while (conn) {
DEQ_REMOVE_HEAD(core->open_connections);
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@qpid.apache.org
For additional commands, e-mail: commits-h...@qpid.apache.org
