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 <gmur...@redhat.com> Authored: Mon Oct 30 10:00:51 2017 -0400 Committer: Ganesh Murthy <gmur...@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-unsubscr...@qpid.apache.org For additional commands, e-mail: commits-h...@qpid.apache.org