Repository: qpid-dispatch Updated Branches: refs/heads/1.0.x b9ce5b4a2 -> 74cecc7d1
DISPATCH-767 - Minor fix to qdr_deliver_continue_peers_CT. Activate the connection if the work is processing Project: http://git-wip-us.apache.org/repos/asf/qpid-dispatch/repo Commit: http://git-wip-us.apache.org/repos/asf/qpid-dispatch/commit/74cecc7d Tree: http://git-wip-us.apache.org/repos/asf/qpid-dispatch/tree/74cecc7d Diff: http://git-wip-us.apache.org/repos/asf/qpid-dispatch/diff/74cecc7d Branch: refs/heads/1.0.x Commit: 74cecc7d115fdf9f6a0a241efcbb0185cec73f71 Parents: b9ce5b4 Author: Ganesh Murthy <gmur...@redhat.com> Authored: Wed Nov 8 09:54:21 2017 -0500 Committer: Ganesh Murthy <gmur...@redhat.com> Committed: Wed Nov 8 09:54:21 2017 -0500 ---------------------------------------------------------------------- src/router_core/transfer.c | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/qpid-dispatch/blob/74cecc7d/src/router_core/transfer.c ---------------------------------------------------------------------- diff --git a/src/router_core/transfer.c b/src/router_core/transfer.c index a23c5c0..f600545 100644 --- a/src/router_core/transfer.c +++ b/src/router_core/transfer.c @@ -1061,7 +1061,7 @@ void qdr_deliver_continue_peers_CT(qdr_core_t *core, qdr_delivery_t *in_dlv) // if (work) { sys_mutex_lock(peer->link->conn->work_lock); - if (work == DEQ_HEAD(peer->link->work_list)) { + if (work->processing || work == DEQ_HEAD(peer->link->work_list)) { qdr_add_link_ref(&peer->link->conn->links_with_work, peer->link, QDR_LINK_LIST_CLASS_WORK); sys_mutex_unlock(peer->link->conn->work_lock); --------------------------------------------------------------------- To unsubscribe, e-mail: commits-unsubscr...@qpid.apache.org For additional commands, e-mail: commits-h...@qpid.apache.org
