qpid-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From gmur...@apache.org
Subject qpid-dispatch git commit: DISPATCH-767 - Minor fix to qdr_deliver_continue_peers_CT. Activate the connection if the work is processing
Date Wed, 08 Nov 2017 14:50:44 GMT
Repository: qpid-dispatch
Updated Branches:
  refs/heads/master a9e114769 -> c39d6ba64


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/c39d6ba6
Tree: http://git-wip-us.apache.org/repos/asf/qpid-dispatch/tree/c39d6ba6
Diff: http://git-wip-us.apache.org/repos/asf/qpid-dispatch/diff/c39d6ba6

Branch: refs/heads/master
Commit: c39d6ba64199e5c33b17b5463088c6bcd06604dd
Parents: a9e1147
Author: Ganesh Murthy <gmurthy@redhat.com>
Authored: Wed Nov 8 09:50:31 2017 -0500
Committer: Ganesh Murthy <gmurthy@redhat.com>
Committed: Wed Nov 8 09:50:31 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/c39d6ba6/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-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org


Mime
View raw message