Repository: qpid-dispatch Updated Branches: refs/heads/master f0e15f82f -> fda49e973
DISPATCH-1112 - Additional fix. Modified qdr_link_process_deliveries() to not continue processing deliveries if detach has been received on that link. This closes #370 Project: http://git-wip-us.apache.org/repos/asf/qpid-dispatch/repo Commit: http://git-wip-us.apache.org/repos/asf/qpid-dispatch/commit/fda49e97 Tree: http://git-wip-us.apache.org/repos/asf/qpid-dispatch/tree/fda49e97 Diff: http://git-wip-us.apache.org/repos/asf/qpid-dispatch/diff/fda49e97 Branch: refs/heads/master Commit: fda49e97370dbcb56e73ace74afe04ebac35db4b Parents: f0e15f8 Author: Ganesh Murthy <[email protected]> Authored: Mon Sep 3 10:29:55 2018 -0400 Committer: Ganesh Murthy <[email protected]> Committed: Wed Sep 5 09:19:05 2018 -0400 ---------------------------------------------------------------------- src/router_core/transfer.c | 5 +++++ 1 file changed, 5 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/qpid-dispatch/blob/fda49e97/src/router_core/transfer.c ---------------------------------------------------------------------- diff --git a/src/router_core/transfer.c b/src/router_core/transfer.c index a2374fb..92b320c 100644 --- a/src/router_core/transfer.c +++ b/src/router_core/transfer.c @@ -155,6 +155,11 @@ int qdr_link_process_deliveries(qdr_core_t *core, qdr_link_t *link, int credit) int num_deliveries_completed = 0; if (link->link_direction == QD_OUTGOING) { + + // If a detach has been received on the link, there is no need to process deliveries on the link. + if (link->detach_received) + return 0; + while (credit > 0) { sys_mutex_lock(conn->work_lock); dlv = DEQ_HEAD(link->undelivered); --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
