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 2018/12/06 16:49:13 UTC

qpid-dispatch git commit: DISPATCH-1212 - When a receiver drops off, increment the core->dropped_presettled_deliveries if there are presettled deliveries in the undelivered list.

Repository: qpid-dispatch
Updated Branches:
  refs/heads/master b501cbafa -> f080baabd


DISPATCH-1212 - When a receiver drops off, increment the core->dropped_presettled_deliveries if there are presettled deliveries in the undelivered list.


Project: http://git-wip-us.apache.org/repos/asf/qpid-dispatch/repo
Commit: http://git-wip-us.apache.org/repos/asf/qpid-dispatch/commit/f080baab
Tree: http://git-wip-us.apache.org/repos/asf/qpid-dispatch/tree/f080baab
Diff: http://git-wip-us.apache.org/repos/asf/qpid-dispatch/diff/f080baab

Branch: refs/heads/master
Commit: f080baabd1a5eb37f94178b0b54a7a70c6271e73
Parents: b501cba
Author: Ganesh Murthy <gm...@redhat.com>
Authored: Wed Dec 5 14:54:23 2018 -0500
Committer: Ganesh Murthy <gm...@redhat.com>
Committed: Thu Dec 6 11:38:13 2018 -0500

----------------------------------------------------------------------
 src/router_core/connections.c | 2 ++
 1 file changed, 2 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/qpid-dispatch/blob/f080baab/src/router_core/connections.c
----------------------------------------------------------------------
diff --git a/src/router_core/connections.c b/src/router_core/connections.c
index d06bec9..f8e3d51 100644
--- a/src/router_core/connections.c
+++ b/src/router_core/connections.c
@@ -634,6 +634,8 @@ static void qdr_link_cleanup_deliveries_CT(qdr_core_t *core, qdr_connection_t *c
     qdr_delivery_t *d = DEQ_HEAD(undelivered);
     while (d) {
         assert(d->where == QDR_DELIVERY_IN_UNDELIVERED);
+        if (d->presettled)
+            core->dropped_presettled_deliveries++;
         d->where = QDR_DELIVERY_NOWHERE;
         d = DEQ_NEXT(d);
     }


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org