You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by tr...@apache.org on 2020/10/29 18:50:15 UTC

[qpid-dispatch] 02/02: DISPATCH-1742 - Fixed leak of stream_data object in reference adaptor.

This is an automated email from the ASF dual-hosted git repository.

tross pushed a commit to branch dev-protocol-adaptors-2
in repository https://gitbox.apache.org/repos/asf/qpid-dispatch.git

commit 3f46bb2392bb72f75ef65bd1b9d1ad98568cc08b
Author: Ted Ross <tr...@apache.org>
AuthorDate: Thu Oct 29 14:39:21 2020 -0400

    DISPATCH-1742 - Fixed leak of stream_data object in reference adaptor.
---
 src/adaptors/reference_adaptor.c | 3 +++
 1 file changed, 3 insertions(+)

diff --git a/src/adaptors/reference_adaptor.c b/src/adaptors/reference_adaptor.c
index 84b14ba..6fb22ee 100644
--- a/src/adaptors/reference_adaptor.c
+++ b/src/adaptors/reference_adaptor.c
@@ -298,6 +298,7 @@ static uint64_t qdr_ref_deliver(void *context, qdr_link_t *link, qdr_delivery_t
 
                 qd_parse_free(footer);
                 qd_iterator_free(footer_iter);
+                qd_message_stream_data_release(stream_data);
                 break;
             }
             
@@ -510,6 +511,8 @@ static void on_stream(void *context)
         qd_compose_start_map(footer);
         qd_compose_insert_symbol(footer, "trailer");
         qd_compose_insert_string(footer, "value");
+        qd_compose_insert_symbol(footer, "second");
+        qd_compose_insert_string(footer, "value2");
         qd_compose_end_map(footer);
         depth = qd_message_extend(adaptor->streaming_message, footer);
         qd_compose_free(footer);


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org