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 2016/04/08 20:08:13 UTC
qpid-dispatch git commit: DISPATCH-268 - Release unsettled deliveries
as well when links close.
Repository: qpid-dispatch
Updated Branches:
refs/heads/master fd38b72b1 -> b88814170
DISPATCH-268 - Release unsettled deliveries as well when links close.
Project: http://git-wip-us.apache.org/repos/asf/qpid-dispatch/repo
Commit: http://git-wip-us.apache.org/repos/asf/qpid-dispatch/commit/b8881417
Tree: http://git-wip-us.apache.org/repos/asf/qpid-dispatch/tree/b8881417
Diff: http://git-wip-us.apache.org/repos/asf/qpid-dispatch/diff/b8881417
Branch: refs/heads/master
Commit: b888141709c913439747ca20c809145c90cb9a61
Parents: fd38b72
Author: Ted Ross <tr...@redhat.com>
Authored: Fri Apr 8 14:07:35 2016 -0400
Committer: Ted Ross <tr...@redhat.com>
Committed: Fri Apr 8 14:07:35 2016 -0400
----------------------------------------------------------------------
src/router_core/connections.c | 5 ++++-
1 file changed, 4 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/qpid-dispatch/blob/b8881417/src/router_core/connections.c
----------------------------------------------------------------------
diff --git a/src/router_core/connections.c b/src/router_core/connections.c
index 2521750..03b96cb 100644
--- a/src/router_core/connections.c
+++ b/src/router_core/connections.c
@@ -474,8 +474,11 @@ static void qdr_link_cleanup_CT(qdr_core_t *core, qdr_connection_t *conn, qdr_li
DEQ_REMOVE_HEAD(unsettled);
peer = dlv->peer;
qdr_delivery_free(dlv);
- if (peer)
+ if (peer) {
peer->peer = 0;
+ if (link->link_direction == QD_OUTGOING)
+ qdr_delivery_release_CT(core, peer);
+ }
dlv = DEQ_HEAD(unsettled);
}
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org