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

kgiusti pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/qpid-dispatch.git


The following commit(s) were added to refs/heads/master by this push:
     new 28200e3  DISPATCH-975: manually free oversized messages that are not 
forwarded
28200e3 is described below

commit 28200e3c5266807624fff2a5e8d04a93a09b017d
Author: Kenneth Giusti <kgiu...@apache.org>
AuthorDate: Wed Apr 22 13:31:13 2020 -0400

    DISPATCH-975: manually free oversized messages that are not forwarded
    
    This closes #723
---
 src/router_node.c | 5 +++++
 1 file changed, 5 insertions(+)

diff --git a/src/router_node.c b/src/router_node.c
index d2e2d36..02eccff 100644
--- a/src/router_node.c
+++ b/src/router_node.c
@@ -395,6 +395,11 @@ static bool AMQP_rx_handler(void* context, qd_link_t *link)
             (void) pn_condition_set_name(       cond, 
QD_AMQP_COND_CONNECTION_FORCED);
             (void) pn_condition_set_description(cond, "Message size exceeded");
             pn_connection_close(pn_conn);
+            if (!delivery) {
+                // this message has not been forwarded yet, so it will not be
+                // cleaned up when the link is freed.
+                qd_message_free(msg);
+            }
         }
         return false;
         // oversize messages are not processed any further


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

Reply via email to