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