You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by gm...@apache.org on 2017/10/30 14:04:23 UTC
qpid-dispatch git commit: DISPATCH-767 - Additional fix to regression
introduced in a previous checkin for this fix. Add the out_link to
links_with_work only on new work creation
Repository: qpid-dispatch
Updated Branches:
refs/heads/master 6284b7a81 -> fff38466a
DISPATCH-767 - Additional fix to regression introduced in a previous checkin for this fix. Add the out_link to links_with_work only on new work creation
Project: http://git-wip-us.apache.org/repos/asf/qpid-dispatch/repo
Commit: http://git-wip-us.apache.org/repos/asf/qpid-dispatch/commit/fff38466
Tree: http://git-wip-us.apache.org/repos/asf/qpid-dispatch/tree/fff38466
Diff: http://git-wip-us.apache.org/repos/asf/qpid-dispatch/diff/fff38466
Branch: refs/heads/master
Commit: fff38466a6a0e8860531cf44e4ffff074bbb1cc1
Parents: 6284b7a
Author: Ganesh Murthy <gm...@redhat.com>
Authored: Mon Oct 30 10:00:51 2017 -0400
Committer: Ganesh Murthy <gm...@redhat.com>
Committed: Mon Oct 30 10:03:55 2017 -0400
----------------------------------------------------------------------
src/router_core/forwarder.c | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/qpid-dispatch/blob/fff38466/src/router_core/forwarder.c
----------------------------------------------------------------------
diff --git a/src/router_core/forwarder.c b/src/router_core/forwarder.c
index f0fc15e..15a75d8 100644
--- a/src/router_core/forwarder.c
+++ b/src/router_core/forwarder.c
@@ -200,8 +200,9 @@ void qdr_forward_deliver_CT(qdr_core_t *core, qdr_link_t *out_link, qdr_delivery
work->work_type = QDR_LINK_WORK_DELIVERY;
work->value = 1;
DEQ_INSERT_TAIL(out_link->work_list, work);
+ qdr_add_link_ref(&out_link->conn->links_with_work, out_link, QDR_LINK_LIST_CLASS_WORK);
}
- qdr_add_link_ref(&out_link->conn->links_with_work, out_link, QDR_LINK_LIST_CLASS_WORK);
+
out_dlv->link_work = work;
sys_mutex_unlock(out_link->conn->work_lock);
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org